mirror of
https://github.com/DeNNiiInc/dbgate.git
synced 2026-05-01 12:03:58 +00:00
refactor
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
class DatabaseAnalyser {
|
||||
/**
|
||||
*
|
||||
* @param {import('dbgate').EngineDriver} driver
|
||||
* @param {import('@dbgate/types').EngineDriver} driver
|
||||
*/
|
||||
constructor(pool, driver) {
|
||||
this.pool = pool;
|
||||
@@ -11,7 +11,7 @@ class DatabaseAnalyser {
|
||||
async runAnalysis() {}
|
||||
}
|
||||
|
||||
/** @returns {import('dbgate').DatabaseInfo} */
|
||||
/** @returns {import('@dbgate/types').DatabaseInfo} */
|
||||
DatabaseAnalyser.createEmptyStructure = () => ({
|
||||
tables: [],
|
||||
});
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
class SqlDumper {
|
||||
/** @param driver {import('dbgate').EngineDriver} */
|
||||
/** @param driver {import('@dbgate/types').EngineDriver} */
|
||||
constructor(driver) {
|
||||
this.s = '';
|
||||
this.driver = driver;
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
|
||||
/** @return {import('dbgate').EngineDriver} */
|
||||
/** @return {import('@dbgate/types').EngineDriver} */
|
||||
function getDriver(connection) {
|
||||
const { engine } = connection;
|
||||
return require(`./${engine}`);
|
||||
|
||||
@@ -2,7 +2,7 @@ const _ = require("lodash");
|
||||
const MsSqlAnalyser = require("./MsSqlAnalyser");
|
||||
const MsSqlDumper = require("./MsSqlDumper");
|
||||
|
||||
/** @type {import('dbgate').SqlDialect} */
|
||||
/** @type {import('@dbgate/types').SqlDialect} */
|
||||
const dialect = {
|
||||
limitSelect: true,
|
||||
quoteIdentifier(s) {
|
||||
@@ -10,7 +10,7 @@ const dialect = {
|
||||
}
|
||||
};
|
||||
|
||||
/** @type {import('dbgate').EngineDriver} */
|
||||
/** @type {import('@dbgate/types').EngineDriver} */
|
||||
const driver = {
|
||||
async connect({ mssql }, { server, port, user, password, database }) {
|
||||
const pool = await mssql.connect({
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
const MySqlAnalyser = require("./MySqlAnalyser");
|
||||
const MySqlDumper = require("./MySqlDumper");
|
||||
|
||||
/** @type {import('dbgate').SqlDialect} */
|
||||
/** @type {import('@dbgate/types').SqlDialect} */
|
||||
const dialect = {
|
||||
rangeSelect: true,
|
||||
quoteIdentifier(s) {
|
||||
@@ -9,7 +9,7 @@ const dialect = {
|
||||
}
|
||||
};
|
||||
|
||||
/** @type {import('dbgate').EngineDriver} */
|
||||
/** @type {import('@dbgate/types').EngineDriver} */
|
||||
const driver = {
|
||||
async connect({ mysql }, { server, port, user, password, database }) {
|
||||
const connection = mysql.createConnection({
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
const PostgreAnalyser = require('./PostgreAnalyser');
|
||||
const PostgreDumper = require('./PostgreDumper');
|
||||
|
||||
/** @type {import('dbgate').SqlDialect} */
|
||||
/** @type {import('@dbgate/types').SqlDialect} */
|
||||
const dialect = {
|
||||
rangeSelect: true,
|
||||
quoteIdentifier(s) {
|
||||
@@ -9,7 +9,7 @@ const dialect = {
|
||||
},
|
||||
};
|
||||
|
||||
/** @type {import('dbgate').EngineDriver} */
|
||||
/** @type {import('@dbgate/types').EngineDriver} */
|
||||
const driver = {
|
||||
async connect({pg}, { server, port, user, password, database }) {
|
||||
const client = new pg.Client({ host: server, port, user, password, database: database || 'postgres' });
|
||||
|
||||
Reference in New Issue
Block a user