From a769d4da408c67e11d36e29fe398ba753e477547 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=A2=81=E5=AD=90=E9=BE=99?= <14096380+qwe963852@user.noreply.gitee.com> Date: Fri, 4 Oct 2024 09:31:04 +0800 Subject: [PATCH] =?UTF-8?q?text:=E4=BC=81=E4=B8=9A=E7=94=A8=E6=88=B7?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=8A=A0=E5=85=A5=E8=A1=A8=E7=9A=84=E5=88=9B?= =?UTF-8?q?=E5=BB=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../muyu/auth/controller/TokenController.java | 28 ++++++++++++++----- 1 file changed, 21 insertions(+), 7 deletions(-) diff --git a/cloud-auth/src/main/java/com/muyu/auth/controller/TokenController.java b/cloud-auth/src/main/java/com/muyu/auth/controller/TokenController.java index 500acc4..3ae446d 100644 --- a/cloud-auth/src/main/java/com/muyu/auth/controller/TokenController.java +++ b/cloud-auth/src/main/java/com/muyu/auth/controller/TokenController.java @@ -104,10 +104,29 @@ public class TokenController { boolean success = stmt.execute(createDatabaseSql); if (success) { - log.info("数据库 {} 创建成功", settlement.getDatabaseName()); + log.info("数据库 {} 创建失败", settlement.getDatabaseName()); } else { - log.warn("数据库 {} 创建失败", settlement.getDatabaseName()); + log.warn("数据库 {} 创建成功", settlement.getDatabaseName()); + // 切换到新创建的数据库 + String useDatabaseSql = "USE " + settlement.getDatabaseName(); + stmt.execute(useDatabaseSql); + // 创建表 + String createTableSql = "CREATE TABLE IF NOT EXISTS `car_type` (\n" + + " `id` int NOT NULL AUTO_INCREMENT COMMENT '车辆类型Id',\n" + + " `type_name` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '车辆类型',\n" + + " `template_id` int NULL DEFAULT NULL COMMENT '报文模版Id',\n" + + " PRIMARY KEY (`id`) USING BTREE\n" + + ") ENGINE = InnoDB AUTO_INCREMENT = 4 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '车辆类型' ROW_FORMAT = Dynamic;"; + stmt.execute(createTableSql); + + // 插入数据 + String insertDataSql1 = "INSERT INTO `car_type` VALUES (1, '货车', 1);"; + String insertDataSql2 = "INSERT INTO `car_type` VALUES (2, '轿车', NULL);"; + String insertDataSql3 = "INSERT INTO `car_type` VALUES (3, 'SUV', NULL);"; + stmt.execute(insertDataSql1); + stmt.execute(insertDataSql2); + stmt.execute(insertDataSql3); } } catch (SQLException e) { @@ -117,11 +136,6 @@ public class TokenController { //企业入组 sysLoginService.enterprise(settlement.getDatabaseName(),settlement.getFirmName()); - - - - - return Result.success(); } }