Spring Data JDBC动态WHERE子句及数据源访问问题咨询

1. 能否通过Spring Data JDBC实现动态WHERE查询？ #

可以。Spring Data JDBC支持动态构建AND组合的查询条件，主要有两种实现方式：

• 使用JdbcAggregateTemplate的findAll方法：你提到的<T> Iterable<T> findAll(Query query, Class<T> domainType)方法完全适用。通过Query对象动态添加Criteria条件，所有条件默认以AND逻辑拼接，刚好匹配你的场景。示例代码：

import org.springframework.data.jdbc.core.JdbcAggregateTemplate;
import org.springframework.data.relational.core.query.Criteria;
import org.springframework.data.relational.core.query.Query;

// 注入JdbcAggregateTemplate
private final JdbcAggregateTemplate jdbcAggregateTemplate;

public Iterable<YourDomain> dynamicSearch(String cond1, String cond2, /* 最多4个额外条件 */) {
    Query query = Query.empty();
    
    if (cond1 != null) {
        query = query.addCriteria(Criteria.where("column1").is(cond1));
    }
    if (cond2 != null) {
        query = query.addCriteria(Criteria.where("column2").is(cond2));
    }
    // 依次处理剩余最多4个条件
    
    return jdbcAggregateTemplate.findAll(query, YourDomain.class);
}

• 手动构建SQL：也可以通过JdbcTemplate手动拼接动态SQL（下文会详细说明），但JdbcAggregateTemplate的方式更简洁，且自动规避SQL注入风险。

2. 如何访问底层DataSource或JdbcTemplate直接执行查询？ #

Spring Data JDBC不依赖JPA，因此无需EntityManager，可直接注入JdbcTemplate或DataSource：

方式一：注入JdbcTemplate（推荐） #

通过构造函数注入JdbcTemplate后，即可执行自定义动态SQL。注意使用参数化查询避免SQL注入：

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

@Repository
public class CustomSearchRepository {
    private final JdbcTemplate jdbcTemplate;

    // 构造函数注入
    public CustomSearchRepository(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public List<Result> executeDynamicQuery(String cond1, String cond2) {
        StringBuilder sql = new StringBuilder("SELECT * FROM your_table WHERE 1=1");
        List<Object> params = new ArrayList<>();

        if (cond1 != null) {
            sql.append(" AND column1 = ?");
            params.add(cond1);
        }
        if (cond2 != null) {
            sql.append(" AND column2 = ?");
            params.add(cond2);
        }
        // 处理剩余最多4个条件

        return jdbcTemplate.query(sql.toString(), params.toArray(), new RowMapper<Result>() {
            @Override
            public Result mapRow(ResultSet rs, int rowNum) throws SQLException {
                Result result = new Result();
                result.setId(rs.getLong("id"));
                // 映射其他字段
                return result;
            }
        });
    }
}

方式二：注入DataSource #

若需直接管理数据库连接，可注入DataSource并手动创建JdbcTemplate：

import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository
public class CustomSearchRepository {
    private final JdbcTemplate jdbcTemplate;

    public CustomSearchRepository(DataSource dataSource) {
        this.jdbcTemplate = new JdbcTemplate(dataSource);
    }

    // 后续用法与方式一一致
}

关于JdbcAggregateTemplate.findAll方法的适用性 #

完全适用。该方法是Spring Data JDBC专为动态查询设计的API：

• 自动根据Query对象生成WHERE子句，条件默认以AND组合；
• 无需手动拼接SQL，自动处理参数绑定，避免SQL注入；
• 自动将查询结果映射到指定的实体类，无需手动编写RowMapper。

内容的提问来源于stack exchange，提问作者Thomas Lang