diff options
Diffstat (limited to 'db')
-rw-r--r-- | db/db.go | 3 | ||||
-rw-r--r-- | db/migrations.go | 16 |
2 files changed, 10 insertions, 9 deletions
@@ -26,6 +26,7 @@ type RedisConfig struct { | |||
26 | Type string // tcp or unix | 26 | Type string // tcp or unix |
27 | Address string | 27 | Address string |
28 | Password string | 28 | Password string |
29 | Database int | ||
29 | } | 30 | } |
30 | 31 | ||
31 | func Init(config DBConfig, redisConfig RedisConfig) { | 32 | func Init(config DBConfig, redisConfig RedisConfig) { |
@@ -42,7 +43,7 @@ func Init(config DBConfig, redisConfig RedisConfig) { | |||
42 | Network: redisConfig.Type, | 43 | Network: redisConfig.Type, |
43 | Addr: redisConfig.Address, | 44 | Addr: redisConfig.Address, |
44 | Password: redisConfig.Password, | 45 | Password: redisConfig.Password, |
45 | DB: 0, | 46 | DB: redisConfig.Database, |
46 | }) | 47 | }) |
47 | 48 | ||
48 | _, err = Redis.Ping().Result() | 49 | _, err = Redis.Ping().Result() |
diff --git a/db/migrations.go b/db/migrations.go index 286fe17..38ea8aa 100644 --- a/db/migrations.go +++ b/db/migrations.go | |||
@@ -26,22 +26,22 @@ var migrations []Migration = []Migration{ | |||
26 | config jsonb, | 26 | config jsonb, |
27 | UNIQUE(user_id, market_name) | 27 | UNIQUE(user_id, market_name) |
28 | )`, | 28 | )`, |
29 | `CREATE TABLE reports ( | ||
30 | id BIGSERIAL PRIMARY KEY, | ||
31 | date timestamp with time zone NOT NULL, | ||
32 | market_config_id bigint NOT NULL, | ||
33 | debug boolean | ||
34 | )`, | ||
35 | "CREATE INDEX IF NOT EXISTS reports_market_config_id ON reports (market_config_id)", | ||
29 | `CREATE TABLE report_lines ( | 36 | `CREATE TABLE report_lines ( |
30 | id BIGSERIAL PRIMARY KEY, | 37 | id BIGSERIAL PRIMARY KEY, |
31 | date timestamp with time zone NOT NULL, | 38 | date timestamp with time zone NOT NULL, |
32 | report_id bigint NOT NULL, | 39 | report_id bigint NOT NULL REFERENCES reports(id), |
33 | type text, | 40 | type text, |
34 | payload jsonb | 41 | payload jsonb |
35 | )`, | 42 | )`, |
36 | "CREATE INDEX IF NOT EXISTS report_lines_report_id ON report_lines (report_id)", | 43 | "CREATE INDEX IF NOT EXISTS report_lines_report_id ON report_lines (report_id)", |
37 | "CREATE INDEX IF NOT EXISTS report_lines_type ON report_lines (type)", | 44 | "CREATE INDEX IF NOT EXISTS report_lines_type ON report_lines (type)", |
38 | `CREATE TABLE reports ( | ||
39 | id BIGSERIAL PRIMARY KEY, | ||
40 | date timestamp with time zone NOT NULL, | ||
41 | market_config_id bigint NOT NULL, | ||
42 | debug boolean | ||
43 | )`, | ||
44 | "CREATE INDEX IF NOT EXISTS reports_market_config_id ON reports (market_config_id)", | ||
45 | }, | 45 | }, |
46 | Down: []string{"DROP TABLE users", "DROP TABLE market_configs", "DROP TABLE report_lines", "DROP TABLE reports"}, | 46 | Down: []string{"DROP TABLE users", "DROP TABLE market_configs", "DROP TABLE report_lines", "DROP TABLE reports"}, |
47 | }, | 47 | }, |