xyz.cofe.sql

Class StreamQueryWriter

java.lang.Object

xyz.cofe.sql.StreamQueryWriter

All Implemented Interfaces:

QueryWriter

public class StreamQueryWriter
extends Object
implements QueryWriter

Пишет данные в QueryStream

Author:

nt.gocha@gmail.com

Field Summary

Fields

Modifier and Type	Field and Description
protected QueryStream	queryStream

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	begin() Начало записи
void	end() Конец записи
QueryStream	getQueryStream() Возвращает поток для записи SQL данных
void	setQueryStream(QueryStream queryStream) Указывает поток для записи SQL данных
void	writeError(Throwable err) Запись ошибки
void	writeGeneratedKeys(ResultSet rs) Записть сгенерированных ключей
void	writeMessage(SQLWarning message) Запись сообщения
void	writeResultSet(ResultSet rs, int rsIndex) Запись ResultSet
protected void	writeResultSet(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 Detail

queryStream

protected QueryStream queryStream

Constructor Detail

StreamQueryWriter

public StreamQueryWriter()

Конструктор

StreamQueryWriter

public StreamQueryWriter(QueryStream qs)

Конструктор

Parameters:

qs - поток SQL куда будет записан результат выполнения

Method Detail

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(ResultSet rs,
                           int rsIndex)

Description copied from interface: QueryWriter

Запись ResultSet

Specified by:

writeResultSet in interface QueryWriter

Parameters:

rs - набор данных

rsIndex - номер набора данных

writeResultSet

protected void writeResultSet(ResultSet rs,
                              int rsIndex,
                              boolean generated)

writeGeneratedKeys

public void writeGeneratedKeys(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(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(Throwable err)

Description copied from interface: QueryWriter

Запись ошибки

Specified by:

writeError in interface QueryWriter

Parameters:

err - ошибка