[关闭]
@Wangww0925 2019-08-07T08:02:11.000000Z 字数 7925 阅读 295

mongodb 操作数据库 模块

NodeJs

crud： 增（create）删（delete）改（update）查（retrieve）

更多crud操作请查看https://docs.mongodb.com/manual

引入mongodb 操作数据库模块： var mongoclient = require("mongodb").MongoClient;

连接数据库

  1. 创建数据库的连接地址
  1. var url = "mongodb://localhost:27017/数据库名";
  1. 连接数据库
  1. // MongoDB 2.x 版本的写法；db 代表当前的数据库对象
  2. mongoclient.connect(url,(err,db)=>{
  3.     if(err){
  4.         res.send("数据库连接失败");
  5.         return
  6.     }
  8.     console.log("数据库连接成功", db);
  9. })
  11. // MongoDB 3.x 版本的写法；client 代表当前的数据库对象
  12. mongoclient.connect(url,(err, client)=>{
  13.     if(err){
  14.         res.send("数据库连接失败");
  15.         return
  16.     }
  18.     // mongodb 3.x 以上的新写法， test是数据库名
  19.     var db = client.db("test")
  21.     console.log("数据库连接成功", db)
  22. })

插入数据

插入一条数据 db.collection("集合").insertOne({}, callback)

  1. db.collection("集合名").insertOne({}, (err,result)=>{
  2.     if(err){
  3.         res.send("插入失败");
  4.         return
  5.     }
  7.     console.log(result)
  8. });

例子

node执行的文件

  1. var express = require("express");
  2. var mongoclient = require("mongodb").MongoClient;   // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test"; //创建数据库连接地址
  10.     //连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         // 插入一条数据
  21.         db.collection("login").insertOne({"name": "www"}, (err,result)=>{
  22.             if(err){
  23.                 res.send("<h1>插入失败</h1>");
  24.                 return;
  25.             }
  27.             res.send("<h1>插入成功</h1>");
  28.             client.close();
  29.         })
  30.     })
  31. })
  33. app.listen(8081);

插入多条数据 db.collection("集合名").insertMany([{},...,{}], callback)

  1. db.collection("集合名").insertMany([{},...,{}], (err,result)=>{
  2.     if(err){
  3.         res.send("插入失败");
  4.         return
  5.     }
  7.     console.log(result)
  8. });

例子

node执行的文件

  1. var express = require("express");
  2. var mongoclient = require("mongodb").MongoClient;   // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test"; //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         // 插入多条数据
  21.         db.collection("login").insertMany([{name:"a"},{name:"b"},{name:"c"}],(err,result)=>{
  22.             if(err){
  23.                 res.send("<h1>插入失败</h1>");
  24.                 return;
  25.             }
  27.             res.send("<h1>插入成功</h1>");
  28.             client.close();
  29.         })
  30.     })
  31. })
  33. app.listen(8081);

查询数据 db.collection("集合名").find(条件, callback)

  1. // doc 游标
  3. // 方法一：
  4. db.collection("集合名").find(条件,(req,doc)=>{
  5.     doc.each((err,data)=>{
  6.         if(err){
  7.             res.send("遍历失败");
  8.             return
  9.         }
  11.         console.log(data)
  12.     }) 
  13. })
  15. // 方法二：
  16. var doc = db.collection("集合名").find(条件)
  18. if(doc){
  19.     doc.each((err,data)=>{
  20.         if(err){
  21.             res.send("遍历失败");
  22.             return;
  23.         }
  25.         console.log(data)
  26.     })
  27. }

列出该集合的所有文档

PS：当查询所有数据的时候查询条件可以不写，或者写为{}

  1. var express = require("express");
  2. var  mongoclient = require("mongodb").MongoClient;    // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test";     //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         var result = [];
  22.         // 列出该集合的所有文档
  23.         db.collection("login").find({},(err,doc)=>{
  24.             doc.each(function(err,data){
  25.                 if(err){
  26.                     res.send("<h1>遍历失败</h1>")
  27.                     return;
  28.                 }
  30.                 if(data != null){
  31.                     result.push(data);
  32.                 }else{
  33.                     res.send(result);
  34.                     client.close();
  35.                 }                
  36.             })
  37.         })
  38.     })
  39. })
  41. app.listen(8081);

精确匹配

  1. var express = require("express");
  2. var  mongoclient = require("mongodb").MongoClient;    // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test";     //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         var result = [];
  22.         // 精确匹配
  23.         db.collection("login").find({name: "www"},(err,doc)=>{
  24.             doc.each(function(err,data){
  25.                 if(err){
  26.                     res.send("<h1>遍历失败</h1>")
  27.                     return;
  28.                 }
  30.                 if(data != null){
  31.                     // console.log(typeof data);
  32.                     result.push(data);
  33.                 }else{
  34.                     res.send(result);
  35.                     client.close();
  36.                 }
  37.             })
  38.         })
  39.     })
  40. })
  42. app.listen(8081);

条件判断查询

  1. var express = require("express");
  2. var  mongoclient = require("mongodb").MongoClient;    // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test";     //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url, (err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         var result = [];
  22.         // 方法一：
  23.         db.collection("login").find({"age":{$gt: 50}}, (err,doc)=>{
  24.             doc.each(function(err,data){
  25.                 if(err){
  26.                     res.send("<h1>遍历失败</h1>")
  27.                     return;
  28.                 }
  30.                 if(data != null){
  31.                     // console.log(typeof data);
  32.                     result.push(data);
  33.                 }else{
  34.                     res.send(result);
  35.                     client.close();
  36.                 }
  37.             })
  38.         })
  40.         // 方法二：
  41.         // var doc = db.collection("login").find({"age":{$gt: 25}});
  42.         // if(doc){
  43.         //     doc.each((err,data)=>{
  44.         //         if(err){
  45.         //             res.send("<h1>遍历失败</h1>");
  46.         //             return;
  47.         //         }
  48.         //         if(data != null){
  49.         //             result.push(data);                    
  50.         //         }else{
  51.         //             res.send(result);
  52.         //             client.close()
  53.         //         }
  54.         //     })
  55.         // }
  56.     })
  57. })
  59. app.listen(8081);

查询并排序 db.collection("集合名").find().sort(obj);

修改数据 db.collection("集合名").update(find_obj, new_obj, callback);

  1. db.collection("集合名").update(find_obj, new_obj, function(err,result){
  2.     if(err){
  3.         res.send("<h1>修改失败</h1>");
  4.         return;
  5.     }
  7.     console.log("修改成功");
  8. })

更改所有匹配项目

PS： 如果不指定修改多条数据{multi: true}，则只修改第一条数据

  1. var express = require("express");
  2. var mongoclient = require("mongodb").MongoClient;    // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test";     //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         // 更改所有匹配项目
  21.         // 只修改一条数据
  22.         db.collection("login").update({"name":"c"},{$set:{"age": 10}}, function(err,result){
  23.             if(err){
  24.                 res.send("<h1>修改失败</h1>");
  25.                 return;
  26.             }
  28.             res.send("修改成功");
  29.             client.close();
  30.         })
  32.         // 修改全部
  33.         // db.collection("login").update({"name":"c"},{$set:{"age": 80}}, {"multi":true},function(err,result){
  34.         //     if(err){
  35.         //         res.send("<h1>修改失败</h1>");
  36.         //         return;
  37.         //     }
  39.         //     res.send("修改成功");
  40.         //     client.close();
  41.         // })
  42.     })
  43. })
  45. app.listen(8081);

完整替换，不出现$set关键字了

  1. var express = require("express");
  2. var mongoclient = require("mongodb").MongoClient;    // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test";     //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         // 完整替换，不出现$set关键字了
  21.         db.collection("login").update({"name":"c"},{"age": 10}, function(err,result){
  22.             if(err){
  23.                 res.send("<h1>修改失败</h1>");
  24.                 return;
  25.             }
  27.             res.send("修改成功");
  28.             client.close();
  29.         })
  30.     })
  31. })
  33. app.listen(8081);

删除数据 db.collection("集合名").remove(obj, callback);

  1. db.collection("集合名").remove(obj, function(err,result){
  2.     if(err){
  3.         res.send("删除失败");
  4.         return;
  5.     }
  7.     if(result.result.n <= 0){
  8.         res.send("<h1>删除失败</h1>");
  9.         return;
  10.     }
  12.     console.log(result)
  13. })

只要匹配成功，就会删除

  1. var express = require("express");
  2. var mongoclient = require("mongodb").MongoClient;    // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test";     //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         // 只要匹配成功，就会删除
  21.         db.collection("login").remove({name: "a"},function(err,result){
  22.             if(err){
  23.                 res.send("删除失败");
  24.                 return;
  25.             }
  27.             // console.log(result)
  29.             if(result.result.n <= 0){
  30.                 res.send("<h1>删除失败</h1>");
  31.                 return;
  32.             }
  34.             res.send("<h1>删除成功</h1>");
  35.             client.close();
  36.         })
  37.     })
  38. })
  40. app.listen(8081);

删除全部

  1. var express = require("express");
  2. var mongoclient = require("mongodb").MongoClient;    // 数据库引用
  4. var app = express();
  6. app.get("/",(req,res)=>{
  8.     var url = "mongodb://localhost:27017/test";     //创建数据库连接地址
  10.     // 连接数据库
  11.     mongoclient.connect(url,(err, client)=>{
  12.         if(err){
  13.             res.send("<h1>数据库连接失败</h1>");
  14.             return;
  15.         }
  17.         // mongodb 3.x 以上的新写法， test是数据库名
  18.         var db = client.db("test");
  20.         // 删除全部
  21.         db.collection("login").remove({},function(err,result){
  22.             if(err){
  23.                 res.send("删除失败");
  24.                 return;
  25.             }
  27.             if(result.result.n <= 0){
  28.                 res.send("<h1>删除失败</h1>");
  29.                 return;
  30.             }
  32.             res.send("<h1>删除成功</h1>");
  33.             client.close();
  34.         })
  35.     })
  36. })
  38. app.listen(8081);

计算集合中文档中数量 db.collection("集合名").count().then(function(count){})

分页，从哪里开始查找数据 db.collection("集合名").find().skip(位置)

限制选取的条数 db.collection("集合名").find().limit(长度);

从哪里开始查找几条数据 db.collection("集合名").find().skip(位置).limit(长度);

作者 wendy
2019 年 2月 1日

添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注