# 重新封裝了一下NODE-MONGO 使其成為一個獨立的服務.可以直接通過get/post來操作
# consts.js 配置用的數據，用于全局參數配置
# log.js 自己寫的一個簡單的存儲本地log的功能，數據庫異常或者邏輯上產生異常數據的時候輸出查錯
# servicemongo.js 主服務程序，可以直接node servicemongo.js 啟動，掛起端口服務
# routemongo.js 請求路由相關
# mongo.js 封裝了一些基本的node對mongo操作
# 使用方法，直接node ?servicemongo.js 就行，也可以在另一個項目里調用servicemongo的start?
# 注意 node包沒傳，缺什么自己安裝什么吧，看下錯誤日志，缺什么就直接npm i XXX 裝上就好

項目我打包上傳到資源了（待審核狀態，差不多明天就能下載了）：

https://me.csdn.net/download/u013761036

consts.js

module.exports = {default: {defaultDataServicePort: 2323,//數據庫服務接口端口defaultMongoUrl : 'mongodb://localhost:27017/',//Mongo數據庫連接地址} }

log.js

var fs = require('fs'); const sd = require('silly-datetime');//輸出log的時候，可以傳過來一個key，來代表這個是誰輸出的，建議是文件名字+函數名字 xxx.js-funxx //consolelog('main.js-main', 'star-ok'); function consolelog(key, data) {try {if ('string' != typeof data) {data = JSON.stringify(data);}let formatData = sd.format(new Date(), 'YYYY-MM-DD HH:mm:ss') + '->' + key + '\n';formatData = formatData + data + '\n\n';// 創建一個可以寫入的流，寫入到文件 xxx-xx-xx.log 中,日期let outPutLogFilePath = "./" + sd.format(new Date(), 'YYYY-MM-DD') + ".log";var writerStream = fs.createWriteStream(outPutLogFilePath, { 'flags': 'a' });writerStream.write(formatData, 'UTF8');writerStream.end();writerStream.on('finish', function () {//console.log("寫入完成。");});writerStream.on('error', function (err) {//console.log(err.stack);});} catch (e) {} } module.exports = {consolelog, };

mongo.js

const url = require('url'); const { MongoClient, ObjectId } = require('mongodb'); const sd = require('silly-datetime'); const _ = require('lodash'); const { consolelog } = require('./log'); const config = require('./consts'); const { defaultMongoUrl: mongourl } = _.get(config, 'defaultMongoUrl', config.default);const goError = (mongoLink, req, res, body = null) => {//數據庫操作失敗一定全都打log出來。const params = url.parse(req.url, true).query;let logMess = 'Mongo operation failed:' + JSON.stringify(params);if (body) {logMess = logMess + '\nBody:' + JSON.stringify(body);}consolelog('mongo.js-goError', logMess);if (mongoLink != null) {mongoLink.close();}res.end(); }//查詢數據，條件查詢，但是不支持ObjectID，條件的格式是{"key":"value"} const findMongo = (dbname, collection, where, req, res) => {MongoClient.connect(mongourl, { useNewUrlParser: true, useUnifiedTopology: true }, function (err, client) {//if (err) throw err;if (err) {return goError(client, req, res);}try {where = JSON.parse(where);} catch (e) {return goError(client, req, res);}const db = client.db(dbname);db.collection(collection).find(where).sort({ updateTime: -1 }).toArray(function (err, datas) {//if (err) throw err;if (err) {return goError(client, req, res);}res.writeHead(200, { "Content-Type": "text/plain; charset=utf8" });res.end(JSON.stringify(datas));client.close();});});return; }//查詢數據，value專門支持ObjectID類型，key可以是_id,也可以是別的 const findMongoByKOBJV = (dbname, collection, key, value, req, res) => {MongoClient.connect(mongourl, { useNewUrlParser: true, useUnifiedTopology: true }, function (err, client) {//if (err) throw err;if (err) {return goError(client, req, res);}const db = client.db(dbname);const were = {};try {were[key] = ObjectId(value);} catch (e) {return goError(client, req, res);}db.collection(collection).find(were).sort({ updateTime: -1 }).toArray(function (err, datas) {//if (err) throw err;if (err) {return goError(client, req, res);}res.writeHead(200, { "Content-Type": "text/plain; charset=utf8" });res.end(JSON.stringify(datas));client.close();});});return; }//根據條件刪除數據,不支持ObjectID類型 const deleteMongo = (dbname, collection, body, req, res) => {MongoClient.connect(mongourl, { useNewUrlParser: true, useUnifiedTopology: true }, function (err, client) {//if (err) throw err;if (err) {return goError(client, req, res, body);}const db = client.db(dbname);if (body.were == null) {//卡一下，防止出人命！return goError(client, req, res, body);}let were = null;try {were = JSON.parse(body.were);} catch (e) {return goError(client, req, res, body);}db.collection(collection).deleteMany(were, function (err, datas) {//if (err) throw err;if (err) {return goError(client, req, res, body);}res.writeHead(200, { "Content-Type": "text/plain; charset=utf8" });//{"result":{"n":0,"ok":1},"connection":{"id":6,"host":"localhost","port":27017},"deletedCount":0,"n":0,"ok":1}res.end(JSON.stringify(datas));client.close();});});return; }const deleteMongoByKOBJV = (dbname, collection, body, req, res) => {MongoClient.connect(mongourl, { useNewUrlParser: true, useUnifiedTopology: true }, function (err, client) {//if (err) throw err;if (err) {return goError(client, req, res, body);}const db = client.db(dbname);let key = body.key;let value = body.value;if ((!key) || (!value)) {//卡一下，防止出人命！return goError(client, req, res, body);}let were = {};try {were[key] = ObjectId(value);} catch (e) {return goError(client, req, res, body);}db.collection(collection).deleteMany(were, function (err, datas) {//if (err) throw err;if (err) {return goError(client, req, res, body);}res.writeHead(200, { "Content-Type": "text/plain; charset=utf8" });//{"result":{"n":0,"ok":1},"connection":{"id":4,"host":"localhost","port":27017},"deletedCount":0,"n":0,"ok":1}res.end(JSON.stringify(datas));client.close();});});return; }//插入一條數據 const insertMongo = (dbname, collection, body, req, res) => {MongoClient.connect(mongourl, { useNewUrlParser: true, useUnifiedTopology: true }, function (err, client) {//if (err) throw err;if (err) {return goError(client, req, res, body);}let db = client.db(dbname);//自動添加創建時間和修改時間body[0]['createdAt'] = new Date();body[0]['updatedAt'] = new Date();db.collection(collection).insertMany(body, function (err, datas) {//if (err) throw err;if (err) {return goError(client, req, res, body);}res.writeHead(200, { "Content-Type": "text/plain; charset=utf8" });//{"result":{"ok":1,"n":1},"ops":[{"v1":"1111","v2":"2222","createdAt":"2019-11-05T08:07:37.087Z","updatedAt":"2019-11-05T08:07:37.087Z","_id":"5dc12dc99af00a30429a4b5c"}],"insertedCount":1,"insertedIds":{"0":"5dc12dc99af00a30429a4b5c"}}res.end(JSON.stringify(datas));client.close();});});return; }const updateById = (dbname, collection, body, req, res) => {MongoClient.connect(mongourl, { useNewUrlParser: true, useUnifiedTopology: true }, function (err, client) {//if (err) throw err;if (err) {return goError(client, req, res, body);}let db = client.db(dbname);let _id = null;let updata = null;try {_id = ObjectId(body.id);updata = JSON.parse(body.data);updata['updatedAt'] = new Date();} catch (e) {return goError(client, req, res, body);}let updateCmd = { $set: updata };db.collection(collection).updateOne({ _id }, updateCmd, function (err, datas) {//if (err) throw err;if (err) {return goError(client, req, res, body);}res.writeHead(200, { "Content-Type": "text/plain; charset=utf8" });//{"result":{"n":1,"nModified":1,"ok":1},"connection":{"id":2,"host":"localhost","port":27017},"modifiedCount":1,"upsertedId":null,"upsertedCount":0,"matchedCount":1,"n":1,"nModified":1,"ok":1}res.end(JSON.stringify(datas));client.close();});});return; }module.exports = {updateById,findMongoByKOBJV,deleteMongoByKOBJV,deleteMongo,findMongo,insertMongo };

routemongo.js

const url = require('url'); const mongo = require('./mongo'); const querystring = require('querystring'); const { consolelog } = require('./log');const workFind = async (req, res) => {const params = url.parse(req.url, true).query;switch (params.cmd) {case 'query': {mongo.findMongo(params.n, params.c, params.w, req, res);} break;case 'querykeyid': {mongo.findMongoByKOBJV(params.n, params.c, params.k, params.v, req, res);} break;default: {res.end();}; break;} }const workUpdate = async (req, res) => {const params = url.parse(req.url, true).query;let postdata = '';req.on('data', function (chunk) {postdata += chunk;});req.on('end', async function () {if (postdata == '') {//過濾掉這種，防止后面誤操作破壞數據庫數據return res.end();}let postdataobj = null;try {postdataobj = querystring.parse(postdata);} catch (e) {let logMess = 'Mongo operation failed:\n' + JSON.stringify(params) + '\npostdata:' + postdataconsolelog('routemongo.js-workUpdate', logMess);return res.end();}try {switch (params.cmd) {case 'delete': {mongo.deleteMongo(params.n, params.c, postdataobj, req, res);} break;case 'deletekeyid': {mongo.deleteMongoByKOBJV(params.n, params.c, postdataobj, req, res);} break;case 'insert': {const postdataobjarr = [postdataobj];mongo.insertMongo(params.n, params.c, postdataobjarr, req, res);} break;case 'updatebyid': {mongo.updateById(params.n, params.c, postdataobj, req, res);} break;default: {res.end();}; break;}} catch (e) {datas = null;}}); }module.exports = {workFind,workUpdate };

servicemongo.js

const http = require('http'); var url = require("url"); const routemongo = require('./routemongo'); const config = require('./consts'); const { consolelog } = require('./log'); const _ = require('lodash');const route = async (req, res) => {switch (url.parse(req.url).pathname) {case "/find": {//查routemongo.workFind(req, res);}; break;case "/update": {//增 刪 改routemongo.workUpdate(req, res);}; break;default: {res.end();} break;} }const start = async () => {const { defaultDataServicePort } = _.get(config, 'defaultDataServicePort', config.default);consolelog('servicemongo.js-start', 'start:' + defaultDataServicePort);http.createServer(function (req, res) {route(req, res);}).listen(defaultDataServicePort); };module.exports = {start, };start();

?

總結

以上是生活随笔為你收集整理的重新封装了一下NODE-MONGO 使其成为一个独立的服务.可以直接通过get/post来操作的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。