Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var Connection = require('tedious').Connection;
- var Request = require('tedious').Request;
- var TYPES = require('tedious').TYPES;
- var async = require('async');
- var app = require('express')();
- var http = require('http').Server(app);
- var io = require('socket.io')(http);
- var port = process.env.PORT || 3000;
- // Create connection to database
- var config = {
- userName: 'ladymey', // update me
- password: 'MeY0544808130', // update me
- server: 'ladymey.database.windows.net',
- options: {
- database: 'meyDB'
- , encrypt: true
- }
- }
- var connection = new Connection(config);
- function Start(callback) {
- console.log('Starting...');
- callback(null, 'Jake', '054432100');
- }
- function Insert(name, Phone, callback) {
- console.log("Inserting '" + name + "' into Table...");
- request = new Request(
- 'INSERT INTO ContactsSchema.Contacts (Name, Phone) OUTPUT INSERTED.Id VALUES (@Name, @Phone);',
- function(err, rowCount, rows) {
- if (err) {
- callback(err);
- } else {
- console.log(rowCount + ' row(s) inserted');
- callback(null, 'Nikita', '054432114');
- }
- });
- request.addParameter('Name', TYPES.NVarChar, name);
- request.addParameter('Phone', TYPES.NVarChar, Phone);
- // Execute SQL statement
- connection.execSql(request);
- }
- function Update(name, Phone, callback) {
- console.log("Updating Phone to '" + Phone + "' for '" + name + "'...");
- // Update the employee record requested
- request = new Request(
- 'UPDATE ContactsSchema.Contacts SET Phone=@Phone WHERE Name = @Name;',
- function(err, rowCount, rows) {
- if (err) {
- callback(err);
- } else {
- console.log(rowCount + ' row(s) updated');
- callback(null, 'Jared');
- }
- });
- request.addParameter('Name', TYPES.NVarChar, name);
- request.addParameter('Phone', TYPES.NVarChar, Phone);
- // Execute SQL statement
- connection.execSql(request);
- }
- function Delete(name, callback) {
- console.log("Deleting '" + name + "' from Table...");
- // Delete the employee record requested
- request = new Request(
- 'DELETE FROM ContactsSchema.Contacts WHERE Name = @Name;',
- function(err, rowCount, rows) {
- if (err) {
- callback(err);
- } else {
- console.log(rowCount + ' row(s) deleted');
- callback(null);
- }
- });
- request.addParameter('Name', TYPES.NVarChar, name);
- // Execute SQL statement
- connection.execSql(request);
- }
- function Read(callback) {
- console.log('Reading rows from the Table...');
- // Read all rows from table
- request = new Request(
- 'SELECT Id, Name, Phone FROM ContactsSchema.Contacts;',
- function(err, rowCount, rows) {
- if (err) {
- callback(err);
- } else {
- console.log(rowCount + ' row(s) returned');
- callback(null);
- }
- });
- // Print the rows read
- var result = "";
- request.on('row', function(columns) {
- columns.forEach(function(column) {
- if (column.value === null) {
- console.log('NULL');
- } else {
- result += column.value + " ";
- }
- });
- console.log(result);
- result = "";
- });
- // Execute SQL statement
- connection.execSql(request);
- }
- function Complete(err, result) {
- if (err) {
- callback(err);
- } else {
- console.log("Done!");
- }
- }
- app.get('/', function(req, res){
- res.sendFile(__dirname + '/index.html');
- });
- io.on('connection', function(socket)
- {
- console.log('On connection from Client...');
- socket.on('load list',function() {
- console.log("load list");
- io.emit('load list','hi!!!!!!!!!!' );});
- });
- http.listen(port, function(){
- console.log('listening on *:' + port);
- });
- // Attempt to connect and execute queries if connection goes through
- connection.on('connect', function(err) {
- if (err) {
- console.log(err);
- } else {
- console.log('Connected');
- // Execute all functions in the array serially
- /*async.waterfall([
- Start,
- Insert,
- Update,
- Delete,
- Read
- ], Complete)*/
- }
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement