diff --git a/packages/tools/src/createBulkInsertStreamBase.ts b/packages/tools/src/createBulkInsertStreamBase.ts index 9aa3129ce..05db2fe24 100644 --- a/packages/tools/src/createBulkInsertStreamBase.ts +++ b/packages/tools/src/createBulkInsertStreamBase.ts @@ -31,7 +31,9 @@ export function createBulkInsertStreamBase(driver: EngineDriver, stream, dbhan, writable.checkStructure = async () => { let structure = await driver.analyseSingleTable(dbhan, name); - // console.log('ANALYSING', name, structure); + if (structure) { + writable.structure = structure; + } if (structure && options.dropIfExists) { logger.info(`Dropping table ${fullNameQuoted}`); await driver.script(dbhan, `DROP TABLE ${fullNameQuoted}`);