feat: add forceSortResults for cassandra

This commit is contained in:
Nybkox
2025-02-04 21:27:15 +01:00
parent 979f2c7dac
commit bb38b93927
3 changed files with 16 additions and 2 deletions

View File

@@ -121,7 +121,12 @@ 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 primary key, ~country varchar(100))');
await runCommandOnDriver(
conn,
driver,
`create table ~t1 (~id int primary key, ~country ${engine.useTextTypeForStrings ? 'text' : 'varchar(100)'})`
);
const data = [
[1, 'Czechia'],
[2, 'Austria'],
@@ -143,7 +148,13 @@ describe('DB Import/export', () => {
const writer = createExportStream();
await copyStream(reader, writer);
expect(writer.resultArray.filter(x => !x.__isStreamHeader).map(row => [row.id, row.country])).toEqual(data);
const result = writer.resultArray.filter(x => !x.__isStreamHeader).map(row => [row.id, row.country]);
if (engine.forceSortResults) {
result.sort((a, b) => a[0] - b[0]);
}
expect(result).toEqual(data);
})
);
});

View File

@@ -628,6 +628,8 @@ const cassandraEngine = {
skipDataDuplicator: true,
skipDeploy: true,
forceSortResults: true,
useTextTypeForStrings: true,
objects: [],
};

View File

@@ -40,6 +40,7 @@ export type TestEngineInfo = {
skipPkDrop?: boolean;
skipOrderBy?: boolean;
forceSortResults?: boolean;
alterTableAddColumnSyntax?: boolean;
dbSnapshotBySeconds?: boolean;
setNullDefaultInsteadOfDrop?: boolean;