如何使用 pyodbc 将数据框中的列插入 SQL Server？

Question

我正在尝试将数据从 CSV（或 DataFrame）插入 MS SQL Server。 表已经创建好了，我使用 pyodbc 在 SQL 中创建了列。

我正在尝试使用 DataFrame 中的一列填充表中的第一列，但出现此错误：

错误: ('07002', '[07002] [Microsoft][ODBC SQL Server Driver]COUNT 字段不正确或语法错误 (0) (SQLExecDirectW)')

我尝试添加不同的列以查看该特定列是否存在问题，但我得到了相同的错误。 （列中没有空值。）

conn = pyodbc.connect("Driver={SQL Server};" 
                      "Server=natsqldevap2ncr\ins2;"
                      "Database=ECDWDEV;"
                      "Trusted_Connection=yes;")

for i in df.iloc[:,0]:
    insert_query1 =  """INSERT INTO TABLE_NAME(COLUMN_NAME) 
                   VALUES 
                   (?)"""

    cursor = conn.cursor()
    result = cursor.execute(insert_query1)
    conn.commit()

期望列 (df.iloc[:,0]) 中的所有值都插入到 SQL 表“TABLE_NAME”的“COLUMN_NAME”列中。

得到：

错误: ('07002', '[07002] [Microsoft][ODBC SQL Server Driver]COUNT 字段不正确或语法错误 (0) (SQLExecDirectW)')

Answer 1

您收到该错误消息是因为您尝试使用参数化查询，但您没有将参数 values 传递给 execute 方法。

此外，您无需通过在显式 for 循环中调用 execute 来逐行插入。您可以改用executemany：

# test data
df = pd.DataFrame(
    [(1, 'Josh', 10000), (2, 'Michael', 5000), (3, 'Sara', 8000)],
    columns=['id', 'name', 'salary'])
#
crsr = cnxn.cursor()
crsr.fast_executemany = True
sql = "INSERT INTO Table_1 (id) VALUES (?)"
# extract column and convert to list of single-value tuples
data = [(x,) for x in df['id']]
crsr.executemany(sql, data)
cnxn.commit()