Skip to content

Commit e968d05

Browse files
committed
change IVM query from SELECT to INSERT
1 parent cc5bb30 commit e968d05

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

include/ivm_rewrite_rule.hpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,6 @@ class IVMRewriteRule : public OptimizerExtension {
305305
}
306306

307307
// generate the optimized logical plan
308-
string augmented_view_query = "INSERT INTO delta_"+ view + " "+ view_entry->query->ToString();
309308
Parser parser;
310309
parser.ParseQuery(view_entry->query->ToString());
311310
auto statement = parser.statements[0].get();

ivm_extension.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ string UpsertDeltaQueries(ClientContext &context, const FunctionParameters &para
9999

100100
string query_create_view_delta_table = "CREATE TABLE delta_"+view_name+" AS (SELECT * FROM "+view_name+" LIMIT 0);";
101101
string query_add_multiplicity_col = "ALTER TABLE delta_"+view_name+" ADD COLUMN _duckdb_ivm_multiplicity BOOL;";
102-
string ivm_query = "SELECT * from DoIVM('"+view_catalog_name+"','"+view_schema_name+"','"+view_name+"');";
102+
string ivm_query = "INSERT INTO delta_"+view_name+" SELECT * from DoIVM('"+view_catalog_name+"','"+view_schema_name+"','"+view_name+"');";
103103
string select_query = "SELECT * FROM delta_"+view_name+";";
104104
string query = query_create_view_delta_table + query_add_multiplicity_col + ivm_query + select_query;
105105
return query;

0 commit comments

Comments
 (0)