带有Koa JS的MongoDB:client.connect不是函数

问题描述 投票:0回答:1

我正在尝试使用Koa开发我的第一个简单应用程序,该应用程序仅接收一些数据并将其放入Mongo数据库中。但是,我发现连到数据库也很困难,因为得到的响应是{"error": "this.db_client.connect is not a function"}。这是应用程序代码:

import Koa from "koa";
import bodyParser from "koa-bodyparser";

import {DBHandler} from "./db"
import {error} from "./middlewares/error";

const app = new Koa();

app.use(bodyParser());
app.use(error);

app.use(async ctx => {
    const db = new DBHandler();

    db.writeEntity(ctx.request.body);
});

app.listen(3000);

DBHandler:

export class DBHandler {
    constructor() {
        this.db_url = "mongodb://localhost:27017";
        this.db_client = new MongoClient(this.db_url, {useNewUrlParser: true, useUnifiedTopology: true});
    }

    writeEntity = (entity) => {

        console.log(this.db_client);
        this.db_client.connect((err, client) => {
            if (err) throw new Error("Connection Error");

            const db = client.db("database");
            const collection = db.collection("users");

            collection.insertOne(entity, (err, res) => {
                if (err) throw new Error("Insertion Error");

                console.log(res.ops);
                client.close;
            });
        });
    };
}

顺便说一下,console.log(this.db_client)打印Promise { <pending> },这意味着我的MongoClient对象是一个承诺!

任何想法,正在发生什么以及如何使之起作用?

javascript node.js mongodb koa koa2
1个回答
0
投票

由于您已通过注释确认要像这样导入MogoClient

import MongoClient from "mongodb";

我可以确定问题出在哪里,MongoClient不是mongodb模块的直接导出,而是一个子导出。您应该这样导入它:

import mongodb from "mongodb";
const MongoClient = mongodb.MongoClient;

// Or using require
const MongoClient = require("mongodb").MongoClient;

这应该可以解决问题。您可以阅读有关通过MongoClienthere连接到MongoDB的更多信息。

© www.soinside.com 2019 - 2024. All rights reserved.