#该文件主要实现将txt文件传入mysql数据库
import pymysql
import re
#变量初始化
con=pymysql.connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='123456',
    db='test',
    charset='utf8',
    )
def insert(con,English,Chinese):
    #数据库游标！
    cue = con.cursor()
    # print("mysql connect succes")  # 测试语句，这在程序执行时非常有效的理解程序是否执行到这一步
    #try-except捕获执行异常
    try:
        cue.execute(
            "insert into words (English,Chinese) values(%s,%s)",
            [English,Chinese,])
        #执行sql语句
        # print("insert success")  # 测试语句
    except Exception as e:
        print('Insert error:', e)
        con.rollback()
        #报错反馈
    else:
        con.commit()
        #真正的执行语句
def read():
    filename=r'C:\Users\kingback\Desktop\龙华老师资料\上交资料\第六次上交材料\words.txt'
    #按行读取txt文本文档
    with open(filename, 'r') as f:
        datas = f.readlines()
    #遍历文件
    for data in datas:
        txt=re.split(r'\t|\n',data)
        english=txt[0]
        chinese=txt[1]
        insert(con, english, chinese)
        #调用insert方法
    print("数据插入完成！")
read()
#执行read函数
con.close()
#关闭连接