Skip to content

Commit 02008f5

Browse files
committed
Fix system tables query
Signed-off-by: Xuanwo <[email protected]>
1 parent ebd9afb commit 02008f5

File tree

5 files changed

+14
-14
lines changed

5 files changed

+14
-14
lines changed

src/query/sql/src/planner/binder/ddl/dictionary.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -400,7 +400,7 @@ impl Binder {
400400
) -> Result<Plan> {
401401
let ShowDictionariesStmt { database, limit } = stmt;
402402

403-
let mut select_builder = SelectBuilder::from("system.dictionaries");
403+
let mut select_builder = SelectBuilder::from("default.system.dictionaries");
404404

405405
select_builder
406406
.with_column("database AS Database")

src/query/sql/src/planner/binder/ddl/stream.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -127,9 +127,9 @@ impl Binder {
127127
let database = self.check_database_exist(catalog, database).await?;
128128

129129
let mut select_builder = if *full {
130-
SelectBuilder::from("system.streams")
130+
SelectBuilder::from("default.system.streams")
131131
} else {
132-
SelectBuilder::from("system.streams_terse")
132+
SelectBuilder::from("default.system.streams_terse")
133133
};
134134

135135
if *full {
@@ -200,7 +200,7 @@ impl Binder {
200200
let (catalog, database, stream) =
201201
self.normalize_object_identifier_triple(catalog, database, stream);
202202

203-
let mut select_builder = SelectBuilder::from("system.streams");
203+
let mut select_builder = SelectBuilder::from("default.system.streams");
204204
select_builder
205205
.with_column("created_on")
206206
.with_column("name")

src/query/sql/src/planner/binder/ddl/table.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -174,9 +174,9 @@ impl Binder {
174174
let database = self.check_database_exist(catalog, database).await?;
175175

176176
let mut select_builder = if stmt.with_history {
177-
SelectBuilder::from("system.tables_with_history")
177+
SelectBuilder::from("default.system.tables_with_history")
178178
} else {
179-
SelectBuilder::from("system.tables")
179+
SelectBuilder::from("default.system.tables")
180180
};
181181

182182
if *full {
@@ -318,21 +318,21 @@ impl Binder {
318318
// Use `system.tables` AS the "base" table to construct the result-set of `SHOW TABLE STATUS ..`
319319
//
320320
// To constraint the schema of the final result-set,
321-
// `(select ${select_cols} from system.tables where ..)`
321+
// `(select ${select_cols} from default.system.tables where ..)`
322322
// is used AS a derived table.
323323
// (unlike mysql, alias of derived table is not required in databend).
324324
let query = match limit {
325325
None => format!(
326-
"SELECT {} FROM system.tables WHERE database = '{}' ORDER BY Name",
326+
"SELECT {} FROM default.system.tables WHERE database = '{}' ORDER BY Name",
327327
select_cols, database
328328
),
329329
Some(ShowLimit::Like { pattern }) => format!(
330-
"SELECT * from (SELECT {} FROM system.tables WHERE database = '{}') \
330+
"SELECT * from (SELECT {} FROM default.system.tables WHERE database = '{}') \
331331
WHERE Name LIKE '{}' ORDER BY Name",
332332
select_cols, database, pattern
333333
),
334334
Some(ShowLimit::Where { selection }) => format!(
335-
"SELECT * from (SELECT {} FROM system.tables WHERE database = '{}') \
335+
"SELECT * from (SELECT {} FROM default.system.tables WHERE database = '{}') \
336336
WHERE ({}) ORDER BY Name",
337337
select_cols, database, selection
338338
),
@@ -353,7 +353,7 @@ impl Binder {
353353

354354
let database = self.check_database_exist(&None, database).await?;
355355

356-
let mut select_builder = SelectBuilder::from("system.tables_with_history");
356+
let mut select_builder = SelectBuilder::from("default.system.tables_with_history");
357357

358358
select_builder
359359
.with_column("name AS Tables")

src/query/sql/src/planner/binder/ddl/view.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -157,9 +157,9 @@ impl Binder {
157157
let database = self.check_database_exist(catalog, database).await?;
158158

159159
let mut select_builder = if stmt.with_history {
160-
SelectBuilder::from("system.views_with_history")
160+
SelectBuilder::from("default.system.views_with_history")
161161
} else {
162-
SelectBuilder::from("system.views")
162+
SelectBuilder::from("default.system.views")
163163
};
164164

165165
if *full {

src/query/sql/src/planner/binder/ddl/virtual_column.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -385,7 +385,7 @@ impl Binder {
385385
}
386386
};
387387

388-
let mut select_builder = SelectBuilder::from("system.virtual_columns");
388+
let mut select_builder = SelectBuilder::from("default.system.virtual_columns");
389389
select_builder
390390
.with_column("database")
391391
.with_column("table")

0 commit comments

Comments
 (0)