无法从 MS Access 查询结果创建数据框

Question

我正在尝试从 MS Access 数据库 MDB 文件中插入信息，不幸的是，我不知道如何使用 Python 分隔数据库表中的列。

我收到了错误

ValueError: 传递值的形状是 (109861, 1)，索引意味着 (3,1)

我使用的代码是：

import os
import shutil
import pyodbc
import pandas as pd
import csv
from datetime import datetime
conn = pyodbc.connect(r'Driver={Microsoft Access Driver (*.mdb, *.accdb)};DBQ=C:\\Users\\sguerra\\Desktop\\Python\\Measurements-2020-12-15.mdb;')
cursor = conn.cursor()
cursor.execute('select * from Measurements')
new = cursor.fetchall()
columns = ['Prod_Date','Prod_Time','CCE_SKU']
df = pd.DataFrame(new,columns)

for row in df.itertuples():
    cursor.execute('''
                   insert into MITSF_1.dbo.MeasurementsTest ([Prod_Date],[Prod_Time],[CCE_SKU])
                   VALUES (?,?,?)
                   ''',
                   row.Prod_Date,
                   row.Prod_Time,
                   row.CCE_SKU
                   )
conn.commit()

Answer 1

您正在使用相同的cursor 来尝试执行select 和insert，因此这两个语句将在同一个数据库上运行。为简单起见，您应该使用 pandas 的 read_sql_query() 从 Access 读取所需的列，然后使用 to_sql() 将它们写入 SQL Server：

df = pd.read_sql_query(
    "SELECT [Prod_Date],[Prod_Time],[CCE_SKU] FROM Measurements",
    conn,
)
from sqlalchemy import create_engine
engine = create_engine(
    "mssql+pyodbc://scott:tiger@192.168.0.199/MITSF_1"
    "?driver=ODBC+Driver+17+for+SQL+Server",
    fast_executemany=True,
)
df.to_sql("MeasurementsTest", engine, schema="dbo", 
    index=False, if_exists="append",
)