Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var mysql = require("mysql");
- var app = require('express')();
- var http = require('http').Server(app);
- var io = require('socket.io')(http);
- app.get('/', function(req, res){
- res.sendfile('testsql.html');
- //res.sendfile('/login/');
- });
- http.listen(3000, function(){
- console.log('listening on *:3000');
- });
- var con = mysql.createConnection({
- host: "localhost",
- user: "root",
- password: "password",
- database: "users"
- });
- io.on('connection', function (socket) {
- console.log('a client connected');
- con.query('SELECT * FROM users',function(err,rows){
- if(err) throw err;
- console.log('Data received from Db:n');
- console.log(rows);
- socket.emit('showrows', rows);
- });
- });
- <!doctype html>
- <html>
- <head>
- <title>Testing socket.io</title>
- </head>
- <body>
- <h1 id="socketio"> not connected </h1>
- <div id="display"> </div>
- <script src="/socket.io/socket.io.js"></script>
- <script>
- var socket = io();
- socket.on('connect', function() {
- document.getElementById("socketio").innerHTML = "socket connected";
- });
- socket.on('showrows', function(dbData) {
- document.getElementById("display").innerHTML = JSON.stringify(dbData);
- });
- </script>
- </body>
- </html>
- var con = mysql.createConnection({
- host: "localhost",
- user: "root",
- password: "password",
- database: "users"
- });
- io.on('connection', function (socket) {
- console.log('a client connected');
- con.query('SELECT * FROM users',function(err,rows){
- if(err) throw err;
- console.log('Data received from Db:n');
- console.log(rows);
- socket.emit('showrows', rows);
- });
- });
- <!doctype html>
- <html>
- <head>
- <title>Testing socket.io</title>
- </head>
- <body>
- <h1 id="socketio"> not connected </h1>
- <div id="display"> </div>
- <script src="/socket.io/socket.io.js"></script>
- <script>
- var socket = io();
- socket.on('connect', function() {
- document.getElementById("socketio").innerHTML = "socket connected";
- });
- socket.on('showrows', function(rows) {
- var html='';
- for (var i=0; i<rows.length; i++) {
- html += rows[i].firstname + ' ' + rows[i].lastname + '<br>';
- }
- document.getElementById("display").innerHTML = html;
- console.log(rows);
- });
- </script>
- </body>
- </html>
- socket.on('showrows', function(rows){
- console.log(rows);
- jQuery("#display").append(rows);
- });
- var socket = io.connect('http://localhost:3000', {'reconnect': true, 'force new connection': true, 'connect timeout': 1000});
- socket.on('showrows', function(rows) {
- jQuery("#display").append(rows);
- });
- io.sockets.on('connection', function (socket) {
- //Run your mysql query method
- //Socket disconnected
- socket.once('disconnect', function () {
- });
- });
- con.connect(function(err){
- if(err){
- console.log('Error connecting to Db');
- return;
- }
- console.log('Connection established');
- });
- //Don't recreate a mysql connection
- con.query('SELECT * FROM users',function(err,rows){
- if(err) throw err;
- console.log('Data received from Db:n');
- console.log(rows);
- });
- con.end(function(err) {
- // The connection is terminated gracefully
- // Ensures all previously enqueued queries are still
- // before sending a COM_QUIT packet to the MySQL server.
- });
Add Comment
Please, Sign In to add comment