采用連接池的方式來(lái)操作DB

#-*- coding:utf-8 -*-

#!/usr/bin/python3

import pymysql

import configUtil

from DBUtils.PooledDB import PooledDB

class MysqlUtil(object):

# 連接池對(duì)象

__pool = None

def __init__(self, config):

# 數(shù)據(jù)庫(kù)構(gòu)造函數(shù)，從連接池中取出連接，并生成操作游標(biāo)

self.pool = MysqlUtil.__get_conn(config)

@staticmethod

def __get_conn(config):

"""

@summary: 靜態(tài)方法，從連接池中取出連接

@return MySQLdb.connection

"""

host = configUtil.read_config(config, "datasource_url", "mysqlConfig")

username = configUtil.read_config(config, "datasource_username", "mysqlConfig")

db_pwd = configUtil.read_config(config, "datasource_password", "mysqlConfig")

db_database = configUtil.read_config(config, "datasource_database", "mysqlConfig")

if MysqlUtil.__pool is None:

__pool = PooledDB(pymysql, mincached=1, maxcached=10, maxconnections=10,

host=host, port=3306, user=username, passwd=db_pwd,

db=db_database, use_unicode=False, blocking=False, charset="utf8")

return __pool

def get_all(self, sql):

"""

@summary: 執(zhí)行查詢，并取出所有結(jié)果集

@param sql:查詢ＳＱＬ，如果有查詢條件，請(qǐng)只指定條件列表，并將條件值使用參數(shù)[param]傳遞進(jìn)來(lái)

@param param: 可選參數(shù)，條件列表值(元組/列表)

@return: result list(字典對(duì)象)/boolean 查詢到的結(jié)果集

"""

try:

con = self.pool.connection()

cur = con.cursor()

count = cur.execute(sql)

if count > 0:

result = cur.fetchall()

else:

result = False

return result

except Exception as e:

print('SQL執(zhí)行有誤,原因:', e)

finally:

cur.close()

con.close()

def update(self, sql):

try:

con = self.pool.connection()

cur = con.cursor()

cur.execute(sql)

con.commit()

except Exception as e:

con.rollback() # 事務(wù)回滾

print('SQL執(zhí)行有誤,原因:', e)

finally:

cur.close()

con.close()

總結(jié)

以上是生活随笔為你收集整理的python连接池框架_python pymysql 连接池的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。