修复初始化创建 mysql 表失败

veoco · Jun 13, 2024 · 64a2d2a · 64a2d2a
1 parent 6676f35
commit 64a2d2a
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/src/init.rs b/src/init.rs
@@ -313,11 +313,18 @@ pub async fn init_table(state: &AppState) {
             "#
         }
     };
-    let _ = state
-        .conn
-        .execute(Statement::from_string(db_backend, sql))
-        .await
-        .expect("database already exists");
+    let stmts = sql.split(";");
+    for stmt in stmts {
+        let stmt = stmt.trim();
+        if stmt.is_empty() {
+            continue;
+        }
+        let _ = state
+            .conn
+            .execute(Statement::from_string(db_backend, format!("{};", stmt)))
+            .await
+            .expect("database already exists");
+    }
 }
 
 pub async fn init_admin(state: &AppState, user_register: UserRegister) {