Блог

Прежде чем описать свою проблему, я хочу сообщить вам, что я новичок в Spring.

Итак, здесь я просто помещаю свой пример кода, что я делаю для извлечения данных из БД с помощью JdbcTemplate :

     SimpleDriverDataSource dataSource = new SimpleDriverDataSource();
    dataSource.setDriver(new org.apache.derby.jdbc.EmbeddedDriver());
    dataSource.setUrl("jdbc:derby:C:/Users/mypc/Downloads/db-derby-10.12.1.1-bin/db-derby-10.12.1.1-bin/demo/databases/toursdb;create=true");
    JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
    List<Map<String, Object>> rows = jdbcTemplate.queryForList("select * from "   tableName);
    dataSource.getConnection().close();
    System.out.println(rows);
  

Итак, здесь я помещаю весь свой результирующий набор в Map, а затем возвращаю его. Проблема в том, что она создает исключение из памяти кучи java для большого набора данных (как я упоминал выше, опубликованный код предназначен для примера).

Теперь я изменяю эту реализацию, используя RowCallbackHandler().

Итак, мой измененный код теперь

             SimpleDriverDataSource dataSource = new SimpleDriverDataSource();
            dataSource.setDriver(new org.apache.derby.jdbc.EmbeddedDriver());
            dataSource.setUrl("jdbc:derby:C:/Users/mypc/Downloads/db-derby-10.12.1.1-bin/db-derby-10.12.1.1-bin/demo/databases/toursdb;create=true");
            JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
            jdbcTemplate.setFetchSize(200);
            jdbcTemplate.query("select * from "   tableName, new RowCallbackHandler() {
                public void processRow(ResultSet rs) throws SQLException {
                    Map<String, Object> rowInMap = new HashMap<String, Object>();
                    for (int i = 1; i <= rs.getMetaData().getColumnCount(); i  ) {
                        rowInMap.put(rs.getMetaData().getColumnName(i), rs.getObject(i));
                    }
                    System.out.println(rowInMap);
                }
            });
            dataSource.getConnection().close();
  

Но проблема в том, как использовать метод rowcallbackhandler из другого метода из другого класса, который будет лениво использовать данные, и, очевидно, он должен быть потокобезопасным. Он будет использоваться для тестирования JUnit.

Вы указываете драйверу jdbc извлекать строки по 200 и 200. Вот объяснение java-документа Statement class.

 /**
     * Gives the JDBC driver a hint as to the number of rows that should
     * be fetched from the database when more rows are needed for
     * <code>ResultSet</code> objects genrated by this <code>Statement</code>.
     * If the value specified is zero, then the hint is ignored.
     * The default value is zero.
     *
     * @param rows the number of rows to fetch
     * @exception SQLException if a database access error occurs,
     * this method is called on a closed <code>Statement</code> or the
     *        condition  <code>rows >= 0</code> is not satisfied.
     * @since 1.2
     * @see #getFetchSize
     */
  

Вы не указываете отложенную загрузку или фильтрацию в своем запросе, вы извлекаете всю таблицу. Самый простой способ — использовать условие where для фильтрации ваших записей или использовать функцию разбивки на страницы.
Для oracle вы можете добавить «where rownum < 200» к вашему запросу.
Spring jdbc основан на выборке записей, сборе внутри коллекции и возврате. Поэтому, когда вы получаете свой список, это означает, что все данные извлекаются из базы данных, а оператор закрывается. Вы можете обработать свою запись внутри класса RowCallbackHandler, однако во время вашего процесса оператор базы данных и набор результатов будут открыты.