crowetic/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add row deletion step to migration

Browse Source
This commit is contained in:
fragosti
2019-02-01 15:50:04 -08:00
parent 4996ae8d9d
commit 4f3cab4213
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/pipeline/migrations/1548809952793-AllowDuplicateTxHashesInDexTrades.ts
View File

@@ -6,7 +6,9 @@ export class AllowDuplicateTxHashesInDexTrades1548809952793 implements Migration
public async up(queryRunner: QueryRunner): Promise<any> {
const dexTradesTable = await queryRunner.getTable(DEX_TRADES_TABLE_NAME);
if (dexTradesTable) {
// Composite key goes from (source_url, tx_hash) to (trade_index, source_url, tx_hash)
// Need new primary key to be non-null. No default value makes sense, so drop table.
await queryRunner.query(`DELETE from ${DEX_TRADES_TABLE_NAME}`);
// Composite key goes from (source_url, tx_hash) to (source_url, tx_hash, trade_index)
await queryRunner.addColumn(
DEX_TRADES_TABLE_NAME,
new TableColumn({