Package org.yamcs.yarch.streamsql

Class SelectTableStatement

java.lang.Object

org.yamcs.yarch.streamsql.SelectTableStatement

All Implemented Interfaces:

StreamSqlStatement

public class SelectTableStatement
extends Object
implements StreamSqlStatement

Constructor Summary

Constructors

Constructor	Description
SelectTableStatement(SelectExpression expression)

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.yarch.streamsql.StreamSqlStatement

execute

Constructor Details

SelectTableStatement

public SelectTableStatement(SelectExpression expression)

Method Details

execute

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

Description copied from interface: StreamSqlStatement

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.

Specified by:

execute in interface StreamSqlStatement

Throws:

StreamSqlException

execute

public StreamSqlResult execute(YarchDatabaseInstance ydb)
                        throws StreamSqlException

Description copied from interface: StreamSqlStatement

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

Specified by:

execute in interface StreamSqlStatement

Returns:

Throws:

StreamSqlException