第一章	第二章	第三章	第四章	第五章
基础语法	判断语句	循环语句	函数使用	数据容器
第六章	第七章	第八章	第九章	第十章
文件基础操作	异常处理	模块与包	面向对象	操作MySQL
第十一章	类型注解	第十二章	高阶技巧

目录

一.安装第三方库

二.在Python中使用

(1) 基本使用

(2) 执行建表SQL

(3) 执行查询SQL

(4) 执行插入SQL

(5) 执行修改SQL

(6) 执行删除SQL

(7) 小结

---

一.安装第三方库

在Python中，通过使用第三方库:pymysql,完成对MySQL数据库的操作。

• 安装指令:

pip install pymysql

---

二.在Python中使用

(1) 基本使用

• 导包-》建立连接-》进行xx操作-》关闭连接：

# 1.导入操作包
from pymysql import Connection

# 2.获取到MySQL数据库的连接对象
conn = Connection(
    host='localhost',  # 主机名或IP地址
    port=3306,  # 端口号，默认3306
    user='root',  # MySQL账号
    password='root'  # MySQL密码
)

# 打印MySQL版本信息
print(conn.get_server_info())

# 3.关闭到数据库的连接
conn.close()

(2) 执行建表SQL

• 导包-》建立连接-》获取游标对象-》选择数据库-》执行相应sql-》关闭连接：

from pymysql import Connection

# 获取到MySQL数据库的连接对象
conn = Connection(
    host='localhost',  # 主机名或IP地址
    port=3306,  # 端口号，默认3306
    user='root',  # MySQL账号
    password='root'  # MySQL密码
)

"""
执行非查询性质SQL
"""
# 获取游标对象(用于操作数据库)
cursor = conn.cursor()
# 选择要操作的数据库
conn.select_db("db1")
# 使用游标对象，执行建表sql语句
cursor.execute("CREATE TABLE tb_user(id INT,name VARCHAR(8),age int)")

# 关闭到数据库的连接
conn.close()

(3) 执行查询SQL

• 导包-》建立连接-》获取游标对象-》选择数据库-》执行相应sql-》获取查询数据，执行xx操作-》关闭连接：

from pymysql import Connection

# 获取到MySQL数据库的连接对象
conn = Connection(
    host='localhost',  # 主机名或IP地址
    port=3306,  # 端口号，默认3306
    user='root',  # MySQL账号
    password='root'  # MySQL密码
)

"""
执行查询性质SQL
"""
# 获取游标对象(用于操作数据库)
cursor = conn.cursor()
# 选择要操作的数据库
conn.select_db("db1")
# 使用游标对象，执行sql语句
cursor.execute("SELECT * FROM tb_user")
# 获取查询结果，返回元组对象
results: tuple = cursor.fetchall()
for result in results:
    print(result)

# 关闭到数据库的连接
conn.close()

(4) 执行插入SQL

• 导包-》建立连接-》获取游标对象-》选择数据库-》执行相应sql-》提交行为-》关闭连接：

from pymysql import Connection

# 获取到MySQL数据库的连接对象
conn = Connection(
    host='localhost',  # 主机名或IP地址
    port=3306,  # 端口号，默认3306
    user='root',  # MySQL账号
    password='root',  # MySQL密码
    autocommit=True  # 设置自动提交(commit)
)

"""
执行插入SQL
"""
# 获取游标对象(用于操作数据库)
cursor = conn.cursor()
# 选择要操作的数据库
conn.select_db("db1")
# 使用游标对象，执行sql语句
cursor.execute("Insert into tb_user values(1,'hhy','250')")
# 确认插入行为
# 如果在获取连接对象时设置自动提交可以不用再写。
conn.commit()

# 关闭到数据库的连接
conn.close()

(5) 执行修改SQL

• 导包-》建立连接-》获取游标对象-》选择数据库-》执行相应sql-》提交行为-》关闭连接：

from pymysql import Connection

# 获取到MySQL数据库的连接对象
conn = Connection(
    host='localhost',  # 主机名或IP地址
    port=3306,  # 端口号，默认3306
    user='root',  # MySQL账号
    password='root',  # MySQL密码
    autocommit=True  # 设置自动提交(commit)
)

"""
执行修改SQL
"""
# 获取游标对象(用于操作数据库)
cursor = conn.cursor()
# 选择要操作的数据库
conn.select_db("db1")
# 使用游标对象，执行sql语句
cursor.execute("UPDATE tb_user set username='hhy' where username = 'fsp'")
# 确认修改行为
# 如果在获取连接对象时设置自动提交可以不用再写。
conn.commit()

# 关闭到数据库的连接
conn.close()

(6) 执行删除SQL

• 导包-》建立连接-》获取游标对象-》选择数据库-》执行相应sql-》提交行为-》关闭连接：

from pymysql import Connection

# 获取到MySQL数据库的连接对象
conn = Connection(
    host='localhost',  # 主机名或IP地址
    port=3306,  # 端口号，默认3306
    user='root',  # MySQL账号
    password='root',  # MySQL密码
    autocommit=True  # 设置自动提交(commit)
)


"""
执行删除SQL
"""
# 获取游标对象(用于操作数据库)
cursor = conn.cursor()
# 选择要操作的数据库
conn.select_db("db1")
# 使用游标对象，执行sql语句
cursor.execute("DELETE from tb_user WHERE username = 'hhy'")
# 确认删除行为
# 如果在获取连接对象时设置自动提交可以不用再写。
conn.commit()

# 关闭到数据库的连接
conn.close()

(7) 小结

• pymysql在执行数据插入或其它产生数据更改的SQL语句时，默认是需要提交更改的，即，需要通过代码“确认”这种更改行为。
• 如果不想手动commit确认，可以在构建连接对象的时候，设置自动commit的属性。
• 查询后，使用游标对象.fetchall()可得到全部的查询结果封装入嵌套元组内
• 可使用游标对象.execute()执行SQL语句