mongoDB.js
3.56 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
const logger = require('./request-logger');
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){
logger.logSqlQuery({id : "session", reqId : req.id}, query);
return new Promise((resolve, reject) => {
MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
if (err) {
console.log(err)
logger.logSqlResult({id : "session", reqId : req.id}, err.errmsg);
resolve({
resultCode : "50001",
message : err.errmsg
});
}
switch (method) {
case "GET":
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 "POST":
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 "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;
}
});
});
}
function checkResponse(req,response)
{
if(response.err)
{
logger.logSqlResult({id : "session", reqId : req.id}, err.errmsg);
var returnData = {
resultCode : "50001",
message : response.err.errmsg
};
}else
{
logger.logSqlResult({id : "session", reqId : req.id}, response);
var returnData = {
resultCode : "20000",
resultDescription : "Success",
resultData : response
};
}
return returnData
}
module.exports = connection;