猿创征文｜Python基础——Visual Studio版本——第六章 MySQL操作
Python基础——Visual Studio版本——第六章 MySQL操作
目录
Python基础——Visual Studio版本——第六章 MySQL操作
1、环境配置
2、环境引入与连接测试
3、创建数据库表
4、增删改语句测试
5、查询语句测试
6、事务测试
异常提交
无异常提交
7、封装DBHelper.py
1、环境配置
pip3 config set global.index-url https://repo.huaweicloud.com/repository/pypi/simplepip3 config listpip3 install --upgrade pippip3 install pymysql2、环境引入与连接测试
数据库是我阿里的数据库，可以用到23年。做测试没问题。
输入顺序：host连接地址，port连接端口号，user连接用户名，password连接密码，db连接数据库，charset连接的编码格式。
import pymysql # 链接MySQL db = pymysql.connect(host='rm-bp1zq3879r28p726lco.mysql.rds.aliyuncs.com', port=3306,user='qwe8403000',password='Qwe8403000',db='mytest',charset='utf8')print(db)
3、创建数据库表
核心编码
conn = pymysql.connect() # 创建连接cursor = conn.cursor() #获取游标对象rows = cursor.execute(sql) #执行SQL语句conn.commit() #提交数据库连接，如果是增、删、改操作，则必须提交cursor.close() #关闭游标对象conn.close() #关闭数据库连接import pymysql#创建数据库连接conn = pymysql.connect(host='rm-bp1zq3879r28p726lco.mysql.rds.aliyuncs.com', port=3306,user='qwe8403000',password='Qwe8403000',db='mytest',charset='utf8')cursor = conn.cursor() #获取游标对象#定义创建user表的sql语句，使用三引号'''表示格式化字符串sql = """CREATE TABLE mytestuser20220829 ( userid int(8) NOT NULL auto_increment, username varchar(50) NOT NULL, password varchar(50) default NULL, PRIMARY KEY (userid))"""rows = cursor.execute(sql) #执行SQL语句conn.commit() #提交数据库连接，如果是增、删、改操作，则必须提交print("mytestuser20220829表创建成功")cursor.close() #关闭游标对象conn.close() #关闭数据库连接
4、增删改语句测试
游标可以多次执行sql语句，最终进行commit即可。
import pymysql#创建数据库连接conn = pymysql.connect(host='rm-bp1zq3879r28p726lco.mysql.rds.aliyuncs.com', port=3306,user='qwe8403000',password='Qwe8403000',db='mytest',charset='utf8')cursor = conn.cursor() #获取游标对象#定义创建user表的sql语句，使用三引号'''表示格式化字符串sqlInsert1 = "insert into mytestuser20220829 values(0,'{0}',{1})".format("王语嫣", "123")sqlInsert2 = "insert into mytestuser20220829 values(0,'{0}',{1})".format("小龙女","123")sqlInsert3 = "insert into mytestuser20220829 values(0,'{0}',{1})".format("赵灵儿", "321")sqlInsert4 = "insert into mytestuser20220829 values(0,'{0}',{1})".format("删除测试", "321")cursor.execute(sqlInsert1)cursor.execute(sqlInsert2)cursor.execute(sqlInsert3)cursor.execute(sqlInsert4)sqlUpdate = "update mytestuser20220829 set password='{0}' where username='{1}'".format("潇洒的姑娘", "赵灵儿")cursor.execute(sqlUpdate)sqlDelete = "delete from mytestuser20220829 where username='{0}'".format("删除测试")cursor.execute(sqlDelete)# 提交conn.commit()# 关闭游标cursor.close()# 关闭数据库conn.close()
5、查询语句测试
使用fetchall函数就可以获取游标中的数据了。
import pymysql#创建数据库连接conn = pymysql.connect(host='rm-bp1zq3879r28p726lco.mysql.rds.aliyuncs.com', port=3306,user='qwe8403000',password='Qwe8403000',db='mytest',charset='utf8')cursor = conn.cursor() #获取游标对象sql = "select * from mytestuser20220829" # 执行SQLcursor.execute(sql) # 回去返回集合 data = cursor.fetchall()for item in data: print(item[0]) print(item[1]) print(item[2])# 关闭游标cursor.close()# 关闭数据库conn.close()
6、事务测试
ACID_MySQL事务的四大特性详解(MySQL高频面试题)_红目香薰的博客-CSDN博客
异常提交
异常回滚测试，我这里一个正确的insert一个错误的，正确的肯定是能添加成功的，但是有由于第二个语句错误，所以回滚的时候一同回滚。
import pymysql#创建数据库连接conn = pymysql.connect(host='rm-bp1zq3879r28p726lco.mysql.rds.aliyuncs.com', port=3306,user='qwe8403000',password='Qwe8403000',db='mytest',charset='utf8')cursor = conn.cursor() #获取游标对象try: sql1 = "insert into mytestuser20220829 values(0,'{0}',{1})".format("事务测试1", "666") cursor.execute(sql1) # 回去返回集合 sql2 = "insert into mytestuser20220829 values(0,'{0}',{1},{2})".format("事务测试2", "666",66) cursor.execute(sql2) # 回去返回集合 conn.commit()except: print("有异常，数据库回滚") conn.rollback() #回滚事务，之前的修改操作都不生效# 关闭游标cursor.close()# 关闭数据库conn.close()异常回滚，可以看到没有任何数据添加成功。
无异常提交
两个sql语句都是正确的sql，一同提交并无异常。
import pymysql#创建数据库连接conn = pymysql.connect(host='rm-bp1zq3879r28p726lco.mysql.rds.aliyuncs.com', port=3306,user='qwe8403000',password='Qwe8403000',db='mytest',charset='utf8')cursor = conn.cursor() #获取游标对象try: sql1 = "insert into mytestuser20220829 values(0,'{0}',{1})".format("事务测试1", "666") cursor.execute(sql1) # 回去返回集合 sql2 = "insert into mytestuser20220829 values(0,'{0}',{1})".format("事务测试2", "666") cursor.execute(sql2) # 回去返回集合 conn.commit()except: print("有异常，数据库回滚") conn.rollback() #回滚事务，之前的修改操作都不生效# 关闭游标cursor.close()# 关闭数据库conn.close()两条sql都添加成功。
7、封装DBHelper.py
主要进行增删改、查询两个函数的封装，其中init是初始化参数，getConnect是获取游标
import pymysqlclass 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()使用DBHelper测试
from DBHelper import DBHelperdb=DBHelper()db.excute("insert into mytestuser20220829 values(0,'{0}',{1})".format("DBHelper测试数据1", "666"))db.excute("insert into mytestuser20220829 values(0,'{0}',{1})".format("DBHelper测试数据2", "666"))db.excute("insert into mytestuser20220829 values(0,'{0}',{1})".format("DBHelper测试数据3", "666"))db.excute("insert into mytestuser20220829 values(0,'{0}',{1})".format("DBHelper测试数据4", "666"))db.excute("insert into mytestuser20220829 values(0,'{0}',{1})".format("DBHelper测试数据5", "666"))result=db.query("select * from mytestuser20220829")print(result)
封装完毕。
