mysql 实时显示

// 客户端代码（浏览器）
const socket = new WebSocket('ws://example.com/socket');

socket.onmessage = function(event) {
    const data = JSON.parse(event.data);
    // 更新UI显示
    console.log('Received data:', data);
};

// 服务器端代码（Node.js）
const WebSocket = require('ws');
const mysql = require('mysql');

const wss = new WebSocket.Server({ port: 8080 });
const db = mysql.createConnection({
    host: 'localhost',
    user: 'user',
    password: 'password',
    database: 'database_name'
});

db.connect();

wss.on('connection', function connection(ws) {
    ws.on('message', function incoming(message) {
        console.log('received: %s', message);
    });

    // 假设有一个定时任务或事件触发数据库更新
    setInterval(function() {
        db.query('SELECT * FROM table_name', function(error, results, fields) {
            if (error) throw error;
            ws.send(JSON.stringify(results));
        });
    }, 1000); // 每秒发送一次更新
});