mongoDB - 插入数据

Posted 2020-12-30 Sunsin

 

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 })()