用python批量向數(shù)據(jù)庫(MySQL)中導(dǎo)入數(shù)據(jù)

現(xiàn)有數(shù)十萬條數(shù)據(jù),如下的經(jīng)過打亂處理過的數(shù)據(jù)進(jìn)行導(dǎo)入

數(shù)據(jù)庫內(nèi)部的表格的數(shù)據(jù)格式如下與下面的表格結(jié)構(gòu)相同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)

實(shí)現(xiàn)方法

import re

from pymysql import connect

# 建立鏈接

conn = connect(host='localhost', port=3306, db='python_test_1', user='root', password='mysql', charset='utf8')

# 獲取游標(biāo)

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)

# 參數(shù)化方式傳參

row_count = cur.execute(sql,[text[0],text[1],text[2],text[3],text[4]])

# 顯示操作結(jié)果

print("SQL語句影響的行數(shù)為%d" % row_count)

# 統(tǒng)一提交

conn.commit()

# 關(guān)閉游標(biāo)

cur.close()

# 關(guān)閉連接

conn.close()

總結(jié)

以上是生活随笔為你收集整理的python 数据导入mysql_用python批量向数据库(MySQL)中导入数据的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。