Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit fa4a18a

Browse files
committed
use do_sql_command() instead of do_sql_send_command()
1 parent b7520b7 commit fa4a18a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

contrib/postgres_fdw/connection.c

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -724,7 +724,7 @@ RunDtmStatement(char const * sql, unsigned expectedStatus, DtmCommandResultHandl
724724
{
725725
if (entry->xact_depth > 0)
726726
{
727-
do_sql_send_command(entry->conn, sql);
727+
do_sql_command(entry->conn, sql);
728728
}
729729
}
730730

@@ -875,6 +875,7 @@ pgfdw_xact_callback(XactEvent event, void *arg)
875875
/* Commit all remote transactions during pre-commit */
876876
entry->changing_xact_state = true;
877877
do_sql_command(entry->conn, "COMMIT TRANSACTION");
878+
// do_sql_send_command(entry->conn, "COMMIT TRANSACTION");
878879
entry->changing_xact_state = false;
879880
continue;
880881

0 commit comments

Comments
 (0)