19
19
*
20
20
* https://github.com/dnvriend/akka-persistence-jdbc/blob/master/src/test/resources/schema/postgres/postgres-schema.sql
21
21
*/
22
+ DROP TABLE IF EXISTS event_journal;
23
+ DROP TABLE IF EXISTS event_tag;
24
+ DROP TABLE IF EXISTS event_snapshot;
25
+ DROP TABLE IF EXISTS durable_state;
22
26
23
- DROP TABLE IF EXISTS akka .event_journal ;
24
-
25
- DROP TABLE IF EXISTS akka .event_snapshot ;
26
-
27
- CREATE TABLE IF NOT EXISTS akka .event_journal (
27
+ CREATE TABLE IF NOT EXISTS event_journal(
28
28
ordering BIGSERIAL ,
29
29
persistence_id VARCHAR (255 ) NOT NULL ,
30
30
sequence_number BIGINT NOT NULL ,
@@ -45,9 +45,9 @@ CREATE TABLE IF NOT EXISTS akka.event_journal(
45
45
PRIMARY KEY (persistence_id, sequence_number)
46
46
);
47
47
48
- CREATE UNIQUE INDEX event_journal_ordering_idx ON akka . event_journal (ordering);
48
+ CREATE UNIQUE INDEX event_journal_ordering_idx ON event_journal(ordering);
49
49
50
- CREATE TABLE IF NOT EXISTS akka . event_tag (
50
+ CREATE TABLE IF NOT EXISTS event_tag(
51
51
event_id BIGINT ,
52
52
tag VARCHAR (256 ),
53
53
PRIMARY KEY (event_id, tag),
@@ -57,7 +57,7 @@ CREATE TABLE IF NOT EXISTS akka.event_tag(
57
57
ON DELETE CASCADE
58
58
);
59
59
60
- CREATE TABLE IF NOT EXISTS akka . snapshot (
60
+ CREATE TABLE IF NOT EXISTS snapshot (
61
61
persistence_id VARCHAR (255 ) NOT NULL ,
62
62
sequence_number BIGINT NOT NULL ,
63
63
created BIGINT NOT NULL ,
@@ -73,7 +73,7 @@ CREATE TABLE IF NOT EXISTS akka.snapshot (
73
73
PRIMARY KEY (persistence_id, sequence_number)
74
74
);
75
75
76
- CREATE TABLE IF NOT EXISTS akka . durable_state (
76
+ CREATE TABLE IF NOT EXISTS durable_state (
77
77
global_offset BIGSERIAL ,
78
78
persistence_id VARCHAR (255 ) NOT NULL ,
79
79
revision BIGINT NOT NULL ,
@@ -84,5 +84,5 @@ CREATE TABLE IF NOT EXISTS akka.durable_state (
84
84
state_timestamp BIGINT NOT NULL ,
85
85
PRIMARY KEY (persistence_id)
86
86
);
87
- CREATE INDEX state_tag_idx on akka . durable_state (tag);
88
- CREATE INDEX state_global_offset_idx on akka . durable_state (global_offset);
87
+ CREATE INDEX state_tag_idx on durable_state (tag);
88
+ CREATE INDEX state_global_offset_idx on durable_state (global_offset);
0 commit comments