QdMG4sWx

1CREATE database akka;
2
3DROP TABLE IF EXISTS akka.journal;
4
5CREATE TABLE IF NOT EXISTS akka.journal (
6  ordering BIGSERIAL,
7  persistence_id VARCHAR(255) NOT NULL,
8  sequence_number BIGINT NOT NULL,
9  deleted BOOLEAN DEFAULT FALSE,
10  tags VARCHAR(255) DEFAULT NULL,
11  message BYTEA NOT NULL,
12  PRIMARY KEY(persistence_id, sequence_number)
13);
14
15CREATE UNIQUE INDEX journal_ordering_idx ON akka.journal(ordering);
16
17DROP TABLE IF EXISTS akka.snapshot;
18
19CREATE TABLE IF NOT EXISTS akka.snapshot (
20  persistence_id VARCHAR(255) NOT NULL,
21  sequence_number BIGINT NOT NULL,
22  created BIGINT NOT NULL,
23  snapshot BYTEA NOT NULL,
24  PRIMARY KEY(persistence_id, sequence_number)
25);
26
27CREATE USER akka;
28
29GRANT ALL on database akka to akka;
30GRANT ALL on table akka.* to akka;