@@ -34,23 +34,9 @@ public PostgreSqlQueryExecutor(PostgreSqlQueryConfiguration configuration, Akka.
34
34
{
35
35
var storedAs = configuration . StoredAs . ToString ( ) . ToUpperInvariant ( ) ;
36
36
37
- CreateEventsJournalSql = configuration . UseBigIntPrimaryKey
38
- ? $@ "
37
+ CreateEventsJournalSql = $@ "
39
38
CREATE TABLE IF NOT EXISTS { Configuration . FullJournalTableName } (
40
- { Configuration . OrderingColumnName } BIGINT NOT NULL GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
41
- { Configuration . PersistenceIdColumnName } VARCHAR(255) NOT NULL,
42
- { Configuration . SequenceNrColumnName } BIGINT NOT NULL,
43
- { Configuration . IsDeletedColumnName } BOOLEAN NOT NULL,
44
- { Configuration . TimestampColumnName } BIGINT NOT NULL,
45
- { Configuration . ManifestColumnName } VARCHAR(500) NOT NULL,
46
- { Configuration . PayloadColumnName } { storedAs } NOT NULL,
47
- { Configuration . TagsColumnName } VARCHAR(100) NULL,
48
- { Configuration . SerializerIdColumnName } INTEGER NULL,
49
- CONSTRAINT { Configuration . JournalEventsTableName } _uq UNIQUE ({ Configuration . PersistenceIdColumnName } , { Configuration . SequenceNrColumnName } )
50
- );"
51
- : $@ "
52
- CREATE TABLE IF NOT EXISTS { Configuration . FullJournalTableName } (
53
- { Configuration . OrderingColumnName } BIGSERIAL NOT NULL PRIMARY KEY,
39
+ { Configuration . OrderingColumnName } { ( configuration . UseBigIntPrimaryKey ? "BIGINT GENERATED ALWAYS AS IDENTITY" : "BIGSERIAL" ) } NOT NULL PRIMARY KEY,
54
40
{ Configuration . PersistenceIdColumnName } VARCHAR(255) NOT NULL,
55
41
{ Configuration . SequenceNrColumnName } BIGINT NOT NULL,
56
42
{ Configuration . IsDeletedColumnName } BOOLEAN NOT NULL,
0 commit comments