"Ungültiger parameter "Typ" (numpy.int64) beim einfügen von Zeilen mit executemany()

Ich versuche, einfügen Haufen Daten in die Datenbank

insert_list = [(1,1,1,1,1,1),(2,2,2,2,2,2),(3,3,3,3,3,3),....] #up to 10000 tuples in this list

conn = pyodbc.connect('DRIVER={FreeTDS};SERVER=xxxxx;DATABASE=xxxx;UID=xx;PWD=xx;TDS_Version=7.0')
cursor = conn.cursor()

sql = "insert into ScanEMAxEMAHistoryDay(SecurityNumber, EMA1, EMA2, CrossType, DayCross, IsLocalMinMax) values (?, ?, ?, ?, ?, ?)"

cursor.executemany(sql, insert_list)

cursor.executemany(sql, insert_list)

pyodbc.ProgrammingError: ('Invalid parameter type. param-index=4 param-type=numpy.int64', 'HY105')

reduzieren zu 100 Tupel:

cursor.executemany(sql, insert_list[:100])

cursor.executemany(sql, insert_list[:100])

pyodbc.ProgrammingError: ('Invalid parameter type. param-index=4 param-type=numpy.int64', 'HY105')
cursor.executemany(sql, insert_list[:100])

reduzieren zu 5-Tupeln:

cursor.executemany(sql, insert_list[:5])
conn.commit()

Kann dies einfügen um die Datenbank

Ich versuche:

sql = 'SET GLOBAL max_allowed_packet=50*1024*1024'
cursor.execute(sql)

bevor excutemany (), aber Sie haben einen Fehler:

pyodbc.ProgrammingError: ('42000', "[42000] [FreeTDS][SQL Server]'GLOBAL' ist nicht ein anerkanntes SET-option. (195) (SQLExecDirectW)")

Wie ich dieses Problem lösen.

Danke.

InformationsquelleAutor YONG BAGJNS | 2017-02-01
  1. 9

    Dein problem nicht mit der Menge der Daten per se, es ist, dass einige Ihrer Tupel enthalten numpy.int64 Werte können nicht direkt verwendet werden als Parameterwerte für die SQL-Anweisung. Zum Beispiel, 

    a = numpy.array([10, 11, 12], dtype=numpy.int64)
params = (1, 1, a[1], 1, 1, 1)
crsr.execute(sql, params)

    werfen

    ProgrammingError: ('Invalid parameter type. param-index=2 param-type=numpy.int64', 'HY105')

    weil der Wert des Dritten Parameters ist ein numpy.int64 element aus Ihrer numpy-array a. Die Umwandlung dieser Wert mit int() vermeiden Sie das Problem:

    a = numpy.array([10, 11, 12], dtype=numpy.int64)
params = (1, 1, int(a[1]), 1, 1, 1)
crsr.execute(sql, params)

    Durch die Art und Weise, der Grund dafür, dass 

    sql = 'SET GLOBAL max_allowed_packet=50*1024*1024'
cursor.execute(sql)

    nicht funktioniert ist, dass max_allowed_packet ist eine MySQL-Einstellung, die keine Bedeutung hat für Microsoft SQL Server.

    • Wie kann ich dies mit ein Pandas DataFrame? Ich habe versucht, df[col].astype(int) für jede Spalte, aber noch keine Freude.
    • Ich habe gerade versucht einen einfachen test mit df.values.tolist() - und es funktionierte für mich. Wenn Sie weitere Unterstützung benötigen, sollten Sie eine neue Frage stellen.
    • ja ich habe es auf der Arbeit.. hatte einige Problem, es war nicht so dass mich das einspielen der dataframe, weil es Duplikate in ein Feld, es sollte nicht sein, und dann, als ich versuchte, zu tun, weniger Aufzeichnungen, die er warf den oben genannten Fehler.. wenn ich gerade geändert die doppelte Datensätze, Dinge zu testen, es funktionierte. Dank
    InformationsquelleAutor Gord Thompson
Schreibe einen Kommentar