Python 之 Mysql 实战

Wu_Candy

发布于 2023-09-14 08:53:42

18000

代码可运行

文章被收录于专栏：无量测试之道无量测试之道

运行总次数：0

代码可运行

Step1、Python 如何操作 Mysql

Python通过DB-API，为大多数的数据库实现了接口，使用它连接各数据库后，就可以用相同的方式操作各数据库。

Python DB-API使用流程：

第一步：引入 API 模块。

第二步：获取与数据库的连接。

第三步：执行SQL语句和存储过程。

第四步：关闭数据库连接。

本次是以PyMysql第三方包为示例来分享MySQL数据库的连接，并实现数据库的各种操作。

Step2、如何安装 Mysql 第三方包 安装命令非常简单：pip install pymysql

Step3、Python 操作 Mysql 的实例代码是两个文件

一个是配置文件，一个是封装好的操作Mysql文件，代码如下：

dbconfig.py #mysql的配置文件
dbDict = {"test5":" beta5.ep.tx1.test.io","test6":"beta6.ep.tx1.test.io",
"test7":"beta7.ep.tx1.test.io"}
dbPort = "3306"
dbUser = "tester"
dbPassword = "123456"

DBUtils.py: #mysql的操作文件
#coding:utf-8
import pymysql
import dbconfig

class DBUtils():
  def __init__(self,dbtype):
        print(dbconfig.dbDict.get(dbtype))
        self.conn = pymysql.connect(dbconfig.dbDict.get(dbtype), dbconfig.dbUser, dbconfig.dbPassword)
        self.cursor = self.conn.cursor()

  def dbSelect(self,sql):
        print ("------------------------------------")
        print(sql)
        resultList = []
        self.cursor.execute(sql)
        result = self.cursor.fetchall()
        columns = self.cursor.description
        for val in result:
            tempDict = {}
        for cloNum in range(len(columns)):
                tempDict[str(columns[cloNum][0])] = val[cloNum]
            resultList.append(tempDict)
        print("---------------------打印查询结果----------------------")
        print(resultList)
        self.dbClose()
        return resultList

  def dbExcute(self,sql):
        print ("execute sql")
        print(sql)
        self.cursor.execute(sql)
        self.dbClose()

  def dbClose(self):
        self.conn.commit()
        self.cursor.close()
        self.conn.close()