com.espertech.esper.epl.spec

Class DBStatementStreamSpec

java.lang.Object

com.espertech.esper.epl.spec.StreamSpecBase

com.espertech.esper.epl.spec.DBStatementStreamSpec

All Implemented Interfaces:

StreamSpec, StreamSpecCompiled, StreamSpecRaw, MetaDefItem, Serializable

public class DBStatementStreamSpec
extends StreamSpecBase
implements StreamSpecRaw, StreamSpecCompiled, MetaDefItem, Serializable

Specification object for historical data poll via database SQL statement.

See Also:

Serialized Form

Field Summary

Fields inherited from interface com.espertech.esper.epl.spec.StreamSpecCompiled

EMPTY_STREAM_ARRAY

Constructor Summary

Constructors

Constructor and Description
DBStatementStreamSpec(String optionalStreamName, ViewSpec[] viewSpecs, String databaseName, String sqlWithSubsParams, String metadataSQL) Ctor.

Method Summary

Modifier and Type	Method and Description
StreamSpecCompiled	compile(StatementContext statementContext, Set<String> eventTypeReferences, boolean isInsertInto, Collection<Integer> assignedTypeNumberStack, boolean isJoin, boolean isContextDeclaration, boolean isOnTrigger, String optionalStreamName) Compiles a raw stream specification consisting event type information and filter expressions to an validated, optimized form for use with filter service
String	getDatabaseName() Returns the database name.
String	getMetadataSQL() Returns the optional sample metadata SQL
String	getSqlWithSubsParams() Returns the SQL with substitution parameters.

Methods inherited from class com.espertech.esper.epl.spec.StreamSpecBase

getOptionalStreamName, getOptions, getViewSpecs

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.spec.StreamSpec

getOptionalStreamName, getOptions, getViewSpecs

Constructor Detail

DBStatementStreamSpec

public DBStatementStreamSpec(String optionalStreamName,
                             ViewSpec[] viewSpecs,
                             String databaseName,
                             String sqlWithSubsParams,
                             String metadataSQL)

Ctor.

Parameters:

optionalStreamName - is a stream name optionally given to stream

viewSpecs - is a list of views onto the stream

databaseName - is the database name to poll

sqlWithSubsParams - is the SQL with placeholder parameters

metadataSQL - is the sample SQL to retrieve statement metadata, if any was supplied

Method Detail

getDatabaseName

public String getDatabaseName()

Returns the database name.

Returns:

name of database.

getSqlWithSubsParams

public String getSqlWithSubsParams()

Returns the SQL with substitution parameters.

Returns:

SQL with parameters embedded as ${stream.param}

getMetadataSQL

public String getMetadataSQL()

Returns the optional sample metadata SQL

Returns:

null if not supplied, or SQL to fire to retrieve metadata

compile

public StreamSpecCompiled compile(StatementContext statementContext,
                                  Set<String> eventTypeReferences,
                                  boolean isInsertInto,
                                  Collection<Integer> assignedTypeNumberStack,
                                  boolean isJoin,
                                  boolean isContextDeclaration,
                                  boolean isOnTrigger,
                                  String optionalStreamName)

Description copied from interface: StreamSpecRaw

Compiles a raw stream specification consisting event type information and filter expressions to an validated, optimized form for use with filter service

Specified by:

compile in interface StreamSpecRaw

Parameters:

statementContext - statement-level services

eventTypeReferences - event type names used by the statement

isInsertInto - true for insert-into

assignedTypeNumberStack - for assigning nested type numbers

isJoin - indicates whether a join or not a join

isContextDeclaration - indicates whether declared as part of the context declarations, if any

isOnTrigger - indicator for on-trigger

optionalStreamName - stream name

Returns:

compiled stream