Advertisement
Guest User

Untitled

a guest
May 18th, 2017
70
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.11 KB | None | 0 0
  1. //server.js
  2. const sql = require('mssql');
  3.  
  4. var sqlQuery = function(config,query){
  5. var res = {complete: '',results: ''};
  6.  
  7. var promise = new Promise((resolve,reject)=>{
  8.  
  9. var pool = new sql.connect(config, err=>{
  10. var request = new sql.Request(pool);
  11. request.query(query,(err,result)=>{
  12. if(err){
  13.  
  14. res.complete="Errors";
  15. res.results = []
  16. reject(res);
  17. }else{
  18.  
  19. res.complete="Complete";
  20. res.results = result;
  21. resolve(res);
  22. pool.close();
  23. }
  24. });
  25.  
  26. });
  27.  
  28. pool.on('error',err=>{
  29. res.complete="ConnectionError";
  30. res.results = [];
  31. reject(res);
  32. })
  33.  
  34. });
  35.  
  36. return promise;
  37.  
  38. }
  39.  
  40. module.exports.sqlQuery = sqlQuery;
  41.  
  42. //other.js
  43. var sql = require('./server.js');
  44. var config = {
  45. server: 'serverIp\\instancia',
  46. database: "mydb",
  47. user: "myuser",
  48. password: "mypass",
  49. port: 1433
  50. }
  51. var query = "select * from mytable where myfield=somevalue";
  52.  
  53. var promise = sql.sqlQuery(config,query);
  54. promise.then(result=>{console.log(result)},err=>{console.log("error",err)})
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement