Python中操作MySQL和SQL Server數(shù)據(jù)庫的實戰(zhàn)指南
更新時間：2025年11月11日 09:02:55 作者：一鍵難忘
本文詳細介紹了如何在Pvthon中使用pymysql和pymssql庫進行MySQL和SQLServer數(shù)據(jù)庫的基本操作,包括連接、查詢、插入、更新、異常處理、參數(shù)化查詢、ORM應用、事務處理以及連接池的使用,為讀者提供了一套全面的數(shù)據(jù)庫操作指南,需要的朋友可以參考下
在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")
# 獲取查詢結果
result = cursor.fetchall()
# 打印結果
for row in result:
print(row)
# 關閉游標和連接
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")
# 獲取查詢結果
result = cursor.fetchall()
# 打印結果
for row in result:
print(row)
# 關閉游標和連接
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)
# 提交事務
connection.commit()
# 關閉游標和連接
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)
# 提交事務
connection.commit()
# 關閉游標和連接
cursor.close()
connection.close()
通過這些簡單的代碼示例，你可以開始在Python中使用pymysql和pymssql庫執(zhí)行基本的數(shù)據(jù)庫操作。根據(jù)實際需求，你可以進一步學習高級用法和優(yōu)化技巧。
6. 實戰(zhàn)：查詢數(shù)據(jù)并處理結果
使用pymysql和pymssql進行查詢并處理結果也是常見的操作，以下是一個示例：
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,))
# 獲取查詢結果
result = cursor.fetchall()
# 處理結果
for row in result:
print(row)
# 關閉游標和連接
cursor.close()
connection.close()
7. 實戰(zhà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")
# 獲取查詢結果
result = cursor.fetchall()
# 打印結果
for row in result:
print(row)
except pymysql.Error as e:
print(f"Error: {e}")
finally:
# 關閉游標和連接
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)
# 獲取查詢結果
result = cursor.fetchall()
# 處理結果
for row in result:
print(row)
# 關閉游標和連接
cursor.close()
connection.close()
10. 實戰(zhàn)：使用上下文管理器
使用上下文管理器可以確保在操作完成后及時關閉數(shù)據(jù)庫連接，以下是一個使用with語句的實例：
import pymysql
# 使用上下文管理器確保在操作完成后關閉數(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")
# 獲取查詢結果
result = cursor.fetchall()
# 處理結果
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)
# 提交事務
connection.commit()
# 關閉游標和連接
cursor.close()
connection.close()
通過這些實戰(zhàn)示例，你可以更深入地了解如何在Python中使用pymysql和pymssql庫進行數(shù)據(jù)庫操作，包括使用參數(shù)化查詢、上下文管理器以及批量插入等高級用法。這些技術將幫助你更有效地處理數(shù)據(jù)庫交互，并確保代碼的性能和安全性。
12. 實戰(zhàn)：使用ORM框架
除了直接使用數(shù)據(jù)庫連接庫，你還可以考慮使用ORM（對象關系映射）框架來簡化數(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()
# 處理結果
for row in result:
print(row.column1, row.column2)
14. 實戰(zhàn)：處理事務
事務是數(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()
try:
# 開始事務
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'))
# 提交事務
connection.commit()
except pymysql.Error as e:
# 出現(xiàn)錯誤時回滾事務
connection.rollback()
print(f"Error: {e}")
finally:
# 關閉游標和連接
cursor.close()
connection.close()
在這個示例中，如果執(zhí)行的所有SQL語句成功，commit()將提交事務，否則rollback()將回滾事務。這有助于保持數(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)
# 關閉游標和連接
cursor.close()
connection.close()
連接池的使用可以顯著提高數(shù)據(jù)庫連接的效率，尤其在并發(fā)訪問高的情況下。
總結
在本篇文章中，我們深入探討了在Python中使用pymysql和pymssql庫進行MySQL和SQL Server數(shù)據(jù)庫操作的基礎與實戰(zhàn)。通過一系列的代碼示例，我們覆蓋了以下關鍵方面：
- 基礎操作： 介紹了連接數(shù)據(jù)庫、查詢數(shù)據(jù)、插入、更新、異常處理等基本操作，通過簡單的代碼展示了如何使用
pymysql和pymssql庫完成這些任務。 - 高級用法： 涵蓋了參數(shù)化查詢、上下文管理器、批量插入等高級用法，以及使用ORM框架SQLAlchemy進行數(shù)據(jù)庫操作的實例。這些技術有助于提高代碼的安全性、可讀性和可維護性。
- 事務處理： 介紹了如何使用事務處理來確保一系列數(shù)據(jù)庫操作的原子性，以維護數(shù)據(jù)的一致性。
- 連接池： 講解了連接池的概念以及如何使用
DBUtils庫中的PooledDB創(chuàng)建連接池，以提高數(shù)據(jù)庫連接的效率和性能。 - 實際應用： 提供了多個實際場景下的代碼示例，包括查詢、更新、事務處理和連接池的應用，幫助讀者更好地理解和應用所學知識。
通過學習本文所涵蓋的內(nèi)容，讀者可以建立起對Python中操作MySQL和SQL Server數(shù)據(jù)庫的全面理解，并掌握一系列實用的技術，從而更加自信地應對各種數(shù)據(jù)庫交互場景。在實際項目中，選擇適合自身需求的技術和工具，并根據(jù)最佳實踐進行優(yōu)化，將有助于提高應用程序的性能、可靠性和安全性。希望本文能成為讀者學習和應用數(shù)據(jù)庫操作的有力指南。
以上就是Python中操作MySQL和SQL Server數(shù)據(jù)庫的實戰(zhàn)指南的詳細內(nèi)容，更多關于Python操作MySQL和SQL Server的資料請關注腳本之家其它相關文章！
相關文章
Python3.10+引入了match-case語句,作為升級版if-elif-else,用于多分支條件及結構化數(shù)據(jù)匹配,本文就來介紹一下match-case的具體使用,具有一定的參考價值,感興趣的可以了解一下2025-07-07
這篇文章主要介紹了python繪制雙柱形圖代碼實例，具有一定借鑒價值，需要的朋友可以參考下。2017-12-12
json path_ng 是 Python 中一款解析和操作 JSON 數(shù)據(jù)的工具,它可以通過 JSONPath 語法來對 JSON 數(shù)據(jù)進行定位和提取,其用法類似于 XPath 語法對 XML 數(shù)據(jù)進行定位,這篇文章主要介紹了Python使用jsonpath_ng的方法,需要的朋友可以參考下2023-12-12
最近學習了python遍歷目錄,下面這篇文章主要給大家介紹了關于Pandas快速合并多張excel表格的兩種方法,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-01-01
Python 是一種腳本語言,相比 C/C++ 這樣的編譯語言,在效率和性能方面存在一些不足,但是,有很多時候,Python 的效率并沒有想象中的那么夸張,本文對一些 Python 代碼加速運行的技巧進行整理,大家可以根據(jù)需求進行選擇2025-06-06
對于編程的入門選手來說,查找一個數(shù)據(jù)表中元素出現(xiàn)的個數(shù),腦海中立刻閃現(xiàn)的是兩個for循環(huán),但是,對于Python來說,我在它的初始庫里面找到了另外一種辦法,能夠讓我們優(yōu)雅地解決這個問題,下面小編就和大家詳細介紹一下吧2026-03-03
python+matplotlib實現(xiàn)動態(tài)繪制圖片實例代碼（交互式繪圖）
這篇文章主要介紹了python+matplotlib實現(xiàn)動態(tài)繪制圖片實例代碼（交互式繪圖），小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下2018-01-01
這篇文章主要介紹了python-opencv-畫外接矩形框的實例代碼，代碼簡單易懂，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-09-09
python Dtale庫交互式數(shù)據(jù)探索分析和可視化界面
這篇文章主要為大家介紹了python Dtale庫交互式數(shù)據(jù)探索分析和可視化界面實現(xiàn)功能詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2024-01-01
今天小編就為大家分享一篇Python查找文件中包含中文的行方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-12-12