diff options
author | Hsuan Lee <boczeratul@gmail.com> | 2019-03-06 17:46:50 +0800 |
---|---|---|
committer | Hsuan Lee <boczeratul@gmail.com> | 2019-03-06 17:46:50 +0800 |
commit | 35703539d0f2b4ddb3b11d0de8c9634af59ab71f (patch) | |
tree | ae3731221dbbb3a6fa40060a8d916cfd3f738289 /packages/pipeline/migrations/1548809952793-AllowDuplicateTxHashesInDexTrades.ts | |
parent | 92a1fde5b1ecd81b07cdb5bf0c9c1cd3544799db (diff) | |
download | dexon-0x-contracts-stable.tar dexon-0x-contracts-stable.tar.gz dexon-0x-contracts-stable.tar.bz2 dexon-0x-contracts-stable.tar.lz dexon-0x-contracts-stable.tar.xz dexon-0x-contracts-stable.tar.zst dexon-0x-contracts-stable.zip |
Deploy @dexon-foundation/0x.jsstable
Diffstat (limited to 'packages/pipeline/migrations/1548809952793-AllowDuplicateTxHashesInDexTrades.ts')
-rw-r--r-- | packages/pipeline/migrations/1548809952793-AllowDuplicateTxHashesInDexTrades.ts | 29 |
1 files changed, 0 insertions, 29 deletions
diff --git a/packages/pipeline/migrations/1548809952793-AllowDuplicateTxHashesInDexTrades.ts b/packages/pipeline/migrations/1548809952793-AllowDuplicateTxHashesInDexTrades.ts deleted file mode 100644 index 21b08f0ef..000000000 --- a/packages/pipeline/migrations/1548809952793-AllowDuplicateTxHashesInDexTrades.ts +++ /dev/null @@ -1,29 +0,0 @@ -import { MigrationInterface, QueryRunner, TableColumn } from 'typeorm'; - -const DEX_TRADES_TABLE_NAME = 'raw.dex_trades'; - -export class AllowDuplicateTxHashesInDexTrades1548809952793 implements MigrationInterface { - public async up(queryRunner: QueryRunner): Promise<any> { - const dexTradesTable = await queryRunner.getTable(DEX_TRADES_TABLE_NAME); - if (dexTradesTable) { - // 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({ - name: 'trade_index', - type: 'varchar', - isPrimary: true, - }), - ); - } - } - - public async down(queryRunner: QueryRunner): Promise<any> { - const dexTradesTable = await queryRunner.getTable(DEX_TRADES_TABLE_NAME); - if (dexTradesTable) { - await queryRunner.dropColumn(dexTradesTable, 'trade_index'); - } - } -} |