jigar patel

jigar patel

  • NA
  • 310
  • 23.9k

connect SQL in Node js

Dec 13 2018 5:55 AM
  1. var express = require('express');  
  2. var bodyParser = require("body-parser");  
  3. var app = express();  
  4. var sql = require("mssql");  
  5.   
  6. // Body Parser Middleware  
  7. app.use(bodyParser.json());  
  8.   
  9. //CORS Middleware  
  10. app.use(function (req, res, next) {  
  11. //Enabling CORS  
  12. res.header("Access-Control-Allow-Origin""*");  
  13. res.header("Access-Control-Allow-Methods""GET,HEAD,OPTIONS,POST,PUT");  
  14. res.header("Access-Control-Allow-Headers""Origin, X-Requested-With, contentType,Content-Type, Accept, Authorization");  
  15. next();  
  16. });  
  17.   
  18.   
  19.   
  20. // config for your database  
  21. var config = {  
  22. user: 'sa',  
  23. password: 'abc@123',  
  24. server: 'MY-PC\\SQL',  
  25. database: 'dbStudent'  
  26. };  
  27. sql.close()  
  28. app.get('/GetTotalStudent'function (req, res) {  
  29. // connect to your database  
  30.   
  31. sql.connect(config, function (err) {  
  32.   
  33. if (err) console.log(err);  
  34.   
  35. // create Request object  
  36. var request = new sql.Request();  
  37.   
  38. // query to the database and get the records  
  39. request.query('select count(*) as totalrow from tblStudent'function (err, recordset) {  
  40.   
  41. if (err) console.log(err)  
  42.   
  43. // send records as a response  
  44. res.send(recordset.recordset[0]);  
  45. sql.close();  
  46. });  
  47. });  
  48. });  
  49.   
  50. app.get('/GetCurrentData'function (req, res) {  
  51. // connect to your database  
  52.   
  53. sql.connect(config, function (err) {  
  54.   
  55. if (err) console.log(err);  
  56. var startpage = parseInt(req.query.Start);  
  57. var endpage = parseInt(req.query.End);  
  58. // create Request object  
  59. var request = new sql.Request();  
  60. var query = " SELECT * FROM ( SELECT ROW_NUMBER() OVER ( ORDER BY st_Id ) AS RowNum, * " +  
  61. " FROM tblStudent " +  
  62. " ) AS RowConstrainedResult " +  
  63. " WHERE RowNum >= " + startpage + " " +  
  64. " AND RowNum <= " + endpage + " " +  
  65. " ORDER BY RowNum";  
  66. // query to the database and get the records  
  67. request.query(query, function (err, recordset) {  
  68.   
  69. if (err) console.log(err)  
  70.   
  71. // send records as a response  
  72. res.send(recordset.recordsets);  
  73. sql.close();  
  74. });  
  75. });  
  76. });  
  77.   
  78. //POST API  
  79. app.post("/addemployee"function(req , res){  
  80. var query = "INSERT INTO [tblEmployee] (firstname,lastname,email,password,birthdate,phonenumber,height,weight,gender) VALUES ('"+req.body.firstname+"','"+req.body.lastname+"','"+req.body.email+"','"+req.body.password+"','"+req.body.birthdate+"','"+req.body.phonenumber+"','"+req.body.height+"','"+req.body.weight+"','"+req.body.gender+"')"  
  81. executeQuery (res, query);  
  82. });  
  83. var server = app.listen(9090, function () {  
  84. console.log('Server is running..');  
  85. });  

Answers (1)