diff --git a/src/gausskernel/storage/replication/pgoutput/pgoutput.cpp b/src/gausskernel/storage/replication/pgoutput/pgoutput.cpp index c6305fada..380542230 100644 --- a/src/gausskernel/storage/replication/pgoutput/pgoutput.cpp +++ b/src/gausskernel/storage/replication/pgoutput/pgoutput.cpp @@ -288,8 +288,8 @@ static void pgoutput_commit_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *t * Send the newest connection information to the subscriber, * when the connection information about the standby changes. */ - if ((t_thrd.publication_cxt.updateConninfoNeeded && ReplconninfoChanged()) || - t_thrd.publication_cxt.firstTimeSendConninfo) { + if (t_thrd.publication_cxt.updateConninfoNeeded && + (ReplconninfoChanged() || t_thrd.publication_cxt.firstTimeSendConninfo)) { StringInfoData standbysInfo; initStringInfo(&standbysInfo); diff --git a/src/test/subscription/testcase/dump_expected/dump_db_puball.pub b/src/test/subscription/testcase/dump_expected/dump_db_puball.pub index 77645e41c..039e05133 100644 --- a/src/test/subscription/testcase/dump_expected/dump_db_puball.pub +++ b/src/test/subscription/testcase/dump_expected/dump_db_puball.pub @@ -9,8 +9,15 @@ SET standard_conforming_strings = on; SET check_function_bodies = false; SET session_replication_role = replica; SET client_min_messages = warning; +SET enable_dump_trigger_definer = on; + +-- +-- Name: BEHAVIORCOMPAT; Type: BEHAVIORCOMPAT; Schema: -; Owner: +-- + SET behavior_compat_options = ''; + -- -- Name: LENGTHSEMANTICS; Type: LENGTHSEMANTICS; Schema: -; Owner: -- diff --git a/src/test/subscription/testcase/dump_expected/dump_db_puball.sub b/src/test/subscription/testcase/dump_expected/dump_db_puball.sub index f9aa0c66f..79d6d64a3 100644 --- a/src/test/subscription/testcase/dump_expected/dump_db_puball.sub +++ b/src/test/subscription/testcase/dump_expected/dump_db_puball.sub @@ -9,8 +9,15 @@ SET standard_conforming_strings = on; SET check_function_bodies = false; SET session_replication_role = replica; SET client_min_messages = warning; +SET enable_dump_trigger_definer = on; + +-- +-- Name: BEHAVIORCOMPAT; Type: BEHAVIORCOMPAT; Schema: -; Owner: +-- + SET behavior_compat_options = ''; + -- -- Name: LENGTHSEMANTICS; Type: LENGTHSEMANTICS; Schema: -; Owner: -- diff --git a/src/test/subscription/testcase/dump_expected/dump_db_pubtable.pub b/src/test/subscription/testcase/dump_expected/dump_db_pubtable.pub index 01c9ac5a9..8e6005712 100644 --- a/src/test/subscription/testcase/dump_expected/dump_db_pubtable.pub +++ b/src/test/subscription/testcase/dump_expected/dump_db_pubtable.pub @@ -9,8 +9,15 @@ SET standard_conforming_strings = on; SET check_function_bodies = false; SET session_replication_role = replica; SET client_min_messages = warning; +SET enable_dump_trigger_definer = on; + +-- +-- Name: BEHAVIORCOMPAT; Type: BEHAVIORCOMPAT; Schema: -; Owner: +-- + SET behavior_compat_options = ''; + -- -- Name: LENGTHSEMANTICS; Type: LENGTHSEMANTICS; Schema: -; Owner: -- @@ -51,7 +58,7 @@ COPY public.test1 (a, b) FROM stdin; -- Name: mypub; Type: PUBLICATION; Schema: -; Owner: gauss -- -CREATE PUBLICATION mypub FOR ALL TABLES WITH (publish = 'insert, update, delete',ddl = 'table'); +CREATE PUBLICATION mypub FOR ALL TABLES WITH (publish = 'insert, update, delete, truncate',ddl = 'table'); ALTER PUBLICATION mypub OWNER TO gauss; diff --git a/src/test/subscription/testcase/dump_expected/dump_db_pubtable.sub b/src/test/subscription/testcase/dump_expected/dump_db_pubtable.sub index f9aa0c66f..79d6d64a3 100644 --- a/src/test/subscription/testcase/dump_expected/dump_db_pubtable.sub +++ b/src/test/subscription/testcase/dump_expected/dump_db_pubtable.sub @@ -9,8 +9,15 @@ SET standard_conforming_strings = on; SET check_function_bodies = false; SET session_replication_role = replica; SET client_min_messages = warning; +SET enable_dump_trigger_definer = on; + +-- +-- Name: BEHAVIORCOMPAT; Type: BEHAVIORCOMPAT; Schema: -; Owner: +-- + SET behavior_compat_options = ''; + -- -- Name: LENGTHSEMANTICS; Type: LENGTHSEMANTICS; Schema: -; Owner: --