Package app.babylon.table.plans

Class TablePlanReadJdbc

java.lang.Object
app.babylon.table.plans.TablePlanCommon<TablePlanReadJdbc>
app.babylon.table.plans.TablePlanReadJdbc
All Implemented Interfaces:
TablePlan
public class TablePlanReadJdbc extends TablePlanCommon<TablePlanReadJdbc>
JDBC-specific read plan that materialises a ResultSet directly into a TableColumnar.

  • Constructor Details

    • TablePlanReadJdbc

      public TablePlanReadJdbc()

  • Method Details

    • withSelectedColumn

      public TablePlanReadJdbc withSelectedColumn(ColumnName columnName)

    • withSelectedColumns

      public TablePlanReadJdbc withSelectedColumns(ColumnName... columnNames)

    • withSelectedColumns

      public TablePlanReadJdbc withSelectedColumns(Collection<ColumnName> columnNames)

    • getSelectedColumns

      public Set<ColumnName> getSelectedColumns()

    • withColumnType

      public TablePlanReadJdbc withColumnType(ColumnName columnName, Column.Type columnType)

    • withColumnTypes

      public TablePlanReadJdbc withColumnTypes(Map<ColumnName,Column.Type> columnTypes)

    • getColumnType

      public Column.Type getColumnType(ColumnName columnName)

    • getColumnTypes

      public Map<ColumnName,Column.Type> getColumnTypes()

    • execute

      public TableColumnar execute(ResultSet resultSet)

    • execute

      public TableColumnar execute(RowCursor rowCursor)
      Description copied from interface: TablePlan
      Executes this plan against an already-open row supplier.

      Use this lower-level entry point when the caller already owns the live source resource and wants to control its lifetime explicitly.

      CSV example: 

      
 StreamSource streamSource = ...;
 TablePlanRead plan = new TablePlanRead();

 try (InputStream inputStream = streamSource.openStream();
         RowCursor rowCursor = RowCursorCsv.builder()
                 .withSeparator(';')
                 .build(inputStream))
 {
     TableColumnar table = plan.execute(rowCursor);
 }
      JDBC example: 
      
 PreparedStatement preparedStatement = ...;
 TablePlanRead plan = new TablePlanRead();

 try (ResultSet resultSet = preparedStatement.executeQuery();
         RowCursor rowCursor = new RowCursorResultSet(resultSet))
 {
     TableColumnar table = plan.execute(rowCursor);
 }
      Parameters:
      rowCursor - open row supplier to consume
      Returns:
      the resulting table

    • execute

      public TableColumnar execute(RowSource rowSource)
      Description copied from interface: TablePlan
      Executes this plan against a configured row source.

      This is the simplest high-level entry point when the source should handle opening and closing its own row supplier internally.

      CSV example: 

      
 StreamSource streamSource = ...;
 TablePlanRead plan = new TablePlanRead();

 TableColumnar table = plan.execute(RowSourceCsv.builder()
         .withStreamSource(streamSource)
         .withSeparator(';')
         .build());
      JDBC example: 
      
 PreparedStatement preparedStatement = ...;
 TablePlanRead plan = new TablePlanRead();

 TableColumnar table = plan.execute(RowSourceResultSet.builder()
         .withPreparedStatement(preparedStatement)
         .build());
      Parameters:
      rowSource - configured source that opens rows for this execution
      Returns:
      the resulting table

    • self

      protected TablePlanReadJdbc self()
      Specified by:
      self in class TablePlanCommon<TablePlanReadJdbc>