我正在尝试使用pyodbc将相当数量（约30万行）的数据上传到数据库。由于数据需要每季度更新一次（从电子表格中），因此我试图创建的是一种动态插入语句，以使事情更加简化。我的思考过程是，我可以将电子表格中各列的标题命名为与要上传相应数据的表中的列相同的名称。
我试图做的是编写一个脚本，该脚本提取工作表标题行中的列名并将其用作变量，从而避免了如果我要从不同的excel上载不同的数据时更改任何代码的需求纸背对背：
import xlrd
import numpy as np
import pyodbc
wb=xlrd.open_workbook(r"FILE")
worksheet = wb.sheet_by_name('SHEET_NAME')
num_rows = worksheet.nrows
num_cols = worksheet.ncols
header_row = 0
header_list = [worksheet.row_values(header_row)]
header_values = ", ".join([str(i) for i in [cell.value for cell in worksheet.row(header_row)]])
question_marks = ",?" * (num_cols - 1)
cell=worksheet.cell(1,1)
arr = []
for rowind in range(num_rows)[(header_row + 1):]:
arr.append([cell.value for cell in worksheet.row(rowind)])
data = np.rec.fromrecords(arr, names=header_values)
cnxn = pyodbc.connect(r"DRIVER={SQL Server};SERVER=XXXXXXXXXX
\DEV_CON1;DATABASE=GGG;UID=AAA_dbo;PWD=XXXXXXXXX;")
cursor = cnxn.cursor()
populate_db = "insert into tblSnap_TEST(" + header_values + ") values (?" + question_marks + ")"
for i in header_list:
i = data[i]
values = header_list
cursor.execute(populate_db,values)
cursor.close
cnxn.commit
cnxn.close`
当我尝试运行脚本时，出现以下错误消息：
File "<ipython-input-45-6809dc4a27ac>", line 1, in <module>
runfile('H:/My Documents/Python/string_search_test.py', wdir='H:/My Documents/Python')
File "C:\Users\xxxx\xxx\xx\x\Anaconda\lib\site- packages\spyderlib\widgets\externalshell\sitecustomize.py", line 580, in runfile
execfile(filename, namespace)
File "H:/My Documents/Python/string_search_test.py", line 67, in <module>
cursor.execute(populate_db,values)
ProgrammingError: ('The SQL contains 21 parameter markers, but 1 parameters were supplied', 'HY000')
我之前完成此操作的方法是显式定义要传递的值，例如：
account_numbers = (sheet.cell(row_index, 1).value)
但是就像我说的那样，我在这里想要做的就是制作它，所以我不必键入它。那就是我试图对i = data [i]所做的事情。我希望Python有一种方法可以识别“ account_numbers”在列表中（从工作表的标题创建），然后根据与i = data[i]我上面尝试过的类似方法获取相应的数据。这样的解决方案可行吗？data [i]确实为每个列返回了我想插入表中的正确数据，但是execute语句无法识别它。
如果您不处理大型Excel工作表或任何有问题的数据类型（例如Excel电子表格中的日期部分中描述的数据类型），则可以简化将所有行读取到一个列表中的操作，弹出插入列的标题值，然后一次调用Cursor.executemany插入电子表格中的所有值，并传递一系列参数值序列。
我删除了numpy数组填充，因为在提供的代码段中没有必要。
header_row = 0
# build list of lists that represents row values in worksheet,
# including column names from header row
rows = [worksheet.row_values(row) for row in range(worksheet.nrows)]
# extract list of column names to use for insert statement, values to be inserted remain
columns = rows.pop(header_row)
cnxn = pyodbc.connect(r"DRIVER={SQL Server};SERVER=XXXXXXXXXX\DEV_CON1;DATABASE=GGG;UID=AAA_dbo;PWD=XXXXXXXXX;")
cursor = cnxn.cursor()
# list of column names used to build SQL statement, including parameter placeholders (?)
populate_db = "insert into tblSnap_TEST ({}) values ({})".format(', '.join(columns),
', '.join('?' * len(columns)))
# insert is executed once for each sequence of parameter values
cursor.executemany(populate_db, rows)
cnxn.commit()
cnxn.close()
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句