Python中操作MySQL和SQL Server數(shù)據(jù)庫的實戰(zhàn)指南

更新時間：2025年11月11日 09:02:55 作者：一鍵難忘

本文詳細介紹了如何在Pvthon中使用pymysql和pymssql庫進行MySQL和SQLServer數(shù)據(jù)庫的基本操作,包括連接、查詢、插入、更新、異常處理、參數(shù)化查詢、ORM應(yīng)用、事務(wù)處理以及連接池的使用,為讀者提供了一套全面的數(shù)據(jù)庫操作指南,需要的朋友可以參考下

1. 安裝依賴庫
2. 連接MySQL數(shù)據(jù)庫
3. 連接SQL Server數(shù)據(jù)庫
4. 實戰(zhàn)：插入數(shù)據(jù)
5. 實戰(zhàn)：更新數(shù)據(jù)
6. 實戰(zhàn)：查詢數(shù)據(jù)并處理結(jié)果
7. 實戰(zhàn)：異常處理
9. 實戰(zhàn)：使用參數(shù)化查詢
10. 實戰(zhàn)：使用上下文管理器
11. 實戰(zhàn)：批量插入數(shù)據(jù)
12. 實戰(zhàn)：使用ORM框架
14. 實戰(zhàn)：處理事務(wù)
15. 實戰(zhàn)：使用連接池
總結(jié)

在Python中，我們經(jīng)常需要與各種數(shù)據(jù)庫進行交互，其中MySQL和SQL Server是兩個常見的選擇。本文將介紹如何使用pymysql和pymssql庫進行基本的數(shù)據(jù)庫操作，并通過實際代碼示例來展示這些操作。

1. 安裝依賴庫

在開始之前，首先需要安裝pymysql和pymssql庫。你可以使用以下命令進行安裝：

pip install pymysql
pip install pymssql

2. 連接MySQL數(shù)據(jù)庫

import pymysql

# 建立數(shù)據(jù)庫連接
connection = pymysql.connect(
    host='your_mysql_host',
    user='your_username',
    password='your_password',
    database='your_database',
    port=3306
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

# 執(zhí)行SQL查詢
cursor.execute("SELECT * FROM your_table")

# 獲取查詢結(jié)果
result = cursor.fetchall()

# 打印結(jié)果
for row in result:
    print(row)

# 關(guān)閉游標和連接
cursor.close()
connection.close()

3. 連接SQL Server數(shù)據(jù)庫

import pymssql

# 建立數(shù)據(jù)庫連接
connection = pymssql.connect(
    host='your_sql_server_host',
    user='your_username',
    password='your_password',
    database='your_database'
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

# 執(zhí)行SQL查詢
cursor.execute("SELECT * FROM your_table")

# 獲取查詢結(jié)果
result = cursor.fetchall()

# 打印結(jié)果
for row in result:
    print(row)

# 關(guān)閉游標和連接
cursor.close()
connection.close()

4. 實戰(zhàn)：插入數(shù)據(jù)

下面是一個簡單的示例，演示如何插入數(shù)據(jù)到MySQL數(shù)據(jù)庫：

import pymysql

# 建立數(shù)據(jù)庫連接
connection = pymysql.connect(
    host='your_mysql_host',
    user='your_username',
    password='your_password',
    database='your_database',
    port=3306
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

# 插入數(shù)據(jù)
insert_query = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)"
data_to_insert = ('value1', 'value2')
cursor.execute(insert_query, data_to_insert)

# 提交事務(wù)
connection.commit()

# 關(guān)閉游標和連接
cursor.close()
connection.close()

5. 實戰(zhàn)：更新數(shù)據(jù)

以下是一個演示如何使用pymssql更新SQL Server數(shù)據(jù)庫中的數(shù)據(jù)的示例：

import pymssql

# 建立數(shù)據(jù)庫連接
connection = pymssql.connect(
    host='your_sql_server_host',
    user='your_username',
    password='your_password',
    database='your_database'
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

# 更新數(shù)據(jù)
update_query = "UPDATE your_table SET column1 = %s WHERE column2 = %s"
data_to_update = ('new_value', 'condition_value')
cursor.execute(update_query, data_to_update)

# 提交事務(wù)
connection.commit()

# 關(guān)閉游標和連接
cursor.close()
connection.close()

通過這些簡單的代碼示例，你可以開始在Python中使用pymysql和pymssql庫執(zhí)行基本的數(shù)據(jù)庫操作。根據(jù)實際需求，你可以進一步學習高級用法和優(yōu)化技巧。

6. 實戰(zhàn)：查詢數(shù)據(jù)并處理結(jié)果

使用pymysql和pymssql進行查詢并處理結(jié)果也是常見的操作，以下是一個示例：

import pymysql

# 建立數(shù)據(jù)庫連接
connection = pymysql.connect(
    host='your_mysql_host',
    user='your_username',
    password='your_password',
    database='your_database',
    port=3306
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

# 查詢數(shù)據(jù)
select_query = "SELECT * FROM your_table WHERE column1 = %s"
condition_value = 'desired_value'
cursor.execute(select_query, (condition_value,))

# 獲取查詢結(jié)果
result = cursor.fetchall()

# 處理結(jié)果
for row in result:
    print(row)

# 關(guān)閉游標和連接
cursor.close()
connection.close()

7. 實戰(zhàn)：異常處理

在實際應(yīng)用中，異常處理是至關(guān)重要的。以下是一個簡單的異常處理的示例：

import pymysql

try:
    # 建立數(shù)據(jù)庫連接
    connection = pymysql.connect(
        host='your_mysql_host',
        user='your_username',
        password='your_password',
        database='your_database',
        port=3306
    )

    # 創(chuàng)建游標對象
    cursor = connection.cursor()

    # 執(zhí)行SQL查詢
    cursor.execute("SELECT * FROM your_table")

    # 獲取查詢結(jié)果
    result = cursor.fetchall()

    # 打印結(jié)果
    for row in result:
        print(row)

except pymysql.Error as e:
    print(f"Error: {e}")

finally:
    # 關(guān)閉游標和連接
    cursor.close()
    connection.close()

9. 實戰(zhàn)：使用參數(shù)化查詢

參數(shù)化查詢是防止SQL注入攻擊的一種重要方法。以下是一個使用參數(shù)化查詢的實例：

import pymysql

# 建立數(shù)據(jù)庫連接
connection = pymysql.connect(
    host='your_mysql_host',
    user='your_username',
    password='your_password',
    database='your_database',
    port=3306
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

# 參數(shù)化查詢
parametrized_query = "SELECT * FROM your_table WHERE column1 = %s AND column2 = %s"
query_params = ('value1', 'value2')
cursor.execute(parametrized_query, query_params)

# 獲取查詢結(jié)果
result = cursor.fetchall()

# 處理結(jié)果
for row in result:
    print(row)

# 關(guān)閉游標和連接
cursor.close()
connection.close()

10. 實戰(zhàn)：使用上下文管理器

使用上下文管理器可以確保在操作完成后及時關(guān)閉數(shù)據(jù)庫連接，以下是一個使用with語句的實例：

import pymysql

# 使用上下文管理器確保在操作完成后關(guān)閉數(shù)據(jù)庫連接
with pymysql.connect(
    host='your_mysql_host',
    user='your_username',
    password='your_password',
    database='your_database',
    port=3306
) as connection:
    # 創(chuàng)建游標對象
    with connection.cursor() as cursor:
        # 執(zhí)行SQL查詢
        cursor.execute("SELECT * FROM your_table")

        # 獲取查詢結(jié)果
        result = cursor.fetchall()

        # 處理結(jié)果
        for row in result:
            print(row)

11. 實戰(zhàn)：批量插入數(shù)據(jù)

如果需要插入大量數(shù)據(jù)，最好使用批量插入以提高性能。以下是一個簡單的批量插入示例：

import pymysql

# 建立數(shù)據(jù)庫連接
connection = pymysql.connect(
    host='your_mysql_host',
    user='your_username',
    password='your_password',
    database='your_database',
    port=3306
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

# 批量插入數(shù)據(jù)
insert_query = "INSERT INTO your_table (column1, column2) VALUES (%s, %s)"
data_to_insert = [('value1', 'value2'), ('value3', 'value4'), ('value5', 'value6')]
cursor.executemany(insert_query, data_to_insert)

# 提交事務(wù)
connection.commit()

# 關(guān)閉游標和連接
cursor.close()
connection.close()

通過這些實戰(zhàn)示例，你可以更深入地了解如何在Python中使用pymysql和pymssql庫進行數(shù)據(jù)庫操作，包括使用參數(shù)化查詢、上下文管理器以及批量插入等高級用法。這些技術(shù)將幫助你更有效地處理數(shù)據(jù)庫交互，并確保代碼的性能和安全性。

12. 實戰(zhàn)：使用ORM框架

除了直接使用數(shù)據(jù)庫連接庫，你還可以考慮使用ORM（對象關(guān)系映射）框架來簡化數(shù)據(jù)庫操作。這里以SQLAlchemy為例進行示范：

首先，確保已經(jīng)安裝SQLAlchemy：

pip install sqlalchemy

然后，以下是一個使用SQLAlchemy進行簡單查詢的實例：

from sqlalchemy import create_engine, Column, String, Integer
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

# 定義數(shù)據(jù)模型
Base = declarative_base()

class YourTable(Base):
    __tablename__ = 'your_table'

    id = Column(Integer, primary_key=True)
    column1 = Column(String)
    column2 = Column(String)

# 創(chuàng)建數(shù)據(jù)庫連接引擎
engine = create_engine('mysql+pymysql://your_username:your_password@your_mysql_host:3306/your_database')

# 創(chuàng)建數(shù)據(jù)表
Base.metadata.create_all(engine)

# 創(chuàng)建會話
Session = sessionmaker(bind=engine)
session = Session()

# 查詢數(shù)據(jù)
result = session.query(YourTable).filter_by(column1='desired_value').all()

# 處理結(jié)果
for row in result:
    print(row.column1, row.column2)

14. 實戰(zhàn)：處理事務(wù)

事務(wù)是數(shù)據(jù)庫操作中的重要概念，用于確保一組相關(guān)操作要么全部成功，要么全部失敗。以下是一個簡單的事務(wù)處理實例：

import pymysql

# 建立數(shù)據(jù)庫連接
connection = pymysql.connect(
    host='your_mysql_host',
    user='your_username',
    password='your_password',
    database='your_database',
    port=3306
)

# 創(chuàng)建游標對象
cursor = connection.cursor()

try:
    # 開始事務(wù)
    connection.begin()

    # 執(zhí)行多個SQL語句
    cursor.execute("UPDATE your_table SET column1 = %s WHERE column2 = %s", ('new_value', 'condition_value'))
    cursor.execute("INSERT INTO your_table (column1, column2) VALUES (%s, %s)", ('value1', 'value2'))

    # 提交事務(wù)
    connection.commit()

except pymysql.Error as e:
    # 出現(xiàn)錯誤時回滾事務(wù)
    connection.rollback()
    print(f"Error: {e}")

finally:
    # 關(guān)閉游標和連接
    cursor.close()
    connection.close()

在這個示例中，如果執(zhí)行的所有SQL語句成功，commit()將提交事務(wù)，否則rollback()將回滾事務(wù)。這有助于保持數(shù)據(jù)的一致性。

15. 實戰(zhàn)：使用連接池

在高并發(fā)環(huán)境中，使用數(shù)據(jù)庫連接池能夠有效地管理和復用數(shù)據(jù)庫連接，提高性能和效率。以下是一個使用pymysql連接池的實例：

首先，確保已經(jīng)安裝DBUtils庫：

pip install DBUtils

然后，使用連接池的代碼示例：

from DBUtils.PooledDB import PooledDB
import pymysql

# 配置連接池
pool = PooledDB(
    creator=pymysql,  # 使用pymysql庫創(chuàng)建連接
    maxconnections=5,  # 連接池允許的最大連接數(shù)
    mincached=2,  # 初始化時連接池中至少創(chuàng)建的空閑的連接，0表示不創(chuàng)建
    maxcached=5,  # 連接池中最多閑置的連接，0和None表示不限制
    maxshared=3,  # 連接池中最多共享的連接數(shù)量，0和None表示全部共享
    blocking=True,  # 當連接池達到最大數(shù)量時，是否阻塞等待連接釋放
    maxusage=None,  # 單個連接最多被重復使用的次數(shù)，None表示無限制
)

# 從連接池獲取連接
connection = pool.connection()

# 使用連接進行操作
cursor = connection.cursor()
cursor.execute("SELECT * FROM your_table")
result = cursor.fetchall()
for row in result:
    print(row)

# 關(guān)閉游標和連接
cursor.close()
connection.close()

連接池的使用可以顯著提高數(shù)據(jù)庫連接的效率，尤其在并發(fā)訪問高的情況下。

總結(jié)

在本篇文章中，我們深入探討了在Python中使用pymysql和pymssql庫進行MySQL和SQL Server數(shù)據(jù)庫操作的基礎(chǔ)與實戰(zhàn)。通過一系列的代碼示例，我們覆蓋了以下關(guān)鍵方面：

基礎(chǔ)操作： 介紹了連接數(shù)據(jù)庫、查詢數(shù)據(jù)、插入、更新、異常處理等基本操作，通過簡單的代碼展示了如何使用pymysql和pymssql庫完成這些任務(wù)。
高級用法： 涵蓋了參數(shù)化查詢、上下文管理器、批量插入等高級用法，以及使用ORM框架SQLAlchemy進行數(shù)據(jù)庫操作的實例。這些技術(shù)有助于提高代碼的安全性、可讀性和可維護性。
事務(wù)處理： 介紹了如何使用事務(wù)處理來確保一系列數(shù)據(jù)庫操作的原子性，以維護數(shù)據(jù)的一致性。
連接池： 講解了連接池的概念以及如何使用DBUtils庫中的PooledDB創(chuàng)建連接池，以提高數(shù)據(jù)庫連接的效率和性能。
實際應(yīng)用： 提供了多個實際場景下的代碼示例，包括查詢、更新、事務(wù)處理和連接池的應(yīng)用，幫助讀者更好地理解和應(yīng)用所學知識。

通過學習本文所涵蓋的內(nèi)容，讀者可以建立起對Python中操作MySQL和SQL Server數(shù)據(jù)庫的全面理解，并掌握一系列實用的技術(shù)，從而更加自信地應(yīng)對各種數(shù)據(jù)庫交互場景。在實際項目中，選擇適合自身需求的技術(shù)和工具，并根據(jù)最佳實踐進行優(yōu)化，將有助于提高應(yīng)用程序的性能、可靠性和安全性。希望本文能成為讀者學習和應(yīng)用數(shù)據(jù)庫操作的有力指南。

以上就是Python中操作MySQL和SQL Server數(shù)據(jù)庫的實戰(zhàn)指南的詳細內(nèi)容，更多關(guān)于Python操作MySQL和SQL Server的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: