database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!6434 修复发布订阅发送发布端主备信息的逻辑bug

Browse Source 
Merge pull request !6434 from pengjiong/fix_col
This commit is contained in:
opengauss_bot
2024-09-25 01:32:55 +00:00
committed by Gitee
parent a43e48068c 7765382bd9
commit 2009605d69
5 changed files with 31 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/gausskernel/storage/replication/pgoutput/pgoutput.cpp
View File

@ -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);

7
src/test/subscription/testcase/dump_expected/dump_db_puball.pub
View File

@ -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:
--

7
src/test/subscription/testcase/dump_expected/dump_db_puball.sub
View File

@ -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:
--

9
src/test/subscription/testcase/dump_expected/dump_db_pubtable.pub
View File

@ -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;

7
src/test/subscription/testcase/dump_expected/dump_db_pubtable.sub
View File

@ -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:
--