瓶实现数据库连接池的方法?这个问题可能是我们日常学习或工作经常见到的。希望通过这个问题能让你收获颇深。下面是小编给大家带来的参考内容,让我们一起来看看吧!
<强>数据库连接池
DBUtils是Python的一个用于实现数据库连接池的模块。
<强>安装
进官网下载https://pypi.org/project/DBUtils/1.2/,然后安装:
<强>连接池有两种方式
(1)模式一
为每个线程创建连接,线程即使调用了近方法,也不会关闭,只是把连接重新放到连接池,供自己线程再次使用。当线程终止时,连接自动关闭。
POOL =, PersistentDB (
,,,的创造者=pymysql,,, #,使用链接数据库的模块
,,,maxusage=没有,,,#,一个链接最多被重复使用的次数,没有表示无限制
,,,setsession=[],,, #,开始会话前执行的命令列表。如:[“set datestyle 用…“,,“set time zone …“)
,,,平=0,
,,,#,ping MySQL服务端,检查是否服务可用。#,如:0,=,None =,永远,,1,=,default =, whenever it is 要求,,2,=,when a cursor is 创建,,4,=,when a query is 执行,,7=,总是
,,,closeable=False,
,,,#,如果为假时,,conn.close(),实际上被忽略,供下次使用,再线程关闭时,才会自动关闭链接。如果为真时,,conn.close()则关闭链接,那么再次调用pool.connection时就会报错,因为已经真的关闭了连接(pool.steady_connection()可以获取一个新的链接)
,,,threadlocal=没有,,,#,本线程独享值得对象,用于保存链接对象,如果链接对象被重置
,,,主机=& # 39;127.0.0.1 # 39;
,,,=3306港
,,,用户=& # 39;根# 39;
,,,密码=& # 39;123 & # 39;
,,,数据库=& # 39;pooldb& # 39;
,,,charset=& # 39; use utf8 # 39;
)
def func ():
,,,conn =, POOL.connection(共享=False)
,,,cursor =, conn.cursor ()
,,,cursor.execute (& # 39; select *,得到tb1& # 39;)
,,,result =, cursor.fetchall ()
,,,cursor.close ()
,,,conn.close ()
func () (2)模式二,推荐使用的方式
创建多个连接,多线程来时,去获取,
import 时间
import pymysql
import 线程
得到DBUtils.PooledDB import PooledDB SharedDBConnection
时间=POOL PooledDB (
,,,的创造者=pymysql,,, #,使用链接数据库的模块
,,,maxconnections=6,,, #,连接池允许的最大连接数,0和没有表示不限制连接数
,,,mincached=2,,, #,初始化时,链接池中至少创建的空闲的链接,0表示不创建
,,,maxcached=5,,, #,链接池中最多闲置的链接,0和没有不限制
,,,maxshared=3,,, #,链接池中最多共享的链接数量,0和没有表示全部共享每分钟:,无用,因为pymysql和MySQLdb等模块的,threadsafety都为1,所有值无论设置为多少,_maxcached永远为0,所以永远是所有链接都共享。
,,,阻塞=True,,, #,连接池中如果没有可用连接后,是否阻塞等待.True,等待;假,不等待然后报的错
,,,maxusage=没有,,,#,一个链接最多被重复使用的次数,没有表示无限制
,,,setsession=[],,, #,开始会话前执行的命令列表。如:[“set datestyle 用…“,,“set time zone …“)
,,,平=0,
,,,#,ping MySQL服务端,检查是否服务可用。#,如:0,=,None =,永远,,1,=,default =, whenever it is 要求,,2,=,when a cursor is 创建,,4,=,when a query is 执行,,7=,总是
,,,主机=& # 39;127.0.0.1 # 39;
,,,=3306港
,,,用户=& # 39;根# 39;
,,,密码=& # 39;123 & # 39;
,,,数据库=& # 39;pooldb& # 39;
,,,charset=& # 39; use utf8 # 39;
)
def func ():
,,,#,检测当前正在运行连接数的是否小于最大链接数,如果不小于则:等待或报raise TooManyConnections异常
,,,#,否则
,,,#,则优先去初始化时创建的链接中获取链接,SteadyDBConnection。
,,,#,然后将SteadyDBConnection对象封装到PooledDedicatedDBConnection中并返回。
,,,#,如果最开始创建的链接没有链接,则去创建一个SteadyDBConnection对象,再封装到PooledDedicatedDBConnection中并返回。
,,,#,一旦关闭链接后,连接就返回到连接池让后续线程继续使用。
,,,conn =, POOL.connection ()
,,,#,打印(th, & # 39;链接被拿走了& # 39;,,conn1._con)
,,,#,打印(th, & # 39;池子里目前有& # 39;,,pool._idle_cache,, & # 39; \ r \ n # 39;)
,,,cursor =, conn.cursor ()
,,,cursor.execute (& # 39; select *,得到tb1& # 39;)
,,,result =, cursor.fetchall ()
,,,conn.close ()
func ()
