Python使用PyMySql增删改查Mysql数据库的实现

2024-01-02 15:33:07 作者：爱写代码的小朋友

PyMysql是Python中用于连接MySQL数据库的一个第三方库,本文主要介绍了Python使用PyMySql增删改查Mysql数据库的实现,具有一定的参考价值,感兴趣的可以了解一下

PyMysql简介

PyMysql是Python中用于连接MySQL数据库的一个第三方库，它实现了MySQL客户端/服务器协议，使得Python程序能够与MySQL服务器进行交互。由于Python2的mysql-python（又称mysqldb）模块在Python 3上支持不够完善，因此pymysql成为了在Python3.x环境中一个流行的替代方案。

PyMysql的主要特点和功能：

兼容性：pymysql与Python 3完全兼容，并且可以在Python
2.7及更高版本上运行，为跨Python版本的应用提供统一的MySQL数据库操作接口。
API设计：提供了类似DB-API 2.0规范的接口，使得开发者可以使用熟悉的执行SQL语句、获取结果集等方法。
安全连接：支持安全的SSL加密连接到MySQL服务器。
事务处理：通过commit()和rollback()方法支持事务控制。
参数化查询：允许使用占位符（%s）进行参数化SQL查询，有效防止SQL注入攻击。
多结果集：对于支持多结果集的MySQL命令，如存储过程，pymysql也能够正确处理。

基本用法步骤：

安装pymysql（通常使用pip install pymysql）
创建数据库连接
创建游标对象并执行SQL语句
处理查询结果
提交或回滚事务
关闭游标和数据库连接

以下使用PyMysql增删改查Mysql数据库

创建数据库

CREATE TABLE `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(50) NOT NULL,
  `email` varchar(100) NOT NULL,
  `password` varchar(100) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

连接MySql数据库

import pymysql

# 连接MySQL数据库
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 创建一个游标对象cursor
cursor = db.cursor()

查询数据（SELECT）

import pymysql

# 连接MySQL数据库
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")
# 创建一个游标对象cursor
cursor = db.cursor()
try:
    sql = "SELECT * FROM users WHERE username = %s"
    val = ("test_user",)
    cursor.execute(sql, val)
    results = cursor.fetchall()
    for row in results:
        print(f"ID: {row[0]}, Username: {row[1]}, Email: {row[2]}, Password: {row[3]}")
except Exception as e:
    print(f"查询数据失败: {e}")

插入数据（INSERT）

import pymysql

# 连接MySQL数据库
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 创建一个游标对象cursor
cursor = db.cursor()
# 插入数据（INSERT）
try:
    sql = "INSERT INTO users (username, email, password) VALUES (%s, %s, %s)"
    val = ("test_user", "test@example.com", "test_password")
    cursor.execute(sql, val)
    db.commit()
    print("插入数据成功")
except Exception as e:
    db.rollback()  # 发生错误时回滚
    print(f"插入数据失败: {e}")

更新数据（UPDATE）

import pymysql

# 连接MySQL数据库
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 创建一个游标对象cursor
cursor = db.cursor()
try:
    sql = "UPDATE users SET email = %s WHERE username = %s"
    val = ("new_email@example.com", "test_user")
    cursor.execute(sql, val)
    db.commit()
    print("更新数据成功")
except Exception as e:
    db.rollback()
    print(f"更新数据失败: {e}")

删除数据（DELETE）

import pymysql

# 连接MySQL数据库
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 创建一个游标对象cursor
cursor = db.cursor()
try:
    sql = "DELETE FROM users WHERE username = %s"
    val = ("test_user",)
    cursor.execute(sql, val)
    db.commit()
    print("删除数据成功")
except Exception as e:
    db.rollback()
    print(f"删除数据失败: {e}")

关闭连接

cursor.close()
db.close()

请确保将上述代码中的"your_username", “your_password”, "your_database"替换为你的实际数据库用户名、密码和数据库名。

到此这篇关于Python使用PyMySql增删改查Mysql数据库的实现的文章就介绍到这了,更多相关PyMySql增删改查Mysql内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！