Java SpringBoot项目中如何检测Snowflake表是否为空并获取返回值

你当前的代码存在两个核心问题：

1. 调用query()方法时没有处理返回的结果集，查询结果被直接丢弃
2. 直接将存储SQL语句的字符串变量和返回值"0"做等值判断，逻辑不成立

正确实现代码 #

使用Spring JdbcTemplate提供的queryForObject()方法获取单行单列的查询结果：

String checkEmptySql = "SELECT CASE WHEN EXISTS(SELECT 1 FROM \"TEST_DATABASE\".\"PUBLIC\".\"USER_TABLE_TEMP\") THEN 0 ELSE 1 END AS IsEmpty;";
// 注意：必须和创建临时表使用同一个JdbcTemplate实例，保证在同一个数据库会话中
Integer isEmptyFlag = jdbcTemplatePerBrand.get(brandAfterMigration)
        .queryForObject(checkEmptySql, Integer.class);

// 空指针兼容处理，查询结果为null时默认按空表处理
isEmptyFlag = isEmptyFlag == null ? 1 : isEmptyFlag;

if (isEmptyFlag == 1) {
    // 表为空，直接返回错误
    throw new RuntimeException("用户无匹配数据，终止导出");
}
// 非空时执行导出到S3的逻辑
doExportCsvToS3();

注意事项 #

• Snowflake的临时表是会话级别的，仅对创建它的数据库会话可见，必须确保创建临时表、检测表空、导出数据三个操作使用同一个连接会话，否则会出现找不到临时表的错误
• 若需要更优雅的空值处理，可以使用Optional封装返回结果：

Integer isEmptyFlag = Optional.ofNullable(jdbcTemplatePerBrand.get(brandAfterMigration)
                .queryForObject(checkEmptySql, Integer.class))
        .orElse(1);

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