如何使用socket.io访问mysql数据库

我只是进入编码服务器端的JavaScript,并已阅读关于socket.ionode.js的教程,但我还没有遇到任何事情展示如何使用node.js来访问MySQL数据库。

例如,我想创build一个方法,在mysql.something.com(与数据库:数据库,用户名:用户名等),我的数据库中的表监听一个表,我怎么会得到socket.io与node.js连接该数据库并监听该表的新input,然后返回该input?

我想知道是否有人可以给我一个使用发布订阅模型的具体例子。

谢谢您的帮助。

       

网上收集的解决方案 "如何使用socket.io访问mysql数据库"

您必须定期轮询mysql数据库以进行更改,并在检测到更改时发出socket.io事件。 这是一个伪代码

 var mysql = require('mysql'); var connect = mysql.createConnection({ host: 'localhost' , database: 'your_database' , username: 'user' , password: 'password'}); var initial_result; // check for changes after 1 second setTimeout(function(){ connect.query('select * from your_table', function(err, result) { if(err) { throw new Error('Failed');} initial_result = initial_result || result; if(Changed(initial_result, result)) { socket.emit('changed', result); } }); function Changed(pre, now) { // return true if pre != now } }, 1000);