first oracle test works

This commit is contained in:
Jan Prochazka
2024-12-10 16:03:26 +01:00
parent 00525f6b81
commit bf85a922ca
4 changed files with 18 additions and 12 deletions

View File

@@ -1,7 +1,8 @@
const { runCommandOnDriver } = require('dbgate-tools');
const engines = require('../engines'); const engines = require('../engines');
const { testWrapper } = require('../tools'); const { testWrapper } = require('../tools');
const t1Sql = 'CREATE TABLE t1 (id int not null primary key, val1 varchar(50))'; const t1Sql = 'CREATE TABLE ~t1 (~id int not null primary key, ~val1 varchar(50))';
const ix1Sql = 'CREATE index ix1 ON t1(val1, id)'; const ix1Sql = 'CREATE index ix1 ON t1(val1, id)';
const t2Sql = engine => const t2Sql = engine =>
`CREATE TABLE t2 (id int not null primary key, val2 varchar(50) ${engine.skipUnique ? '' : 'unique'})`; `CREATE TABLE t2 (id int not null primary key, val2 varchar(50) ${engine.skipUnique ? '' : 'unique'})`;
@@ -15,7 +16,7 @@ const txMatch = (engine, tname, vcolname, nextcol, defaultValue) =>
columns: [ columns: [
expect.objectContaining({ expect.objectContaining({
columnName: 'id', columnName: 'id',
dataType: expect.stringMatching(/int.*/i), dataType: expect.stringMatching(/int.*|number/i),
...(engine.skipNullability ? {} : { notNull: true }), ...(engine.skipNullability ? {} : { notNull: true }),
}), }),
expect.objectContaining({ expect.objectContaining({
@@ -59,9 +60,10 @@ describe('Table analyse', () => {
test.each(engines.map(engine => [engine.label, engine]))( test.each(engines.map(engine => [engine.label, engine]))(
'Table structure - full analysis - %s', 'Table structure - full analysis - %s',
testWrapper(async (conn, driver, engine) => { testWrapper(async (conn, driver, engine) => {
await driver.query(conn, t1Sql); await runCommandOnDriver(conn, driver, dmp => dmp.put(t1Sql));
const structure = await driver.analyseFull(conn); const structure = await driver.analyseFull(conn);
console.log(JSON.stringify(structure, null, 2));
expect(structure.tables.length).toEqual(1); expect(structure.tables.length).toEqual(1);
expect(structure.tables[0]).toEqual(t1Match(engine)); expect(structure.tables[0]).toEqual(t1Match(engine));
@@ -77,7 +79,7 @@ describe('Table analyse', () => {
expect(structure1.tables.length).toEqual(1); expect(structure1.tables.length).toEqual(1);
expect(structure1.tables[0]).toEqual(t2Match(engine)); expect(structure1.tables[0]).toEqual(t2Match(engine));
await driver.query(conn, t1Sql); await runCommandOnDriver(conn, driver, dmp => dmp.put(t1Sql));
const structure2 = await driver.analyseIncremental(conn, structure1); const structure2 = await driver.analyseIncremental(conn, structure1);
expect(structure2.tables.length).toEqual(2); expect(structure2.tables.length).toEqual(2);
@@ -89,7 +91,7 @@ describe('Table analyse', () => {
test.each(engines.map(engine => [engine.label, engine]))( test.each(engines.map(engine => [engine.label, engine]))(
'Table remove - incremental analysis - %s', 'Table remove - incremental analysis - %s',
testWrapper(async (conn, driver, engine) => { testWrapper(async (conn, driver, engine) => {
await driver.query(conn, t1Sql); await runCommandOnDriver(conn, driver, dmp => dmp.put(t1Sql));
await driver.query(conn, t2Sql(engine)); await driver.query(conn, t2Sql(engine));
const structure1 = await driver.analyseFull(conn); const structure1 = await driver.analyseFull(conn);
expect(structure1.tables.length).toEqual(2); expect(structure1.tables.length).toEqual(2);
@@ -107,7 +109,7 @@ describe('Table analyse', () => {
test.each(engines.map(engine => [engine.label, engine]))( test.each(engines.map(engine => [engine.label, engine]))(
'Table change - incremental analysis - %s', 'Table change - incremental analysis - %s',
testWrapper(async (conn, driver, engine) => { testWrapper(async (conn, driver, engine) => {
await driver.query(conn, t1Sql); await runCommandOnDriver(conn, driver, dmp => dmp.put(t1Sql));
await driver.query(conn, t2Sql(engine)); await driver.query(conn, t2Sql(engine));
const structure1 = await driver.analyseFull(conn); const structure1 = await driver.analyseFull(conn);
@@ -130,7 +132,7 @@ describe('Table analyse', () => {
test.each(engines.filter(x => !x.skipIndexes).map(engine => [engine.label, engine]))( test.each(engines.filter(x => !x.skipIndexes).map(engine => [engine.label, engine]))(
'Index - full analysis - %s', 'Index - full analysis - %s',
testWrapper(async (conn, driver, engine) => { testWrapper(async (conn, driver, engine) => {
await driver.query(conn, t1Sql); await runCommandOnDriver(conn, driver, dmp => dmp.put(t1Sql));
await driver.query(conn, ix1Sql); await driver.query(conn, ix1Sql);
const structure = await driver.analyseFull(conn); const structure = await driver.analyseFull(conn);

View File

@@ -1,10 +1,12 @@
const requireEngineDriver = require('dbgate-api/src/utility/requireEngineDriver'); const requireEngineDriver = require('dbgate-api/src/utility/requireEngineDriver');
const crypto = require('crypto'); const crypto = require('crypto');
function randomDbName() { function randomDbName(dialect) {
const generatedKey = crypto.randomBytes(6); const generatedKey = crypto.randomBytes(6);
const newKey = generatedKey.toString('hex'); const newKey = generatedKey.toString('hex');
return `db${newKey}`; const res = `db${newKey}`;
if (dialect.upperCaseAllDbObjectNames) return res.toUpperCase();
return res;
} }
function extractConnection(engine) { function extractConnection(engine) {
@@ -75,7 +77,7 @@ const testWrapper =
async (label, ...other) => { async (label, ...other) => {
const engine = other[other.length - 1]; const engine = other[other.length - 1];
const driver = requireEngineDriver(engine.connection); const driver = requireEngineDriver(engine.connection);
const conn = await connect(engine, randomDbName()); const conn = await connect(engine, randomDbName(driver.dialect));
try { try {
await body(conn, driver, ...other); await body(conn, driver, ...other);
} finally { } finally {
@@ -88,7 +90,7 @@ const testWrapperPrepareOnly =
async (label, ...other) => { async (label, ...other) => {
const engine = other[other.length - 1]; const engine = other[other.length - 1];
const driver = requireEngineDriver(engine.connection); const driver = requireEngineDriver(engine.connection);
const conn = await prepareConnection(engine, randomDbName()); const conn = await prepareConnection(engine, randomDbName(driver.dialect));
await body(conn, driver, ...other); await body(conn, driver, ...other);
}; };

View File

@@ -52,6 +52,7 @@ export interface SqlDialect {
dropReferencesWhenDropTable?: boolean; dropReferencesWhenDropTable?: boolean;
requireFromDual?: boolean; requireFromDual?: boolean;
userDatabaseNamePrefix?: string; // c## in Oracle userDatabaseNamePrefix?: string; // c## in Oracle
upperCaseAllDbObjectNames?: boolean;
predefinedDataTypes: string[]; predefinedDataTypes: string[];

View File

@@ -20,7 +20,8 @@ const dialect = {
quoteIdentifier(s) { quoteIdentifier(s) {
return '"' + s + '"'; return '"' + s + '"';
}, },
userDatabaseNamePrefix: 'c##', userDatabaseNamePrefix: 'C##',
upperCaseAllDbObjectNames: true,
createColumn: true, createColumn: true,
dropColumn: true, dropColumn: true,