律师网站 扁平化,网站运营专员做六休一,外包app开发多少钱,定制开发平台用python批量向数据库(MySQL)中导入数据现有数十万条数据,如下的经过打乱处理过的数据进行导入数据库内部的表格的数据格式如下与下面的表格结构相同Current database: python_test_1--------------------------------------------------------| Field | Type | Null | Key | D…用python批量向数据库(MySQL)中导入数据现有数十万条数据,如下的经过打乱处理过的数据进行导入数据库内部的表格的数据格式如下与下面的表格结构相同Current database: python_test_1--------------------------------------------------------| Field | Type | Null | Key | Default | Extra |--------------------------------------------------------| id | int(11) | NO | PRI | NULL | auto_increment || name | varchar(20) | YES | | NULL | || maile | varchar(50) | YES | | NULL | || wchat | varchar(50) | YES | | NULL | || phone | varchar(50) | YES | | NULL | || brith | varchar(50) | YES | | NULL | |--------------------------------------------------------6 rows in set (0.18 sec)实现方法import refrom pymysql import connect# 建立链接conn connect(hostlocalhost, port3306, dbpython_test_1, userroot, passwordmysql, charsetutf8)# 获取游标cur conn.cursor()# 打开文件读取所有文件存成列表with open(/home/python/Desktop/code/data01.txt, r) as file:# 可以选择readline或者read的方式,但下面的代码要有所变化data_list file.readlines()# 遍历列表for t in data_list:# 正则方式匹配处理字符串text_list re.split(r\n, t)text re.split(r\t, text_list[0])# print(text)# sql语句sql insert into test_db values (0,%s,%s,%s,%s,%s)print(sql)# 参数化方式传参row_count cur.execute(sql,[text[0],text[1],text[2],text[3],text[4]])# 显示操作结果print(SQL语句影响的行数为%d % row_count)# 统一提交conn.commit()# 关闭游标cur.close()# 关闭连接conn.close()
