快捷導(dǎo)航

Python使用PyMySql增刪改查Mysql數(shù)據(jù)庫的實現(xiàn)

更新時間：2024年01月02日 15:36:15 作者：愛寫代碼的小朋友

PyMysql是Python中用于連接MySQL數(shù)據(jù)庫的一個第三方庫,本文主要介紹了Python使用PyMySql增刪改查Mysql數(shù)據(jù)庫的實現(xiàn),具有一定的參考價值,感興趣的可以了解一下

PyMysql簡介

PyMysql是Python中用于連接MySQL數(shù)據(jù)庫的一個第三方庫，它實現(xiàn)了MySQL客戶端/服務(wù)器協(xié)議，使得Python程序能夠與MySQL服務(wù)器進(jìn)行交互。由于Python2的mysql-python（又稱mysqldb）模塊在Python 3上支持不夠完善，因此pymysql成為了在Python3.x環(huán)境中一個流行的替代方案。

PyMysql的主要特點和功能：

兼容性：pymysql與Python 3完全兼容，并且可以在Python
2.7及更高版本上運行，為跨Python版本的應(yīng)用提供統(tǒng)一的MySQL數(shù)據(jù)庫操作接口。
API設(shè)計：提供了類似DB-API 2.0規(guī)范的接口，使得開發(fā)者可以使用熟悉的執(zhí)行SQL語句、獲取結(jié)果集等方法。
安全連接：支持安全的SSL加密連接到MySQL服務(wù)器。
事務(wù)處理：通過commit()和rollback()方法支持事務(wù)控制。
參數(shù)化查詢：允許使用占位符（%s）進(jìn)行參數(shù)化SQL查詢，有效防止SQL注入攻擊。
多結(jié)果集：對于支持多結(jié)果集的MySQL命令，如存儲過程，pymysql也能夠正確處理。

基本用法步驟：

安裝pymysql（通常使用pip install pymysql）
創(chuàng)建數(shù)據(jù)庫連接
創(chuàng)建游標(biāo)對象并執(zhí)行SQL語句
處理查詢結(jié)果
提交或回滾事務(wù)
關(guān)閉游標(biāo)和數(shù)據(jù)庫連接

以下使用PyMysql增刪改查Mysql數(shù)據(jù)庫

創(chuàng)建數(shù)據(jù)庫

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數(shù)據(jù)庫

import pymysql

# 連接MySQL數(shù)據(jù)庫
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 創(chuàng)建一個游標(biāo)對象cursor
cursor = db.cursor()

查詢數(shù)據(jù)（SELECT）

import pymysql

# 連接MySQL數(shù)據(jù)庫
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")
# 創(chuàng)建一個游標(biāo)對象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"查詢數(shù)據(jù)失敗: {e}")

插入數(shù)據(jù)（INSERT）

import pymysql

# 連接MySQL數(shù)據(jù)庫
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 創(chuàng)建一個游標(biāo)對象cursor
cursor = db.cursor()
# 插入數(shù)據(jù)（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("插入數(shù)據(jù)成功")
except Exception as e:
    db.rollback()  # 發(fā)生錯誤時回滾
    print(f"插入數(shù)據(jù)失敗: {e}")

更新數(shù)據(jù)（UPDATE）

import pymysql

# 連接MySQL數(shù)據(jù)庫
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 創(chuàng)建一個游標(biāo)對象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("更新數(shù)據(jù)成功")
except Exception as e:
    db.rollback()
    print(f"更新數(shù)據(jù)失敗: {e}")

刪除數(shù)據(jù)（DELETE）

import pymysql

# 連接MySQL數(shù)據(jù)庫
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 創(chuàng)建一個游標(biāo)對象cursor
cursor = db.cursor()
try:
    sql = "DELETE FROM users WHERE username = %s"
    val = ("test_user",)
    cursor.execute(sql, val)
    db.commit()
    print("刪除數(shù)據(jù)成功")
except Exception as e:
    db.rollback()
    print(f"刪除數(shù)據(jù)失敗: {e}")