rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-07 05:42:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix develop (#166)

Browse Source
This commit is contained in:
Lei, Huang
2022-08-12 14:21:52 +08:00
committed by GitHub
parent 4098c57446
commit 28b7a7cf35
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/common/servers/tests/mysql/mysql_server_test.rs
View File

@@ -4,7 +4,9 @@ use std::time::Duration;
use async_trait::async_trait;
use catalog::memory::{MemoryCatalogList, MemoryCatalogProvider, MemorySchemaProvider};
use catalog::{CatalogList, SchemaProvider, DEFAULT_CATALOG_NAME, DEFAULT_SCHEMA_NAME};
use catalog::{
CatalogList, CatalogProvider, SchemaProvider, DEFAULT_CATALOG_NAME, DEFAULT_SCHEMA_NAME,
};
use common_recordbatch::RecordBatch;
use common_runtime::Builder as RuntimeBuilder;
use common_servers::mysql::error::{Result, RuntimeResourceSnafu};
@@ -28,7 +30,7 @@ fn create_mysql_server(table: MemTable) -> Result<Box<dyn Server>> {
let schema_provider = Arc::new(MemorySchemaProvider::new());
schema_provider.register_table(table_name, table).unwrap();
let catalog_provider = Arc::new(MemoryCatalogProvider::new());
catalog_provider.register_schema(DEFAULT_SCHEMA_NAME, schema_provider);
catalog_provider.register_schema(DEFAULT_SCHEMA_NAME.to_string(), schema_provider);
let catalog_list = Arc::new(MemoryCatalogList::default());
catalog_list.register_catalog(DEFAULT_CATALOG_NAME.to_string(), catalog_provider);
let factory = QueryEngineFactory::new(catalog_list);