MonGoDb 简单的增删改查

Posted 2020-10-06 被遗忘的优雅

一: 启动数据库服务
    1: cmd 进入数据库安装目录的 bin 目录
    2: mongpd --dbpath 数据库数据存放目录
       例如: mongod --dbpath E:\NODE\MonGoDB
       数据库数据存放目录为任意的已存在目录

二: 连接已经启动的数据库服务
    1: cmd 进入数据库安装目录的 bin 目录, (第一步打开的窗口不能关闭和停止)
    2: mongo 数据库访问地址:端口
       例如: mongo 127.0.0.1:27017
       本机的访问地址为 127.0.0.1 或者 localhost
       默认端口为 27017

三: 常用命令
    1: show dbs -> 查看所有已经创建的数据库
    2: use 数据库名称 -> 切换或者创建数据库
    3: db.dropDatabase(); -> 删除当前数据库
    4: db.getName(); -> 获取当前数据库的名称
    5: db.getMongo(); -> 获取当前数据库的连接地址
    7: show cellections -> 获取当前数据库的所有集合(表)
    8: db.集合名称.save(json) -> 向集合(表)添加数据, 不存在的集合会自动创建
    9: db.集合名称.update(json1, json2) -> 修改数据
       json1 为查询条件 如 {"id": 25}
       json2 为修改成 如 {"name": "测试"}
       意思为 将 id 是 25 的所有数据的 name 字段修改为 "测试"
    10: db.集合名称.remove(json) -> 删除数据
        json 和 9 的 json1 相似, 为需要删除的条件
    11: db.结合名称.find(json) -> 查询数据
        json 和 9 的 json1 相似, 为需要查询的条件

四: 代码示例

let mongoClient = require("MonGoDB").MongoClient;
let url = "mongodb://localhost:27017/admin";

mongoClient.connect(url, function (err, db) {
    if (err) {
        console.log("数据库连接失败!");
    } else {
        insertOne(db);
    }
});

function insertOne(db) {
    db.collection("User").insertOne({
        "name": "测试",
        "sex": 1
    }, function (err, result) {
        console.log(result.result);
        console.log(result.ops)
        db.close();
    });
}

let MongoClient = require("MonGoDB").MongoClient;
let ObjectId = require("MonGoDB").ObjectID;
let url = "mongodb://localhost:27017/admin";

MongoClient.connect(url, function (err, db) {
    if (err) {
        console.log("数据库连接失败!");
    } else {
        deleteData(db);
    }
});

function deleteData(db) {
    db.collection("User").deleteOne({
        _id: new ObjectId("59ba30b2d5f3741b9831bea8")
    }, function (err, result) {
        console.log(result.result);
        db.close();
    });
}

let mongoClient = require("MonGoDB").MongoClient;
let url = "mongodb://localhost:27017/admin";

mongoClient.connect(url, function (err, db) {
    if (err) {
        console.log("数据库连接失败!");
    } else {
        uodateData(db);
    }
});

function uodateData(db) {
    var cursor = db.collection("User").updateMany({
        "name": "张三"
    }, {
        "$set": {
            "name": "陈辉",
            "sex": 1
        }
    }, function (err, result) {
        console.log(result.result);
    });
}

let mongoClient = require("MonGoDB").MongoClient;
let ObjectId = require("MonGoDB").ObjectID;
let url = "mongodb://localhost:27017/admin";

mongoClient.connect(url, function (err, db) {
    if (err) {
        console.log("数据库连接失败!");
    } else {
        selectAll(db);
    }
});

function selectAll(db) {
    // 精确查找
    // var cursor = db.collection("User").find({_id: new ObjectId("59ba30970692cd172083a836")});
    // 查询全部
    var cursor = db.collection("User").find();
    var result = [];
    cursor.each(function (err, doc) {
        if (doc == null) {
            console.log(result);
            db.close();
        } else {
            result.push(doc);
        }
    })
}