text:企业用户修改加入表的创建

dev.vehiclegateway
袁子龙 2024-10-04 09:31:04 +08:00
parent 709878fbab
commit a769d4da40
1 changed files with 21 additions and 7 deletions

View File

@ -104,10 +104,29 @@ public class TokenController {
boolean success = stmt.execute(createDatabaseSql); boolean success = stmt.execute(createDatabaseSql);
if (success) { if (success) {
log.info("数据库 {} 创建成功", settlement.getDatabaseName()); log.info("数据库 {} 创建失败", settlement.getDatabaseName());
} else { } 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) { } catch (SQLException e) {
@ -117,11 +136,6 @@ public class TokenController {
//企业入组 //企业入组
sysLoginService.enterprise(settlement.getDatabaseName(),settlement.getFirmName()); sysLoginService.enterprise(settlement.getDatabaseName(),settlement.getFirmName());
return Result.success(); return Result.success();
} }
} }