java实现数据库触发器

在Java中实现数据库触发器，可以使用JDBC（Java Database Connectivity）来连接和操作数据库，以下是一个简单的示例，展示了如何在MySQL数据库中创建一个触发器。

1、确保已经安装了MySQL数据库，并创建了一个名为testdb的数据库和一个名为testtable的表，表结构如下：

CREATE TABLE testtable (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(255) NOT NULL,
    age INT NOT NULL
);

2、在Java项目中添加MySQL JDBC驱动的依赖，如果使用Maven，可以在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysqlconnectorjava</artifactId>
    <version>8.0.26</version>
</dependency>

3、编写Java代码来创建触发器，以下是一个简单的示例，当向testtable表中插入数据时，触发器会将插入的数据打印到控制台：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class TriggerExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false&serverTimezone=UTC";
        String user = "root";
        String password = "your_password";
        try {
            // 加载驱动并连接数据库
            Class.forName("com.mysql.cj.jdbc.Driver");
            Connection connection = DriverManager.getConnection(url, user, password);
            // 创建触发器SQL语句
            String createTriggerSql = "CREATE TRIGGER print_insert_data " +
                    "AFTER INSERT ON testtable " +
                    "FOR EACH ROW " +
                    "BEGIN " +
                    "   INSERT INTO testtable_log (operation, data) " +
                    "   VALUES ('INSERT', NEW.name || ', ' || NEW.age); " +
                    "END;";
            // 创建触发器日志表（如果不存在）
            String createLogTableSql = "CREATE TABLE IF NOT EXISTS testtable_log (" +
                    "id INT AUTO_INCREMENT PRIMARY KEY," +
                    "operation VARCHAR(255) NOT NULL," +
                    "data TEXT NOT NULL" +
                    ");";
            // 执行创建触发器和日志表的SQL语句
            try (PreparedStatement preparedStatement = connection.prepareStatement(createLogTableSql)) {
                preparedStatement.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try (PreparedStatement preparedStatement = connection.prepareStatement(createTriggerSql)) {
                preparedStatement.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            // 关闭连接
            connection.close();
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }
    }
}

4、运行Java程序，向testtable表中插入数据。

INSERT INTO testtable (name, age) VALUES ('张三', 25);

5、查看testtable_log表中的日志，可以看到触发器已经成功捕获了插入的数据并将其打印到日志中。