如何在MySQL中使用Python编写自定义触发器

pip install pymysql

CREATE TABLE test_table (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(50),
    age INT
);

import pymysql

def handle_trigger(context):
    # 在此处编写你需要执行的操作，比如插入日志表或更新其他表等。
    # 你可以使用context参数获取插入操作的相关信息。
    pass

def create_trigger():
    conn = pymysql.connect(
        host="localhost",
        user="root",
        passWord="password",
        database="your_database"
    )
    
    cursor = conn.cursor()
    
    sql = """
    CREATE TRIGGER test_trigger
    AFTER INSERT ON test_table
    FOR EACH ROW
    BEGIN
        SET @context = CONCAT(
            'id:', NEW.id,
            ', name:', NEW.name,
            ', age:', NEW.age
        );
        
        CALL handle_trigger(@context);
    END
    """
    
    cursor.execute(sql)
    
    cursor.close()
    conn.close()

# 创建触发器
create_trigger()