怎么利用python list完成最簡(jiǎn)單的DB連接池方法

小編給大家分享一下怎么利用python list完成最簡(jiǎn)單的DB連接池方法，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

python主要應(yīng)用領(lǐng)域有哪些

1、云計(jì)算，典型應(yīng)用OpenStack。2、WEB前端開(kāi)發(fā)，眾多大型網(wǎng)站均為Python開(kāi)發(fā)。3.人工智能應(yīng)用，基于大數(shù)據(jù)分析和深度學(xué)習(xí)而發(fā)展出來(lái)的人工智能本質(zhì)上已經(jīng)無(wú)法離開(kāi)python。4、系統(tǒng)運(yùn)維工程項(xiàng)目，自動(dòng)化運(yùn)維的標(biāo)配就是python+Django/flask。5、金融理財(cái)分析，量化交易，金融分析。6、大數(shù)據(jù)分析。

先來(lái)看查看效果:

在代碼連接數(shù)據(jù)庫(kù)后，并且執(zhí)行三條sql后，將mysql直接重啟掉，故我們的連接池連接均是不ok的，所以，它會(huì)全部刪除再抓新的連接下來(lái)，重啟mysql命令:

關(guān)于python代碼:

'''
遇到問(wèn)題沒(méi)人解答？小編創(chuàng)建了一個(gè)Python學(xué)習(xí)交流QQ群：857662006 
尋找有志同道合的小伙伴，互幫互助,群里還有不錯(cuò)的視頻學(xué)習(xí)教程和PDF電子書(shū)！
'''
#!/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連接池的類(lèi)型，這里定義為 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數(shù)據(jù)庫(kù)成功，MySQL數(shù)據(jù)庫(kù)ID為:%s" %(db))
      return_db_list.append(db)
    except Exception as e:
      print ("連接MySQL數(shù)據(jù)庫(kù)出錯(cuò)")
      print (e)

  # 如果mysql連接池為空，則返回-1
  if 0 == len(return_db_list):
    print ("錯(cuò)誤 , 連接MySQL數(shù)據(jù)庫(kù)失敗,連接池為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) :
  
  # 打印補(bǔ)充前的mysql連接數(shù)
  print ("補(bǔ)充前MySQL連接數(shù)為:",len(MySQL_Connect_Pool))
  
  # 循環(huán)相差的連接數(shù)
  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 ("重新補(bǔ)充，連接MySQL數(shù)據(jù)庫(kù)成功，MySQL數(shù)據(jù)庫(kù)ID為:%s" %(db))
      # 將剛剛連接成功的DB連接追加到MySQL_Connect_Pool中
      MySQL_Connect_Pool.append(db)
    except Exception as e:
      print ("重新補(bǔ)充，連接MySQL數(shù)據(jù)庫(kù)出錯(cuò)")
      print (e)

  if 0 == len(MySQL_Connect_Pool):
    print ("錯(cuò)誤 , 連接MySQL數(shù)據(jù)庫(kù)失敗,連接池為0")
    return -1

  else:
    # 打印連接池總數(shù)并且返回
    print("Mysql 連接池總數(shù)為:" , len(MySQL_Connect_Pool))
    return MySQL_Connect_Pool 

def main() :

  # 定義測(cè)試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:
    # 隨機(jī)獲連接池的下標(biāo)
    db_link = random.randint(0,len(MySQL_Connect_Pool)-1)
    try:
      # 執(zhí)行sql 
      cursor = MySQL_Connect_Pool[db_link].cursor()
      cursor.execute(sql)
      print (cursor.fetchall())
    except Exception as e:
      # 如果執(zhí)行失敗，模擬為DB連接失效，則打印錯(cuò)誤信息，刪除錯(cuò)誤的MySQL_Connect_Pool信息
      print (e)
      del MySQL_Connect_Pool[db_link]
      print ("數(shù)據(jù)庫(kù)無(wú)法連接，刪除Mysql連接池下標(biāo):" , db_link)
      # 重新補(bǔ)充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()

以上是“怎么利用python list完成最簡(jiǎn)單的DB連接池方法”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！