From 4d238c116c795fd9e4114f1a59d20e325645afee Mon Sep 17 00:00:00 2001 From: Owen Cliffe Date: Mon, 25 Jun 2018 18:48:01 +0100 Subject: [PATCH] Add triggers table via migration (#1088) * Add triggers table via migration --- .../sql/migrations/17_add_triggers.go | 38 +++++++++++++++++++ api/datastore/sql/sql.go | 2 +- 2 files changed, 39 insertions(+), 1 deletion(-) create mode 100644 api/datastore/sql/migrations/17_add_triggers.go diff --git a/api/datastore/sql/migrations/17_add_triggers.go b/api/datastore/sql/migrations/17_add_triggers.go new file mode 100644 index 000000000..e667aad43 --- /dev/null +++ b/api/datastore/sql/migrations/17_add_triggers.go @@ -0,0 +1,38 @@ +package migrations + +import ( + "context" + + "github.com/fnproject/fn/api/datastore/sql/migratex" + "github.com/jmoiron/sqlx" +) + +func up17(ctx context.Context, tx *sqlx.Tx) error { + createQuery := `CREATE TABLE IF NOT EXISTS triggers ( + id varchar(256) NOT NULL PRIMARY KEY, + name varchar(256) NOT NULL, + app_id varchar(256) NOT NULL, + fn_id varchar(256) NOT NULL, + created_at varchar(256) NOT NULL, + updated_at varchar(256) NOT NULL, + type varchar(256) NOT NULL, + source varchar(256) NOT NULL, + annotations text NOT NULL, + CONSTRAINT name_app_id_fn_id_unique UNIQUE (app_id, fn_id, name) +);` + _, err := tx.ExecContext(ctx, createQuery) + return err +} + +func down17(ctx context.Context, tx *sqlx.Tx) error { + _, err := tx.ExecContext(ctx, "DROP TABLE triggers;") + return err +} + +func init() { + Migrations = append(Migrations, &migratex.MigFields{ + VersionFunc: vfunc(17), + UpFunc: up17, + DownFunc: down17, + }) +} diff --git a/api/datastore/sql/sql.go b/api/datastore/sql/sql.go index 63b4cf701..e9664bebc 100644 --- a/api/datastore/sql/sql.go +++ b/api/datastore/sql/sql.go @@ -88,7 +88,7 @@ var tables = [...]string{`CREATE TABLE IF NOT EXISTS routes ( type varchar(256) NOT NULL, source varchar(256) NOT NULL, annotations text NOT NULL, - CONSTRAINT name_app_id_fn_id_unique UNIQUE (app_id, fn_id,name) + CONSTRAINT name_app_id_fn_id_unique UNIQUE (app_id, fn_id, name) );`, `CREATE TABLE IF NOT EXISTS logs (