diff --git a/initdb.d/jdbc-journal-schema.sql b/initdb.d/jdbc-journal-schema.sql new file mode 100644 index 0000000..5c57be2 --- /dev/null +++ b/initdb.d/jdbc-journal-schema.sql @@ -0,0 +1,38 @@ +CREATE TABLE IF NOT EXISTS event_journal( + ordering SERIAL, + deleted BOOLEAN DEFAULT false NOT NULL, + persistence_id VARCHAR(255) NOT NULL, + sequence_number BIGINT NOT NULL, + writer TEXT NOT NULL, + write_timestamp BIGINT NOT NULL, + adapter_manifest TEXT NOT NULL, + event_payload BLOB NOT NULL, + event_ser_id INTEGER NOT NULL, + event_ser_manifest TEXT NOT NULL, + meta_payload BLOB, + meta_ser_id INTEGER,meta_ser_manifest TEXT, + PRIMARY KEY(persistence_id,sequence_number) +); + +CREATE UNIQUE INDEX event_journal_ordering_idx ON event_journal(ordering); + +CREATE TABLE IF NOT EXISTS event_tag ( + event_id BIGINT UNSIGNED NOT NULL, + tag VARCHAR(255) NOT NULL, + PRIMARY KEY(event_id, tag), + FOREIGN KEY (event_id) + REFERENCES event_journal(ordering) + ON DELETE CASCADE + ); + +CREATE TABLE IF NOT EXISTS snapshot ( + persistence_id VARCHAR(255) NOT NULL, + sequence_number BIGINT NOT NULL, + created BIGINT NOT NULL, + snapshot_ser_id INTEGER NOT NULL, + snapshot_ser_manifest TEXT NOT NULL, + snapshot_payload BLOB NOT NULL, + meta_ser_id INTEGER, + meta_ser_manifest TEXT, + meta_payload BLOB, + PRIMARY KEY (persistence_id, sequence_number)); diff --git a/initdb.d/jdbc-journal-schema.sql b/initdb.d/jdbc-journal-schema.sql new file mode 100644 index 0000000..5c57be2 --- /dev/null +++ b/initdb.d/jdbc-journal-schema.sql @@ -0,0 +1,38 @@ +CREATE TABLE IF NOT EXISTS event_journal( + ordering SERIAL, + deleted BOOLEAN DEFAULT false NOT NULL, + persistence_id VARCHAR(255) NOT NULL, + sequence_number BIGINT NOT NULL, + writer TEXT NOT NULL, + write_timestamp BIGINT NOT NULL, + adapter_manifest TEXT NOT NULL, + event_payload BLOB NOT NULL, + event_ser_id INTEGER NOT NULL, + event_ser_manifest TEXT NOT NULL, + meta_payload BLOB, + meta_ser_id INTEGER,meta_ser_manifest TEXT, + PRIMARY KEY(persistence_id,sequence_number) +); + +CREATE UNIQUE INDEX event_journal_ordering_idx ON event_journal(ordering); + +CREATE TABLE IF NOT EXISTS event_tag ( + event_id BIGINT UNSIGNED NOT NULL, + tag VARCHAR(255) NOT NULL, + PRIMARY KEY(event_id, tag), + FOREIGN KEY (event_id) + REFERENCES event_journal(ordering) + ON DELETE CASCADE + ); + +CREATE TABLE IF NOT EXISTS snapshot ( + persistence_id VARCHAR(255) NOT NULL, + sequence_number BIGINT NOT NULL, + created BIGINT NOT NULL, + snapshot_ser_id INTEGER NOT NULL, + snapshot_ser_manifest TEXT NOT NULL, + snapshot_payload BLOB NOT NULL, + meta_ser_id INTEGER, + meta_ser_manifest TEXT, + meta_payload BLOB, + PRIMARY KEY (persistence_id, sequence_number)); diff --git a/initdb.d/jdbc-journal.sql b/initdb.d/jdbc-journal.sql deleted file mode 100644 index 5c57be2..0000000 --- a/initdb.d/jdbc-journal.sql +++ /dev/null @@ -1,38 +0,0 @@ -CREATE TABLE IF NOT EXISTS event_journal( - ordering SERIAL, - deleted BOOLEAN DEFAULT false NOT NULL, - persistence_id VARCHAR(255) NOT NULL, - sequence_number BIGINT NOT NULL, - writer TEXT NOT NULL, - write_timestamp BIGINT NOT NULL, - adapter_manifest TEXT NOT NULL, - event_payload BLOB NOT NULL, - event_ser_id INTEGER NOT NULL, - event_ser_manifest TEXT NOT NULL, - meta_payload BLOB, - meta_ser_id INTEGER,meta_ser_manifest TEXT, - PRIMARY KEY(persistence_id,sequence_number) -); - -CREATE UNIQUE INDEX event_journal_ordering_idx ON event_journal(ordering); - -CREATE TABLE IF NOT EXISTS event_tag ( - event_id BIGINT UNSIGNED NOT NULL, - tag VARCHAR(255) NOT NULL, - PRIMARY KEY(event_id, tag), - FOREIGN KEY (event_id) - REFERENCES event_journal(ordering) - ON DELETE CASCADE - ); - -CREATE TABLE IF NOT EXISTS snapshot ( - persistence_id VARCHAR(255) NOT NULL, - sequence_number BIGINT NOT NULL, - created BIGINT NOT NULL, - snapshot_ser_id INTEGER NOT NULL, - snapshot_ser_manifest TEXT NOT NULL, - snapshot_payload BLOB NOT NULL, - meta_ser_id INTEGER, - meta_ser_manifest TEXT, - meta_payload BLOB, - PRIMARY KEY (persistence_id, sequence_number)); diff --git a/initdb.d/jdbc-journal-schema.sql b/initdb.d/jdbc-journal-schema.sql new file mode 100644 index 0000000..5c57be2 --- /dev/null +++ b/initdb.d/jdbc-journal-schema.sql @@ -0,0 +1,38 @@ +CREATE TABLE IF NOT EXISTS event_journal( + ordering SERIAL, + deleted BOOLEAN DEFAULT false NOT NULL, + persistence_id VARCHAR(255) NOT NULL, + sequence_number BIGINT NOT NULL, + writer TEXT NOT NULL, + write_timestamp BIGINT NOT NULL, + adapter_manifest TEXT NOT NULL, + event_payload BLOB NOT NULL, + event_ser_id INTEGER NOT NULL, + event_ser_manifest TEXT NOT NULL, + meta_payload BLOB, + meta_ser_id INTEGER,meta_ser_manifest TEXT, + PRIMARY KEY(persistence_id,sequence_number) +); + +CREATE UNIQUE INDEX event_journal_ordering_idx ON event_journal(ordering); + +CREATE TABLE IF NOT EXISTS event_tag ( + event_id BIGINT UNSIGNED NOT NULL, + tag VARCHAR(255) NOT NULL, + PRIMARY KEY(event_id, tag), + FOREIGN KEY (event_id) + REFERENCES event_journal(ordering) + ON DELETE CASCADE + ); + +CREATE TABLE IF NOT EXISTS snapshot ( + persistence_id VARCHAR(255) NOT NULL, + sequence_number BIGINT NOT NULL, + created BIGINT NOT NULL, + snapshot_ser_id INTEGER NOT NULL, + snapshot_ser_manifest TEXT NOT NULL, + snapshot_payload BLOB NOT NULL, + meta_ser_id INTEGER, + meta_ser_manifest TEXT, + meta_payload BLOB, + PRIMARY KEY (persistence_id, sequence_number)); diff --git a/initdb.d/jdbc-journal.sql b/initdb.d/jdbc-journal.sql deleted file mode 100644 index 5c57be2..0000000 --- a/initdb.d/jdbc-journal.sql +++ /dev/null @@ -1,38 +0,0 @@ -CREATE TABLE IF NOT EXISTS event_journal( - ordering SERIAL, - deleted BOOLEAN DEFAULT false NOT NULL, - persistence_id VARCHAR(255) NOT NULL, - sequence_number BIGINT NOT NULL, - writer TEXT NOT NULL, - write_timestamp BIGINT NOT NULL, - adapter_manifest TEXT NOT NULL, - event_payload BLOB NOT NULL, - event_ser_id INTEGER NOT NULL, - event_ser_manifest TEXT NOT NULL, - meta_payload BLOB, - meta_ser_id INTEGER,meta_ser_manifest TEXT, - PRIMARY KEY(persistence_id,sequence_number) -); - -CREATE UNIQUE INDEX event_journal_ordering_idx ON event_journal(ordering); - -CREATE TABLE IF NOT EXISTS event_tag ( - event_id BIGINT UNSIGNED NOT NULL, - tag VARCHAR(255) NOT NULL, - PRIMARY KEY(event_id, tag), - FOREIGN KEY (event_id) - REFERENCES event_journal(ordering) - ON DELETE CASCADE - ); - -CREATE TABLE IF NOT EXISTS snapshot ( - persistence_id VARCHAR(255) NOT NULL, - sequence_number BIGINT NOT NULL, - created BIGINT NOT NULL, - snapshot_ser_id INTEGER NOT NULL, - snapshot_ser_manifest TEXT NOT NULL, - snapshot_payload BLOB NOT NULL, - meta_ser_id INTEGER, - meta_ser_manifest TEXT, - meta_payload BLOB, - PRIMARY KEY (persistence_id, sequence_number)); diff --git a/initdb.d/projection-schema.sql b/initdb.d/projection-schema.sql new file mode 100644 index 0000000..8d9e671 --- /dev/null +++ b/initdb.d/projection-schema.sql @@ -0,0 +1,19 @@ +CREATE TABLE IF NOT EXISTS akka_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 BOOLEAN NOT NULL, + last_updated BIGINT NOT NULL, + PRIMARY KEY(projection_name, projection_key) +); + +CREATE INDEX projection_name_index ON akka_projection_offset_store (projection_name); + +CREATE TABLE IF NOT EXISTS akka_projection_management ( + projection_name VARCHAR(255) NOT NULL, + projection_key VARCHAR(255) NOT NULL, + paused BOOLEAN NOT NULL, + last_updated BIGINT NOT NULL, + PRIMARY KEY(projection_name, projection_key) +);