Springboot+JPA调用Snowflake COPY INTO插入行数为0问题排查

• 验证实际执行的SQL语句
  开启Spring Boot的SQL日志（比如logging.level.org.hibernate.SQL=DEBUG），查看最终执行的SQL是否正确拼接了文件名。重点检查@SOME_STAGE/some-folder/后的文件名是否完全匹配S3中的文件（包括大小写、后缀、特殊字符），Snowflake对路径大小写敏感，若S3文件名是Data.csv而参数传的是data.csv会导致无法识别。

• 手动在Snowflake端验证数据读取
  直接在SnowSQL或Web UI执行以下语句：

  1. 确认文件存在：LIST @SOME_STAGE/some-folder/你的真实文件名;
  2. 尝试读取文件内容：SELECT s.$1, s.$2, s.$3 FROM @SOME_STAGE/some-folder/你的真实文件名 s;
     如果这一步返回0行，说明Snowflake无法读取文件内容，问题出在stage配置或文件本身：
  • 检查stage的文件格式（默认格式是否与S3文件匹配，比如CSV/JSON/Parquet），可在查询中显式指定：SELECT ... FROM @SOME_STAGE/... s (FILE_FORMAT => '你的文件格式名');
  • 验证stage的存储集成权限：确认Snowflake使用的IAM角色拥有该S3路径的读权限。

• 检查QUERY_HISTORY获取执行细节
  由于你用的是INSERT ... SELECT而非COPY INTO，ACCOUNT_USAGE.COPY_HISTORY不会记录该操作。执行以下查询查看语句执行详情：

  SELECT QUERY_TEXT, ROWS_PRODUCED, ROWS_INSERTED, ERROR_MESSAGE, WARNING_MESSAGE
  FROM TABLE(INFORMATION_SCHEMA.QUERY_HISTORY())
  WHERE QUERY_TEXT LIKE '%INSERT INTO BLABLA%'
  ORDER BY START_TIME DESC LIMIT 10;
  

  重点看ROWS_PRODUCED（SELECT返回的行数）和ROWS_INSERTED（实际插入的行数），以及是否有警告/错误信息。

• 修正SQL中的参数绑定方式
  当前SQL中直接将:filename拼在stage路径后可能存在语法问题，Snowflake对路径变量的处理更推荐使用LOCATION参数拼接：

  @Query(value = "INSERT INTO BLABLA (A, B, C) SELECT s.$1 AS A, s.$2 AS B, s.$3 AS C FROM @SOME_STAGE (LOCATION => 'some-folder/' || :filename) s;", nativeQuery = true)
  

  或者使用字符串拼接确保路径被正确识别，避免JDBC参数绑定导致的路径解析异常。

• 修正Repository方法的返回类型
  INSERT ... SELECT语句默认返回的是插入行数（更新计数），而非结果集。你当前的返回类型List<Map<String, String>>可能无法正确获取实际插入行数，导致误判为0行。建议改为：

  @Modifying(clearAutomatically = true, flushAutomatically = true)
  int copyFromStage(@Param("filename") String filename);
  

  通过返回的int值确认实际插入行数，避免返回类型不匹配带来的误解。

• 检查文件的行格式与数据兼容性
  即使文件非空，若数据格式与表字段不匹配（比如分隔符错误、存在表头行、数据类型不兼容），SELECT s.$1...会返回null或空值，导致INSERT时没有有效行。可在查询中添加SKIP_HEADER = 1等参数处理表头：

  SELECT ... FROM @SOME_STAGE/... s (FILE_FORMAT => (TYPE => 'CSV', SKIP_HEADER => 1, FIELD_DELIMITER => ','));
  

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