fmt

Author: JasonShin

src/ts_generator/errors.rs

@@ -46,7 +46,9 @@ pub enum TsGeneratorError {
   TableNotFoundInSchema { table: String },
   #[error("[E019] Failed to infer table name while processing WHERE clause. Query: `{query}`")]
   TableNameInferenceFailedInWhere { query: String },
-  #[error("[E020] Invalid column reference '{column}' for table '{table}'. Ensure the column exists in the table schema.")]
+  #[error(
+    "[E020] Invalid column reference '{column}' for table '{table}'. Ensure the column exists in the table schema."
+  )]
   InvalidColumnReference { column: String, table: String },
   #[error("Unknown error: `{0}`")]
   Unknown(String),

src/ts_generator/sql_parser/expressions/translate_expr.rs

@@ -148,11 +148,7 @@ pub async fn get_sql_query_param(
   match (column_name, expr_placeholder, table_name) {
     (Some(column_name), Some(expr_placeholder), Some(table_name)) => {
       let table_names = vec![table_name.as_str()];
-      let columns = DB_SCHEMA
-        .lock()
-        .await
-        .fetch_table(&table_names, db_conn)
-        .await;
+      let columns = DB_SCHEMA.lock().await.fetch_table(&table_names, db_conn).await;
 
       if columns.is_none() {
         error!(

src/ts_generator/sql_parser/translate_insert.rs

@@ -56,7 +56,11 @@ pub async fn translate_insert(
               .value;
 
             let field = table_details.get(match_col.as_str()).ok_or_else(|| {
-              let available_columns = table_details.keys().map(|k| k.as_str()).collect::<Vec<_>>().join(", ");
+              let available_columns = table_details
+                .keys()
+                .map(|k| k.as_str())
+                .collect::<Vec<_>>()
+                .join(", ");
               TsGeneratorError::ColumnNotFoundInTable {
                 column: match_col.clone(),
                 table: table_name.to_string(),
@@ -109,9 +113,10 @@ pub async fn translate_insert(
     SetExpr::Delete(delete) => translate_stmt(ts_query, &delete, None, conn).await?,
     SetExpr::Merge(merge) => translate_stmt(ts_query, &merge, None, conn).await?,
     SetExpr::Table(table) => {
-      return Err(TsGeneratorError::TableExpressionInInsertStatement(
-        format!("INSERT INTO {} ... FROM {}", table_name, table),
-      ));
+      return Err(TsGeneratorError::TableExpressionInInsertStatement(format!(
+        "INSERT INTO {} ... FROM {}",
+        table_name, table
+      )));
     }
   }