PostgreSQL / psycopg2 ETL Testing

__author__ = 'matthew_baker'
import psycopg2

connDev = psycopg2.connect("host=host1 dbname=dpspgisdev user=postgres password=***")
connQa = psycopg2.connect("host=host2 dbname=dpspgisdev user=postgres password=***")
curDev = connDev.cursor()
curQa = connQa.cursor()

print "Truncating Source"
curQa.execute('delete from "tempHoods"')
connQa.commit()
#Get Data
curDev.execute('select  nbhd_id, ltrim(rtrim(nbhd_name)), typology, ltrim(rtrim(notes)), cast(geom as varchar) from "CCD_Neighborhoods";')
rows = curDev.fetchall()


sql_insert = 'INSERT INTO "tempHoods" (nbhd_id, nbhd_name, typology, notes, geom) values '
sql_values = ['(%s, %s, %s, %s, %s)']


data_values = []
batch_size = 1

for i, row in enumerate(rows, 1):
            data_values += row[:5]
            if i % batch_size == 0:
                sql_stmt = sql_insert + ','.join(sql_values*batch_size) + ';'
                #print (sql_stmt, data_values)
                curQa.execute (sql_stmt , data_values )
                connQa.commit()
               # print data_values
                data_values = []

            if (i % batch_size != 0):
                sql_stmt = sql_insert + ','.join(sql_values*(i % batch_size)) + ';'
                curQa.execute (sql_stmt, data_values)
                #print (sql_stmt, data_values)
                connQa.commit()

# close connections
curDev.close()
curQa.close()
connDev.close()
connQa.close()