Проблема Spring Boot + JPA + Snowflake COPY INTOJAVA

Программисты JAVA общаются здесь
Anonymous
Проблема Spring Boot + JPA + Snowflake COPY INTO

Сообщение Anonymous »

Я пытаюсь выполнить INSERT/COPY INTO из Java в Snowflake через этап S3.
Файл в S3 существует/файл не пуст/таблица существует/у меня есть все разрешения для этой таблицы.
Я использую Java 21, Springboot 3.3.2 и Snowflake-jdbc 3.18.0
Процесс всегда завершается успешно, но с ответом «количество вставленных строк=0».< /p>
Мой класс репозитория выглядит так:

Код: Выделить всё

@Repository
public interface BlahBlahRepository extends JpaRepository {

@Query(value = "INSERT INTO BLABLA (A, B, C) SELECT s.$1 AS A, s.$2 AS B, s.$3 AS C FROM @SOME_STAGE/some-folder/:filename s;", nativeQuery = true)
@Modifying(clearAutomatically = true, flushAutomatically = true)
List copyFromStage(@Param("filename") String filename);
}
Я пытался экспериментировать с транзакциями/изоляцией/и т.д. Ничего не помогло.
При проверке ACCOUNT_USAGE.COPY_HISTORY (для COPY INTO) записей не было (кстати, я знаю о задержке распространения ~ 45 минут). Кроме того, для COPY INTO я использовал FORCE=TRUE — не помогло.
Есть идеи, почему эта конкретная команда не работает? Все остальные «обычные» команды sql работают хорошо.

Подробнее здесь: https://stackoverflow.com/questions/790 ... into-issue

Вернуться в «JAVA»