akka cockroachdb sql init

akka_cockroach.sql

CREATE database akka;

DROP TABLE IF EXISTS akka.journal;

CREATE TABLE IF NOT EXISTS akka.journal (
  ordering BIGSERIAL,
  persistence_id VARCHAR(255) NOT NULL,
  sequence_number BIGINT NOT NULL,
  deleted BOOLEAN DEFAULT FALSE,
  tags VARCHAR(255) DEFAULT NULL,
  message BYTEA NOT NULL,
  PRIMARY KEY(persistence_id, sequence_number)
);

CREATE UNIQUE INDEX journal_ordering_idx ON akka.journal(ordering);

DROP TABLE IF EXISTS akka.snapshot;

CREATE TABLE IF NOT EXISTS akka.snapshot (
  persistence_id VARCHAR(255) NOT NULL,
  sequence_number BIGINT NOT NULL,
  created BIGINT NOT NULL,
  snapshot BYTEA NOT NULL,
  PRIMARY KEY(persistence_id, sequence_number)
);

CREATE USER akka;

GRANT ALL on database akka to akka;
GRANT ALL on table akka.* to akka;