快捷導(dǎo)航

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

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

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

PyMysql簡(jiǎn)介

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

PyMysql的主要特點(diǎn)和功能：

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

基本用法步驟：

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

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

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

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ù)庫(kù)

import pymysql

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

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

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

import pymysql

# 連接MySQL數(shù)據(jù)庫(kù)
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")
# 創(chuàng)建一個(gè)游標(biāo)對(duì)象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ù)庫(kù)
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 創(chuàng)建一個(gè)游標(biāo)對(duì)象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ā)生錯(cuò)誤時(shí)回滾
    print(f"插入數(shù)據(jù)失敗: {e}")

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

import pymysql

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

# 創(chuàng)建一個(gè)游標(biāo)對(duì)象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ù)庫(kù)
db = pymysql.connect("localhost", "your_username", "your_password", "your_database")

# 創(chuàng)建一個(gè)游標(biāo)對(duì)象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}")

關(guān)閉連接

cursor.close()
db.close()

請(qǐng)確保將上述代碼中的"your_username", “your_password”, "your_database"替換為你的實(shí)際數(shù)據(jù)庫(kù)用戶名、密碼和數(shù)據(jù)庫(kù)名。

到此這篇關(guān)于Python使用PyMySql增刪改查Mysql數(shù)據(jù)庫(kù)的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)PyMySql增刪改查Mysql內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: