camel jdbc out of memory exception

Question

Я пытаюсь глотать данные из postgres в другую БД, и я использую компонент camel-jdbc для этого. У меня большой стол, поэтому я хочу читать несколько строк за раз, а не всю таблицу. поэтому мой маршрут выглядит ниже (только для целей тестирования) from (fromUri) .setBody ("select * from limit limit 10") .to ("jdbc: // myDataSource? resetAutoCommit = false & statement.fetchSize = 2") .split (body()). streaming(). process (test)

Как показано выше, я получаю только 10 строк за раз для целей тестирования, и я установил fetchSize в 2, чтобы получать только 2 строки при время. Тем не менее, я все еще получаю все 10 строк. Когда я удаляю «предел 10» из запроса, я получаю ошибку «Из памяти» непосредственно перед командой split, которая говорит мне, что пытается загрузить весь результирующий набор в память.

Что мне здесь не хватает или что я делаю неправильно?

Спасибо за помощь.

Answer 1

Я думаю, что fetchSize - это скорее намек на драйвер JDBC. Вы можете использовать параметр maxRows, чтобы действительно ограничить серверную сторону, например statement.maxRows=2. Подробнее об этих параметрах вы можете прочитать в документации Javdoc JDBC.

https://docs.oracle.com/javase/7/docs/api/java/sql/Statement.html