Nodejs MongoDB核心驱动模块mongodb-core的使用

Nodejs MongoDB核心驱动模块mongodb-core的使用
mongodb-core 是 Node.js 中一个底层的 MongoDB 驱动模块，它提供了对 MongoDB 的直接访问，但通常需要更多的手动配置和错误处理。更高级、更易于使用的模块是 mongodb，它是基于 mongodb-core 构建的。

然而，如果你确实需要使用 mongodb-core，下面是一些基本的使用示例：

安装

首先，你需要安装 mongodb-core 模块。你可以通过 npm 来安装：

npm install mongodb-core

基本连接

以下是如何使用 mongodb-core 连接到 MongoDB 数据库的基本示例：

const MongoClient = require('mongodb-core').MongoClient;

const uri = 'mongodb://localhost:27017/mydatabase';

const client = new MongoClient(uri, { useNewUrlParser: true });

client.connect(function(err) {
    if (err) throw err;
    console.log("Connected successfully to server");

    const db = client.db();
    // 你的数据库操作代码可以放在这里

    client.close();
});

执行查询

以下是如何使用 mongodb-core 执行基本的查询：

client.collection('users', function(err, collection) {
    if (err) throw err;

    collection.find({}).toArray(function(err, docs) {
        if (err) throw err;

        console.log(docs);
        client.close();
    });
});

插入文档

以下是如何插入一个新的文档到集合中：

client.collection('users', function(err, collection) {
    if (err) throw err;

    const doc = { name: "Alice", age: 25 };

    collection.insertOne(doc, function(err, result) {
        if (err) throw err;

        console.log("Document inserted");
        client.close();
    });
});

更新文档

以下是如何更新集合中的一个文档：

client.collection('users', function(err, collection) {
    if (err) throw err;

    const query = { name: "Alice" };
    const updateDoc = { $set: { age: 30 } };

    collection.updateOne(query, updateDoc, function(err, res) {
        if (err) throw err;

        console.log("Document updated");
        client.close();
    });
});

删除文档

以下是如何删除集合中的一个文档：

client.collection('users', function(err, collection) {
    if (err) throw err;

    const query = { name: "Alice" };

    collection.deleteOne(query, function(err, obj) {
        if (err) throw err;

        console.log("Document deleted");
        client.close();
    });
});

这些只是 mongodb-core 的一些基本用法。实际应用中，你可能还需要处理更复杂的场景，如事务、聚合管道等。对于大多数情况，推荐使用更高层次的 mongodb 包，因为它提供了更好的错误处理和更简洁的 API。