blob: 1ec485699c64ca933a4c2cfc9744039436d8dbaf [file] [log] [blame]
#create-table-mssql
IF NOT EXISTS (SELECT 1 FROM SYS.OBJECTS WHERE OBJECT_ID = OBJECT_ID(N'pekko_projection_offset_store') AND TYPE IN (N'U'))
BEGIN
CREATE TABLE pekko_projection_offset_store (
projection_name VARCHAR(255) NOT NULL,
projection_key VARCHAR(255) NOT NULL,
current_offset VARCHAR(255) NOT NULL,
manifest VARCHAR(4) NOT NULL,
mergeable BIT NOT NULL,
last_updated BIGINT NOT NULL
)
ALTER TABLE pekko_projection_offset_store ADD CONSTRAINT pk_projection_id PRIMARY KEY(projection_name, projection_key)
CREATE INDEX projection_name_index ON pekko_projection_offset_store (projection_name)
END
IF NOT EXISTS (SELECT 1 FROM SYS.OBJECTS WHERE OBJECT_ID = OBJECT_ID(N'pekko_projection_management') AND TYPE IN (N'U'))
BEGIN
CREATE TABLE pekko_projection_management (
projection_name VARCHAR(255) NOT NULL,
projection_key VARCHAR(255) NOT NULL,
paused BIT NOT NULL,
last_updated BIGINT NOT NULL
)
ALTER TABLE pekko_projection_management ADD CONSTRAINT pk_projection_management_id PRIMARY KEY(projection_name, projection_key)
END
#create-table-mssql