Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- create table ms_registereduser(userID Varchar(10),socketID Varchar(255));
- var http = require("http");
- var mysql = require('mysql');
- var connection = mysql.createConnection({
- host : 'localhost',
- user : 'root',
- password : '',
- database : 'pushnotificationdb'
- });
- var userID = "1234567890",
- socketID = "asd123";
- http.createServer(function(request, response) {
- response.writeHead(200, {"Content-Type": "text/plain"});
- response.write("Hello World");
- response.end();
- }).listen(1111);
- connection.connect();
- connection.query('callpushnotificationdb.spUpdateSocketID('+userID+','+socketID+');').on('end',function()
- {
- console.log('User '+ userID+' has updated his socketID to '+socketID);
- });
- connection.end();
- DROP PROCEDURE IF EXISTS spUpdateSocketID//
- CREATE PROCEDURE spUpdateSocketID(IN userID Varchar(10) ,IN socketID Varchar(255))
- BEGIN
- set @userID = userID;
- set @socketID = socketID;
- set @s = CONCAT('UPDATE ms_registereduser SET socketID = @socketID WHERE userID = @userID');
- PREPARE stmt FROM @s;
- EXECUTE stmt;
- DEALLOCATE PREPARE stmt;
- END//
- call pushnotificationdb.spUpdateSocketID('1234567890','asd123');
- connection.query(
- 'callpushnotificationdb.spUpdateSocketID("'+userID+'","'+socketID+'");'
- )
- .on('end',function(){
- console.log('User '+ userID+' has updated his socketID to '+socketID);
- });
- DROP PROCEDURE IF EXISTS spUpdateSocketID//
- CREATE PROCEDURE spUpdateSocketID(IN _userID VARCHAR(10) ,IN _socketID VARCHAR(255))
- BEGIN
- UPDATE ms_registereduser SET socketID = _socketID WHERE userID = _userID;
- END//
- DROP PROCEDURE IF EXISTS spUpdateSocketID//
- CREATE PROCEDURE spUpdateSocketID(IN userID VARCHAR(10) ,IN socketID VARCHAR(255))
- BEGIN
- SET @s = CONCAT("UPDATE ms_registereduser SET socketID = '", socketID, "' WHERE userID = '", userID, "'");
- PREPARE stmt FROM @s;
- EXECUTE stmt;
- DEALLOCATE PREPARE stmt;
- END//
Add Comment
Please, Sign In to add comment