pymysql简单使用
在 python 中 mysql 数据库的简单使用，此处不介绍 mysql 数据库的使用
1. 下载pymysql软件包
命令行窗口运行pip install pymysql，即可安装pymysql包，注：pip在下载python时已经自带。
下载pymysql软件包
如果 在下载时发现是下载速度较慢可以更换pip的下载的地址 (此处的是清华大学的镜像)
pip config set global.index-url https://pypi.tuna.tsinghua.edu.cn/simple/输入完上面的代码，设置镜像地址后，再重新安装即可使用镜像下载。
扩展知识：pip config unset global.index-url 表示不设置下载源，即恢复默认下载地址.
更换下载源+下载pymysql软件包
2. 使用pymysql工具
2.1 与数据库建立连接
从pymysql中导入连接对象，并提供连接数据库信息创建连接对象
# 导入pymysql
from pymysql import Connection
# 提供相关参数建立数据库连接
conn = Connection(
host="localhost", # 地址
port=3306, # 端口号
user="root", # 用户名
password="123456", # 密码
autocommit=True # 自动提交
)
此处的
autocommit=True # 自动提交是设置为默认提交，当然你也可以选择手动提交（默认值为False，即不自动提交），只需要在希望更新数据库时调用conn.commit()即可。其底层就是mysql的事务transaction。
2.2 执行sql语句
要执行sql语句首先需要获取到 cursor 游标对象（鼠标），通过 cursor 的 execute(str) 方法去执行slq语句，具体方式如下：
# 获取游标对象
cursor = conn.cursor()
# 执行sql语句
cursor.execute("create database test") # 创建数据库test
上面执行的语句是创建数据库，并没有指定当前使用的数据库。如果你要对某个数据库内进行操作时，需要先指定当前连接的数据库具体是哪个。这里我们就选择使用刚创建的test的数据库了。
注意：如果创建的数据库已经存在，即sql语句无法正常运行，代码本身是会抛出异常中断的。
如果已经执行了这段代码，你可以选择：
- 删除数据库 test
- 将
cursor.execute("create database test")暂时注释掉- 在创建数据库的前面添加条件删除语句
drop database if exists test（包括下面create table 创建表 的语句也是如此，后面就不在提示了，这里我就用方法2，直接注释掉了）
# 为连接指定数据库
conn.select_db("test") # 指定使用数据库为test
# 创建表user
cursor.execute(
"""
create table user
(
id int primary key auto_increment comment '用户身份标识',
username varchar(20) comment '用户名',
password varchar(20) comment '密码'
) comment '用户表';
"""
)
2.3 基本 增删改查 示例
基本的 增删改 操作都是直接使用 cursor.execute() 执行相应sql语句即可，对了，如果在创建连接的时候没有设置autocommit=True自动提交的话，在进行完以下操作后，执行conn.commit()提交更改，当然我设置了自动提交，这里就把它注释掉了。
# 增
cursor.execute("insert into user (username, password) values ('zhangsan', '123')") # 添加用户1
cursor.execute("insert into user (username, password) values ('lisi', '1234');") # 添加用户2
# 删
cursor.execute("delete from user where id = 1") # 删除id为1的用户
# 改
cursor.execute("update user set password = '123456'") # 设置所有用户密码为123456
# 提交修改
# conn.commit()
对于查询操作有些许特殊，因为他是需要一个返回值的。但基本思路和上面基本一致，只是在执行完查询语句后需要使用cursor.fetchall()方法拿出结果。
# 查
cursor.execute("select * from user") # 执行sql：获取所有用户信息
# 获取执行结果的返回信息，类型为元组嵌套，即tuple[tuple[Any, ...], ...]
result: tuple = cursor.fetchall()
# 打印查询的结果
for m in result:
print(m)
注意：如果执行了多条sql查询语句，cursor.fetchall() 只会拿回最近一次的返回数据，而前面的数据都会被覆盖掉。
2.4 关闭连接
这个按道理应该放在开头，但是为了保证代码的正确顺序，而不至于太乱。所有我将其放在最后。就是关闭资源
# 关闭连接
cursor.close()
conn.close()
3 操作完整代码
- sql代码实现：
# 创建数据库test
create database test;
# 使用数据库test
use test;
# 创建表user
create table user
(
id int primary key auto_increment comment '用户身份标识',
username varchar(20) comment '用户名',
password varchar(20) comment '密码'
) comment '用户表';
# 增
insert into user (username, password) values ('zhangsan', '123');
insert into user (username, password) values ('lisi', '1234');
# 删
delete from user where id = 1;
# 改
update user set password = '123456';
# 查1
select * from user;
- python调用实现：
# 导入pymysql
from pymysql import Connection
# 提供相关参数建立数据库连接
conn = Connection(
host="localhost", # 地址
port=3306, # 端口号
user="root", # 用户名
password="123456", # 密码
autocommit=True # 自动提交
)
# 获取游标对象
cursor = conn.cursor()
# # 执行sql语句
# cursor.execute("create database test") # 创建数据库test
# 为连接指定数据库
conn.select_db("test") # 指定数据库为test
# # 创建表user
# cursor.execute(
# """
# create table user
# (
# id int primary key auto_increment comment '用户身份标识',
# username varchar(20) comment '用户名',
# password varchar(20) comment '密码'
# ) comment '用户表';
# """
# )
# 增
cursor.execute("insert into user (username, password) values ('zhangsan', '123')") # 添加用户1
cursor.execute("insert into user (username, password) values ('lisi', '1234');") # 添加用户2
# 删
cursor.execute("delete from user where id = 1") # 删除id为1的用户
# 改
cursor.execute("update user set password = '123456'") # 设置所有用户密码为123456
# 提交修改
# conn.commit()
# 查
cursor.execute("select * from user") # 获取所有用户信息
result: tuple = cursor.fetchall() # 获取执行结果的返回值，类型为元组嵌套，即tuple[tuple[Any, ...], ...]
# 打印查询的结果
for m in result:
print(m)
# 关闭连接
cursor.close()
conn.close()
