mongoDB.js
4.19 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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
var MongoClient = require('mongodb').MongoClient;
const core = require('./core');
const log = core.log;
const stat = core.stats;
const constants = core.constants;
const config = core.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,collection,query);
stat.sendQuery(method,collection);
},
detailSqlResult : function(result, err){
log.detailSqlResult(req,collection,result || err);
if(result)
stat.receiveQuery(method,collection);
else
stat.receiveBadQuery(method,collection);
},
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(method,result,err,funStats));
});
break;
case constants.METHOD.POST:
db.db(database).collection(collection).insertOne(query, function(err, result) {
var response = checkResponse(method,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(method,result,err,funStats)
{
funStats.detailSqlResult(result, err);
if(err)
{
var returnData = constants.RESPONSECONN.MESSAGE.DBERROR;
funStats.addErrorSummary(returnData);
}
else
{
if(result.length == 0 && constants.METHOD.GET == method )
{
var returnData = constants.RESPONSERESULT.DATA_NOT_FOUND;
funStats.addErrorSummary(returnData);
}else
{
var returnData = constants.RESPONSERESULT.SUCCESS;
returnData.resultData = result;
funStats.addSuccessSummary(returnData);
}
}
return returnData
}
module.exports = connection;