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

fixed oracle export + clickhouse test

Browse Source
This commit is contained in:
Jan Prochazka
2024-12-20 12:23:29 +01:00
parent 62c028fc3c
commit b07ee91cf9
3 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
integration-tests/__tests__/db-import-export.spec.js
View File

@@ -26,9 +26,9 @@ function createImportStream() {
function createExportStream() {
const writable = new stream.Writable({ objectMode: true });
writable.result = [];
writable.resultArray = [];
writable._write = (chunk, encoding, callback) => {
writable.result.push(chunk);
writable.resultArray.push(chunk);
callback();
};
return writable;
@@ -116,7 +116,7 @@ describe('DB Import/export', () => {
testWrapper(async (conn, driver, engine) => {
// const reader = await fakeObjectReader({ delay: 10 });
// const reader = await fakeObjectReader();
await runCommandOnDriver(conn, driver, 'create table ~t1 (~id int, ~country varchar(100))');
await runCommandOnDriver(conn, driver, 'create table ~t1 (~id int primary key, ~country varchar(100))');
const data = [
[1, 'Czechia'],
[2, 'Austria'],
@@ -138,7 +138,7 @@ describe('DB Import/export', () => {
const writer = createExportStream();
await copyStream(reader, writer);
expect(writer.result.filter(x => !x.__isStreamHeader).map(row => [row.id, row.country])).toEqual(data);
expect(writer.resultArray.filter(x => !x.__isStreamHeader).map(row => [row.id, row.country])).toEqual(data);
})
);
});

4
integration-tests/engines.js
View File

@@ -580,11 +580,11 @@ const enginesOnLocal = [
// mysqlEngine,
// mariaDbEngine,
// postgreSqlEngine,
sqlServerEngine,
// sqlServerEngine,
// sqliteEngine,
// cockroachDbEngine,
// clickhouseEngine,
// oracleEngine,
oracleEngine,
];
module.exports = process.env.CITEST ? enginesOnCi : enginesOnLocal;

3
plugins/dbgate-plugin-oracle/src/backend/driver.js
View File

@@ -306,12 +306,9 @@ const driver = {
}
wasHeader = true;
}
pass.write(zipDataRow(row, columns));
});
query.on('data', row => {
// console.log('readQuery data', row);
pass.write(zipDataRow(row, columns));
});