mirror of
https://github.com/DeNNiiInc/dbgate.git
synced 2026-04-23 16:16:02 +00:00
fix
This commit is contained in:
@@ -7,7 +7,7 @@ const initSql = ['CREATE TABLE t1 (id int)', 'CREATE TABLE t2 (id int)'];
|
|||||||
|
|
||||||
function flatSource() {
|
function flatSource() {
|
||||||
return _.flatten(
|
return _.flatten(
|
||||||
engines.map(engine => (engine.objects || []).map(object => [engine.label, engine, object.type, object]))
|
engines.map(engine => (engine.objects || []).map(object => [engine.label, object.type, object, engine]))
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -18,7 +18,7 @@ const obj1Match = expect.objectContaining({
|
|||||||
describe('Object analyse', () => {
|
describe('Object analyse', () => {
|
||||||
test.each(flatSource())(
|
test.each(flatSource())(
|
||||||
'Full analysis (%s - %s)',
|
'Full analysis (%s - %s)',
|
||||||
testWrapper(async (conn, driver, engine, type, object) => {
|
testWrapper(async (conn, driver, type, object, engine) => {
|
||||||
for (const sql of initSql) await driver.query(conn, sql);
|
for (const sql of initSql) await driver.query(conn, sql);
|
||||||
|
|
||||||
await driver.query(conn, object.create1);
|
await driver.query(conn, object.create1);
|
||||||
@@ -31,7 +31,7 @@ describe('Object analyse', () => {
|
|||||||
|
|
||||||
test.each(flatSource())(
|
test.each(flatSource())(
|
||||||
'Incremental analysis - add (%s - %s)',
|
'Incremental analysis - add (%s - %s)',
|
||||||
testWrapper(async (conn, driver, engine, type, object) => {
|
testWrapper(async (conn, driver, type, object, engine) => {
|
||||||
for (const sql of initSql) await driver.query(conn, sql);
|
for (const sql of initSql) await driver.query(conn, sql);
|
||||||
|
|
||||||
await driver.query(conn, object.create2);
|
await driver.query(conn, object.create2);
|
||||||
@@ -46,7 +46,7 @@ describe('Object analyse', () => {
|
|||||||
|
|
||||||
test.each(flatSource())(
|
test.each(flatSource())(
|
||||||
'Incremental analysis - drop (%s - %s)',
|
'Incremental analysis - drop (%s - %s)',
|
||||||
testWrapper(async (conn, driver, engine, type, object) => {
|
testWrapper(async (conn, driver, type, object, engine) => {
|
||||||
for (const sql of initSql) await driver.query(conn, sql);
|
for (const sql of initSql) await driver.query(conn, sql);
|
||||||
|
|
||||||
await driver.query(conn, object.create1);
|
await driver.query(conn, object.create1);
|
||||||
|
|||||||
@@ -44,11 +44,12 @@ async function connect(engine, database) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const testWrapper = body => async (label, engine, ...other) => {
|
const testWrapper = body => async (label, ...other) => {
|
||||||
|
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());
|
||||||
try {
|
try {
|
||||||
await body(conn, driver, engine, ...other);
|
await body(conn, driver, ...other);
|
||||||
} finally {
|
} finally {
|
||||||
await driver.close(conn);
|
await driver.close(conn);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user