diff --git a/crates/dbx-core/src/db/postgres.rs b/crates/dbx-core/src/db/postgres.rs index 4f0a2e72e9..69c218e8d9 100644 --- a/crates/dbx-core/src/db/postgres.rs +++ b/crates/dbx-core/src/db/postgres.rs @@ -6427,7 +6427,8 @@ async fn get_columns_with_sql( pub async fn get_columns(pool: &Pool, schema: &str, table: &str) -> Result, String> { let client = checkout_postgres_client(pool, None, super::connection_timeout()).await?; let tiers = [POSTGRES_COLUMNS_SQL, POSTGRES_COLUMNS_COMPAT_SQL, POSTGRES_COLUMNS_INFORMATION_SCHEMA_SQL]; - query_with_non_empty_compat_fallback("get_columns", &tiers, |sql| get_columns_with_sql(&client, sql, schema, table)).await + query_with_non_empty_compat_fallback("get_columns", &tiers, |sql| get_columns_with_sql(&client, sql, schema, table)) + .await } fn pg_quote_literal(value: &str) -> String { diff --git a/crates/dbx-core/src/schema.rs b/crates/dbx-core/src/schema.rs index ba5e6004db..b3571d768a 100644 --- a/crates/dbx-core/src/schema.rs +++ b/crates/dbx-core/src/schema.rs @@ -1711,12 +1711,8 @@ async fn external_driver_oracle_columns_via_sql( } } -fn should_query_oracle_columns_via_sql_first( - db_type: &DatabaseType, - client_session_id: Option<&str>, -) -> bool { - *db_type == DatabaseType::Oracle - && client_session_id.is_some_and(|session_id| !session_id.trim().is_empty()) +fn should_query_oracle_columns_via_sql_first(db_type: &DatabaseType, client_session_id: Option<&str>) -> bool { + *db_type == DatabaseType::Oracle && client_session_id.is_some_and(|session_id| !session_id.trim().is_empty()) } fn oracle_object_statistics_sql(schema: &str) -> String {