dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-25 16:35:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

database connection fix

Browse Source
This commit is contained in:
Jan Prochazka
2020-01-19 21:10:30 +01:00
parent 69322a4e41
commit 23492a3bef
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
api/src/controllers/databaseConnections.js
View File

@@ -35,7 +35,7 @@ module.exports = {
subprocess.on('message', ({ msgtype, ...message }) => { subprocess.on('message', ({ msgtype, ...message }) => {
this[`handle_${msgtype}`](id, database, message); this[`handle_${msgtype}`](id, database, message);
}); });
subprocess.send({ msgtype: 'connect', ...connection }); subprocess.send({ msgtype: 'connect', ...connection, database });
return newOpened; return newOpened;
}, },

9
api/src/proc/databaseConnectionProcess.js
View File

@@ -6,15 +6,14 @@ let storedConnection;
async function handleFullRefresh() { async function handleFullRefresh() {
const driver = engines(storedConnection); const driver = engines(storedConnection);
const structure = await driver.analyseFull(systemConnection); const structure = await driver.analyseFull(systemConnection);
console.log('SENDING STRUCTURE', structure);
process.send({ msgtype: 'structure', structure }); process.send({ msgtype: 'structure', structure });
} }
async function handleConnect(connection, database) { async function handleConnect(connection) {
storedConnection = connection; storedConnection = connection;
const driver = engines(storedConnection); const driver = engines(storedConnection);
systemConnection = await driver.connect({ ...storedConnection, database }); systemConnection = await driver.connect(storedConnection);
handleFullRefresh(); handleFullRefresh();
setInterval(handleFullRefresh, 30 * 1000); setInterval(handleFullRefresh, 30 * 1000);
} }
@@ -23,9 +22,9 @@ const messageHandlers = {
connect: handleConnect, connect: handleConnect,
}; };
async function handleMessage({ msgtype, database, ...other }) { async function handleMessage({ msgtype, ...other }) {
const handler = messageHandlers[msgtype]; const handler = messageHandlers[msgtype];
await handler(other, database); await handler(other);
} }
process.on('message', async message => { process.on('message', async message => {