public abstract class BaseStoreProvider
extends com.tibco.cep.runtime.service.store.AbstractStoreProvider
BEStoreProvider
is an entry point for implementing custom stores.Modifier and Type | Method and Description |
---|---|
abstract void |
commit()
Commits the transaction.
|
abstract void |
delete(java.util.List rowsList)
Delete the record from the implemented store.
|
abstract void |
delete(StoreRowHolder row)
Delete the records from the implemented store.
|
abstract void |
endTransaction()
Ends the transaction.
|
java.lang.String |
getFilterBuilderClass()
Returns the fully qualified class name of
StoreFilterBuilder . |
abstract StoreDataTypeMapper |
getStoreDataTypeMapper()
Returns the handle for
StoreDataTypeMapper |
StoreProperties |
getStoreProperties()
Sets database specific properties.
|
protected abstract void |
initConnection(java.util.Properties storeConfigProperties)
This method should be used to initialize connection objects and connection pools.
|
protected abstract boolean |
isConnectionAlive()
Set if connection is a alive or not.
|
boolean |
isTransactionEnabled()
Returns true by default.
|
abstract StoreRowHolder |
read(StoreRowHolder query)
Read the record from the implemented store.
|
abstract java.util.List |
readAll(StoreRowHolder query)
Read the records from the implemented store.
|
abstract java.util.List |
readAvg(StoreRowHolder query)
Reads the avg value from the implemented store.
|
abstract java.util.List |
readCount(StoreRowHolder query)
Reads the count value from the implemented store.
|
abstract java.util.List |
readMax(StoreRowHolder query)
Reads the max value from the implemented store.
|
abstract java.util.List |
readMin(StoreRowHolder query)
Reads the min value from the implemented store.
|
abstract java.util.List |
readSum(StoreRowHolder query)
Reads the sum value from the implemented store.
|
abstract void |
rollback()
Rollbacks the transaction.
|
abstract void |
startTransaction()
Starts the transaction.
|
abstract void |
update(java.util.List dataHolder)
Updates the records to the implemented store.
|
abstract void |
write(java.util.List dataHolder)
Writes the records to the implemented store.
|
public abstract StoreDataTypeMapper getStoreDataTypeMapper()
StoreDataTypeMapper
public boolean isTransactionEnabled()
public abstract void startTransaction()
public abstract void endTransaction()
public abstract void commit()
public abstract void rollback()
public java.lang.String getFilterBuilderClass()
StoreFilterBuilder
. Override this method in case StoreFilterBuilder
is extended.getFilterBuilderClass
in class com.tibco.cep.runtime.service.store.AbstractStoreProvider
protected abstract void initConnection(java.util.Properties storeConfigProperties)
storeConfigProperties
- property values configured in the cdd.java.lang.Exception
public abstract void write(java.util.List dataHolder)
dataHolder
- list containing information about data to write. See StoreRowHolder
java.lang.Exception
public abstract void update(java.util.List dataHolder)
dataHolder
- list containing information about data to update. See StoreRowHolder
java.lang.Exception
public abstract StoreRowHolder read(StoreRowHolder query)
query
- provides information about table name, select fields, and filter fields.java.lang.Exception
public abstract java.util.List readAll(StoreRowHolder query)
query
- provides information about table name, select fields, and filter fields.java.lang.Exception
public abstract void delete(java.util.List rowsList)
rowsList
- gives information about query parameters to delete data.java.lang.Exception
public abstract void delete(StoreRowHolder row)
row
- gives information about query parameters to delete data.java.lang.Exception
public abstract java.util.List readMin(StoreRowHolder query)
query
- gives information about query parameters.java.lang.Exception
public abstract java.util.List readMax(StoreRowHolder query)
query
- gives information about query parameters.java.lang.Exception
public abstract java.util.List readAvg(StoreRowHolder query)
query
- gives information about queryparameters .java.lang.Exception
public abstract java.util.List readCount(StoreRowHolder query)
query
- gives information about query parameters.java.lang.Exception
public abstract java.util.List readSum(StoreRowHolder query)
query
- gives information about query parameters.java.lang.Exception
public StoreProperties getStoreProperties()
java.lang.Exception
protected abstract boolean isConnectionAlive()
java.lang.Exception