python下如何往数据库批量插入数据?方法是什么?假如我们想要往数据库表中的插入的数据有几百上千条,那么一条条插入,则调用sql语句查询插入就需要执行几百上千,这样花费的时间就非常的长。因此我们可以使用cursor.executemany(sql,args)来实现批量插入数据,那么具体怎样做呢?接着往下看。
现使用cursor.executemany(sql,args) ,可对数据进行批量插入,其中args是一个包含多个元组的list列表,每个元组对应mysql当中的一条数据
以下是实例:
往数据库中的order表、order_detail表和pay表中插入1000条订单数据,订单详情数据以及支付数据
1.pay表中的id字段是order表中的pay_id字段
2.order表中的id字段是order_detail表中的order_id字段
1.初始化属性(包括host、port、user、password和database)
def __init__(self):
self.__db_host=XXX
self.__db_port=XXX
self.__db_user=XXX
self.__db_password=XXX
self.__db_database=XXX
2.连接数据库
def isConnection(self):
self.__db=pymysql.connect(
host=self.__db_host,
port=self.__db_port,
user=self.__db_user,
password=self.__db_password,
database=self.__db_database,
charset='utf8'
)
3.批量往pay表中插入1000条数据
# 插入数据进pay表
def pay_insert(self,pay_value):
try:
# 连接数据库
self.isConnection()
# 创建游标
global cursor
cursor=self.__db.cursor()
# 执行
cursor.executemany('insert into `pay表`(type,pay_money,pay_time,pay_no,STATUS,create_by,create_time,update_by,
update_time) value (%s,%s,%s,%s,%s,%s,%s,%s,%s)',pay_value)
except Exception as e:
print e
finally:
cursor.close()
self.__db.commit()
self.__db.close()
# 生成pay表所需字段,并调用sql
def pay_data(self):
pay_value=list()
for i in range(1,1000):
pay_value.append((0,8800,time.localtime(),str(random.randint(712300000000,712399999999)),3,49338,
time.localtime(),49338,time.localtime()))
now_time=time.localtime()
self.pay_insert(pay_value)
return now_time
4.pay表中生成的1000条数据,依次取出id
# 获取pay_id
def get_pay_id(self,now_time):
try:
self.isConnection()
global cursor
cursor=self.__db.cursor()
cursor.execute('select id from `pay表` where create_time >= %s',now_time)
id_value=list()
for i in range(1,1000):
pay_id=cursor.fetchone()
id_value.append(pay_id)
return id_value
except Exception as e:
print e
finally:
cursor.close()
self.__db.commit()
self.__db.close()
以下是完整代码:
# #!/usr/bin/python
# # -*- coding: UTF-8 -*-
大型站长资讯类网站! https://www.0455zz.com