在現實生活中,經常會使用到Python 將信息清洗完后插入數據庫,但一條條插入勢必速度效率跟不上,此時將需要使用批量插入的思維。
# coding:utf-8
import pymysql
# 打開數據庫連接
db = pymysql.connect(host='localhost', port=3306,
user='username', passwd='password', db='database_name', charset='utf8')
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 插入語句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, AGE, SEX) VALUES (%s,%s,%s)"
# 一個tuple或者list
T = (('xiaoming', 31, 'boy'), ('hong', 22, 'girl'), ('wang', 90, 'man'))
try:
# 執行sql語句
cursor.executemany(sql, T)
# 提交到數據庫執行
db.commit()
except :
# 如果發生錯誤則回滾
db.rollback()
# 關閉游標
cursor.close()
# 關閉數據庫連接
db.close()