Python操作MySQL(十一)

python学习之旅(十一)
学习汇总入口【Python】学习汇总(3万字+思维导图)
写作不易，如果您觉得写的不错，欢迎给博主来一波点赞、收藏~让博主更有动力吧！

一.安装第三方库

在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()