mirrors/dbgate
1
0
Fork 0
mirror of https://github.com/dbgate/dbgate synced 2024-11-07 20:26:23 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

drop object test

Browse Source
This commit is contained in:
Jan Prochazka 2021-09-13 21:38:28 +02:00
parent 2fa48b1138
commit dcaf8351b5
1 changed files with 30 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
integration-tests/__tests__/alter-database.spec.js
View File

@ -6,17 +6,25 @@ const { testWrapper } = require('../tools');
const engines = require('../engines'); const engines = require('../engines');
const { getAlterDatabaseScript, extendDatabaseInfo, generateDbPairingId } = require('dbgate-tools'); const { getAlterDatabaseScript, extendDatabaseInfo, generateDbPairingId } = require('dbgate-tools');
async function testDatabaseDiff(conn, driver, mangle) { function flatSource() {
await driver.query(conn, `create table t0 (id int not null primary key)`); return _.flatten(
engines.map(engine => (engine.objects || []).map(object => [engine.label, object.type, object, engine]))
);
}
async function testDatabaseDiff(conn, driver, mangle, createObject = null) {
await driver.query(conn, `create table t1 (id int not null primary key)`);
await driver.query( await driver.query(
conn, conn,
`create table t1 ( `create table t2 (
col_pk int not null primary key, id int not null primary key,
col_fk int null references t0(id) t1_id int null references t1(id)
)` )`
); );
if (createObject) await driver.query(conn, createObject);
const structure1 = generateDbPairingId(extendDatabaseInfo(await driver.analyseFull(conn))); const structure1 = generateDbPairingId(extendDatabaseInfo(await driver.analyseFull(conn)));
let structure2 = _.cloneDeep(structure1); let structure2 = _.cloneDeep(structure1);
mangle(structure2); mangle(structure2);
@ -30,6 +38,7 @@ async function testDatabaseDiff(conn, driver, mangle) {
const structure2Real = extendDatabaseInfo(await driver.analyseFull(conn)); const structure2Real = extendDatabaseInfo(await driver.analyseFull(conn));
expect(structure2Real.tables.length).toEqual(structure2.tables.length); expect(structure2Real.tables.length).toEqual(structure2.tables.length);
return structure2Real;
} }
describe('Alter database', () => { describe('Alter database', () => {
@ -37,8 +46,23 @@ describe('Alter database', () => {
'Drop referenced table - %s', 'Drop referenced table - %s',
testWrapper(async (conn, driver, engine) => { testWrapper(async (conn, driver, engine) => {
await testDatabaseDiff(conn, driver, db => { await testDatabaseDiff(conn, driver, db => {
_.remove(db.tables, x => x.pureName == 't0'); _.remove(db.tables, x => x.pureName == 't1');
}); });
}) })
); );
test.each(flatSource())(
'Drop object - %s - %s',
testWrapper(async (conn, driver, type, object, engine) => {
const db = await testDatabaseDiff(
conn,
driver,
db => {
_.remove(db[type], x => x.pureName == 'obj1');
},
object.create1
);
expect(db[type].length).toEqual(0);
})
);
}); });