python怎么監聽數據庫表的變化

146次閱讀

共計 881 個字符，預計需要花費 3 分鐘才能閱讀完成。

在 Python 中，可以使用數據庫的觸發器（trigger）來監聽數據庫表的變化。觸發器是一段在特定事件（例如插入、更新、刪除等）發生時自動執行的代碼。下面是使用 MySQL 數據庫的示例代碼：

首先，創建一個名為 my_trigger 的觸發器，該觸發器在 my_table 表的數據發生變化時執行：

CREATE TRIGGER my_trigger
AFTER INSERT ON my_table
FOR EACH ROW
BEGIN
-- 在這里編寫觸發器要執行的代碼
-- 可以是任何 Python 代碼，例如發送郵件或執行其他操作
END;

在 Python 中，可以使用 pymysql 庫來連接 MySQL 數據庫，并執行查詢操作。以下是一個簡單的示例代碼：

import pymysql
from pymysql import OperationalError
# 連接數據庫
def connect_db():
try:
conn = pymysql.connect(
host='localhost',
user='username',
password='password',
database='database_name'
)
return conn
except OperationalError as e:
print(f"Error connecting to database: {e}")
# 監聽數據庫表變化
def listen_table_changes():
conn = connect_db()
if conn:
cursor = conn.cursor()
# 執行 SQL 查詢語句
cursor.execute("SELECT * FROM my_table")
# 獲取查詢結果
result = cursor.fetchall()
# 處理查詢結果
for row in result:
# 在這里編寫處理結果的代碼
print(row)
# 關閉數據庫連接
conn.close()
# 調用監聽函數
listen_table_changes()

請注意，此示例代碼僅演示了如何連接數據庫并執行查詢操作。在實際應用中，您需要根據自己的需求自定義觸發器和處理查詢結果的代碼。

丸趣 TV 網 – 提供最優質的資源集合！

正文完