前言
本节内容为方便大家复制，所有内容都写在了引用模块。
环境要求
pip3 config set global.index-url https://repo.huaweicloud.com/repository/pypi/simple pip3 config list pip3 install --upgrade pip pip3 install pymysql
DBHelper源码
import pymysql class DBHelper(): def __init__(self): # 数据库连接参数 self.host = "rm-bp1zq3879r28p726lco.mysql.rds.aliyuncs.com" self.user = "qwe8403000" self.pwd = "Qwe8403000" self.db = "mytest" self.charset = "utf-8" # 获取游标 def getConnect(self): if not self.db: raise(NameError, "没有设置数据库信息") self.conn = pymysql.connect(host=self.host, port=3306, user=self.user, passwd=self.pwd, db=self.db, charset="utf8mb4") # 按照字典的方式返回 cursor = self.conn.cursor(cursor=pymysql.cursors.DictCursor) if not cursor: raise(NameError, "连接数据库失败") else: return cursor # 查 def query(self, sql): cursor = self.getConnect() cursor.execute(sql) result = cursor.fetchall() # 获取查询的所有数据 # 查询完毕后必须关闭连接 self.conn.close() return result # 增删改查 def excute(self, sql): cursor = self.getConnect() cursor.execute(sql) self.conn.commit() self.conn.close()
调用示例：
from DBHelper import DBHelper db=DBHelper() db.excute("sql") result=db.query("sql") print(result)
希望对大家有所帮助，复制起来很方便。
