在 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语句无法正常运行，代码本身是会抛出异常中断的。

如果已经执行了这段代码，你可以选择：

1. 删除数据库 test
2. 将cursor.execute("create database test")暂时注释掉
3. 在创建数据库的前面添加条件删除语句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()