dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-26 15:36:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

data duplicator runs in transaction

Browse Source
This commit is contained in:
Jan Prochazka
2023-02-12 12:14:07 +01:00
parent 5b6f90abc5
commit bb2f1399ba
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
packages/datalib/src/DataDuplicator.ts
View File

@@ -207,11 +207,18 @@ export class DataDuplicator {
async run() { async run() {
this.createPlan(); this.createPlan();
await runCommandOnDriver(this.pool, this.driver, dmp => dmp.beginTransaction());
try {
for (const item of this.itemPlan) { for (const item of this.itemPlan) {
const stats = await item.runImport(); const stats = await item.runImport();
logger.info( logger.info(
`Duplicated ${item.name}, inserted ${stats.inserted} rows, mapped ${stats.mapped} rows, missing ${stats.missing} rows` `Duplicated ${item.name}, inserted ${stats.inserted} rows, mapped ${stats.mapped} rows, missing ${stats.missing} rows`
); );
} }
} catch (err) {
logger.error({ err }, 'Failed duplicator job, rollbacking');
await runCommandOnDriver(this.pool, this.driver, dmp => dmp.rollbackTransaction());
}
await runCommandOnDriver(this.pool, this.driver, dmp => dmp.commitTransaction());
} }
} }