logo
关于我们

技术分享

技术分享 flask--数据库连接池

flask--数据库连接池

2021-06-07

定义: 

创建一个连接池(10个链接),为所有线程提供链接,使用时来进行获取,使用完毕时,再次放回到连接池。

等待下次其他线程的调用

 

单例模式使用连接池

import pymysql
import threadingfrom DBUtils.PooledDB import PooledDB
class SingletonDBPool(object):
   _instance_lock = threading.Lock()  #设置锁

   def __init__(self):
       self.pool = PooledDB(
           creator=pymysql,  # 使用链接数据库的模块
           maxconnections=6,  # 连接池允许的最大连接数,0和None表示不限制连接数
           mincached=2,  # 初始化时,链接池中至少创建的空闲的链接,0表示不创建

           maxcached=5,  # 链接池中最多闲置的链接,0和None不限制
           maxshared=3,
           # 链接池中最多共享的链接数量,0和None表示全部共享。PS: 无用,因为pymysql和MySQLdb等模块的 threadsafety都为1,所有值无论设置为多少,_maxcached永远为0,所以永远是所有链接都共享。
           blocking=True,  # 连接池中如果没有可用连接后,是否阻塞等待。True,等待;False,不等待然后报错
           maxusage=None,  # 一个链接最多被重复使用的次数,None表示无限制
           setsession=[],  # 开始会话前执行的命令列表。如:["set datestyle to ...", "set time zone ..."]
           ping=0,
           # ping MySQL服务端,检查是否服务可用。# 如:0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
           host='127.0.0.1',
           port=3306,
           user='root',
           password='123',
           database='pooldb',
           charset='utf8'
       )

   def __new__(cls, *args, **kwargs):  #当程序初始化之前,会先调用__new__方法.  实现单例模式
       if not hasattr(SingletonDBPool, "_instance"):
           with SingletonDBPool._instance_lock:
               if not hasattr(SingletonDBPool, "_instance"):
                   SingletonDBPool._instance = object.__new__(cls, *args, **kwargs)
       return SingletonDBPool._instance

   def connect(self):  #设置连接方法
       return self.pool.connection()


调用时

from pool import SingletonDBPool

def run():
    pool = SingletonDBPool()
    con = pool.connect()
    # xxxxxx

    con.close()if __name__ == '__main__':
    run()
调用

 

云祺备份软件,云祺容灾备份系统,虚拟机备份,数据库备份,文件备份,实时备份,勒索软件,美国,图书馆
  • 标签:
  • 网络安全

您可能感兴趣的新闻 换一批

现在下载,可享30天免费试用

立即下载