You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by ds...@apache.org on 2023/12/06 16:10:14 UTC
(incubator-pekko-persistence-r2dbc) 01/01: remove pekko table prefix
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 <ds...@scaling.ch>
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: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org