CREATE DATABASE "db_remote_txn";
\c db_remote_txn
CREATE EXTENSION timescaledb;

CREATE SCHEMA IF NOT EXISTS test;
GRANT USAGE ON SCHEMA test TO PUBLIC;

CREATE OR REPLACE FUNCTION test.remote_exec(srv_name name[], command text)
RETURNS VOID
AS '/Volumes/Work/postgresql-15.0/build/lib/timescaledb-tsl-2.9.0-dev.so', 'ts_remote_exec'
LANGUAGE C;

CREATE OR REPLACE FUNCTION test.remote_exec_get_result_strings(srv_name name[], command text)
RETURNS TABLE("table_record" CSTRING[])
AS '/Volumes/Work/postgresql-15.0/build/lib/timescaledb-tsl-2.9.0-dev.so', 'ts_remote_exec_get_result_strings'
LANGUAGE C;

CREATE OR REPLACE FUNCTION remote_node_killer_set_event(text, text)
RETURNS VOID
AS '/Volumes/Work/postgresql-15.0/build/lib/timescaledb-tsl-2.9.0-dev.so', 'ts_remote_node_killer_set_event'
LANGUAGE C;

CREATE OR REPLACE FUNCTION test_remote_txn_persistent_record(srv_name name)
RETURNS VOID
AS '/Volumes/Work/postgresql-15.0/build/lib/timescaledb-tsl-2.9.0-dev.so', 'ts_test_remote_txn_persistent_record'
LANGUAGE C;

CREATE OR REPLACE FUNCTION debug_waitpoint_enable(TEXT)
RETURNS VOID
AS '/Volumes/Work/postgresql-15.0/build/lib/timescaledb-2.9.0-dev.so', 'ts_debug_point_enable'
LANGUAGE C VOLATILE STRICT;

CREATE OR REPLACE FUNCTION debug_waitpoint_release(TEXT)
RETURNS VOID
AS '/Volumes/Work/postgresql-15.0/build/lib/timescaledb-2.9.0-dev.so', 'ts_debug_point_release'
LANGUAGE C VOLATILE STRICT;

CREATE OR REPLACE FUNCTION add_loopback_server(
    server_name            NAME,
    host                   TEXT = 'localhost',
    database               NAME = current_database(),
    port                   INTEGER = inet_server_port(),
    if_not_exists          BOOLEAN = FALSE,
    bootstrap              BOOLEAN = TRUE,
    password               TEXT = NULL
) RETURNS TABLE(server_name NAME, host TEXT, port INTEGER, database NAME,
                server_created BOOL, database_created BOOL, extension_created BOOL)
AS '/Volumes/Work/postgresql-15.0/build/lib/timescaledb-tsl-2.9.0-dev.so', 'ts_unchecked_add_data_node'
LANGUAGE C;

SELECT server_name, database, server_created, database_created, extension_created FROM add_loopback_server('loopback', database => 'db_remote_txn', bootstrap => false);
SELECT server_name, database, server_created, database_created, extension_created FROM add_loopback_server('loopback2', database => 'db_remote_txn', bootstrap => false);

drop table "S 1"."T 1";
CREATE SCHEMA "S 1";
CREATE TABLE "S 1"."T 1" (
    "C 1" int NOT NULL,
    c2 int NOT NULL,
    c3 text,
    c4 timestamptz,
    c5 timestamp,
    c6 varchar(10),
    c7 char(10),
    CONSTRAINT t1_pkey PRIMARY KEY ("C 1")
);
ANALYZE "S 1"."T 1";

INSERT INTO "S 1"."T 1"
    SELECT id,
           id % 10,
           to_char(id, 'FM00000'),
           '1970-01-01'::timestamptz + ((id % 100) || ' days')::interval,
           '1970-01-01'::timestamp + ((id % 100) || ' days')::interval,
           id % 10,
           id % 10
    FROM generate_series(1, 1000) id;

SELECT test_remote_txn_persistent_record('loopback');
SET timescaledb.enable_2pc = false;

BEGIN;
    SELECT test.remote_exec('{loopback}', $$ INSERT INTO "S 1"."T 1" VALUES (20001,1,'bleh', '2001-01-01', '2001-01-01', 'bleh') $$);
COMMIT;

_timescaledb_internal.show_connection_cache() ORDER BY 1,4;
BEGIN;
    SELECT remote_node_killer_set_event('pre-commit', 'loopback');
    SELECT debug_waitpoint_enable('remote_conn_xact_end');
    SELECT test.remote_exec('{loopback}', $$ INSERT INTO "S 1"."T 1" VALUES (20003,1,'bleh', '2001-01-01', '2001-01-01', 'bleh') $$);

COMMIT;

SELECT debug_waitpoint_release('remote_conn_xact_end');

commit af7d9fe4d63e727e4d326b0c8ee09974f3d214e4
Author: Matvey Arye <mat@timescale.com>
Date:   Thu Jun 7 15:51:07 2018 -0400

    Add remote txns support (1pc)
    
    This commit adds the ability to open remote transactions
    that share transactional semantics with the ongoing local
    transaction. This is done by adding txn hooks to the local
    transaction that performs txn commands on remote nodes.
    
    This commit adds the 1pc variant of the commit protocol.
    A 2-pc variant is going to be added in an upcoming PR.
    The 1pc variant exists mostly for performance testing (i.e. how much is the 2pc penalty).
    But, there are also cases where 1pc is good enough (non-critical
    data and/or data backed by Kafka).
    
    Note that the remote_txn test is not run during sanitizer tests due to
    an apparent bug in PostgreSQL. (The test fails on an assertion of a
    global variable `AbortStartTime`, which is non-atomic although read
    across the ServerLoop and signal handlers.)