Package app.babylon.table.io

Class RowCursorResultSet

java.lang.Object
app.babylon.table.io.RowCursorResultSet
All Implemented Interfaces:
RowCursor, AutoCloseable
public class RowCursorResultSet extends Object implements RowCursor
Supplies rows from a caller-owned ResultSet.

This supplier adapts a caller-owned ResultSet. Closing the supplier is a no-op; the caller remains responsible for the lifecycle of the underlying JDBC resources.

Example: 


 Connection connection = ...;
 try (PreparedStatement statement = connection
         .prepareStatement("select city, amount from trades where trade_date >= ?"))
 {
     statement.setDate(1, java.sql.Date.valueOf("2026-01-01"));
     try (ResultSet resultSet = statement.executeQuery())
     {
         RowCursor supplier = new RowCursorResultSet(resultSet);

         ColumnDefinition[] columns = supplier.columns();
         while (supplier.next())
         {
             Row row = supplier.current();
         }
     }
 }
This implementation is a demonstration of what is possible and the likely structure given the ResultSet API. Different drivers may still have quirks that require special implementations.

  • Constructor Details

    • RowCursorResultSet

      public RowCursorResultSet(ResultSet resultSet)

  • Method Details

    • columns

      public ColumnDefinition[] columns()
      Description copied from interface: RowCursor
      Returns the source-side column definitions exposed by this cursor.

      A non-null type here is not just metadata. It can be used by downstream row consumers to choose a more direct builder from the start, bypassing intermediate String materialization when the source type already has an efficient slice-based parser.

      That is most useful for primitive numerics and for special object types whose direct parser is genuinely better than first building a string dictionary.

      Specified by:
      columns in interface RowCursor
      Returns:
      the source column definitions in source order

    • next

      public boolean next()
      Specified by:
      next in interface RowCursor

    • current

      public Row current()
      Specified by:
      current in interface RowCursor

    • close

      public void close() throws SQLException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface RowCursor
      Throws:
      SQLException