aboutsummaryrefslogtreecommitdiffstats
path: root/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts')
-rw-r--r--packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts46
1 files changed, 46 insertions, 0 deletions
diff --git a/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts b/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts
new file mode 100644
index 000000000..5c7ec6de7
--- /dev/null
+++ b/packages/pipeline/migrations/1542655823221-NewMetadataAndOHLCVTables.ts
@@ -0,0 +1,46 @@
+import {MigrationInterface, QueryRunner} from 'typeorm';
+
+export class NewMetadataAndOHLCVTables1542655823221 implements MigrationInterface {
+
+ public async up(queryRunner: QueryRunner): Promise<any> {
+
+ await queryRunner.query(`
+ CREATE TABLE raw.trusted_tokens (
+ address VARCHAR NOT NULL,
+ authority VARCHAR NOT NULL,
+
+ PRIMARY KEY (address, authority)
+ );
+ `);
+
+ await queryRunner.query(`
+ CREATE TABLE raw.ohlcv_external (
+ exchange VARCHAR NOT NULL,
+ from_symbol VARCHAR NOT NULL,
+ to_symbol VARCHAR NOT NULL,
+ start_time BIGINT NOT NULL,
+ end_time BIGINT NOT NULL,
+
+ open DOUBLE PRECISION NOT NULL,
+ close DOUBLE PRECISION NOT NULL,
+ low DOUBLE PRECISION NOT NULL,
+ high DOUBLE PRECISION NOT NULL,
+ volume_from DOUBLE PRECISION NOT NULL,
+ volume_to DOUBLE PRECISION NOT NULL,
+
+ source VARCHAR NOT NULL,
+ observed_timestamp BIGINT NOT NULL,
+
+ PRIMARY KEY (exchange, from_symbol, to_symbol, start_time, end_time, source, observed_timestamp)
+ );
+ `);
+ }
+
+ public async down(queryRunner: QueryRunner): Promise<any> {
+
+ await queryRunner.dropTable('raw.trusted_tokens');
+
+ await queryRunner.dropTable('raw.ohlcv_external');
+ }
+
+}