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

merge dbgate master and test drivers

Browse Source
This commit is contained in:
Rinie Kervel
2022-10-30 08:32:53 +01:00
parent 5c0c145fd6
commit a0cefbc1ca
2 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -108,7 +108,7 @@ const drivers = driverBases.map(driverBase => ({
};
}
try {
//console.log('sql', sql);
console.log('sql', sql);
const res = await client.execute(sql);
//console.log('res', res);
const columns = extractOracleColumns(res.metaData);
@@ -239,7 +239,7 @@ finally {
rowMode: 'array',
});
*/
//console.log('readQuery', sql, structure);
console.log('readQuery', sql, structure);
const query = await client.queryStream(sql);
let wasHeader = false;
@@ -250,29 +250,28 @@ finally {
highWaterMark: 100,
});
query.on('data', row => {
query.on('metadata', row => {
console.log('readQuery metadata', row);
if (!wasHeader) {
columns = extractOracleColumns(query._result);
columns = extractOracleColumns(row);
if (columns && columns.length > 0) {
pass.write({
__isStreamHeader: true,
...(structure || { columns }),
});
}
wasHeader = true;
}
pass.write(zipDataRow(row, columns));
});
query.on('end', () => {
if (!wasHeader) {
columns = extractOracleColumns(query._result);
pass.write({
__isStreamHeader: true,
...(structure || { columns }),
});
wasHeader = true;
}
query.on('data', row => {
console.log('readQuery data', row);
pass.write(zipDataRow(row, columns));
});
query.on('end', () => {
pass.end();
});