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

commented out some console.log in oracle driver

Browse Source
This commit is contained in:
Jan Prochazka
2023-01-01 19:48:36 +01:00
parent fd2e1e0cae
commit 0c795e33c3
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
plugins/dbgate-plugin-oracle/src/backend/drivers.js
View File

@@ -85,7 +85,7 @@ const drivers = driverBases.map(driverBase => ({
}; };
} }
console.log('OPTIONS', options); // console.log('OPTIONS', options);
/* /*
const client = new pg.Client(options); const client = new pg.Client(options);
await client.connect(); await client.connect();
@@ -135,14 +135,14 @@ finally {
rowMode: 'array', rowMode: 'array',
}); });
*/ */
console.log('queryStream', sql); // console.log('queryStream', sql);
const query = client.queryStream(sql); const query = client.queryStream(sql);
// const consumeStream = new Promise((resolve, reject) => { // const consumeStream = new Promise((resolve, reject) => {
let rowcount = 0; let rowcount = 0;
let wasHeader = false; let wasHeader = false;
query.on('metadata', row => { query.on('metadata', row => {
console.log('metadata', row); // console.log('metadata', row);
if (!wasHeader) { if (!wasHeader) {
columns = extractOracleColumns(row); columns = extractOracleColumns(row);
if (columns && columns.length > 0) { if (columns && columns.length > 0) {
@@ -155,7 +155,7 @@ finally {
}); });
query.on('data', row => { query.on('data', row => {
console.log('stream DATA'); // console.log('stream DATA');
if (!wasHeader) { if (!wasHeader) {
columns = extractOracleColumns(row); columns = extractOracleColumns(row);
if (columns && columns.length > 0) { if (columns && columns.length > 0) {
@@ -251,7 +251,7 @@ finally {
rowMode: 'array', rowMode: 'array',
}); });
*/ */
console.log('readQuery', sql, structure); // console.log('readQuery', sql, structure);
const query = await client.queryStream(sql); const query = await client.queryStream(sql);
let wasHeader = false; let wasHeader = false;
@@ -263,7 +263,7 @@ finally {
}); });
query.on('metadata', row => { query.on('metadata', row => {
console.log('readQuery metadata', row); // console.log('readQuery metadata', row);
if (!wasHeader) { if (!wasHeader) {
columns = extractOracleColumns(row); columns = extractOracleColumns(row);
if (columns && columns.length > 0) { if (columns && columns.length > 0) {
@@ -279,7 +279,7 @@ finally {
}); });
query.on('data', row => { query.on('data', row => {
console.log('readQuery data', row); // console.log('readQuery data', row);
pass.write(zipDataRow(row, columns)); pass.write(zipDataRow(row, columns));
}); });