import psycopg2

import MySQLdb

import datetime

from xml.dom import minidom

from xml.dom.minidom import getDOMImplementation

from bien.v.models import *

mysqldb = MySQLdb.connect(host="localhost", user="admin", passwd="lae5eiNa",db="bien2")

mysqlcursor = mysqldb.cursor()

psqlconn = psycopg2.connect("dbname=bien_test user=bien_dba password=bien")

psqlconn.set_client_encoding('LATIN1')

psqlcur = psqlconn.cursor()

system = "BIEN2"

scope = "system"

entryInfoInsertBeginning = 'INSERT INTO v_entryinfo ("creationDate","lastUpdatedDate","dataSource") VALUES'

vegXInsertBeginning = 'INSERT INTO v_vegx ("entryInfo_id","projects_id") VALUES'

projectsInsertBeg = 'INSERT INTO v_projects ("entryInfo_id") VALUES'

projectInsertBeg = 'INSERT INTO v_researchprojecttype ("entryInfo_id","projects_id_id","attr_id","attr_system","attr_scope") VALUES'

projTitleInsertBeg = 'INSERT INTO v_researchprojecttype_title ("entryInfo_id","ResearchProjectType_id_id","primitive_type_value") VALUES'

batchSize = 500

maxEISql = 'select max(id) from v_entryinfo'

psqlcur.execute(maxEISql)

maxEntryInfo = psqlcur.fetchone()[0]

maxProjectsSQL = 'select max(id) from v_projects'

psqlcur.execute(maxProjectsSQL)

maxProjects = psqlcur.fetchone()[0]

if maxProjects == None:

  maxProjects = 0

maxProjectSQL = 'select max(id) from v_researchprojecttype'

psqlcur.execute(maxProjectSQL)

maxProject = psqlcur.fetchone()[0]

if maxProject == None:

  maxProject = 0

getSql = 'SELECT distinct(DBSourceName) from PlotMetaDataDimension'

mysqlcursor.execute(getSql)

result = mysqlcursor.fetchall()

eii = entryInfoInsertBeginning

vxi = vegXInsertBeginning

psi = projectsInsertBeg

pi = projectInsertBeg

pti = projTitleInsertBeg

maxEntryInfo = 1699127

maxProjects = 40

maxProject = 20

iterCt = 0

for record in result:

  iterCt = iterCt + 1

  eii = eii + "('" + datetime.date.today().strftime("%Y-%m-%d") + "','" + datetime.date.today().strftime("%Y-%m-%d") + "','BIEN2'), "

  psi = psi + '(' + str(maxEntryInfo + iterCt) + '), '

  vxi = vxi + '(' + str(maxEntryInfo + iterCt) + ',' + str(maxProjects + iterCt) + '), '

  pi = pi + '(' + str(maxEntryInfo + iterCt) + ',' + str(maxProjects + iterCt) + ",'BIEN2_" + str(record[0]) + "','" + system + "','" + scope + "'), "

  pti = pti + '(' + str(maxEntryInfo + iterCt) + ',' + str(maxProject + iterCt) + ",'BIEN2_" + str(record[0]) + "'), "

  if iterCt % batchSize == 0 or iterCt == len(result):

#    psqlcur.execute(eii[:(len(eii)-2)])

#    psqlconn.commit()

    psqlcur.execute(psi[:(len(psi)-2)])

    psqlconn.commit()

    psqlcur.execute(vxi[:(len(vxi)-2)])

    psqlconn.commit()

    psqlcur.execute(pi[:(len(pi)-2)])

    psqlconn.commit()

    psqlcur.execute(pti[:(len(pti)-2)])

    psqlconn.commit()

    eii = entryInfoInsertBeginning

    vxi = vegXInsertBeginning

    psi = projectsInsertBeg

    pi = projectInsertBeg

    pti = projTitleInsertBeg

psqlconn.rollback()

INSERT INTO v_entryinfo ("creationDate","lastUpdatedDate","dataSource") VALUES('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2'), ('2010-12-01','2010-12-01','BIEN2')