We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f78b55e commit 482e6eaCopy full SHA for 482e6ea
src/datanode/src/instance/sql.rs
@@ -138,13 +138,11 @@ impl Instance {
138
unimplemented!("SHOW CREATE TABLE is unimplemented yet");
139
}
140
QueryStatement::Sql(Statement::Use(schema)) => {
141
- let catalog = query_ctx
142
- .current_catalog()
143
- .as_deref()
144
- .unwrap_or(DEFAULT_CATALOG_NAME);
+ let catalog = query_ctx.current_catalog();
+ let catalog = catalog.as_deref().unwrap_or(DEFAULT_CATALOG_NAME);
145
146
ensure!(
147
- self.is_valid_schema(&catalog, &schema)?,
+ self.is_valid_schema(catalog, &schema)?,
148
error::DatabaseNotFoundSnafu { catalog, schema }
149
);
150
0 commit comments