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

feat: skip order by for cassandra

Browse Source
This commit is contained in:
Nybkox
2025-02-04 00:29:58 +01:00
parent c0ca84f347
commit de4cea86da
2 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
integration-tests/__tests__/query.spec.js
View File

@@ -73,7 +73,9 @@ describe('Query', () => {
await runCommandOnDriver(conn, driver, dmp => dmp.put(sql)); await runCommandOnDriver(conn, driver, dmp => dmp.put(sql));
} }
const res = await runQueryOnDriver(conn, driver, dmp => dmp.put('SELECT ~id FROM ~t1 ORDER BY ~id')); const res = await runQueryOnDriver(conn, driver, dmp =>
dmp.put(`SELECT ~id FROM ~t1 ${engine.skipOrderBy ? '' : 'ORDER BY ~id'}`)
);
expect(res.columns).toEqual([ expect(res.columns).toEqual([
expect.objectContaining({ expect.objectContaining({
columnName: 'id', columnName: 'id',
@@ -98,7 +100,11 @@ describe('Query', () => {
await runCommandOnDriver(conn, driver, dmp => dmp.put(sql)); await runCommandOnDriver(conn, driver, dmp => dmp.put(sql));
} }
const results = await executeStream(driver, conn, 'SELECT ~id FROM ~t1 ORDER BY ~id'); const results = await executeStream(
driver,
conn,
`SELECT ~id FROM ~t1 ${engine.skipOrderBy ? '' : 'ORDER BY ~id'}`
);
expect(results.length).toEqual(1); expect(results.length).toEqual(1);
const res = results[0]; const res = results[0];
@@ -107,7 +113,7 @@ describe('Query', () => {
}) })
); );
test.each(engines.map(engine => [engine.label, engine]))( test.each(engines.filter(i => !i.skipOrderBy).map(engine => [engine.label, engine]))(
'More queries - %s', 'More queries - %s',
testWrapper(async (conn, driver, engine) => { testWrapper(async (conn, driver, engine) => {
for (const sql of initSql) { for (const sql of initSql) {
@@ -137,7 +143,9 @@ describe('Query', () => {
const results = await executeStream( const results = await executeStream(
driver, driver,
conn, conn,
'CREATE TABLE ~t1 (~id int primary key); INSERT INTO ~t1 (~id) VALUES (1); INSERT INTO ~t1 (~id) VALUES (2); SELECT ~id FROM ~t1 ORDER BY ~id; ' `CREATE TABLE ~t1 (~id int primary key); INSERT INTO ~t1 (~id) VALUES (1); INSERT INTO ~t1 (~id) VALUES (2); SELECT ~id FROM ~t1 ${
engine.skipOrderBy ? '' : 'ORDER BY ~id'
}; `
); );
expect(results.length).toEqual(1); expect(results.length).toEqual(1);

1
integration-tests/engines.js
View File

@@ -622,6 +622,7 @@ const cassandraEngine = {
skipNullability: true, skipNullability: true,
skipUnique: true, skipUnique: true,
skipIndexes: true, skipIndexes: true,
skipOrderBy: true,
// objects: [], // objects: [],
}; };