Python操作MySQL

发布时间:2024年01月16日

1.安装第三方库

pip install pymysql

2.在Python中使用

2.1基本使用

  • 导包 -> 建立连接 -> 进行操作 -> 关闭数据库
# 1.导包操作
from pymysql import Connection
# 2.获取到MySQL数据库的连接对象
conn = Connection(
    host="10.10.100.220",  #主机名或ip地址
    port=3306,  # 数据库端口
    user="root",  # 数据库账户
    password="123456",  # 账户密码
    autocommit=True   # 开启自动提交功能
)
# 打印MySQL的版本信息
print(conn.get_server_info())
# 关闭数据库
conn.close()

2.2执行建表SQL

  • 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 关闭连接:
# 1.导包操作
from pymysql import Connection
# 2.获取到MySQL数据库的连接对象
conn = Connection(
    host="10.10.100.220",  #主机名或ip地址
    port=3306,  # 数据库端口
    user="root",  # 数据库账户
    password="123456",  # 账户密码
    autocommit=True   # 开启自动提交功能
)

# 获取游标对象
cursor = conn.cursor()
conn.select_db("test")  # 先选择数据库
# 使用游标对象,执行sql
cursor.execute("CREATE TABLE test01 (id INT , name varchar(20))")

# 关闭数据库
conn.close()

2.3执行SQL语句

  • 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 获取查询数据,执行操作 -> 关闭数据库
# 1.导包操作
from pymysql import Connection
# 2.获取到MySQL数据库的连接对象
conn = Connection(
    host="10.10.100.220",  #主机名或ip地址
    port=3306,  # 数据库端口
    user="root",  # 数据库账户
    password="123456",  # 账户密码
    autocommit=True   # 开启自动提交功能
)

# 获取游标对象
cursor = conn.cursor()
conn.select_db("test")  # 先选择数据库
# 使用游标对象,执行sql
cursor.execute("SELECT * FROM test01")
# 获取查询结果,返回元组对象
results: tuple = cursor.fetchall()
for result in results:
    print(result)

# 关闭数据库
conn.close()

2.4执行插入SQL

  • 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 提交行为 -> 关闭数据库
# 1.导包操作
from pymysql import Connection
# 2.获取到MySQL数据库的连接对象
conn = Connection(
    host="10.10.100.220",  #主机名或ip地址
    port=3306,  # 数据库端口
    user="root",  # 数据库账户
    password="123456",  # 账户密码
    autocommit=True   # 开启自动提交功能
)

# 获取游标对象
cursor = conn.cursor()
conn.select_db("test")  # 先选择数据库
# 使用游标对象,执行sql
cursor.execute("INSERT INTO test01 VALUES(1,'张三')")
# 确认插入对象
# 如果在获取连接对象时设置自动提交可以不用写
conn.commit()

# 关闭数据库
conn.close()

2.5执行修改操作

  • 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 提交行为 -> 关闭数据库
# 1.导包操作
from pymysql import Connection
# 2.获取到MySQL数据库的连接对象
conn = Connection(
    host="10.10.100.220",  #主机名或ip地址
    port=3306,  # 数据库端口
    user="root",  # 数据库账户
    password="123456",  # 账户密码
    autocommit=True   # 开启自动提交功能
)

# 获取游标对象
cursor = conn.cursor()
conn.select_db("test")  # 先选择数据库
# 使用游标对象,执行sql
cursor.execute("UPDATE test01 SET name = '李四' where id = 1")

# 关闭数据库
conn.close()

2.6执行删除操作

  • 导包 -> 建立连接 -> 获取游标对象 -> 选择数据库 -> 执行相应sql -> 提交行为 -> 关闭数据库
# 1.导包操作
from pymysql import Connection
# 2.获取到MySQL数据库的连接对象
conn = Connection(
    host="10.10.100.220",  #主机名或ip地址
    port=3306,  # 数据库端口
    user="root",  # 数据库账户
    password="123456",  # 账户密码
    autocommit=True   # 开启自动提交功能
)

# 获取游标对象
cursor = conn.cursor()
conn.select_db("test")  # 先选择数据库
# 使用游标对象,执行sql
cursor.execute("DELETE FROM test01 where id = 1")

# 关闭数据库
conn.close()

2.7小结

  • pymysql在执行数据插入或其它产生数据更改的SQL语句时,默认是需要提交更改的,即,需要通过代码“确认”这种更改行为。
  • 如果不想手动commit确认,可以在构建连接对象的时候,设置自动commit的属性
  • 查询后,使用游标对象.fetchall()可得到全部的查询结果封装入嵌套元组内
  • 可使用游标对象.execute()执行SQL语句
文章来源:https://blog.csdn.net/m0_71163619/article/details/135626752
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。