爲何要使用數據庫鏈接池？以及用法(DBUtils)

看代碼，mysql

from flask import Flask from db import POOL import pymysql app = Flask(__name__) app.secret_key ='sdfsdfsdf' @app.route('/index') def index(): # 第一步：缺點：每次請求反覆建立數據庫鏈接，鏈接數太多。
    # conn = pymysql.connect()
    # cursor = conn.cursor()
    # cursor.execute('select * from tb where id > %s',[5,])
    # result = cursor.fetchall()
    # cursor.close()
    # conn.close()
    # print(result)

對於這種方式，每來一個用戶請求，都要去建立一個連接。對於數據庫來講，過度了。可併發，可是鏈接數太多。sql

就算你改爲在全局建立，只用一個連接，可是會變成串行。數據庫

若是是多線程的話，這樣的方式是否是會報錯哦？pymysql它同一時間只能處理一個線程。flask

那來，咱們這樣玩，仍是在將連接操做放在全局。session

# 第二步：缺點，不能支持併發
    # pymysql.threadsafety
    # with LOCK:
    # cursor = CONN.cursor()
    # cursor.execute('select * from tb where id > %s', [5, ])
    # result = cursor.fetchall()
    # cursor.close()
    #     # print(result)

加把鎖。這樣支持多線程了吧？多線程

但是。。。它支持併發嗎？並不支持併發

讓它倆折中一下，這樣來玩。app

　　基於DBUtils實現數據連接池。ide

　　　　模式一：每一個線程獨立建立本身的連接，不管該線程使用多少次，用的都是同一個。該線程關閉時，僞關閉，本地線程再次調用時，繼續使用最開始建立的連接。fetch

　　　　　　　　什麼時候關閉？線程不終止，永不關閉！全部線程終止數據庫鏈接，該線程關閉。

　　　　模式二：多線程間不分彼此。建立一個鏈接池（此處才體現出池），爲全部線程提供連接。

　　　　　　　　使用時從池裏獲取，使用完畢後，放回鏈接池。

　　　　　　　　拿的時候，pop出來，用完再append進去。

　　　　　　　　鏈接池裏的鏈接，排隊依次被使用。

　　　　　　　　　　補充：共享時，可設置最多共享數？？？

　　　　　　　　　　　　　　文檔裏寫的能夠設置最大共享數，好比我池裏有10個線程，最大共享數設置5，你是否定爲最多5個能夠被來回玩？

　　　　　　　　　　　　　　　　NO！源碼裏面，清清楚楚的寫到：你們都是朋友，不見外，一塊兒玩。

　　　　　　　　　　　　　　　　pymsql裏面的threadsafety=1，表明：不管你如何使用，全部鏈接均可被重複使用。

本地線程示例：保證每一個線程都有數據庫鏈接，都持有本身的一份數據，在操做時，不會相互影響。

import threading import time # 本地線程對象
local_values = threading.local() def func(num): """ # 第一個線程進來，本地線程對象會爲他建立一個 # 第二個線程進來，本地線程對象會爲他建立一個 :param num: :return: """ local_values.name = num # 4
    # 線程停下來了
    time.sleep(2) print(local_values.name, threading.current_thread().name) for i in range(5): th = threading.Thread(target=func, args=(i,), name='線程%s' % i) th.start()

local

模式二示例：

import time import pymysql import threading from DBUtils.PooledDB import PooledDB, SharedDBConnection 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 func(): # 檢測當前正在運行鏈接數的是否小於最大連接數，若是不小於則：等待或報raise TooManyConnections異常
    # 不然
    # 則優先去初始化時建立的連接中獲取連接 SteadyDBConnection。
    # 而後將SteadyDBConnection對象封裝到PooledDedicatedDBConnection中並返回。
    # 若是最開始建立的連接沒有連接，則去建立一個SteadyDBConnection對象，再封裝到PooledDedicatedDBConnection中並返回。
    # 一旦關閉連接後，鏈接就返回到鏈接池讓後續線程繼續使用。

    # PooledDedicatedDBConnection
    conn = POOL.connection() # print(th, '連接被拿走了', conn1._con)
    # print(th, '池子裏目前有', pool._idle_cache, '\r\n')
 cursor = conn.cursor() cursor.execute('select * from tb1') result = cursor.fetchall() conn.close() conn = POOL.connection() # print(th, '連接被拿走了', conn1._con)
    # print(th, '池子裏目前有', pool._idle_cache, '\r\n')
 cursor = conn.cursor() cursor.execute('select * from tb1') result = cursor.fetchall() conn.close() func()

PooledDB

模式二鏈接池用法：

import time import pymysql import threading from DBUtils.PooledDB import PooledDB, SharedDBConnection 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' )

from flask import Flask from db import POOL import pymysql app = Flask(__name__) app.secret_key ='sdfsdfsdf' @app.route('/index') def index(): conn = POOL.connection() cursor = conn.cursor() cursor.execute('select * from tb1') result = cursor.fetchall() conn.close() return '執行成功'

if __name__ == '__main__': # app.__call__
    app.run()