db.use.js
1 /** 2 * 使用前：先安装node环境、express、mongodb. 3 * 4 * 1.1 安装Node 5 * 1.2 npm i -D express mongodb && npm i -g express mongodb 6 * 1.3 db.action：增、删、查、改(目前只添加了增作为示例)、db.config：配置数据库连接名还有ip地址以及端口号. 7 */
8
9 const express = require('express'); 10 const app = express(); 11 const db = require('./db.action'); 12 const DbConfig = require('./db.config'); 13
14 app.get('/', function (req, res) { 15
16 // 插入多条数据
17 db.insertMany(DbConfig.dbname, [ 18 { 'name': '小蓝', 'age': 20, 'home': '郴州市' }, 19 { 'name': '小绿', 'age': 21, 'home': '永州市' }, 20 { 'name': '小红', 'age': 22, 'home': '北京市' } 21 ], function (err, result) { 22 if (err) throw err; 23 res.send('插入成功'); 24 // db.close();
25 }); 26
27 }).listen(80);
db.config.js
1 // 数据库名
2 let dbname = 'test'; 3
4 // ip地址
5 let ip = '127.0.0.1'; 6
7 // 端口号
8 let port = 27017; 9
10
11 // ES5导出.
12 module.exports = { 13 url: 'mongodb://' + ip + ':' + port + '/', 14 dbname: dbname 15 } 16
17 // ES6 导出
18 // export { url,db };
db.action.js
1 // import { url,db } from './db.config' ES6导入 ;
2 (function () { 3 const MongoClient = require('mongodb').MongoClient; 4 const DbConfig = require('./db.config'); 5
6 function _connectDB(callback) { 7 let dburl = DbConfig.url; 8 let dbname = DbConfig.dbname; 9 //链接数据库
10 MongoClient.connect(dburl + dbname, function (err, db) { 11 callback(err, db); 12 }); 13 } 14
15 //插入单条数据
16 exports.insertOne = function (collectionName, data, callback) { 17 _connectDB(function (err, db) { 18
19 if (err) { 20 callback(err, db); 21 return; 22 } 23
24 db = db.db(collectionName); 25
26 db.collection(db.databaseName).insertOne(data, function (err, result) { 27 callback(err, result); 28 // db.close(); //关闭数据库
29 }); 30 }); 31 } 32
33
34 // 插入多条数据
35 exports.insertMany = function (collectionName, data, callback) { 36 _connectDB(function (err, db) { 37 if (err) { 38 callback(err, db); 39 return; 40 } 41
42 db = db.db(collectionName); 43
44 db.collection(collectionName).insertMany(data, function (err, result) { 45 callback(err, result); 46 // db.close(); //关闭数据库
47 }); 48 }); 49 } 50 })()
