数据库的变化如何通过node js发送到web客户端？

// 安装依赖模块
// npm install mysql socket.io

const mysql = require('mysql');
const io = require('socket.io')();

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydatabase'
});

// 建立连接
connection.connect();

// 监听数据库变化
const query = connection.query('SELECT * FROM mytable');
query.on('result', (row) => {
  // 处理数据库变化事件
  io.emit('dataChange', row); // 发送变化到web客户端
});

// 启动WebSocket服务器
io.listen(3000);
console.log('WebSocket服务器已启动，监听端口：3000');

// 引入Socket.io库
// <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/4.1.3/socket.io.min.js"></script>

// 连接WebSocket服务器
const socket = io('http://localhost:3000');

// 接收数据库变化
socket.on('dataChange', (data) => {
  // 处理数据变化，更新用户界面
  console.log('数据库变化：', data);
});