一, python3 中安装 PyMySQL 模块
命令安装:
sudo apt-get install python-MySQL
或者
pip install pymysql
2, 使用在 pyCharm 中安装 PyMySQL 模块
二, PyMysql 对象说明
1,Connection 对象
用于建立与数据库的连接
创建对象: 调用 connect() 方法
conn=connect(参数列表)
参数 host: 连接的 MySQL 主机, 如果本机是'localhost'
参数 port: 连接的 MySQL 主机的端口, 默认是 3306
参数 database: 数据库的名称
参数 user: 连接的用户名
参数 password: 连接的密码
参数 charset: 通信采用的编码方式, 默认是'gb2312', 要求与数据库创建时指定的编码一致, 否则中文会乱码
对象的方法
close() 关闭连接
commit() 事务, 所以需要提交才会生效
rollback() 事务, 放弃之前的操作
cursor() 返回 Cursor 对象, 用于执行 sql 语句并获得结果
2,Cursor 对象
执行 sql 语句
创建对象: 调用 Connection 对象的 cursor() 方法
cursor1=conn.cursor()
对象的方法
close() 关闭
execute(operation [, parameters ]) 执行语句, 返回受影响的行数
fetchone() 执行查询语句时, 获取查询结果集的第一个行数据, 返回一个元组
next() 执行查询语句时, 获取当前行的下一行
fetchall() 执行查询时, 获取结果集的所有行, 一行构成一个元组, 再将这些元组装入一个元组返回
scroll(value[,mode]) 将行指针移动到某个位置
mode 表示移动的方式
mode 的默认值为 relative, 表示基于当前行移动到 value,value 为正则向下移动, value 为负则向上移动
mode 的值为 absolute, 表示基于第一条数据的位置, 第一条数据的位置为 0
对象的属性
rowcount 只读属性, 表示最近一次 execute() 执行后受影响的行数
connection 获得当前连接对象
三, 对 MySQL 基本操作的封装
1, 我们创建 MySQLManager.py 模块, 对 MySQL 的基本操作封装
- # coding=utf-8;
- # 导入模块 pymysql 模块
- import pymysql
- # 封装 MySQL 数据库管理类
- class MySQL_Manager(object):
- # 初始化方法
- def __init__(self,host,port,database,user,password,charset='utf8'):
- # 配置连接 MySQL 数据库的基本信息
- self.host = host
- self.port = port
- self.database = database
- self.user = user
- self.password = password
- self.charset = charset
- # 使用 python3 链接 MySQL 数据库
- def connect(self):
- # 链接
- self.connect = pymysql.connect(host = self.host, port = self.port, database = self.database, user = self.user, password = self.password,charset = self.charset)
- # 得到一个可以执行 SQL 语句的光标对象
- self.cursor = self.connect.cursor()
- # 操作完毕后关闭
- def close(self):
- # 关闭执行语句
- self.cursor.close()
- # 关闭连接
- self.connect.close()
- # 创建表操作
- def create_table(self,sql,params=()):
- # 先连接
- self.connect()
- # 执行创建语句
- self.cursor.execute(sql,params)
- # 关闭连接
- self.close()
- # 查询一条数据
- def select_one(self,sql,params=()):
- result = None
- try:
- self.connect()
- self.cursor.execute(sql,params)
- result = self.cursor.fetchone()
- self.close()
- except Exception as e:
- print(e)
- return result
- # 查询全部数据
- def select_all(self,sql,params=()):
- list=()
- try:
- self.connect()
- self.cursor.execute(sql,params)
- list = self.cursor.fetchall()
- self.close()
- except Exception as e:
- print(e)
- return list
- # 插入
- def insert(self, sql, params=()):
- return self.__edit(sql, params)
- # 修改
- def update(self, sql, params=()):
- return self.__edit(sql, params)
- # 删除
- def delete(self, sql, params=()):
- return self.__edit(sql, params)
- # 插入, 修改, 删除其实一样的, 只是 sql 代码不同, 但是为了代码的阅读性更高, 还是分开写
- def __edit(self, sql, params):
- count = 0
- try:
- self.connect()
- count = self.cursor.execute(sql, params)
- self.connect.commit()
- self.close()
- except Exception as e:
- print(e)
- return count
2. 创建 testMySQL.py 模块对我们创建的 MySQLManager.py 模块测试
- # coding = utf-8
- from MySQLManager import *
- mysql_manager = MySQL_Manager("192.168.100.114",3306,"Hero","root","123456")
- # 创建表
- create_sql = "create table hero(id int auto_increment primary key,name varchar(20) not null unique,skill varchar(20) not null) engine=innodb default charset=utf8;"
- mysql_manager.create_table(create_sql)
- # 添加数据
- insert_sql = "insert into hero(id,name,skill) values(1,'李白','青莲剑歌');"
- mysql_manager.insert(insert_sql)
- # 查询语句
- select_sql = "select * from hero;"
- list = mysql_manager.select_all(select_sql)
- print(list)
- # 修改
- update_sql = "update hero set name='韩信'where id=1;"
- mysql_manager.update(update_sql)
- # 删除语句
- delete_sql = "delete from hero where id=1;"
- mysql_manager.delete(delete_sql)
说明:
为什么 MySQLManager 里面的方法都有 params 参数, 这里却没用? 因为这只是测试, 我把所有的参数都直接写在了 sql 语句中, 但是为了程序的可扩展性, 建议大家还是使用参数 params
testMysql.py 文件每运行一次里面对数据库的操作就会执行一次, 例如创建表的操作只需要执行一次, 当我们创建表成功之后, 就可以把创建表的方法注释掉, 不用再创建了, 同样的, 添加, 删除也是一样.
来源: https://www.cnblogs.com/Se7eN-HOU/p/11173618.html