Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- conn_mssql = pymssql.connect(server='127.0.0.1', database='...')
- cursor_mssql = conn_mssql.cursor()
- conn_pg = psycopg2.connect(database="..", user="...", password="..", host="127.0.0.1", port="5432")
- cursor_pg = conn_pg.cursor()
- print "Opened database successfully"
- l = ["тут список полей"]
- cursor_mssql.execute('SELECT TOP 333333 * FROM "....."."documents";')
- row = cursor_mssql.fetchone()
- while row:
- # .... тут обработка записей, формирование списка vals
- sql = """ INSERT INTO "documents" (%s) VALUES (%s); """
- print sql
- # вот сама вставка
- cursor_pg.execute(sql, vals)
- # берем следующую сроку из MSSQL
- row = cursor_mssql.fetchone()
- conn_mssql.close()
- # подтверждаем записи
- conn_pg.commit()
- conn_pg.close()
Add Comment
Please, Sign In to add comment