NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commitb75fbe9

committed

Fix dblink's failure to report correct connection name in error messages.

The DBLINK_GET_CONN and DBLINK_GET_NAMED_CONN macros did not set thesurrounding function's conname variable, causing errors to be incorrectlyreported as having occurred on the "unnamed" connection in some cases.This bug was actually visible in two cases in the regression tests,but apparently whoever added those cases wasn't paying attention.Noted by Kyotaro Horiguchi, though this is different from his proposedpatch.Back-patch to 8.4; 8.3 does not have the same type of error reportingso the patch is not relevant.

1 parent566a1d4 commitb75fbe9Copy full SHA for b75fbe9

File tree

2 files changed

+11

-5

lines changed

contrib/dblink
- dblink.c
- expected
  - dblink.out

2 files changed

+11

-5

lines changed

`‎contrib/dblink/dblink.c`

Lines changed: 9 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -153,9 +153,10 @@ typedef struct remoteConnHashEnt`
`153`	`153`	`do { \`
`154`	`154`	`char *conname_or_str = text_to_cstring(PG_GETARG_TEXT_PP(0)); \`
`155`	`155`	`rconn = getConnectionByName(conname_or_str); \`
`156`		`-if(rconn) \`
	`156`	`+if(rconn) \`
`157`	`157`	`{ \`
`158`	`158`	`conn = rconn->conn; \`
	`159`	`+conname = conname_or_str; \`
`159`	`160`	`} \`
`160`	`161`	`else \`
`161`	`162`	`{ \`
`@@ -183,9 +184,9 @@ typedef struct remoteConnHashEnt`
`183`	`184`
`184`	`185`	`#defineDBLINK_GET_NAMED_CONN \`
`185`	`186`	`do { \`
`186`		`-char *conname = text_to_cstring(PG_GETARG_TEXT_PP(0)); \`
	`187`	`+conname = text_to_cstring(PG_GETARG_TEXT_PP(0)); \`
`187`	`188`	`rconn = getConnectionByName(conname); \`
`188`		`-if(rconn) \`
	`189`	`+if(rconn) \`
`189`	`190`	`conn = rconn->conn; \`
`190`	`191`	`else \`
`191`	`192`	`DBLINK_CONN_NOT_AVAIL; \`
`@@ -598,6 +599,7 @@ PG_FUNCTION_INFO_V1(dblink_send_query);`
`598`	`599`	`Datum`
`599`	`600`	`dblink_send_query(PG_FUNCTION_ARGS)`
`600`	`601`	`{`
	`602`	`+char*conname=NULL;`
`601`	`603`	`PGconn*conn=NULL;`
`602`	`604`	`char*sql=NULL;`
`603`	`605`	`remoteConn*rconn=NULL;`
`@@ -919,6 +921,7 @@ PG_FUNCTION_INFO_V1(dblink_is_busy);`
`919`	`921`	`Datum`
`920`	`922`	`dblink_is_busy(PG_FUNCTION_ARGS)`
`921`	`923`	`{`
	`924`	`+char*conname=NULL;`
`922`	`925`	`PGconn*conn=NULL;`
`923`	`926`	`remoteConn*rconn=NULL;`
`924`	`927`
`@@ -945,6 +948,7 @@ Datum`
`945`	`948`	`dblink_cancel_query(PG_FUNCTION_ARGS)`
`946`	`949`	`{`
`947`	`950`	`intres=0;`
	`951`	`+char*conname=NULL;`
`948`	`952`	`PGconn*conn=NULL;`
`949`	`953`	`remoteConn*rconn=NULL;`
`950`	`954`	`PGcancel*cancel;`
`@@ -979,6 +983,7 @@ Datum`
`979`	`983`	`dblink_error_message(PG_FUNCTION_ARGS)`
`980`	`984`	`{`
`981`	`985`	`char*msg;`
	`986`	`+char*conname=NULL;`
`982`	`987`	`PGconn*conn=NULL;`
`983`	`988`	`remoteConn*rconn=NULL;`
`984`	`989`
`@@ -1488,6 +1493,7 @@ PG_FUNCTION_INFO_V1(dblink_get_notify);`
`1488`	`1493`	`Datum`
`1489`	`1494`	`dblink_get_notify(PG_FUNCTION_ARGS)`
`1490`	`1495`	`{`
	`1496`	`+char*conname=NULL;`
`1491`	`1497`	`PGconn*conn=NULL;`
`1492`	`1498`	`remoteConn*rconn=NULL;`
`1493`	`1499`	`PGnotify*notify;`

`‎contrib/dblink/expected/dblink.out`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -371,7 +371,7 @@ SELECT *`
`371`	`371`	`FROM dblink('myconn','SELECT * FROM foobar',false) AS t(a int, b text, c text[])`
`372`	`372`	`WHERE t.a > 7;`
`373`	`373`	`NOTICE: relation "foobar" does not exist`
`374`		`-CONTEXT: Error occurred on dblink connection named "unnamed": could not execute query.`
	`374`	`+CONTEXT: Error occurred on dblink connection named "myconn": could not execute query.`
`375`	`375`	`a \| b \| c`
`376`	`376`	`---+---+---`
`377`	`377`	`(0 rows)`
`@@ -494,7 +494,7 @@ SELECT dblink_close('myconn','rmt_foo_cursor');`
`494`	`494`	`-- this should fail because there is no open transaction`
`495`	`495`	`SELECT dblink_exec('myconn','DECLARE xact_test CURSOR FOR SELECT * FROM foo');`
`496`	`496`	`ERROR: DECLARE CURSOR can only be used in transaction blocks`
`497`		`-CONTEXT: Error occurred on dblink connection named "unnamed": could not execute command.`
	`497`	`+CONTEXT: Error occurred on dblink connection named "myconn": could not execute command.`
`498`	`498`	`-- reset remote transaction state`
`499`	`499`	`SELECT dblink_exec('myconn','ABORT');`
`500`	`500`	`dblink_exec`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitb75fbe9

File tree

2 files changed

2 files changed

`‎contrib/dblink/dblink.c`

`‎contrib/dblink/expected/dblink.out`

0 commit comments