import pymysql
# 按行读取txt文本文档
with open('price.txt', 'r', encoding='utf-8') as f:
datas = f.readlines()
# 连接数据库
con = pymysql.connect(
host='localhost',
user='root',
password='123456',
database='mydatebase3',
port=3306,
charset='utf8',
cursorclass=pymysql.cursors.DictCursor
)
cur = con.cursor()
# 编写插入数据的sql
sql = 'insert into taobao(price) values(%s)'
try:
# 执行sql
cur.executemany(sql,datas)
# 提交事务
con.commit()
print('插入成功')
except Exception as e:
print(e)
con.rollback()
print('插入失败')
finally:
con.close()