mysql触发器跨数据库

DELIMITER //

CREATE PROCEDURE update_db2()
BEGIN
    -- 在这里编写更新db2的逻辑
    UPDATE db2.target_table
    SET column1 = (SELECT column1 FROM db1.source_table WHERE ...)
    WHERE ...;
END //

DELIMITER ;

CREATE EVENT IF NOT EXISTS update_db2_event
ON SCHEDULE EVERY 1 MINUTE
DO
CALL update_db2();

import mysql.connector

def update_db2():
    db1_conn = mysql.connector.connect(user='user', password='password', host='host', database='db1')
    db2_conn = mysql.connector.connect(user='user', password='password', host='host', database='db2')

    db1_cursor = db1_conn.cursor()
    db2_cursor = db2_conn.cursor()

    # 查询db1中的数据
    db1_cursor.execute("SELECT * FROM source_table WHERE ...")
    result = db1_cursor.fetchall()

    # 更新db2中的数据
    for row in result:
        db2_cursor.execute("UPDATE target_table SET column1 = %s WHERE ...", (row[0],))

    db2_conn.commit()
    db1_conn.close()
    db2_conn.close()

update_db2()

DELIMITER //

CREATE TRIGGER trigger_name
AFTER INSERT ON db1.source_table
FOR EACH ROW
BEGIN
    -- 调用外部脚本
    SELECT system('python /path/to/update_db2.py');
END //

DELIMITER ;