python3使用pymysql模块，连接mysql数据库，实现新增、查询和更新 *** 作

概述1、环境数据准备： python3环境、pymysql模块 mysql数据库：本次代码中用到的数据库为本地的testdb数据库，user表(表字段比较简单，只有主键id，手机号mobile，密码pas

1、环境数据准备：

python3环境、pyMysqL模块

MysqL数据库：本次代码中用到的数据库为本地的testdb数据库，user表(表字段比较简单，只有主键ID，手机号mobile，密码passwd)

2、本次代码直接封装为类，代码中附有注释，把数据库参数改为自己实际的就可以直接使用

 

 1 #引入pyMysqL模块 2 import pyMysqL 3  4 class DoMysqL: 5     #初始化 6     def __init__(self): 7         #创建连接 8         self.conn = pyMysqL.Connect( 9           host = 'localhost',10           port = 3306,11           user = 'root',12           password = 'root',13           db = 'testdb',14           charset = 'utf8',15           cursorclass = pyMysqL.cursors.DictCursor  #以字典的形式返回数据16         )17         #获取游标18         self.cursor = self.conn.cursor()19 20     #返回多条数据21     def fetchAll(self,sql):22         self.cursor.execute(sql)23         return self.cursor.fetchall()24 25     #插入一条数据26     def insert_one(self,sql):27         result = self.cursor.execute(sql)28         self.conn.commit()29         return result30 31     #插入多条数据32     def insert_many(self,sql,datas):33         result = self.cursor.executemany(sql,datas)34         self.conn.commit()35         return result36 37     #更新数据38     def update(self,sql):39         result = self.cursor.execute(sql)40         self.conn.commit()41         return result42 43     #关闭连接44     def close(self):45         self.cursor.close()46         self.conn.close()47 48 49 50 51 if __name__ == '__main__':52     MysqL  = DoMysqL()53     #插入一条数据54     sql = 'insert into `user`(`mobile`,`passwd`) values("13100010000","123456")'55     result = MysqL.insert_one(sql)56     print(result) #返回插入数据的条数(1)57 58     #插入多条数据59     datas = [60         ("13100010001","111111"),61         ("13100010002","666666")62     ]63     sql = 'insert into `user`(`mobile`,`passwd`) values(%s,%s)'64     result = MysqL.insert_many(sql,datas)65     print(result) #返回插入数据的条数(2)66 67     #查询数据68     sql = 'select * from user'69     result = MysqL.fetchAll(sql) #返回列表,如果多条数据，列表中嵌套字典70     for item in result:71         print(item.get('mobile')) #循环列表，输出mobile值72 73     #关闭连接74     MysqL.close()

 

3、扩展信息

pyMysqL.Connect()参数说明
host(str): MysqL服务器地址
port(int): MysqL服务器端口号
user(str): 用户名
passwd(str): 密码
db(str): 数据库名称
charset(str): 连接编码

connection对象支持的方法
cursor() 使用该连接创建并返回游标
commit() 提交当前事务
rollback() 回滚当前事务
close() 关闭连接

cursor对象支持的方法
execute(op) 执行一个数据库的查询命令
fetchone() 取得结果集的下一行
fetchmany(size) 获取结果集的下几行
fetchall() 获取结果集中的所有行
rowcount() 返回数据条数或影响行数
close() 关闭游标对象

 

总结

以上是内存溢出为你收集整理的python3使用pymysql模块，连接mysql数据库，实现新增、查询和更新 *** 作全部内容，希望文章能够帮你解决python3使用pymysql模块，连接mysql数据库，实现新增、查询和更新 *** 作所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。