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

mysql, mssql connect

Browse Source
This commit is contained in:
Jan Prochazka
2020-01-01 19:34:34 +01:00
parent 8d949f52c4
commit 4da867e725
8 changed files with 110 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
api/src/connectProcess.js
View File

@@ -1,12 +1,8 @@
const mssql = require('mssql');
process.on('message', async connection => {
const { server, port, user, password } = connection;
try {
const pool = await mssql.connect({ server, port, user, password });
const resp = await pool.request().query('SELECT @@VERSION AS version');
const { version } = resp.recordset[0];
process.send({ version });
const connectFunc = require(`./engines/${connection.engine}/connect`);
const res = await connectFunc(connection);
process.send(res);
} catch (e) {
process.send({ error: e.message });
}

8
api/src/engines/mssql/connect.js Normal file
View File

@@ -0,0 +1,8 @@
const mssql = require('mssql');
module.exports = async function connect({ server, port, user, password }) {
const pool = await mssql.connect({ server, port, user, password });
const resp = await pool.request().query('SELECT @@VERSION AS version');
const { version } = resp.recordset[0];
return { version };
};

12
api/src/engines/mysql/connect.js Normal file
View File

@@ -0,0 +1,12 @@
const mysql = require('mysql');
module.exports = function connect({ server, port, user, password }) {
return new Promise((resolve, reject) => {
const connection = mysql.createConnection({ host: server, port, user, password });
connection.query("show variables like 'version'", function(error, results, fields) {
if (error) reject(error);
const version = results[0].Value;
resolve({ version });
});
});
};