This is an automated email from the ASF dual-hosted git repository. dsc pushed a commit to branch rm-table-prefix in repository https://gitbox.apache.org/repos/asf/incubator-pekko-persistence-r2dbc.git
commit c670079beec71c6a429fd6607b41b80baec07594 Author: Daniel Schroeter <[email protected]> AuthorDate: Wed Dec 6 17:10:02 2023 +0100 remove pekko table prefix --- ddl-scripts/create_tables_postgres.sql | 6 +++--- ddl-scripts/create_tables_yugabyte.sql | 6 +++--- ddl-scripts/drop_tables_postgres.sql | 6 +++--- docs/src/main/paradox/projection.md | 2 +- projection/src/main/resources/reference.conf | 6 +++--- 5 files changed, 13 insertions(+), 13 deletions(-) diff --git a/ddl-scripts/create_tables_postgres.sql b/ddl-scripts/create_tables_postgres.sql index 4b50ad9..ebb91c6 100644 --- a/ddl-scripts/create_tables_postgres.sql +++ b/ddl-scripts/create_tables_postgres.sql @@ -61,7 +61,7 @@ CREATE INDEX IF NOT EXISTS durable_state_slice_idx ON durable_state(slice, entit -- Primitive offset types are stored in this table. -- If only timestamp based offsets are used this table is optional. -- Configure pekko.projection.r2dbc.offset-store.offset-table="" if the table is not created. -CREATE TABLE IF NOT EXISTS pekko_projection_offset_store ( +CREATE TABLE IF NOT EXISTS projection_offset_store ( projection_name VARCHAR(255) NOT NULL, projection_key VARCHAR(255) NOT NULL, current_offset VARCHAR(255) NOT NULL, @@ -72,7 +72,7 @@ CREATE TABLE IF NOT EXISTS pekko_projection_offset_store ( ); -- Timestamp based offsets are stored in this table. -CREATE TABLE IF NOT EXISTS pekko_projection_timestamp_offset_store ( +CREATE TABLE IF NOT EXISTS projection_timestamp_offset_store ( projection_name VARCHAR(255) NOT NULL, projection_key VARCHAR(255) NOT NULL, slice INT NOT NULL, @@ -86,7 +86,7 @@ CREATE TABLE IF NOT EXISTS pekko_projection_timestamp_offset_store ( PRIMARY KEY(slice, projection_name, timestamp_offset, persistence_id, seq_nr) ); -CREATE TABLE IF NOT EXISTS pekko_projection_management ( +CREATE TABLE IF NOT EXISTS projection_management ( projection_name VARCHAR(255) NOT NULL, projection_key VARCHAR(255) NOT NULL, paused BOOLEAN NOT NULL, diff --git a/ddl-scripts/create_tables_yugabyte.sql b/ddl-scripts/create_tables_yugabyte.sql index 2412cdd..af5528c 100644 --- a/ddl-scripts/create_tables_yugabyte.sql +++ b/ddl-scripts/create_tables_yugabyte.sql @@ -63,7 +63,7 @@ CREATE INDEX IF NOT EXISTS durable_state_slice_idx ON durable_state(slice ASC, e -- Primitive offset types are stored in this table. -- If only timestamp based offsets are used this table is optional. -- Configure pekko.projection.r2dbc.offset-store.offset-table="" if the table is not created. -CREATE TABLE IF NOT EXISTS pekko_projection_offset_store ( +CREATE TABLE IF NOT EXISTS projection_offset_store ( projection_name VARCHAR(255) NOT NULL, projection_key VARCHAR(255) NOT NULL, current_offset VARCHAR(255) NOT NULL, @@ -75,7 +75,7 @@ CREATE TABLE IF NOT EXISTS pekko_projection_offset_store ( -- Timestamp based offsets are stored in this table. -CREATE TABLE IF NOT EXISTS pekko_projection_timestamp_offset_store ( +CREATE TABLE IF NOT EXISTS projection_timestamp_offset_store ( projection_name VARCHAR(255) NOT NULL, projection_key VARCHAR(255) NOT NULL, slice INT NOT NULL, @@ -89,7 +89,7 @@ CREATE TABLE IF NOT EXISTS pekko_projection_timestamp_offset_store ( PRIMARY KEY(slice ASC, projection_name ASC, timestamp_offset ASC, persistence_id ASC, seq_nr ASC) ) SPLIT AT VALUES ((127), (255), (383), (511), (639), (767), (895)); -CREATE TABLE IF NOT EXISTS pekko_projection_management ( +CREATE TABLE IF NOT EXISTS projection_management ( projection_name VARCHAR(255) NOT NULL, projection_key VARCHAR(255) NOT NULL, paused BOOLEAN NOT NULL, diff --git a/ddl-scripts/drop_tables_postgres.sql b/ddl-scripts/drop_tables_postgres.sql index 6ffb3d3..2fdd4ad 100644 --- a/ddl-scripts/drop_tables_postgres.sql +++ b/ddl-scripts/drop_tables_postgres.sql @@ -2,6 +2,6 @@ DROP INDEX event_journal_slice_idx; DROP TABLE IF EXISTS event_journal; DROP TABLE IF EXISTS snapshot; DROP TABLE IF EXISTS durable_state; -DROP TABLE IF EXISTS pekko_projection_offset_store; -DROP TABLE IF EXISTS pekko_projection_timestamp_offset_store; -DROP TABLE IF EXISTS pekko_projection_management; +DROP TABLE IF EXISTS projection_offset_store; +DROP TABLE IF EXISTS projection_timestamp_offset_store; +DROP TABLE IF EXISTS projection_management; diff --git a/docs/src/main/paradox/projection.md b/docs/src/main/paradox/projection.md index 974e06a..f01c4cc 100644 --- a/docs/src/main/paradox/projection.md +++ b/docs/src/main/paradox/projection.md @@ -39,7 +39,7 @@ The table below shows `pekko-projection-r2dbc`'s direct dependencies, and the se ## Schema -The `pekko_projection_offset_store`, `pekko_projection_timestamp_offset_store` and `pekko_projection_management` tables +The `projection_offset_store`, `projection_timestamp_offset_store` and `projection_management` tables need to be created in the configured database, see schema definition in @ref:[Creating the schema](getting-started.md#schema). ## Configuration diff --git a/projection/src/main/resources/reference.conf b/projection/src/main/resources/reference.conf index 305935a..cf8a83b 100644 --- a/projection/src/main/resources/reference.conf +++ b/projection/src/main/resources/reference.conf @@ -13,13 +13,13 @@ pekko.projection.r2dbc { schema = "" # the database table name for the offset store, # can be set to "" if only timestamp offsets are used and table is not created - offset-table = "pekko_projection_offset_store" + offset-table = "projection_offset_store" # the database table name for the offset store - timestamp-offset-table = "pekko_projection_timestamp_offset_store" + timestamp-offset-table = "projection_timestamp_offset_store" # the database table name for the projection manangement data - management-table = "pekko_projection_management" + management-table = "projection_management" # The offset store will keep track of persistence ids and sequence numbers # within this time window from latest offset. --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
