Spring JDBC Template传递Schema参数无效，如何正确在查询中使用？

JDBC预编译语句的?占位符仅支持替换查询参数值（如WHERE id = ?中的值），不能用来替换Schema、表名这类SQL标识符。你直接用?.network的写法会导致数据库解析错误——它将?视为列参数，但实际没有对应的值，因此抛出索引越界异常。

1. 字符串拼接（需注意SQL注入风险） #

如果Schema名称是可信的（非用户输入或已严格校验），可以直接拼接SQL语句：

String schema = "_2022_12_003_data";
final String sql = String.format("SELECT * FROM %s.network LIMIT 1", schema);
final List<Map<String, Object>> maps = jdbcTemplate.queryForList(sql);

注意：若Schema名称来自外部输入，必须通过白名单等方式严格校验，避免SQL注入风险。

2. 使用NamedParameterJdbcTemplate+标识符转义（更安全） #

借助PostgreSQL内置函数或Spring的标识符处理工具，既支持动态传入Schema，又能避免注入风险：

方式一：用PostgreSQL内置函数转义 #

String schema = "_2022_12_003_data";
NamedParameterJdbcTemplate namedJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate);
String sql = "SELECT * FROM quote_ident(:schema).network LIMIT 1";
Map<String, Object> params = Collections.singletonMap("schema", schema);
List<Map<String, Object>> maps = namedJdbcTemplate.queryForList(sql, params);

方式二：用Spring 6+的SqlIdentifier #

String schema = "_2022_12_003_data";
NamedParameterJdbcTemplate namedJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate);
String sql = "SELECT * FROM :schema.network LIMIT 1";
MapSqlParameterSource params = new MapSqlParameterSource();
params.addValue("schema", SqlIdentifier.of(schema), Types.OTHER);
List<Map<String, Object>> maps = namedJdbcTemplate.queryForList(sql, params);

3. 修复Connection.setSchema的用法 #

之前用Connection.setSchema失败，可能是权限或执行时机问题，可通过JdbcTemplate统一设置：

// 设置当前连接的默认Schema
jdbcTemplate.execute(connection -> {
    connection.setSchema("_2022_12_003_data");
    return null;
});
// 后续查询直接使用表名，无需指定Schema
List<Map<String, Object>> maps = jdbcTemplate.queryForList("SELECT * FROM network LIMIT 1");

需确保数据库用户拥有SET SCHEMA权限，且目标Schema确实存在。

• 直接用?传Schema：占位符不支持标识符类型，数据库无法解析，导致参数索引越界。
• 直接给JdbcTemplate传MapSqlParameterSource：JdbcTemplate不支持命名参数，需配合NamedParameterJdbcTemplate使用。

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