import pyodbc
import pandas as pd
import pymysql # 导入 pymysql
conn = pyodbc.connect(r'DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};DBQ=D:\1\系统.accdb')
cur = conn.cursor()
db= pymysql.connect(host="192.168.2.1",user="root",
password="705154",db="hgl",port=3307)
mysql_cur = db.cursor()
#mysql_cur.execute("create table shengchanjihua(id char(12) primary key ,xiadan_date date ,leixing char(20),ling_ll float(5))")
SQL1 = "SELECT * from 生产计划表"
l = pd.read_sql(SQL1,conn)#获取ACCESS记录集
for i in range(0,3):
a = l.iloc[[i],[0]].values[0][0]
d = "2021-6-1"
print(a)
sql_insert = "insert into sc_jihua(id,xiadan_date)values (%s,%s)"
try:
mysql_cur.execute(sql_insert, (a,d))#将ACCESS获取到的记录追加到MySQL
db.commit()
print("已追加")
except Exception as e:
db.rollback()
print("错误")
finally:
pass
cur.close()
mysql_cur.close()
conn.close()
db.close()