public static < E extends Exception , E2 extends Exception > void parse ( final Connection conn , final String sql , final long offset , final long count , final int processThreadNum , final int queueSize , final Try . Consumer < Object [ ] , E > rowParser , final Try . Runnable < E2 > onComplete ) throws UncheckedSQLException , E , E2 { PreparedStatement stmt = null ; try { stmt = prepareStatement ( conn , sql ) ; stmt . setFetchSize ( 200 ) ; parse ( stmt , offset , count , processThreadNum , queueSize , rowParser , onComplete ) ; } catch ( SQLException e ) { throw new UncheckedSQLException ( e ) ; } finally { closeQuietly ( stmt ) ; } }
Parse the ResultSet obtained by executing query with the specified Connection and sql .