mirror of
https://github.com/DeNNiiInc/dbgate.git
synced 2026-05-02 23:03:58 +00:00
test views
This commit is contained in:
62
integration-tests/__tests__/object-analyse.spec.js
Normal file
62
integration-tests/__tests__/object-analyse.spec.js
Normal file
@@ -0,0 +1,62 @@
|
|||||||
|
const { connect, randomDbName } = require('../tools');
|
||||||
|
const requireEngineDriver = require('dbgate-api/src/utility/requireEngineDriver');
|
||||||
|
const engines = require('../engines');
|
||||||
|
const _ = require('lodash');
|
||||||
|
|
||||||
|
const initSql = ['CREATE TABLE t1 (id int)', 'CREATE TABLE t2 (id int)'];
|
||||||
|
|
||||||
|
function flatSource() {
|
||||||
|
return _.flatten(
|
||||||
|
engines.map(engine => (engine.objects || []).map(object => [engine.label, object.type, engine, object]))
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
const obj1Match = expect.objectContaining({
|
||||||
|
pureName: 'obj1',
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('Object analyse', () => {
|
||||||
|
test.each(flatSource())('Full analysis (%s - %s)', async (label, type, engine, object) => {
|
||||||
|
const conn = await connect(engine, randomDbName());
|
||||||
|
const driver = requireEngineDriver(engine.connection);
|
||||||
|
for (const sql of initSql) await driver.query(conn, sql);
|
||||||
|
|
||||||
|
await driver.query(conn, object.create1);
|
||||||
|
const structure = await driver.analyseFull(conn);
|
||||||
|
|
||||||
|
expect(structure[type].length).toEqual(1);
|
||||||
|
expect(structure[type][0]).toEqual(obj1Match);
|
||||||
|
await driver.close(conn);
|
||||||
|
});
|
||||||
|
|
||||||
|
test.each(flatSource())('Incremental analysis - add (%s - %s)', async (label, type, engine, object) => {
|
||||||
|
const conn = await connect(engine, randomDbName());
|
||||||
|
const driver = requireEngineDriver(engine.connection);
|
||||||
|
for (const sql of initSql) await driver.query(conn, sql);
|
||||||
|
|
||||||
|
await driver.query(conn, object.create2);
|
||||||
|
const structure1 = await driver.analyseFull(conn);
|
||||||
|
await driver.query(conn, object.create1);
|
||||||
|
const structure2 = await driver.analyseIncremental(conn, structure1);
|
||||||
|
|
||||||
|
expect(structure2[type].length).toEqual(2);
|
||||||
|
expect(structure2[type].find(x => x.pureName == 'obj1')).toEqual(obj1Match);
|
||||||
|
await driver.close(conn);
|
||||||
|
});
|
||||||
|
|
||||||
|
test.each(flatSource())('Incremental analysis - drop (%s - %s)', async (label, type, engine, object) => {
|
||||||
|
const conn = await connect(engine, randomDbName());
|
||||||
|
const driver = requireEngineDriver(engine.connection);
|
||||||
|
for (const sql of initSql) await driver.query(conn, sql);
|
||||||
|
|
||||||
|
await driver.query(conn, object.create1);
|
||||||
|
await driver.query(conn, object.create2);
|
||||||
|
const structure1 = await driver.analyseFull(conn);
|
||||||
|
await driver.query(conn, object.drop2);
|
||||||
|
const structure2 = await driver.analyseIncremental(conn, structure1);
|
||||||
|
|
||||||
|
expect(structure2[type].length).toEqual(1);
|
||||||
|
expect(structure2[type][0]).toEqual(obj1Match);
|
||||||
|
await driver.close(conn);
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -26,7 +26,7 @@ const t1Match = expect.objectContaining({
|
|||||||
}),
|
}),
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('Table analyse tests', () => {
|
describe.skip('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)',
|
||||||
async (label, engine) => {
|
async (label, engine) => {
|
||||||
|
|||||||
@@ -1,3 +1,11 @@
|
|||||||
|
const views = {
|
||||||
|
type: 'views',
|
||||||
|
create1: 'CREATE VIEW obj1 AS SELECT id FROM t1',
|
||||||
|
create2: 'CREATE VIEW obj2 AS SELECT id FROM t2',
|
||||||
|
drop1: 'DROP VIEW obj1',
|
||||||
|
drop2: 'DROP VIEW obj2',
|
||||||
|
};
|
||||||
|
|
||||||
const engines = [
|
const engines = [
|
||||||
{
|
{
|
||||||
label: 'MySQL',
|
label: 'MySQL',
|
||||||
@@ -8,6 +16,7 @@ const engines = [
|
|||||||
user: 'root',
|
user: 'root',
|
||||||
port: 15001,
|
port: 15001,
|
||||||
},
|
},
|
||||||
|
objects: [views],
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
label: 'PostgreSQL',
|
label: 'PostgreSQL',
|
||||||
@@ -18,6 +27,7 @@ const engines = [
|
|||||||
user: 'postgres',
|
user: 'postgres',
|
||||||
port: 15000,
|
port: 15000,
|
||||||
},
|
},
|
||||||
|
objects: [views],
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
label: 'SQL Server',
|
label: 'SQL Server',
|
||||||
@@ -28,6 +38,7 @@ const engines = [
|
|||||||
user: 'sa',
|
user: 'sa',
|
||||||
port: 15002,
|
port: 15002,
|
||||||
},
|
},
|
||||||
|
objects: [views],
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
label: 'SQLite',
|
label: 'SQLite',
|
||||||
@@ -35,6 +46,7 @@ const engines = [
|
|||||||
connection: {
|
connection: {
|
||||||
engine: 'sqlite@dbgate-plugin-sqlite',
|
engine: 'sqlite@dbgate-plugin-sqlite',
|
||||||
},
|
},
|
||||||
|
objects: [views],
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
label: 'CockroachDB',
|
label: 'CockroachDB',
|
||||||
@@ -44,6 +56,7 @@ const engines = [
|
|||||||
user: 'root',
|
user: 'root',
|
||||||
port: 15003,
|
port: 15003,
|
||||||
},
|
},
|
||||||
|
objects: [views],
|
||||||
},
|
},
|
||||||
];
|
];
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user