Package org.yamcs.yarch.streamsql

Interface StreamSqlStatement

All Known Implementing Classes:

AlterSequenceStatement, AlterTableStatement, CloseStreamStatement, CreateInputStreamStatement, CreateOutputStreamStatement, CreateStreamStatement, CreateTableStatement, DeleteStatement, DescribeStatement, DropTableStatement, InsertStatement, MergeStatement, SelectTableStatement, ShowDatabasesStatement, ShowEnginesStatement, ShowSequencesStatement, ShowStreamsStatement, ShowStreamStatement, ShowTablesStatement, SimpleStreamSqlStatement, UpdateTableStatement

public interface StreamSqlStatement

Tag interface for all StreamSQL statements.

Method Summary

Modifier and Type	Method	Description
StreamSqlResult	execute(YarchDatabaseInstance ydb)	Execute query and return a result.
default void	execute(YarchDatabaseInstance ydb, ResultListener resultListener)	Execute query and send the results to the result listener.
void	execute(YarchDatabaseInstance ydb, ResultListener resultListener, long limit)	Execute query and limit the number of results returned.

Method Details

execute

void execute(YarchDatabaseInstance ydb,
 ResultListener resultListener,
 long limit)
      throws StreamSqlException

Execute query and limit the number of results returned.

Note that the update/delete/drop table queries that return one row are executed even if the limit is 0. The output however is suppressed when the limit is set to 0.

Parameters:

ydb -

resultListener -

limit -

Throws:

StreamSqlException

execute

default void execute(YarchDatabaseInstance ydb,
 ResultListener resultListener)
              throws StreamSqlException

Execute query and send the results to the result listener.

Parameters:

ydb -

resultListener -

Throws:

StreamSqlException

execute

StreamSqlResult execute(YarchDatabaseInstance ydb)
                 throws StreamSqlException

Execute query and return a result. The result can be closed at any time.

Parameters:

ydb -

Returns:

Throws:

StreamSqlException