数据库更新监听

要实现Java监听MySQL数据库更新，可以使用JDBC连接数据库并定时查询数据变化。以下是一个简单的示例：，，1. 确保已经安装了MySQL JDBC驱动，如果没有安装，可以在项目的pom.xml文件中添加以下依赖：，，“xml，， mysql， mysql-connector-java， 8.0.26，，`，，2. 创建一个名为DatabaseListener的类，用于监听数据库更新：，，`java，import java.sql.Connection;，import java.sql.DriverManager;，import java.sql.ResultSet;，import java.sql.Statement;，import java.util.Timer;，import java.util.TimerTask;，，public class DatabaseListener {， private static final String URL = “jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC”;， private static final String USER = “root”;， private static final String PASSWORD = “your_password”;， private static final String TABLE_NAME = “your_table_name”;， private static final long CHECK_INTERVAL = 5000; // 检查间隔，单位：毫秒，， public static void main(String[] args) {， Timer timer = new Timer();， timer.schedule(new TimerTask() {， @Override， public void run() {， try {， checkDataChanges();， } catch (Exception e) {， e.printStackTrace();， }， }， }, 0, CHECK_INTERVAL);， }，， private static void checkDataChanges() throws Exception {， try (Connection connection = DriverManager.getConnection(URL, USER, PASSWORD)) {， connection.setAutoCommit(false); // 开启事务， Statement statement = connection.createStatement();， ResultSet resultSet = statement.executeQuery(“SELECT * FROM ” + TABLE_NAME + ” FOR UPDATE”); // 加锁查询，等待其他事务释放锁， if (!resultSet.next()) { // 如果没有数据，说明没有更新， System.out.println(“No data changes found.”);， } else { // 如果有数据，说明有更新， System.out.println(“Data has changed!”);， }， resultSet.close();， statement.close();， connection.commit(); // 提交事务， } catch (Exception e) {， throw e;， }， }，}，`，，3. 修改URL、USER、PASSWORD和TABLE_NAME变量为实际的数据库连接信息和表名。，，4. 运行DatabaseListener类的main`方法，程序将每隔5秒检查一次数据库是否有更新。如果有更新，控制台将输出”Data has changed!”。