SpringBoot动态表操作服务的实现代码

spring.datasource.url=jdbc:mysql://localhost:3306/your_database
spring.datasource.username=root
spring.datasource.password=password
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.platform=mysql
spring.jpa.database-platform=org.hibernate.dialect.MySQL8Dialect

public String createTable(String tableName) {
    // 初始化的表结构
    String createTableSql = "CREATE TABLE IF NOT EXISTS `" + tableName + "` ("
            + "`id` varchar(50) COLLATE utf8mb4_general_ci NOT NULL, "
            + "`create_id` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL, "
            + "`create_time` datetime DEFAULT NULL, "
            + "`update_id` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL, "
            + "`update_time` datetime DEFAULT NULL, "
            + "PRIMARY KEY (`id`)"
            + ") ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;";

    try {
        jdbcTemplate.execute(createTableSql);
        return "Table created successfully";
    } catch (Exception e) {
        e.printStackTrace();
        return "Error creating table: " + e.getMessage();
    }
}

public String addColumn(String tableName, String columnName, String columnType) {
    // 拼接 ALTER TABLE 语句
    String alterTableSql = "ALTER TABLE " + tableName + " ADD COLUMN " + columnName + " " + columnType;
    try {
        // 执行 SQL 语句
        jdbcTemplate.execute(alterTableSql);
        return "Column added successfully";
    } catch (Exception e) {
        e.printStackTrace();
        return "Error adding column: " + e.getMessage();
    }
}

public String dropColumn(String tableName, String columnName) {
    // 拼接 ALTER TABLE 语句
    String alterTableSql = "ALTER TABLE " + tableName + " DROP COLUMN " + columnName;
    try {
        // 执行 SQL 语句
        jdbcTemplate.execute(alterTableSql);
        return "Column dropped successfully";
    } catch (Exception e) {
        e.printStackTrace();
        return "Error dropping column: " + e.getMessage();
    }
}

public String modifyColumnType(String tableName, String columnName, String newColumnType) {
    // 拼接 ALTER TABLE 语句
    String alterTableSql = "ALTER TABLE " + tableName + " MODIFY COLUMN " + columnName + " " + newColumnType;
    try {
        // 执行 SQL 语句
        jdbcTemplate.execute(alterTableSql);
        return "Column type modified successfully";
    } catch (Exception e) {
        e.printStackTrace();
        return "Error modifying column type: " + e.getMessage();
    }
}

public String dropTable(String tableName) {
    // 拼接 DROP TABLE 语句
    String dropTableSql = "DROP TABLE IF EXISTS " + tableName;
    try {
        // 执行 SQL 语句
        jdbcTemplate.execute(dropTableSql);
        return "Table dropped successfully";
    } catch (Exception e) {
        e.printStackTrace();
        return "Error dropping table: " + e.getMessage();
    }
}