Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Node.js script to connect to MySQL database through socket.io
- var app = require('net')
- , fs = require('fs')
- , Client = require('mysql').Client
- , client = new Client();
- client.user = 'user';
- client.password = 'password'; // Obviously this is not my real password
- var sockets_list = [];
- var server = app.createServer(function (socket) {
- sockets_list.push(socket);
- socket.write("Hello Clientrn");
- socket.on('data', function(data) {
- console.log(data);
- for (var i = 0; i < sockets_list.length; i++) {
- sockets_list[i].write(data);
- }
- });
- client.connect(function(err, results) {
- if (err) {
- console.log("ERROR: " + err.message);
- socket.write("NO!rn");
- throw err;
- }
- console.log("connected.");
- socket.write("Got through herern");
- clientConnected(client);
- });
- socket.on('end', function() {
- var i = sockets_list.indexOf(socket);
- sockets_list.splice(i, 1);
- });
- });
- server.listen(8080);
- clientConnected = function(client)
- {
- client.query('USE db', function(err, results) {
- if (err) {
- console.log("ERROR: " + err.message);
- throw err;
- }
- });
- };
- exports.CallStoredProcedureSync = function (test) {
- test.expect(12);
- var conn;
- var result;
- var row;
- var rows;
- var host = "localhost";
- var user = "test";
- var password = **********;
- var database = *******;
- var sockets_list = [];
- conn = mysql.createConnectionSync();
- conn.connectSync(host, user, password, database, 0, 0, conn.CLIENT_MULTI_RESULTS);
- if (!conn.connectedSync())
- {
- sys.puts("Connection error " + conn.connectErrno + ": " + conn.connectError);
- socket.write("Connection error " + conn.connectErrno + ": " + conn.connectError);
- process.exit(1);
- }
- // More code here
- }
- var app = require('net')
- , mysql = require('mysql-libmysqlclient')
- , conn = mysql.createConnectionSync();
- conn.connectSync('localhost', 'user', 'password', 'database');
- conn.setCharsetSync('utf8');
- var sockets_list = [];
- var server = app.createServer(function (socket) {
- sockets_list.push(socket);
- socket.write("Hello Clientrn");
- socket.on('data', function(data) {
- console.log(data);
- for (var i = 0; i < sockets_list.length; i++) {
- sockets_list[i].write(data);
- }
- });
- clientConnected = function() {
- conn.query('SELECT * FROM table', function(err, results) {
- if (err)
- throw err;
- else {
- results.fetchAll(function (err, rows) {
- if (err)
- throw err;
- // print out database info
- console.log(rows);
- socket.write('socket writes here');
- });
- }
- });
- };
- clientConnected();
- socket.on('end', function() {
- var i = sockets_list.indexOf(socket);
- sockets_list.splice(i, 1);
- });
- });
- server.listen(8080);
Add Comment
Please, Sign In to add comment