<>强如何通过扭曲实现数据库异步插入?
1。导入adbapi
2。生成数据库连接池
3。执行数据数据库插入操作
4。打印错误信息,并排错
# !/usr/bin/python3
__author__=' beimenchuixue '
__blog__=' http://www.cnblogs.com/2bjiujiu/'
进口pymysql
从扭曲。企业进口adbapi
从twisted.internet进口反应堆
def go_insert (sql游标):
#对数据库进行插入操作,并不需要提交,扭曲会自动帮我提交
试一试:
因为我在范围(10):
data=https://www.yisu.com/zixun/str(我)
游标。执行(sql,数据)
除了例外e:
打印(e)
def handle_error(失败):
#打印错误
如果失败:
打印(失败)
if __name__==癬_main__”:
#数据库基本配置
db_settings={
“主机”:“localhost”,
“分贝”:“jobole”,
“用户”:“根”,
“密码”:“passwort”,
“字符集”:“use utf8”,
“use_unicode”:真的
}
# sql语句模版
insert_sql='插入test_1 (text_1)值(% s) '
#普通方法插入数据
#康涅狄格州=pymysql.connect (* * db_settings)
#光标=conn.cursor ()
#光标。execute (insert_sql ' 1 ')
# conn.commit ()
试一试:
#生成连接池
db_conn=adbapi。ConnectionPool (pymysql, * * db_settings)
#通过连接池执行具体的sql操作,返回一个对象
查询=db_conn.runInteraction (go_insert insert_sql)
#对错误信息进行提示处理
query.addCallbacks (handle_error)
除了例外e:
打印(e)
#定时,给4秒时间让扭曲的异步框架完成数据库插入异步操作,没有定时什么都不会做
反应堆。reactor.stop callLater (4)
reactor.run ()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
