new ProcessUtilityHook signature

kelvich · kelvich · commit 39f73f5fa484 · 2017-04-04T12:33:16.000+03:00
diff --git a/contrib/test_decoding/test_decoding.c b/contrib/test_decoding/test_decoding.c
@@ -102,7 +102,8 @@ static void test_decoding_xact_callback(XactEvent event, void *arg);
 
 static void test_decoding_process_utility(PlannedStmt *pstmt,
 					const char *queryString, ProcessUtilityContext context,
-					ParamListInfo params, DestReceiver *dest, char *completionTag);
+					ParamListInfo params, QueryEnvironment *queryEnv,
+					DestReceiver *dest, char *completionTag);
 
 static bool test_decoding_twophase_commit();
 
@@ -188,7 +189,8 @@ test_decoding_executor_finish(QueryDesc *queryDesc)
 static void
 test_decoding_process_utility(PlannedStmt *pstmt,
 					const char *queryString, ProcessUtilityContext context,
-					ParamListInfo params, DestReceiver *dest, char *completionTag)
+					ParamListInfo params, QueryEnvironment *queryEnv,
+					DestReceiver *dest, char *completionTag)
 {
 	Node	   *parsetree = pstmt->utilityStmt;
 
@@ -267,13 +269,13 @@ test_decoding_process_utility(PlannedStmt *pstmt,
 
 	if (PreviousProcessUtilityHook != NULL)
 	{
-		PreviousProcessUtilityHook(pstmt, queryString, context,
-								   params, dest, completionTag);
+		PreviousProcessUtilityHook(pstmt, queryString, context, params, queryEnv,
+								   dest, completionTag);
 	}
 	else
 	{
-		standard_ProcessUtility(pstmt, queryString, context,
-								params, dest, completionTag);
+		standard_ProcessUtility(pstmt, queryString, context, params, queryEnv,
+								dest, completionTag);
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,8 @@ static void test_decoding_xact_callback(XactEvent event, void *arg);`
`102`	`102`
`103`	`103`	`static void test_decoding_process_utility(PlannedStmt *pstmt,`
`104`	`104`	`const char *queryString, ProcessUtilityContext context,`
`105`		`- ParamListInfo params, DestReceiver dest, char completionTag);`
	`105`	`+ ParamListInfo params, QueryEnvironment *queryEnv,`
	`106`	`+ DestReceiver dest, char completionTag);`
`106`	`107`
`107`	`108`	`static bool test_decoding_twophase_commit();`
`108`	`109`
`@@ -188,7 +189,8 @@ test_decoding_executor_finish(QueryDesc *queryDesc)`
`188`	`189`	`static void`
`189`	`190`	`test_decoding_process_utility(PlannedStmt *pstmt,`
`190`	`191`	`const char *queryString, ProcessUtilityContext context,`
`191`		`- ParamListInfo params, DestReceiver dest, char completionTag)`
	`192`	`+ ParamListInfo params, QueryEnvironment *queryEnv,`
	`193`	`+ DestReceiver dest, char completionTag)`
`192`	`194`	`{`
`193`	`195`	`Node *parsetree = pstmt->utilityStmt;`
`194`	`196`
`@@ -267,13 +269,13 @@ test_decoding_process_utility(PlannedStmt *pstmt,`
`267`	`269`
`268`	`270`	`if (PreviousProcessUtilityHook != NULL)`
`269`	`271`	`{`
`270`		`- PreviousProcessUtilityHook(pstmt, queryString, context,`
`271`		`- params, dest, completionTag);`
	`272`	`+ PreviousProcessUtilityHook(pstmt, queryString, context, params, queryEnv,`
	`273`	`+ dest, completionTag);`
`272`	`274`	`}`
`273`	`275`	`else`
`274`	`276`	`{`
`275`		`- standard_ProcessUtility(pstmt, queryString, context,`
`276`		`- params, dest, completionTag);`
	`277`	`+ standard_ProcessUtility(pstmt, queryString, context, params, queryEnv,`
	`278`	`+ dest, completionTag);`
`277`	`279`	`}`
`278`	`280`	`}`
`279`	`281`