node-mongoose

const Mongo = require('node-mongoose');
Mongo.config({
    //连接mongodb的用户用户名(for connecting mongodb's user)
    user: 'username',
    //连接mongodb的用户密码(for connecting mongodb's password)
    password: 'password',
    //...主机名(hostname)
    hostname: '127.0.0.1',
    //端口号(port)
    port: '27017',
    //数据库名称(database's name)
    db: 'test'
});

const mongo = new Mongo({
    table1: {
        tableField1: {
            type: String,
            value: 'defaultValue'
        }
    },
    table2: {
        tableField1: {
            type: Number,
            required: true
        },
        tableField2: {
            type: Date
        }
    },
    /*
        ...
    */
});

async function a(){
    await mongo.insert('table', { key1: 'value1' }, false);
}
//or
function a(){
    mongo.insert('table', { key1: 'value1' }, false, (err, doc) => {
        //TODO sth with err and doc
        //err means the error message 
    })
}
//您可以不填写第三个参数,当您不填写时默认值就是true
//you can not fill in the third parameter, the default value is true when you dont fill in
mongo.insert('table', { field1: 'value1' }, true, (err, doc) => {
    //TODO sth with err and doc
    //err means the error message 
}); 
//=== (equals to)
mongo.insert('table', { field1: 'value1' }, (err, doc) => {
    //TODO sth with err and doc
    //err means the error message 
});
//传入回调函数的doc参数与使用await的返回值是相同的
//callback's parameter doc is equals to the await function's return's value

//(this means its a repeat data)
return { status: 2, message: '数据重复'};
//(this means insert successfully)
return { status: 1, message: '添加成功'};
//(message means insert failed, this reason is the error message)
return { status: 0, message: '添加失败', reason: error}

async function a(){
    await mongo.findInTable( 'table', { field1: 'value1' } );
}
//or
function a(){
    mongo.findInTable('table', { field1: 'value1'}, (err, doc) => {
        //TODO sth with err and doc
        //err means the error message
    })
}
//传入回调函数的doc参数与使用await的返回值是相同的
//callback's parameter doc is equals to the await function's return's value

//(length是结果的长度,data是个以数组类型的结果集,查询的每个结果都是一个对象)
//(message means find data successful, result is this data.The result is an Array, every data in result is an object in this Array)
return {status: 1, body: doc, reason: undefined};
//(查询错误,reason是错误信息)
//(find failed, the reason is the error message)
return {status: 0, body: undefined, reason: err};

async function a(){
    await mongo.deleteMany('table', {field1: 'value1'});
}
//or
function a(){
    mongo.deleteMany('table', {field1: 'value1'}, (err, doc) => {
        //TODO sth with err and doc
        //err means the error message 
    });
}
//传入回调函数的doc参数与使用await的返回值是相同的
//callback's parameter doc is equals to the await function's return's value
//他们都将会删除table表中key1字段值为value1的所有数据
//these will delete all data that meets the criteria

//this means delete successfully
return { status: 1, message: '批量删除成功' };
//this means delete failed, the reason is error message
return { status: 0, reason: error, message: '批量删除失败'}

async function a(){
    //这将会删除table表中key1字段值为value1的第一个查询到的数据
    //第三个参数为可选配置项
    //this will delete the first data that meets the criteria
    //the third parameter is options you can add to the method
    await mongo.deleteOne('table', {field1: 'value1'}, {sort: {field2: 1}});
}
//or
function a(){
    //这将会删除table表中key1字段值为value1的第一个查询到的数据
    //第三个参数为可选配置项
    //this will delete the first data that meets the criteria
    //the third parameter is options you can add to the method
    mongo.deleteOne('teble', {field1: 'value1'}, {sort: {field2: 1}}, (err, doc) => {
        //TODO sth with err and doc
        //err means the error message
    })
}
//传入回调函数的doc参数与使用await的返回值是相同的
//callback's parameter doc is equals to the await function's return's value

//(this means delete successfully)
return {status: 1, reason: undefined, message: '删除单条数据成功'};
//(this means delete failed, the reason is error message)
return {status: 0, reason: err, message: '删除单条数据失败'};

async function a(){
    //这将会更新查询到的第一条数据
    //第四个参数是可选配置项
    //this will update the first piece of data to the query
    //the last parameter is options you can add to the method
    await mongo.updateOne('table', {field: 'oldValue'}, {field1: 'newValue'}, {sort: {field2: 1}});
}
//or
function a(){
    //这将会更新查询到的第一条数据
    //第四个参数是可选配置项
    //this will update the first piece of data to the query
    //the last parameter is options you can add to the method
    mongo.updateOne('table', {field: 'oldValue'}, {field1: 'newValue'}, {sort: {field2: 1}}, (err, doc) => {
        //TODO sth with err and doc
        //err means error message
    })
}
//传入回调函数的doc参数与使用await的返回值是相同的
//callback's parameter doc is equals to the await function's return's value

//(更新成功,result为更新后的该字段的对象)
//(update successfully, result is the one data which has updated)
return { status: 1, body: doc};
//(更新失败,reason是失败原因)
//(update failed, reason is error message)
return { status: 0, body: undefined, reason: error};

(async function a(){
    const doc = await mongo.updateMany('table', {matchKey: 'matchValue'}, {updateKey: 'updateValue'});
    //TODO with doc
    // doc.n Number  of documents matched
    // doc.nModified  Number of documents modified
})();
 
(function (){
    mongo.updateMany('table', {matchKey: 'matchValue'}, {updateKey: 'updateValue'}, (err, doc) => {
        //TODO with doc
        // doc.n      Number  of documents matched
        // doc.nModified  Number of documents modified
    });
})();
//您也可以在第四个参数处传入一个可选配置的对象
//You can also pass in an optionally configured object at the fourth argument
 

//更新成功 body为updateMany()返回对象,有以下属性
// doc.n      匹配的文档数
// doc.nModified  修改的文档数
// update successful 
// body.n      Number  of documents matched
// body.nModified  Number of documents modified
return {status: 1, body: doc};
//更新失败 reason是失败原因
//update failed , reason is the error message
return {status: 0, body: undefined, reason: err}

const client = mongo.getClient('table');
//您可以自己构建诸如查询等逻辑语句
//You can build your own logical statements such as queries, eg.
//like this => 
client.find({name: 'leng'}).where('age').gt(20).limit(5).exec((err, doc) => {
    //TODO sth with err and doc
})

mongo.close();
//想再次连接数据库可以再次调用实例化方法,并且传入schema对象
// 如果想切换连接的数据库,则需要调用静态方法config()重新配置再调用实例化方法传入schema对象
// To connect to the database again, you can call the instantiation method again and pass in the schema object
// If you want to switch the connected database, you need to call static method Config () Reconfigure and then call the instantiation method to pass in the schema object