mysql 新数据发送邮件

基础概念

MySQL是一种关系型数据库管理系统，广泛用于存储和管理数据。当有新数据插入到MySQL数据库时，可以通过触发器或外部脚本监控数据库的变化，并发送邮件通知相关人员。

类型

触发器：在MySQL中创建触发器，当满足特定条件时自动执行SQL语句。
外部脚本：使用编程语言（如Python、PHP）编写脚本，定期或实时监控数据库变化，并发送邮件。

应用场景

数据变更通知：当有新数据插入、更新或删除时，通知相关人员。
审计日志：记录数据库变更历史，并通过邮件发送审计日志。
异常检测：检测到异常数据时，及时通知相关人员进行处理。

实现方法

使用触发器

MySQL触发器可以在数据变更时自动执行SQL语句，但MySQL触发器本身不支持直接发送邮件。可以通过触发器将变更记录到另一个表中，然后通过外部脚本读取该表并发送邮件。

-- 创建一个触发器，当有新数据插入时记录到log表中
DELIMITER $$
CREATE TRIGGER after_insert_data
AFTER INSERT ON your_table
FOR EACH ROW
BEGIN
    INSERT INTO log_table (table_name, action, data)
    VALUES ('your_table', 'INSERT', NEW);
END$$
DELIMITER ;

使用外部脚本

可以使用Python编写一个脚本，定期或实时监控数据库变化，并发送邮件。

import mysql.connector
import smtplib
from email.mime.text import MIMEText

# 连接数据库
db = mysql.connector.connect(
    host="your_host",
    user="your_user",
    password="your_password",
    database="your_database"
)

cursor = db.cursor()

# 查询新数据
cursor.execute("SELECT * FROM log_table WHERE status = 'NEW'")
new_data = cursor.fetchall()

# 发送邮件
msg = MIMEText(str(new_data))
msg['Subject'] = 'New Data Inserted'
msg['From'] = 'your_email'
msg['To'] = 'recipient_email'

smtp_server = smtplib.SMTP('smtp.your_email_provider.com', 587)
smtp_server.starttls()
smtp_server.login('your_email', 'your_password')
smtp_server.sendmail('your_email', 'recipient_email', msg.as_string())
smtp_server.quit()

# 更新状态
cursor.execute("UPDATE log_table SET status = 'PROCESSED' WHERE status = 'NEW'")
db.commit()

cursor.close()
db.close()