Advertisement
Guest User

Untitled

a guest
Oct 13th, 2017
115
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 4.24 KB | None | 0 0
  1. var Connection = require('tedious').Connection;
  2. var Request = require('tedious').Request;
  3. var TYPES = require('tedious').TYPES;
  4. var async = require('async');
  5.  
  6. var app = require('express')();
  7. var http = require('http').Server(app);
  8. var io = require('socket.io')(http);
  9. var port = process.env.PORT || 3000;
  10.  
  11. // Create connection to database
  12. var config = {
  13. userName: 'ladymey', // update me
  14. password: 'MeY0544808130', // update me
  15. server: 'ladymey.database.windows.net',
  16. options: {
  17. database: 'meyDB'
  18. , encrypt: true
  19.  
  20. }
  21. }
  22.  
  23. var connection = new Connection(config);
  24.  
  25. function Start(callback) {
  26. console.log('Starting...');
  27. callback(null, 'Jake', '054432100');
  28. }
  29.  
  30. function Insert(name, Phone, callback) {
  31. console.log("Inserting '" + name + "' into Table...");
  32.  
  33. request = new Request(
  34. 'INSERT INTO ContactsSchema.Contacts (Name, Phone) OUTPUT INSERTED.Id VALUES (@Name, @Phone);',
  35. function(err, rowCount, rows) {
  36. if (err) {
  37. callback(err);
  38. } else {
  39. console.log(rowCount + ' row(s) inserted');
  40. callback(null, 'Nikita', '054432114');
  41. }
  42. });
  43. request.addParameter('Name', TYPES.NVarChar, name);
  44. request.addParameter('Phone', TYPES.NVarChar, Phone);
  45.  
  46. // Execute SQL statement
  47. connection.execSql(request);
  48. }
  49.  
  50. function Update(name, Phone, callback) {
  51. console.log("Updating Phone to '" + Phone + "' for '" + name + "'...");
  52.  
  53. // Update the employee record requested
  54. request = new Request(
  55. 'UPDATE ContactsSchema.Contacts SET Phone=@Phone WHERE Name = @Name;',
  56. function(err, rowCount, rows) {
  57. if (err) {
  58. callback(err);
  59. } else {
  60. console.log(rowCount + ' row(s) updated');
  61. callback(null, 'Jared');
  62. }
  63. });
  64. request.addParameter('Name', TYPES.NVarChar, name);
  65. request.addParameter('Phone', TYPES.NVarChar, Phone);
  66.  
  67. // Execute SQL statement
  68. connection.execSql(request);
  69. }
  70.  
  71. function Delete(name, callback) {
  72. console.log("Deleting '" + name + "' from Table...");
  73.  
  74. // Delete the employee record requested
  75. request = new Request(
  76. 'DELETE FROM ContactsSchema.Contacts WHERE Name = @Name;',
  77. function(err, rowCount, rows) {
  78. if (err) {
  79. callback(err);
  80. } else {
  81. console.log(rowCount + ' row(s) deleted');
  82. callback(null);
  83. }
  84. });
  85. request.addParameter('Name', TYPES.NVarChar, name);
  86.  
  87. // Execute SQL statement
  88. connection.execSql(request);
  89. }
  90.  
  91. function Read(callback) {
  92. console.log('Reading rows from the Table...');
  93.  
  94. // Read all rows from table
  95. request = new Request(
  96. 'SELECT Id, Name, Phone FROM ContactsSchema.Contacts;',
  97. function(err, rowCount, rows) {
  98. if (err) {
  99. callback(err);
  100. } else {
  101. console.log(rowCount + ' row(s) returned');
  102. callback(null);
  103. }
  104. });
  105.  
  106. // Print the rows read
  107. var result = "";
  108. request.on('row', function(columns) {
  109. columns.forEach(function(column) {
  110. if (column.value === null) {
  111. console.log('NULL');
  112. } else {
  113. result += column.value + " ";
  114. }
  115. });
  116. console.log(result);
  117. result = "";
  118. });
  119.  
  120. // Execute SQL statement
  121. connection.execSql(request);
  122. }
  123.  
  124. function Complete(err, result) {
  125. if (err) {
  126. callback(err);
  127. } else {
  128. console.log("Done!");
  129. }
  130. }
  131.  
  132. app.get('/', function(req, res){
  133. res.sendFile(__dirname + '/index.html');
  134. });
  135.  
  136. io.on('connection', function(socket)
  137. {
  138. console.log('On connection from Client...');
  139.  
  140. socket.on('load list',function() {
  141. console.log("load list");
  142. io.emit('load list','hi!!!!!!!!!!' );});
  143. });
  144.  
  145. http.listen(port, function(){
  146. console.log('listening on *:' + port);
  147. });
  148.  
  149. // Attempt to connect and execute queries if connection goes through
  150. connection.on('connect', function(err) {
  151. if (err) {
  152. console.log(err);
  153. } else {
  154. console.log('Connected');
  155.  
  156. // Execute all functions in the array serially
  157. /*async.waterfall([
  158. Start,
  159. Insert,
  160. Update,
  161. Delete,
  162. Read
  163. ], Complete)*/
  164. }
  165.  
  166.  
  167. });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement