rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2025-12-25 23:49:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: remove info log (#1483)

Browse Source
This commit is contained in:
Weny Xu
2023-04-27 15:05:22 +09:00
committed by GitHub
parent b88d8e5b82
commit 09f55e3cd8
1 changed files with 4 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/frontend/src/tests/instance_test.rs
View File

@@ -1123,13 +1123,11 @@ async fn test_execute_copy_to_s3(instance: Arc<dyn MockInstance>) {
assert!(matches!(output, Output::AffectedRows(2))); assert!(matches!(output, Output::AffectedRows(2)));
let key_id = env::var("GT_S3_ACCESS_KEY_ID").unwrap(); let key_id = env::var("GT_S3_ACCESS_KEY_ID").unwrap();
let key = env::var("GT_S3_ACCESS_KEY").unwrap(); let key = env::var("GT_S3_ACCESS_KEY").unwrap();
let url =
env::var("GT_S3_ENDPOINT_URL").unwrap_or("https://s3.amazonaws.com".to_string());
let root = uuid::Uuid::new_v4().to_string(); let root = uuid::Uuid::new_v4().to_string();
// exports // exports
let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}',ENDPOINT_URL='{}')", bucket, root, key_id, key, url); let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}')", bucket, root, key_id, key);
let output = execute_sql(&instance, &copy_to_stmt).await; let output = execute_sql(&instance, &copy_to_stmt).await;
assert!(matches!(output, Output::AffectedRows(2))); assert!(matches!(output, Output::AffectedRows(2)));
@@ -1165,11 +1163,8 @@ async fn test_execute_copy_from_s3(instance: Arc<dyn MockInstance>) {
let root = uuid::Uuid::new_v4().to_string(); let root = uuid::Uuid::new_v4().to_string();
let key_id = env::var("GT_S3_ACCESS_KEY_ID").unwrap(); let key_id = env::var("GT_S3_ACCESS_KEY_ID").unwrap();
let key = env::var("GT_S3_ACCESS_KEY").unwrap(); let key = env::var("GT_S3_ACCESS_KEY").unwrap();
let url =
env::var("GT_S3_ENDPOINT_URL").unwrap_or("https://s3.amazonaws.com".to_string());
let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}',ENDPOINT_URL='{}')", bucket, root, key_id, key, url); let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}')", bucket, root, key_id, key);
logging::info!("Copy table to s3: {}", copy_to_stmt);
let output = execute_sql(&instance, &copy_to_stmt).await; let output = execute_sql(&instance, &copy_to_stmt).await;
assert!(matches!(output, Output::AffectedRows(2))); assert!(matches!(output, Output::AffectedRows(2)));
@@ -1210,8 +1205,8 @@ async fn test_execute_copy_from_s3(instance: Arc<dyn MockInstance>) {
) )
.await; .await;
let sql = format!( let sql = format!(
"{} CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}',ENDPOINT_URL='{}')", "{} CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}')",
test.sql, key_id, key, url test.sql, key_id, key
); );
logging::info!("Running sql: {}", sql); logging::info!("Running sql: {}", sql);