java springboot +mybatisplus 根据参数生成新建表和字段

在使用 Spring Boot 和 MyBatis-Plus 的项目中，根据参数动态创建表和字段并不是一个常规的操作，因为数据库模式通常是在应用程序开发阶段预先设计好的。然而，如果确实需要实现这样的功能，例如构建一个可以自定义数据模型的应用程序，那么可以通过执行 SQL 语句来完成这个任务。

下面是一个简化的示例，展示了如何基于给定的参数（如表名、字段信息等）生成并执行创建表的 SQL 语句。

实现步骤

1. 定义服务接口

首先，定义一个服务接口，用于接收用户提供的表结构信息：

public interface TableCreationService {
    void createTable(String tableName, Map<String, String> columns);
}

columns 参数是一个键值对映射，其中键是列名，值是该列的数据类型（如 VARCHAR(255)、INT 等）。

2. 创建服务实现类

接下来，实现上述接口的方法：

@Service
public class TableCreationServiceImpl implements TableCreationService {

    @Autowired
    private DataSource dataSource;

    @Override
    public void createTable(String tableName, Map<String, String> columns) {
        StringBuilder sql = new StringBuilder("CREATE TABLE IF NOT EXISTS ");
        sql.append(tableName).append(" (");

        // 构建列定义部分
        List<String> columnDefs = new ArrayList<>();
        for (Map.Entry<String, String> entry : columns.entrySet()) {
            columnDefs.add(entry.getKey() + " " + entry.getValue());
        }
        sql.append(String.join(", ", columnDefs));

        // 添加主键或其他约束条件（可选）
        // sql.append(", PRIMARY KEY (id)");

        sql.append(");");

        try (Connection conn = dataSource.getConnection();
             Statement stmt = conn.createStatement()) {
            stmt.execute(sql.toString());
        } catch (SQLException e) {
            throw new RuntimeException("Failed to create table", e);
        }
    }
}

3. 控制器层处理请求

最后，在控制器层编写 RESTful API 来接收来自客户端的请求，并调用服务层的方法：

@RestController
@RequestMapping("/api/table")
public class TableController {

    @Autowired
    private TableCreationService tableCreationService;

    @PostMapping("/create")
    public ResponseEntity<String> createTable(@RequestBody Map<String, Object> payload) {
        String tableName = (String) payload.get("tableName");
        @SuppressWarnings("unchecked")
        Map<String, String> columns = (Map<String, String>) payload.get("columns");

        if (tableName == null || columns == null || columns.isEmpty()) {
            return ResponseEntity.badRequest().body("Invalid parameters");
        }

        tableCreationService.createTable(tableName, columns);

        return ResponseEntity.ok("Table created successfully.");
    }
}

4. 测试API

可以使用 Postman 或其他 HTTP 客户端发送 POST 请求到 /api/table/create，并在请求体中提供 JSON 格式的参数，如下所示：

{
  "tableName": "test_table",
  "columns": {
    "id": "INT AUTO_INCREMENT PRIMARY KEY",
    "name": "VARCHAR(255)",
    "age": "INT"
  }
}

这将尝试在数据库中创建一个名为 test_table 的新表，并包含三个字段：id、name 和 age。