mongoDB.js
3.63 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
const log = require('./log');
var constants = require('./constants');
var MongoClient = require('mongodb').MongoClient;
var config = require('./config');
var connection = {};
connection.reqMongo = async function (req,method, query, collection) {
// console.log(req.id)
var mongoData = config.get('mongoDB');
var url = "mongodb://"+mongoData.hopitalIp;
var database = mongoData.hopitalName;
var result = await mongoReq(req,url,database,method, query, collection);
return result;
}
function mongoReq(req,url,database,method, query, collection){
var nodeName = "MongoDB";
var funStats = {
detailSqlQuery : function(query){log.detailSqlQuery(req,method,query);},
detailSqlResult : function(result, err){log.detailSqlResult(req,method,result || err);},
addSuccessSummary : function(result){log.addSuccessSummary(req,nodeName,collection,result);},
addErrorSummary : function(result){log.addErrorSummary(req,nodeName,collection,result);}
};
return new Promise((resolve, reject) => {
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) {
console.log(err)
resolve(constants.RESPONSECONN.MESSAGE.DBERROR);
}
funStats.detailSqlQuery(query);
var dbInstant = db.db(database).collection(collection);
switch (method) {
case constants.METHOD.GET:
dbInstant.find(query, { projection: { _id: 0 } }).toArray(function(err, result) {
resolve(checkResponse(result,err,funStats));
});
break;
case constants.METHOD.POST:
db.db(database).collection(collection).insertOne(query, function(err, result) {
var response = checkResponse(result,err,funStats);
delete response.resultData;
resolve(response);
});
break;
case "PUT":
// db.db(database).collection(collection).find(query, { projection: { _id: 0 } }).toArray(function(err, result) {
// db.close();
// if (err) {
// console.log(err)
// resolve(checkResponse(req,{err:err}));
// }else
// resolve(checkResponse(req,result));
// });
break;
case "DELETE":
// db.db(database).collection(collection).find(query, { projection: { _id: 0 } }).toArray(function(err, result) {
// db.close();
// if (err) {
// console.log(err)
// resolve(checkResponse(req,{err:err}));
// }else
// resolve(checkResponse(req,result));
// });
break;
}
db.close();
});
});
}
function checkResponse(result,err,funStats)
{
funStats.detailSqlResult(result, err);
if(err)
{
var returnData = constants.RESPONSECONN.MESSAGE.DBERROR;
funStats.addErrorSummary(returnData);
}
else
{
var returnData = constants.RESPONSECONN.MESSAGE.SUCCESS;
returnData.resultData = result;
funStats.addSuccessSummary(returnData);
}
return returnData
}
module.exports = connection;