File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -136,6 +136,7 @@ static void MtmMakeRelationLocal(Oid relid, bool locked);
136136static List * AdjustCreateSequence (List * options );
137137
138138static void MtmProcessDDLCommand (char const * queryString , bool transactional );
139+ static void MtmFinishDDLCommand (void );
139140
140141PG_FUNCTION_INFO_V1 (mtm_make_table_local );
141142
@@ -229,13 +230,16 @@ static void
229230temp_schema_reset (void )
230231{
231232 Assert (TempDropRegistered );
233+
234+ MtmTx .contains_ddl = true;
232235 MtmProcessDDLCommand (
233236 psprintf ("select mtm.set_temp_schema('%s'); "
234237 "DROP SCHEMA IF EXISTS %s CASCADE; "
235238 "DROP SCHEMA IF EXISTS %s_toast CASCADE" ,
236239 MtmTempSchema , MtmTempSchema , MtmTempSchema ),
237- false
240+ true
238241 );
242+ MtmFinishDDLCommand ();
239243}
240244
241245/* Exit callback to call temp_schema_reset() */
You can’t perform that action at this time.
0 commit comments