python操作mysql数据库的精美实用模块(升级版)

写在前面

之前,给大家分享过一个我自己写的实用模块:《python操作mysql数据库的精美实用模块》

这个模块,我自己也一直在用的,没出过什么BUG。但其实,这个代码,也一直存在着一个不太优雅的问题——

就是对数据库进行了频繁地创建连接和销毁连接,这减慢了操作时间,也消耗了服务器内存。

最近,看到了 数据库连接池技术,其实这个技术理解起来也很简单,所以果断对自己的代码了进行升级。

当然,之前的《python操作mysql数据库的精美实用模块》也并非完全无用武之地了,就像我手上其中一个项目,因为之前整体构架的问题,偏偏就用不上数据库连接池技术,上了反而会出问题。

凡事都有利有弊,大家都需要根据自己项目的情况,对应选择运用合适自己项目的技术。

数据库连接池技术

好了,正式介绍下这个技术:

连接池是一种常见的数据库优化技术,它可以减少数据库连接的开销,提高程序性能。

连接池的基本思想是在程序启动时,创建一定数量的数据库连接,并保存在一个容器中。

当程序需要访问数据库时,从容器中获取一个空闲的连接,使用完毕后,将连接归还到容器中,而不是关闭连接。

DBUtils 库

DBUtils 是一个常用的 Python 的第三方数据库连接池库,支持多种数据库,包括 MySQL、PostgreSQL、SQLite 等。

网上相关资料,也是比较丰富的,如需详细了解,大家自行搜索资料吧。

这里按照我的风格惯例,给大家直接上我自己写好的实用模块,方便拿走即用。

其中,我的初代版《python操作mysql数据库的精美实用模块》也已经改为类实现了,这次一起奉上。

python操作mysql数据库的精美实用模块—— DBUtils连接池版

import pymysql
from dbutils.pooled_db import PooledDB
#############################################################################################
# 连接mysql数据库-----使用数据库连接池技术----dbutils库
#############################################################################################
db_pool = PooledDB(
    creator=pymysql,  # 使用链接数据库的模块
    maxconnections=800,  # 连接池允许的最大连接数,0和None表示不限制连接数
    mincached=8,  # 初始化时,链接池中至少创建的空闲的链接,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='root',
    database='mydbdemo',
    charset='utf8'
)



class DBManager():
    # 创建数据库连接
    def __init__(self):
        self.db = db_pool.connection()

    # 关闭数据库连接
    def closeDB(self):
        self.db.close()


    #连接数据库,执行插入SQl
    def executeQueryID(self,sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            self.db.commit()
            the_id = int(cursor.lastrowid)
            #the_id = int(db.insert_id())
            return the_id
        except Exception:
            return False
        finally:
            self.db.close()  # 关闭数据库连接




    # 连接数据库,执行SQl,无返回
    def executeQueryNO(self, sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            self.db.commit()
            return True
        except Exception:
            self.db.rollback()
            return False
        finally:
            self.db.close()  # 关闭数据库连接


    #连接数据库,执行SQL,返回单条数据
    def executeQueryone(self, sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            dataone = cursor.fetchone()
            return dataone
        except Exception:
            return False
        finally:
            self.db.close()  # 关闭数据库连接

    #连接数据库,执行SQL,返回多条数据
    def executeQueryall(self, sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            dataall = cursor.fetchall()
            return dataall
        except Exception:
            return False
        finally:
            self.db.close()  # 关闭数据库连接





python操作mysql数据库的精美实用模块—— 原版改用类实现

##############################################################################################
# 连接mysql数据库
#############################################################################################
class DBManager_Old():
    # 创建数据库连接
    def __init__(self):
        db_config = ConfigManager.get_db_config()
        self.db = pymysql.Connect(
        host='127.0.0.1',
        port=3306,
        user='root',
        passwd='root',
        db='mydbdemo',
        charset='utf8')

    # 关闭数据库连接
    def closeDB(self):
        self.db.close()

    #连接数据库,执行插入SQl
    def executeQueryID(self,sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            self.db.commit()
            the_id = int(cursor.lastrowid)
            #the_id = int(db.insert_id())
            return the_id
        except Exception:
            return False
        finally:
            self.db.close()  # 关闭数据库连接




    # 连接数据库,执行SQl,无返回
    def executeQueryNO(self, sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            self.db.commit()
            return True
        except Exception:
            self.db.rollback()
            return False
        finally:
            self.db.close()  # 关闭数据库连接


    #连接数据库,执行SQL,返回单条数据
    def executeQueryone(self, sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            dataone = cursor.fetchone()
            return dataone
        except Exception:
            return False
        finally:
            self.db.close()  # 关闭数据库连接

    #连接数据库,执行SQL,返回多条数据
    def executeQueryall(self, sqlstring):
        try:
            cursor = self.db.cursor()
            cursor.execute(sqlstring)
            dataall = cursor.fetchall()
            return dataall
        except Exception:
            return False
        finally:
            self.db.close()  # 关闭数据库连接

写在最后

所以,你看,大家平时学习或开发时,发现更好更合适的技术或方法,就要积极去升级自己项目的代码,这就是所谓的重构。

《程序员修炼之道》有言:尽早重构,经常重构。

重构的思想精髓,就是不断地去升级项目的代码,同时,这个过程也在不断地修炼自己的技术。

其实,代码需要重构,整个项目也需要重构,我们的能力也需要重构,我们的人生也需要重构。

重构,不是推倒重来,是在现有的基础上,一步一步,不断去升级,去变得更好。

这其实就是修炼啊,人生本就是一场修炼。

这就是我理解的重构。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,980评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,178评论 2 380
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,868评论 0 336
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,498评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,492评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,521评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,910评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,569评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,793评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,559评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,639评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,342评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,931评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,904评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,144评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,833评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,350评论 2 342

推荐阅读更多精彩内容