Wie kann ich eine Ergebnismenge von psycopg2 mit pyodbc in eine SQL-Tabelle einfügen?

Question

Ich habe eine psycopg Verbindung:

conngre = psycopg2.connect("host='blah' port='blah' dbname='blah' user='blah' password='blah'") 
conngre = conngre.cursor() 

with open('exportgre', 'r') as selectexport: 
    var1 = selectexport.read() 
    conngre.execute(var1) 

Dieses eine resultset nennt, die ich will, um dann mit Verbindung SQL Server vordefinierte Tabelle Dump in:

sqlconn = pyodbc.connect(r'DSN=d;UID=blah;PWD=blah') 
cursql = sqlconn.cursor() 

with open('importsql', 'r') as selectexport: 
    var2 = selectexport.read() 
    cursql.execute(var2) 

Ist thier eine Möglichkeit, die Ergebnisse aus der zu übergeben erstes Ergebnis in eine Einfügung für die zweite Ergebnismenge gesetzt?

Ich habe lief nun den folgenden Code als Test, um diese vor der Verwendung meiner eigentlichen SQL zur Arbeit zu kommen:

import pyodbc 

sqlconn = pyodbc.connect(r'DSN=d;UID=blah;PWD=blah') 
cursql = sqlconn.cursor() 

with cursql.execute("select * from blah.dbo.export_test"): 

rows = cursql.fetchall() 

for row in rows: 
    cursql.execute('insert into TouchStar.dbo.export_test values (?)', (row[0])) 
    print(row) 

Allerdings scheint es, nur meine Daten überschreiben, die bereits in der Tabelle?

Muss ich irgendwie anhängen?

Answer 1

Sie sollten Python-Wörterbücher in der Mitte verwenden. Wählen Sie zunächst aus PostgreSQL mit RealDictCursor:

conngre = psycopg2.connect("host='blah' port='blah' dbname='blah' user='blah' password='blah'", cursor_factory=psycopg2.extras.RealDictCursor) 
curgre = conngre.cursor() 

sqlconn = pyodbc.connect(r'DSN=d;UID=blah;PWD=blah') 
cursql = sqlconn.cursor() 

with open('exportgre', 'r') as selectexport: 
    var1 = selectexport.read() 
    curgre.execute(var1) 
    rows = curgre.fetchall() 
    for row in rows: 
     cursql.execute('INSERT INTO table_name (col1, col2, col3) VALUES (?, ?, ?)', (row[0], row[1], row[2])) 

Für jede SELECT-Anweisung in "selectexport", dies wird die Abfrage und Schleife über die Zeilen laufen. Für jede Zeile wird es in den Pyodbc-Cursor eingefügt. Sie müssen die Insert-Anweisung anpassen, um zu passen. Viel Glück!