Spring Boot中如何创建编译时未知表结构的完全自定义查询

这个需求我之前在做动态实体与自定义字段系统的时候碰到过，核心难点就是要应对编译时完全不确定的数据库表结构——既不知道表存不存在，也不确定目标列是否存在。下面给你一套实用的解决思路：

1. 先做运行时元数据校验（必做步骤） #

在执行查询前，必须先验证目标表和列是否存在，不然直接跑SQL会抛出异常。我们可以通过查询数据库的元数据来做这件事，用JdbcTemplate就能轻松实现：

@Autowired
private JdbcTemplate jdbcTemplate;

// 检查表是否存在
public boolean isTablePresent(String tableName) {
    // 注意：不同数据库的INFORMATION_SCHEMA语法略有差异，这里以MySQL/PostgreSQL为例
    Integer count = jdbcTemplate.queryForObject(
        "SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = ?",
        Integer.class,
        tableName.toUpperCase() // 部分数据库（比如Oracle）表名是大写的，按需调整
    );
    return count != null && count > 0;
}

// 检查指定表中的列是否存在
public boolean isColumnPresent(String tableName, String columnName) {
    Integer count = jdbcTemplate.queryForObject(
        "SELECT COUNT(*) FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = ? AND COLUMN_NAME = ?",
        Integer.class,
        tableName.toUpperCase(),
        columnName.toUpperCase()
    );
    return count != null && count > 0;
}

2. 执行动态查询的三种实用方式 #

方式一：用JdbcTemplate（最灵活推荐） #

JdbcTemplate是Spring处理原生SQL的利器，完全支持动态拼接SQL，返回结果可以用Map<String, Object>来接收，完美适配动态列的场景：

public List<Map<String, Object>> executeDynamicQuery(String tableName, List<String> targetColumns) {
    // 先做校验，避免无效查询
    if (!isTablePresent(tableName)) {
        throw new IllegalArgumentException("目标表 " + tableName + " 不存在");
    }
    for (String column : targetColumns) {
        if (!isColumnPresent(tableName, column)) {
            throw new IllegalArgumentException("表 " + tableName + " 中不存在列 " + column);
        }
    }

    // 动态构建SQL语句
    String columnsStr = String.join(", ", targetColumns);
    String sql = String.format("SELECT %s FROM %s", columnsStr, tableName);

    // 执行查询并返回结果
    return jdbcTemplate.queryForList(sql);
}

调用示例：

// 查询person表的firstname和lastname列
List<Map<String, Object>> results = executeDynamicQuery("person", Arrays.asList("firstname", "lastname"));

// 遍历处理结果
for (Map<String, Object> row : results) {
    String firstName = (String) row.get("firstname");
    String lastName = (String) row.get("lastname");
    // 这里写你的业务逻辑
}

方式二：用EntityManager执行原生查询（JPA项目适用） #

如果你的项目已经用了JPA，也可以用EntityManager来执行动态原生查询，返回结果可以是Object[]数组（按列顺序对应值）：

@PersistenceContext
private EntityManager entityManager;

public List<Object[]> executeJpaDynamicQuery(String tableName, List<String> targetColumns) {
    // 复用上面的校验逻辑
    if (!isTablePresent(tableName)) {
        throw new IllegalArgumentException("目标表 " + tableName + " 不存在");
    }
    // ...列校验省略

    String columnsStr = String.join(", ", targetColumns);
    String sql = String.format("SELECT %s FROM %s", columnsStr, tableName);

    Query query = entityManager.createNativeQuery(sql);
    return query.getResultList();
}

方式三：Spring Data JPA的@Query（不推荐） #

因为你的查询是完全动态的，编译时无法确定SQL内容，所以@Query注解的静态SQL写法基本不适用——虽然可以用SpEL表达式动态拼接，但灵活性远不如前两种方式，而且容易出错，所以不推荐这种方案。

3. 关键注意事项 #

• 防范SQL注入：上面的示例用了String.format拼接SQL，如果tableName或columns是用户输入的内容，一定要做严格的白名单校验（比如只允许字母、下划线），或者直接用前面的元数据查询来验证存在性，绝对不能直接拼接未过滤的用户输入！
• 数据库兼容性：不同数据库的元数据查询语法有差异，比如SQL Server的系统视图是sys.tables和sys.columns，需要根据你的数据库类型调整校验代码。
• 结果转换：如果需要把动态结果转换成自定义对象，可以通过反射根据列名动态给对象字段赋值，或者用BeanUtils工具类简化操作。

内容的提问来源于stack exchange，提问作者Richard Tingle