import pymysql
from DBUtils.PersistentDB import PersistentDB
POOL = PersistentDB(
  creator=pymysql, # 使用鏈接數(shù)據(jù)庫的模塊
  maxusage=None, # 一個(gè)鏈接最多被重復(fù)使用的次數(shù)，None表示無限制
  setsession=[], # 開始會(huì)話前執(zhí)行的命令列表。如：["set datestyle to ...", "set time zone ..."]
  ping=0, # ping MySQL服務(wù)端，檢查是否服務(wù)可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
  closeable=False,
  # 建議為False,如果為False時(shí)， conn.close() 實(shí)際上被忽略，供下次使用，再線程關(guān)閉時(shí)，才會(huì)自動(dòng)關(guān)閉鏈接。如果為True時(shí)， conn.close()則關(guān)閉鏈接，那么再次調(diào)用pool.connection時(shí)就會(huì)報(bào)錯(cuò)，因?yàn)橐呀?jīng)真的關(guān)閉了連接（pool.steady_connection()可以獲取一個(gè)新的鏈接）
  threadlocal=None, # 本線程獨(dú)享值得對(duì)象，用于保存鏈接對(duì)象，如果鏈接對(duì)象被重置
  host='127.0.0.1',
  port=3306,
  user='root',
  password='123',
  database='pooldb',
  charset='utf8'
)
def func():
  conn = POOL.connection(shareable=False)
  cursor = conn.cursor()
  cursor.execute('select * from tb1')
  result = cursor.fetchall()
  cursor.close()
  conn.close()
func()

import time
import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
  creator=pymysql, # 使用鏈接數(shù)據(jù)庫的模塊
  maxconnections=6, # 連接池允許的最大連接數(shù)，0和None表示不限制連接數(shù)
  mincached=2, # 初始化時(shí)，鏈接池中至少創(chuàng)建的空閑的鏈接，0表示不創(chuàng)建
  maxcached=5, # 鏈接池中最多閑置的鏈接，0和None不限制
  maxshared=3, # 鏈接池中最多共享的鏈接數(shù)量，0和None表示全部共享。PS: 無用，因?yàn)閜ymysql和MySQLdb等模塊的 threadsafety都為1，所有值無論設(shè)置為多少，_maxcached永遠(yuǎn)為0，所以永遠(yuǎn)是所有鏈接都共享。
  blocking=True, # 連接池中如果沒有可用連接后，是否阻塞等待。True，等待；False，不等待然后報(bào)錯(cuò)
  maxusage=None, # 一個(gè)鏈接最多被重復(fù)使用的次數(shù)，None表示無限制
  setsession=[], # 開始會(huì)話前執(zhí)行的命令列表。如：["set datestyle to ...", "set time zone ..."]
  ping=0,
  # ping MySQL服務(wù)端，檢查是否服務(wù)可用。# 如：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():
  # 檢測(cè)當(dāng)前正在運(yùn)行連接數(shù)的是否小于最大鏈接數(shù)，如果不小于則：等待或報(bào)raise TooManyConnections異常
  # 否則
  # 則優(yōu)先去初始化時(shí)創(chuàng)建的鏈接中獲取鏈接 SteadyDBConnection。
  # 然后將SteadyDBConnection對(duì)象封裝到PooledDedicatedDBConnection中并返回。
  # 如果最開始創(chuàng)建的鏈接沒有鏈接，則去創(chuàng)建一個(gè)SteadyDBConnection對(duì)象，再封裝到PooledDedicatedDBConnection中并返回。
  # 一旦關(guān)閉鏈接后，連接就返回到連接池讓后續(xù)線程繼續(xù)使用。
  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()

from flask import Flask
from db_helper import SQLHelper
app = Flask(__name__)
@app.route("/")
def hello():
  result = SQLHelper.fetch_one('select * from xxx',[])
  print(result)
  return "Hello World"
if __name__ == '__main__':
  app.run()

import time
import pymysql
from DBUtils.PooledDB import PooledDB
POOL = PooledDB(
  creator=pymysql, # 使用鏈接數(shù)據(jù)庫的模塊
  maxconnections=6, # 連接池允許的最大連接數(shù)，0和None表示不限制連接數(shù)
  mincached=2, # 初始化時(shí)，鏈接池中至少創(chuàng)建的空閑的鏈接，0表示不創(chuàng)建
  maxcached=5, # 鏈接池中最多閑置的鏈接，0和None不限制
  maxshared=3, # 鏈接池中最多共享的鏈接數(shù)量，0和None表示全部共享。PS: 無用，因?yàn)閜ymysql和MySQLdb等模塊的 threadsafety都為1，所有值無論設(shè)置為多少，_maxcached永遠(yuǎn)為0，所以永遠(yuǎn)是所有鏈接都共享。
  blocking=True, # 連接池中如果沒有可用連接后，是否阻塞等待。True，等待；False，不等待然后報(bào)錯(cuò)
  maxusage=None, # 一個(gè)鏈接最多被重復(fù)使用的次數(shù)，None表示無限制
  setsession=[], # 開始會(huì)話前執(zhí)行的命令列表。如：["set datestyle to ...", "set time zone ..."]
  ping=0,
  # ping MySQL服務(wù)端，檢查是否服務(wù)可用。# 如：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'
)
"""
class SQLHelper(object):
  @staticmethod
  def fetch_one(sql,args):
    conn = POOL.connection()
    cursor = conn.cursor()
    cursor.execute(sql, args)
    result = cursor.fetchone()
    conn.close()
    return result
  @staticmethod
  def fetch_all(self,sql,args):
    conn = POOL.connection()
    cursor = conn.cursor()
    cursor.execute(sql, args)
    result = cursor.fetchone()
    conn.close()
    return result
# 調(diào)用方式：
result = SQLHelper.fetch_one('select * from xxx',[])
print(result)
"""
"""
#第二種：
class SQLHelper(object):
  def __init__(self):
    self.conn = POOL.connection()
    self.cursor = self.conn.cursor()
  def close(self):
    self.cursor.close()
    self.conn.close()
  def fetch_one(self,sql, args):
    self.cursor.execute(sql, args)
    result = self.cursor.fetchone()
    self.close()
    return result
  def fetch_all(self, sql, args):
    self.cursor.execute(sql, args)
    result = self.cursor.fetchall()
    self.close()
    return result
obj = SQLHelper()
obj.fetch_one()
"""