0.数据库连接池模式一模式二示例使用数据库连接池进行登录验证10.数据库连接池

参考https://www.cnblogs.com/wangkun122/articles/8992637.html

pip

DBUtils1.2注意python3现在回安装最新2.0版本的from

DBUtils.PersistentDB

PersistentDB这样导入时会找不到模块要安装低版本到1.2版本。

模式一

为每个线程创建一个连接线程即使调用了close方法也不会关闭只是把连接重新放到连接池供自己线程再次使用。

当线程终止时连接自动关闭

from

一个链接最多被重复使用的次数None表示无限制setsession[],

datestyle

实际上被忽略供下次使用再线程关闭时才会自动关闭链接。

如果为True时

conn.close()则关闭链接那么再次调用pool.connection时就会报错因为已经真的关闭了连接pool.steady_connection()可以获取一个新的链接threadlocalNone,

本线程独享值得对象用于保存链接对象如果链接对象被重置host127.0.0.1,port3306,userroot,password123,databasepooldb,charsetutf8

)def

POOL.connection(shareableFalse)cursor

conn.cursor()cursor.execute(select

from

cursor.fetchall()cursor.close()

#这里的关闭没有真正的关闭了线程在使用的话还是使用的那一个链接conn.close()func()模式二

由于pymysql、MySQLdb等threadsafety值为1所以该模式连接池中的线程会被所有线程共享。

import

连接池允许的最大连接数0和None表示不限制连接数mincached2,

初始化时链接池中至少创建的空闲的链接0表示不创建maxcached5,

链接池中最多闲置的链接0和None不限制maxshared3,

#这个参数没多大用

threadsafety都为1所有值无论设置为多少_maxcached永远为0所以永远是所有链接都共享。

blockingTrue,

连接池中如果没有可用连接后是否阻塞等待。

True等待False不等待然后报错maxusageNone,

一个链接最多被重复使用的次数None表示无限制setsession[],

datestyle

alwayshost127.0.0.1,port3306,userroot,password123456,databases8day127db,#链接的数据库的名字charsetutf8)def

func():#

检测当前正在运行连接数的是否小于最大链接数如果不小于则等待或报raise

否则#

然后将SteadyDBConnection对象封装到PooledDedicatedDBConnection中并返回。

#

如果最开始创建的链接没有链接则去创建一个SteadyDBConnection对象再封装到PooledDedicatedDBConnection中并返回。

#

POOL.connection()#

conn.cursor()cursor.execute(select

from

#这里的关闭也没有彻底关闭而是将线程放回数据库连接池中去了func()示例使用数据库连接池进行登录验证

首先把数据库连接池放进配置文件

AKL;FGMASDFASPERMANENT_SESSION_LIFETIME

timedelta(minutes20)SESSION_REFRESH_EACH_REQUEST

True

是否应该为每一个请求设置cookie默认为True如果为False则必须显性调用set_cookie函数SESSION_TYPE

redis

连接池允许的最大连接数0和None表示不限制连接数mincached2,

初始化时链接池中至少创建的空闲的链接0表示不创建maxcached5,

链接池中最多闲置的链接0和None不限制maxshared3,

这个参数没多大用

最大可以被大家共享的链接blockingTrue,maxusageNone,

一个链接最多被重复使用的次数None表示无限制setsession[],

ping0,host127.0.0.1,port3306,userroot,password123456,databaseflask01,

ProductionConfig(Config):SESSION_REDIS

Redis(host127.0.0.1,

DevelopmentConfig(Config):SESSION_REDIS

Redis(host127.0.0.1,

TestConfig(Config):passsql_helper.py

使用数据库连接池

current_app.config[PYMYSQL_POOL]conn

conn.cursor(cursorpymysql.cursors.DictCursor)return

conn,

cursor):conn.commit()cursor.close()conn.close()classmethoddef

fetch_one(cls,

cursor.fetchone()cls.close(conn,

cursor)return

cursor.fetchall()cls.close(conn,

cursor)return

render_template(login.html)user

数据库中查询数据obj