From ee5ec21aa3122109c4015011d7d5fee3dfd80ebf Mon Sep 17 00:00:00 2001 From: LingandRX Date: Sun, 29 Dec 2024 00:32:58 +0800 Subject: [PATCH] =?UTF-8?q?feat(db):=20=E4=BC=98=E5=8C=96=20MongoDB=20?= =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E9=80=BB=E8=BE=91=EF=BC=8C=E7=A7=BB=E9=99=A4?= =?UTF-8?q?=E4=B8=8D=E5=BF=85=E8=A6=81=E7=9A=84=E4=BB=A3=E7=A0=81=E5=B9=B6?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=BF=9E=E6=8E=A5=E9=80=89=E9=A1=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- db/mongodbConfig.js | 44 ++++++++++++++++++-------------------------- 1 file changed, 18 insertions(+), 26 deletions(-) diff --git a/db/mongodbConfig.js b/db/mongodbConfig.js index 5b8c842..0bafb37 100644 --- a/db/mongodbConfig.js +++ b/db/mongodbConfig.js @@ -6,7 +6,6 @@ const account = process.env.MONGO_ACCOUNT const password = process.env.MONGO_PASSWORD const host = process.env.MONGO_HOST || '122.152.201.90' const port = process.env.MONGO_PORT || '27017' -// const dbName = process.env.MONGO_DB_NAME || 'customer' let isConnected = false @@ -22,36 +21,29 @@ exports.connectMongoDB = async function () { } try { - try { - const mongoDBUrl = `mongodb://${account}:${password}@${host}:${port}` + const mongoDBUrl = `mongodb://${account}:${password}@${host}:${port}` - // 连接 MongoDB,不再需要 useNewUrlParser 和 useUnifiedTopology - await mongoose.connect(mongoDBUrl) + mongoose.connect(mongoDBUrl, { + useNewUrlParser: true, + useUnifiedTopology: true + }) - const db = mongoose.connection + mongoose.connection.on('open', () => { + console.log('MongoDB 连接成功') + isConnected = true + }) - db.once('open', () => { - console.log('MongoDB 连接成功') - isConnected = true - }) + mongoose.connection.on('error', (err) => { + console.error('MongoDB 连接错误:', err.message) + isConnected = false + }) - db.on('error', (err) => { - console.error('MongoDB 连接错误:', err.message) - isConnected = false - }) - - db.on('close', () => { - console.log('MongoDB 连接关闭') - isConnected = false - }) - - console.log('MongoDB 连接初始化成功') - } catch (err) { - console.error('MongoDB 连接初始化失败:', err.message) - throw err - } + mongoose.connection.on('close', () => { + console.log('MongoDB 连接关闭') + isConnected = false + }) } catch (err) { console.error('MongoDB 连接初始化失败:', err.message) - throw err // 重新抛出错误,以便其他地方可以处理 + throw err } }