用pymysql連接DBUtils中的 PooledDB，實現增刪改查

備注：1，記得先修改連接的數據庫哦，（用navicat更方便一點）；2，分開兩個py文件寫入，運行sqlhelper.py文件

 

一、在utils.py中寫

import pymysql
from DBUtils.PooledDB import PooledDB

POOL = PooledDB(
    creator=pymysql,  # 使用鏈接數據庫的模塊
    maxconnections=6,  # 連接池允許的最大連接數，0和None表示不限制連接數
    mincached=2,  # 初始化時，鏈接池中至少創建的空閑的鏈接，0表示不創建
    maxcached=5,  # 鏈接池中最多閑置的鏈接，0和None不限制
    maxshared=1,  # 鏈接池中最多共享的鏈接數量，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='',
    database='ziji',
    charset='utf8'
)


二、在sqlhelper.py中寫入：

from utils import POOL
import pymysql


def create_conn():
    conn = POOL.connection()
    cursor = conn.cursor(pymysql.cursors.DictCursor)
    return conn, cursor


def close_conn(conn, cursor):
    conn.close()
    cursor.close()


def select_one(sql, args):
    conn, cur = create_conn()
    cur.execute(sql, args)
    result = cur.fetchone()
    close_conn(conn, cur)
    return result


def select_all(sql, args):
    conn, cur = create_conn()
    cur.execute(sql, args)
    result = cur.fetchall()
    close_conn(conn, cur)
    return result


def insert_one(sql, args):
    conn, cur = create_conn()
    result = cur.execute(sql, args)
    conn.commit()
    close_conn(conn, cur)
    return result


def delete_one(sql,args):
    conn,cur = create_conn()
    result = cur.execute(sql,args)
    conn.commit()
    close_conn(conn,cur)
    return result

def update_one(sql,args):
    conn,cur = create_conn()
    result = cur.execute(sql,args)
    conn.commit()
    close_conn(conn,cur)
    return result



# sql = "insert into stu(id,name,age) VALUE (%s,%s,%s)"   #增加
# res = insert_one(sql, [2,"飛機", 28])
# print(res)

# sql = "delete from stu where name = %s"   #刪除
# res = delete_one(sql, "哪吒")
# print(res)

# sql = "select * from stu"   #查詢全部
# res = select_all(sql, [])
# print(res)

# sql = "select * from stu where name=%s"   #查詢一條
# res = select_one(sql, "趙振偉")
# print(res)



# sql = " UPDATE stu set name=%s where name = %s"   #更新
# res = update_one(sql,("坦克","飛機"))
# print(res)