Package xyz.cofe.sql.stream

Class StreamQueryWriter

java.lang.Object
xyz.cofe.sql.stream.StreamQueryWriter
All Implemented Interfaces:
QueryWriter
public class StreamQueryWriter
extends java.lang.Object
implements QueryWriter
Пишет данные в QueryStream
Author:
nt.gocha@gmail.com

  • Field Summary

    Fields 
    Modifier and Type Field Description
    protected QueryStream queryStream  

  • Constructor Summary

    Constructors 
    Constructor Description
    StreamQueryWriter()
    Конструктор
    StreamQueryWriter​(QueryStream qs)
    Конструктор

  • Method Summary

    Modifier and Type Method Description
    void begin()
    Начало записи
    void end()
    Конец записи
    QueryStream getQueryStream()
    Возвращает поток для записи SQL данных
    void setQueryStream​(QueryStream queryStream)
    Указывает поток для записи SQL данных
    void writeError​(java.lang.Throwable err)
    Запись ошибки
    void writeGeneratedKeys​(java.sql.ResultSet rs)
    Записть сгенерированных ключей
    void writeMessage​(java.sql.SQLWarning message)
    Запись сообщения
    void writeResultSet​(java.sql.ResultSet rs, int rsIndex)
    Запись ResultSet
    protected void writeResultSet​(java.sql.ResultSet rs, int rsIndex, boolean generated)  
    void writeUpdateCount​(int count)
    Запись счетчика обновленных строк

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

    • StreamQueryWriter

      public StreamQueryWriter()
      Конструктор

    • StreamQueryWriter

      public StreamQueryWriter​(QueryStream qs)
      Конструктор
      Parameters:
      qs - поток SQL куда будет записан результат выполнения

  • Method Details

    • getQueryStream

      public QueryStream getQueryStream()
      Возвращает поток для записи SQL данных
      Returns:
      поток для записи

    • setQueryStream

      public void setQueryStream​(QueryStream queryStream)
      Указывает поток для записи SQL данных
      Parameters:
      queryStream - поток для записи

    • begin

      public void begin()
      Description copied from interface: QueryWriter
      Начало записи
      Specified by:
      begin in interface QueryWriter

    • writeResultSet

      public void writeResultSet​(java.sql.ResultSet rs, int rsIndex)
      Description copied from interface: QueryWriter
      Запись ResultSet
      Specified by:
      writeResultSet in interface QueryWriter
      Parameters:
      rs - набор данных
      rsIndex - номер набора данных

    • writeResultSet

      protected void writeResultSet​(java.sql.ResultSet rs, int rsIndex, boolean generated)

    • writeGeneratedKeys

      public void writeGeneratedKeys​(java.sql.ResultSet rs)
      Description copied from interface: QueryWriter
      Записть сгенерированных ключей
      Specified by:
      writeGeneratedKeys in interface QueryWriter
      Parameters:
      rs - ключи

    • writeUpdateCount

      public void writeUpdateCount​(int count)
      Description copied from interface: QueryWriter
      Запись счетчика обновленных строк
      Specified by:
      writeUpdateCount in interface QueryWriter
      Parameters:
      count - кол-во строк

    • writeMessage

      public void writeMessage​(java.sql.SQLWarning message)
      Description copied from interface: QueryWriter
      Запись сообщения
      Specified by:
      writeMessage in interface QueryWriter
      Parameters:
      message - сообщение

    • end

      public void end()
      Description copied from interface: QueryWriter
      Конец записи
      Specified by:
      end in interface QueryWriter

    • writeError

      public void writeError​(java.lang.Throwable err)
      Description copied from interface: QueryWriter
      Запись ошибки
      Specified by:
      writeError in interface QueryWriter
      Parameters:
      err - ошибка