如何使用节点js和socket.io在mysql数据库中插入新记录时通知和更新客户端。

npm install socket.io mysql

const io = require('socket.io')(server); // server为Node.js服务器实例
io.on('connection', (socket) => {
  console.log('客户端已连接');
});

CREATE TRIGGER notify_insert AFTER INSERT ON your_table
FOR EACH ROW
BEGIN
  INSERT INTO notification (message) VALUES ('新记录已插入');
END

const mysql = require('mysql');
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database'
});

connection.connect();

const query = connection.query('SELECT * FROM notification');
query.on('result', (row) => {
  socket.emit('notification', row.message);
});

connection.end();

const socket = io('http://localhost:3000'); // 服务器地址和端口
socket.on('notification', (message) => {
  console.log('收到通知：', message);
});