node.js 中使用 Mongodb

Posted 2021-02-20 zhaofeis

安装node的mongodb  https://www.npmjs.com/package/mongodb

const MongoClient = require(‘mongodb‘).MongoClient;
const assert = require(‘assert‘);

// Connection URL
const url = ‘mongodb://localhost:27017‘;

// Database Name
const dbName = ‘admin‘;

// Use connect method to connect to the server
MongoClient.connect(url, function(err, client) {
        // assert.equal(null, err);
        if (err) { console.log(err); return}
        console.log(‘数据库连接成功‘);

        const db = client.db(dbName);

        const collection = db.collection(‘admin‘);

        // 添加数据
        // collection.insertMany([
        //         {‘name‘: ‘qqq‘, ‘age‘: ‘10‘},
        //         {‘name‘: ‘www‘, ‘age‘: ‘20‘},
        //         {‘name‘: ‘eee‘, ‘age‘: ‘30‘},
        // ], function(err, result) {
        //         if (err) { console.log(err); return}
        //         // assert.equal(err, null);
        //         // assert.equal(3, result.result.n);
        //         // assert.equal(3, result.ops.length);
        //         client.close();
        //         console.log(‘添加成功‘);
        // });

        // 删除数据
        // collection.deleteOne({ ‘name‘ : ‘qqq‘ }, function(err, result) {
        //         if (err) { console.log(err); return}
        //         // assert.equal(err, null);
        //         // assert.equal(1, result.result.n);
        //         // client.close();
        //         console.log(‘删除成功‘);
        // });

        // 修改更新数据
        collection.updateOne(
            { ‘name‘ : ‘www‘ },
            { $set: { ‘name‘ : ‘111‘ } },
            (err, result) => {
                    if (err) { console.log(err); return}
                    // assert.equal(err, null);
                    // assert.equal(1, result.result.n);
                    console.log(‘更新成功‘);
                    client.close();
            });

        // 查看数据
        collection.find({}).toArray(function(err, docs) {
                if (err) { console.log(err); return}
                // assert.equal(err, null);
                console.log(docs);
                client.close();
        });


});