1
This commit is contained in:
parent
5036ac7373
commit
bbe7718539
@ -43,18 +43,23 @@ async function internalCreateConn(app, name) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async function reconnectDb(app, name, conn) {
|
async function reconnectDb(app, name, conn) {
|
||||||
if (!dbHash.hasOwnProperty(name)) {
|
|
||||||
throw new Error('reconnectDb dbpool error dbname:' + name);
|
|
||||||
}
|
|
||||||
conn.release();
|
|
||||||
const dbObj = dbHash[name];
|
|
||||||
try {
|
try {
|
||||||
const {err, conn} = await app.getDbConn(name);
|
if (!dbHash.hasOwnProperty(name)) {
|
||||||
if (err) {
|
throw new Error('reconnectDb dbpool error dbname:' + name);
|
||||||
throw new Error('reconnectDb getGBcEventConn error:' + err);
|
|
||||||
}
|
}
|
||||||
dbObj.conn = conn;
|
conn.release();
|
||||||
} finally {
|
const dbObj = dbHash[name];
|
||||||
|
try {
|
||||||
|
const {err, conn} = await app.getDbConn(name);
|
||||||
|
if (err) {
|
||||||
|
throw new Error('reconnectDb getGBcEventConn error:' + err);
|
||||||
|
}
|
||||||
|
dbObj.conn = conn;
|
||||||
|
} finally {
|
||||||
|
}
|
||||||
|
await app.sleep(1000 * 3);
|
||||||
|
} catch (err) {
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
2
third_party/j7
vendored
2
third_party/j7
vendored
@ -1 +1 @@
|
|||||||
Subproject commit ce0b30e27a45d3a3a7e95d407d4ac62cd5c9fe56
|
Subproject commit f81baf8c264c00395b4dd27f900df6ffedceac08
|
Loading…
x
Reference in New Issue
Block a user