- conn = Connection(
- host=myCert.host,
- user=myCert.user,
- password=myCert.password,
- port=myCert.port,
- database=myCert.database,
- charset=myCert.charset
- )
-
- def executeSql(sqlConn: Connection, sqlStr: str):
- # 获取游标对象
- cursor = sqlConn.cursor()
- # 执行sql
- cursor.execute(sqlStr)
- # 获取结果元组
- result = cursor.fetchall()
- # 关闭连接
- cursor.close()
- return result
-
-
-
- result = executeSql(conn, sqlStr)
- for item in result:
- print(COLOR.GREEN + str(item))
- conn.close()
- # 用于开启自动提交
- autocommit=True,
在配置中加入上面的字段可以实施自动更新
- # 打开文件
- with open('../../assets/Files/财务数据.txt', 'r') as f:
- lineList = f.readlines()
- dataList = []
- for line in lineList:
- if not line == '\n':
- dataList.append(tuple(line.strip().split(',')))
-
- dataTuple = tuple(dataList)
-
- for item in dataTuple:
- sqlStr = 'insert into salary_data(date, hashId,salary,province) values("%s","%s",%s,"%s")' % (
- item[0], item[1], int(item[2]), str(item[3]).strip())
- executeSql(conn, sqlStr)
-
- print('写入完毕')