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

import/export log messages

Browse Source
This commit is contained in:
SPRINX0\prochazka
2025-03-04 14:29:52 +01:00
parent 257ffa3cc4
commit 3bf22a8606
9 changed files with 3 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/api/src/shell/dataDuplicator.js
View File

@@ -24,8 +24,6 @@ async function dataDuplicator({
const dbhan = systemConnection || (await connectUtility(driver, connection, 'write')); const dbhan = systemConnection || (await connectUtility(driver, connection, 'write'));
try { try {
logger.info(`Connected.`);
if (!analysedStructure) { if (!analysedStructure) {
analysedStructure = await driver.analyseFull(dbhan); analysedStructure = await driver.analyseFull(dbhan);
} }

2
packages/api/src/shell/dropAllDbObjects.js
View File

@@ -19,8 +19,6 @@ async function dropAllDbObjects({ connection, systemConnection, driver, analysed
const dbhan = systemConnection || (await connectUtility(driver, connection, 'write')); const dbhan = systemConnection || (await connectUtility(driver, connection, 'write'));
logger.info(`Connected.`);
if (!analysedStructure) { if (!analysedStructure) {
analysedStructure = await driver.analyseFull(dbhan); analysedStructure = await driver.analyseFull(dbhan);
} }

2
packages/api/src/shell/dumpDatabase.js
View File

@@ -31,8 +31,6 @@ async function dumpDatabase({
const dbhan = systemConnection || (await connectUtility(driver, connection, 'read', { forceRowsAsObjects: true })); const dbhan = systemConnection || (await connectUtility(driver, connection, 'read', { forceRowsAsObjects: true }));
try { try {
logger.info(`Connected.`);
const dumper = await driver.createBackupDumper(dbhan, { const dumper = await driver.createBackupDumper(dbhan, {
outputFile, outputFile,
databaseName, databaseName,

2
packages/api/src/shell/executeQuery.js
View File

@@ -36,7 +36,7 @@ async function executeQuery({
} }
try { try {
logger.info(`Connected.`); logger.debug(`Running SQL query, length: ${sql.length}`);
await driver.script(dbhan, sql, { logScriptItems }); await driver.script(dbhan, sql, { logScriptItems });
} finally { } finally {

2
packages/api/src/shell/importDatabase.js
View File

@@ -50,8 +50,6 @@ async function importDatabase({ connection = undefined, systemConnection = undef
if (!driver) driver = requireEngineDriver(connection); if (!driver) driver = requireEngineDriver(connection);
const dbhan = systemConnection || (await connectUtility(driver, connection, 'write')); const dbhan = systemConnection || (await connectUtility(driver, connection, 'write'));
try { try {
logger.info(`Connected.`);
logger.info(`Input file: ${inputFile}`); logger.info(`Input file: ${inputFile}`);
const downloadedFile = await download(inputFile); const downloadedFile = await download(inputFile);
logger.info(`Downloaded file: ${downloadedFile}`); logger.info(`Downloaded file: ${downloadedFile}`);

6
packages/api/src/shell/loadDatabase.js
View File

@@ -6,15 +6,13 @@ const exportDbModel = require('../utility/exportDbModel');
const logger = getLogger('analyseDb'); const logger = getLogger('analyseDb');
async function loadDatabase({ connection = undefined, systemConnection = undefined, driver = undefined, outputDir }) { async function loadDatabase({ connection = undefined, systemConnection = undefined, driver = undefined, outputDir }) {
logger.info(`Analysing database`); logger.debug(`Analysing database`);
if (!driver) driver = requireEngineDriver(connection); if (!driver) driver = requireEngineDriver(connection);
const dbhan = systemConnection || (await connectUtility(driver, connection, 'read', { forceRowsAsObjects: true })); const dbhan = systemConnection || (await connectUtility(driver, connection, 'read', { forceRowsAsObjects: true }));
try { try {
logger.info(`Connected.`);
const dbInfo = await driver.analyseFull(dbhan); const dbInfo = await driver.analyseFull(dbhan);
logger.info(`Analyse finished`); logger.debug(`Analyse finished`);
await exportDbModel(dbInfo, outputDir); await exportDbModel(dbInfo, outputDir);
} finally { } finally {

1
packages/api/src/shell/queryReader.js
View File

@@ -30,7 +30,6 @@ async function queryReader({
const driver = requireEngineDriver(connection); const driver = requireEngineDriver(connection);
const pool = await connectUtility(driver, connection, queryType == 'json' ? 'read' : 'script'); const pool = await connectUtility(driver, connection, queryType == 'json' ? 'read' : 'script');
logger.info(`Connected.`);
const reader = const reader =
queryType == 'json' ? await driver.readJsonQuery(pool, query) : await driver.readQuery(pool, query || sql); queryType == 'json' ? await driver.readJsonQuery(pool, query) : await driver.readQuery(pool, query || sql);
return reader; return reader;

1
packages/api/src/shell/tableReader.js
View File

@@ -18,7 +18,6 @@ async function tableReader({ connection, systemConnection, pureName, schemaName,
driver = requireEngineDriver(connection); driver = requireEngineDriver(connection);
} }
const dbhan = systemConnection || (await connectUtility(driver, connection, 'read')); const dbhan = systemConnection || (await connectUtility(driver, connection, 'read'));
logger.info(`Connected.`);
const fullName = { pureName, schemaName }; const fullName = { pureName, schemaName };

1
packages/api/src/shell/tableWriter.js
View File

@@ -26,7 +26,6 @@ async function tableWriter({ connection, schemaName, pureName, driver, systemCon
} }
const dbhan = systemConnection || (await connectUtility(driver, connection, 'write')); const dbhan = systemConnection || (await connectUtility(driver, connection, 'write'));
logger.info(`Connected.`);
return await driver.writeTable(dbhan, { schemaName, pureName }, options); return await driver.writeTable(dbhan, { schemaName, pureName }, options);
} }