Guest User

Untitled

a guest
Oct 23rd, 2018
96
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.87 KB | None | 0 0
  1. create table ms_registereduser(userID Varchar(10),socketID Varchar(255));
  2.  
  3. var http = require("http");
  4.  
  5. var mysql = require('mysql');
  6.  
  7. var connection = mysql.createConnection({
  8. host : 'localhost',
  9. user : 'root',
  10. password : '',
  11. database : 'pushnotificationdb'
  12. });
  13.  
  14. var userID = "1234567890",
  15. socketID = "asd123";
  16.  
  17.  
  18. http.createServer(function(request, response) {
  19.  
  20. response.writeHead(200, {"Content-Type": "text/plain"});
  21. response.write("Hello World");
  22.  
  23. response.end();
  24. }).listen(1111);
  25.  
  26. connection.connect();
  27.  
  28. connection.query('callpushnotificationdb.spUpdateSocketID('+userID+','+socketID+');').on('end',function()
  29. {
  30. console.log('User '+ userID+' has updated his socketID to '+socketID);
  31. });
  32.  
  33. connection.end();
  34.  
  35. DROP PROCEDURE IF EXISTS spUpdateSocketID//
  36.  
  37. CREATE PROCEDURE spUpdateSocketID(IN userID Varchar(10) ,IN socketID Varchar(255))
  38. BEGIN
  39. set @userID = userID;
  40. set @socketID = socketID;
  41. set @s = CONCAT('UPDATE ms_registereduser SET socketID = @socketID WHERE userID = @userID');
  42. PREPARE stmt FROM @s;
  43. EXECUTE stmt;
  44. DEALLOCATE PREPARE stmt;
  45. END//
  46.  
  47. call pushnotificationdb.spUpdateSocketID('1234567890','asd123');
  48.  
  49. connection.query(
  50. 'callpushnotificationdb.spUpdateSocketID("'+userID+'","'+socketID+'");'
  51. )
  52. .on('end',function(){
  53. console.log('User '+ userID+' has updated his socketID to '+socketID);
  54. });
  55.  
  56. DROP PROCEDURE IF EXISTS spUpdateSocketID//
  57.  
  58. CREATE PROCEDURE spUpdateSocketID(IN _userID VARCHAR(10) ,IN _socketID VARCHAR(255))
  59. BEGIN
  60. UPDATE ms_registereduser SET socketID = _socketID WHERE userID = _userID;
  61. END//
  62.  
  63. DROP PROCEDURE IF EXISTS spUpdateSocketID//
  64.  
  65. CREATE PROCEDURE spUpdateSocketID(IN userID VARCHAR(10) ,IN socketID VARCHAR(255))
  66. BEGIN
  67. SET @s = CONCAT("UPDATE ms_registereduser SET socketID = '", socketID, "' WHERE userID = '", userID, "'");
  68. PREPARE stmt FROM @s;
  69. EXECUTE stmt;
  70. DEALLOCATE PREPARE stmt;
  71. END//
Add Comment
Please, Sign In to add comment