Update broker.rs

mjm918 · Jun 5, 2024 · 2059f4c · 2059f4c
1 parent fd9a845
commit 2059f4c
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/src/broker.rs b/src/broker.rs
@@ -182,11 +182,14 @@ impl Broker {
 
     pub async fn definitions(&mut self) -> Result<()> {
         self.definition.clear();
-        let sql = r#"
-            SELECT COLUMN_NAME, DATA_TYPE
-            FROM INFORMATION_SCHEMA.COLUMNS
-            WHERE TABLE_NAME = 'IV' ORDER BY ORDINAL_POSITION;
-        "#;
+        let sql = format!(
+	        r#"
+	        SELECT COLUMN_NAME, DATA_TYPE
+	        FROM INFORMATION_SCHEMA.COLUMNS
+	        WHERE TABLE_NAME = '{}' ORDER BY ORDINAL_POSITION;
+	        "#,
+	        self.table
+	    );
         let client = self.pool.client().await;
         let mut conn = client.expect("Mssql Connection is closed");
         let stream = conn.simple_query(sql).await?;