Commitc097b27

committed

Fix more user-visible elog() calls.

Michael Paquier discovered that this could be triggered via SQL;give a nicer message instead.Patch by Michael Paquier, reviewed by Masahiko Sawada.Discussion:http://postgr.es/m/CAB7nPqQtPg+LKKtzdKN26judHcvPZ0s1gNigzOT4j8CYuuuBYg@mail.gmail.com

1 parent036166f commitc097b27Copy full SHA for c097b27

File tree

+21

-5

lines changed

+21

-5

lines changed

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,14 @@ SELECT pg_replication_origin_drop('test_decoding: temp');`
`26`	`26`	`(1 row)`
`27`	`27`
`28`	`28`	`SELECT pg_replication_origin_drop('test_decoding: temp');`
`29`		`-ERROR: cache lookup failed for replication origin 'test_decoding: temp'`
	`29`	`+ERROR: replication origin "test_decoding: temp" does not exist`
	`30`	`+-- various failure checks for undefined slots`
	`31`	`+select pg_replication_origin_advance('test_decoding: temp', '0/1');`
	`32`	`+ERROR: replication origin "test_decoding: temp" does not exist`
	`33`	`+select pg_replication_origin_session_setup('test_decoding: temp');`
	`34`	`+ERROR: replication origin "test_decoding: temp" does not exist`
	`35`	`+select pg_replication_origin_progress('test_decoding: temp', true);`
	`36`	`+ERROR: replication origin "test_decoding: temp" does not exist`
`30`	`37`	`SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot', 'test_decoding');`
`31`	`38`	`?column?`
`32`	`39`	`----------`

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -13,6 +13,11 @@ SELECT pg_replication_origin_create('test_decoding: temp');`
`13`	`13`	`SELECT pg_replication_origin_drop('test_decoding: temp');`
`14`	`14`	`SELECT pg_replication_origin_drop('test_decoding: temp');`
`15`	`15`
	`16`	`+-- various failure checks for undefined slots`
	`17`	`+select pg_replication_origin_advance('test_decoding: temp','0/1');`
	`18`	`+select pg_replication_origin_session_setup('test_decoding: temp');`
	`19`	`+select pg_replication_origin_progress('test_decoding: temp', true);`
	`20`	`+`
`16`	`21`	`SELECT'init'FROM pg_create_logical_replication_slot('regression_slot','test_decoding');`
`17`	`22`
`18`	`23`	`-- origin tx`

Lines changed: 8 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -225,8 +225,10 @@ replorigin_by_name(char *roname, bool missing_ok)`
`225`	`225`	`ReleaseSysCache(tuple);`
`226`	`226`	`}`
`227`	`227`	`elseif (!missing_ok)`
`228`		`-elog(ERROR,"cache lookup failed for replication origin '%s'",`
`229`		`-roname);`
	`228`	`+ereport(ERROR,`
	`229`	`+(errcode(ERRCODE_UNDEFINED_OBJECT),`
	`230`	`+errmsg("replication origin \"%s\" does not exist",`
	`231`	`+roname)));`
`230`	`232`
`231`	`233`	`returnroident;`
`232`	`234`	`}`
`@@ -437,8 +439,10 @@ replorigin_by_oid(RepOriginId roident, bool missing_ok, char **roname)`
`437`	`439`	`*roname=NULL;`
`438`	`440`
`439`	`441`	`if (!missing_ok)`
`440`		`-elog(ERROR,"cache lookup failed for replication origin with oid %u",`
`441`		`-roident);`
	`442`	`+ereport(ERROR,`
	`443`	`+(errcode(ERRCODE_UNDEFINED_OBJECT),`
	`444`	`+errmsg("replication origin with OID %u does not exist",`
	`445`	`+roident)));`
`442`	`446`
`443`	`447`	`return false;`
`444`	`448`	`}`

Comments

(0)