利用python list完成最简单的DB连接池方法
作者:我爱学python 发布时间:2022-04-19 18:38:00
标签:python,list,DB连接池
先来看查看效果:
在代码连接数据库后,并且执行三条sql后,将mysql直接重启掉,故我们的连接池连接均是不ok的,所以,它会全部删除再抓新的连接下来,重启mysql命令:
关于python代码:
'''
遇到问题没人解答?小编创建了一个Python学习交流QQ群:857662006
寻找有志同道合的小伙伴,互帮互助,群里还有不错的视频学习教程和PDF电子书!
'''
#!/usr/bin/env python3
# -*- coding: UTF-8 -*-
import pymysql
import random
import time
# 初始化mysql 连接池
def MySQLInit(mysql_host,mysql_port,mysql_user,mysql_password,mysql_charset,mysql_dbname,mysql_maxconnect):
# 定义返回mysql连接池的类型,这里定义为 list
return_db_list = []
for Connect in range(0,mysql_maxconnect):
try:
db = pymysql.connect(
host = mysql_host ,
port = mysql_port ,
user = mysql_user ,
passwd = mysql_password ,
db = mysql_dbname ,
charset = mysql_charset
)
print ("连接MySQL数据库成功,MySQL数据库ID为:%s" %(db))
return_db_list.append(db)
except Exception as e:
print ("连接MySQL数据库出错")
print (e)
# 如果mysql连接池为空,则返回-1
if 0 == len(return_db_list):
print ("错误 , 连接MySQL数据库失败,连接池为0")
return -1
else:
# 返回mysql连接池
return return_db_list
def Pull_DB_Connect(mysql_host,mysql_port,mysql_user,mysql_password,mysql_charset,mysql_dbname , MySQL_Connect_Pool , mysql_maxconnect) :
# 打印补充前的mysql连接数
print ("补充前MySQL连接数为:",len(MySQL_Connect_Pool))
# 循环相差的连接数
for Connect in range((len(MySQL_Connect_Pool)) , mysql_maxconnect):
try:
db = pymysql.connect(
host = mysql_host ,
port = mysql_port ,
user = mysql_user ,
passwd = mysql_password ,
db = mysql_dbname ,
charset = mysql_charset
)
print ("重新补充,连接MySQL数据库成功,MySQL数据库ID为:%s" %(db))
# 将刚刚连接成功的DB连接追加到MySQL_Connect_Pool中
MySQL_Connect_Pool.append(db)
except Exception as e:
print ("重新补充,连接MySQL数据库出错")
print (e)
if 0 == len(MySQL_Connect_Pool):
print ("错误 , 连接MySQL数据库失败,连接池为0")
return -1
else:
# 打印连接池总数并且返回
print("Mysql 连接池总数为:" , len(MySQL_Connect_Pool))
return MySQL_Connect_Pool
def main() :
# 定义测试mysql信息
mysql_host = "192.168.1.100"
mysql_port = 3306
mysql_user = "liwang"
mysql_password = "liwang"
mysql_charset = "utf8"
mysql_dbname = "itchat"
mysql_maxconnect = 3
# 初始化mysql连接池
MySQL_Connect_Pool = MySQLInit(mysql_host,mysql_port,mysql_user,mysql_password,mysql_charset,mysql_dbname,mysql_maxconnect)
# 定义初始化sql
sql = "show databases;"
while True:
# 随机获连接池的下标
db_link = random.randint(0,len(MySQL_Connect_Pool)-1)
try:
# 执行sql
cursor = MySQL_Connect_Pool[db_link].cursor()
cursor.execute(sql)
print (cursor.fetchall())
except Exception as e:
# 如果执行失败,模拟为DB连接失效,则打印错误信息,删除错误的MySQL_Connect_Pool信息
print (e)
del MySQL_Connect_Pool[db_link]
print ("数据库无法连接,删除Mysql连接池下标:" , db_link)
# 重新补充mysql连接池
Pull_DB_Connect(mysql_host,mysql_port,mysql_user,mysql_password,mysql_charset,mysql_dbname,MySQL_Connect_Pool,mysql_maxconnect)
# 休眠10s
time.sleep(10)
if __name__ == "__main__" :
main()
来源:https://www.jianshu.com/p/5e4595dd8e72
0
投稿
猜你喜欢
- 准备工作去年的时候,青云发表过关于栅格系统的文章 . 我们知道网页的栅格系统是运用固定的格子设计版面布局,使其风格工整简洁. 视觉上来说,栅
- 导言:在前面的教程里我们探讨了如何为GridView控件添加radio buttons列。当用户最多只能选择一项数据时,我们可以在用户界面里
- 以a=[1,2,3] 为例,似乎使用del, remove, pop一个元素2 之后 a都是为 [1,3],如下:>>>
- Session每台电脑访问服务器,都有独立的session,key值都一样,内容不一样。1.session保存在服务器上。2.session
- 现在介绍加速网页图形显示速度的六种方法,为你解决这个难题。其最基本的宗旨就是,让你用买鱼的价钱,品尝到熊掌的美味和营养。 1.首先要确定图像
- 本文主要是写了一个将指定文件夹下的指定文件类型移动到指定位置,具体内容如下# coding:utf-8import osimport shu
- 看到很多站长工具网,都提供了通过域名获取网站IP的方法。自己也想做一个,网上查了不少代码。有说用WSHSHELL,也有说用ASPPING组件
- 本系列专栏写作将采用首创的问答式写作形式,快速让你学习到 OpenCV 的初级、中级、高级知识。6. 在 Python OpenCV 针对图
- 编写兼容IE和FireFox的脚本确定的件很烦人的事,今日又经历了一次。一、正式表达式问题试图用以下表达式提取中括号“]”后面的内容,连接调
- 【原文地址】 Tip/Trick: How to upload a .SQL file to a Hoster and
- ORACLE EBS操作某一个FORM界面,或者后台数据库操作某一个表时发现一直出于"假死"状态,可能是该表被某一用户锁
- 如下所示:#-*- coding: utf-8 -*-import pandas as pdimport numpy as npfrom p
- 本文实例讲述了PHP判断是否微信访问的方法。分享给大家供大家参考,具体如下:在开发中有时需要禁止或者仅允许微信浏览器进行访问,则此时就需要对
- 本篇我们将学习简单的json数据的存储首先我们需要引入json模块:import json这里我们模拟一个常见常见,我们让用户输入用户名、密
- 控制结构就是for,while,if-else,if-elif,while…else,在web.py中其实和我们以前学过的一样,操作基本是相
- flask之模板继承为什么要用模板继承?原因很简单,因为模板继承能让我们在实现效果的前提下少些很多代码!咱废话不多说,先来看个小例子,看完我
- 本文给出了几个表单常用的js验证函数,有检查、\等特殊字符的,有检查是否含有空格,检查是否为Email 地址,也有检查是否是小数或负数的,检
- 以下的文章主要是对MySQL性能影响关系紧密的五大配置参数的介绍,我前几天在相关网站看见对MySQL性能影响关系紧密的五大配置参数的资料,觉
- 天下武功,唯快不破。编程也不例外,你的代码跑的快,你能快速找出代码慢的原因,你的码功就高。安装pip install pyinstrumen
- value_counts()方法返回一个序列Series,该序列包含每个值的数量(对于数据框中的任何列,value_counts()方法会返