FRAMES NO FRAMES | |||||||
| |||||||
SUMMARY: IMPORT | CONSTANT | MEMBER | ACTION | DETAIL: IMPORT | CONSTANT | MEMBER | ACTION |
Constant summary | |
---|---|
string | NOT_SET := "ADBC_NULL"
Constant for param of open database actions. |
Action summary | |
---|---|
void |
closeDatabase(action<com.apama.database.Connection, string> callback)
Closes a connection to the database. |
void |
closeDatabaseFull(boolean force, dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)
Close a connection to the database. This action allows you to pass in any extra parameters. |
integer |
commitRequest(action<com.apama.database.Connection, integer, string, string> callback)
Send a commit request to the database. |
integer |
commitRequestFull(string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, integer, string, string> callback)
Send a commit request to the database. This action allows you to pass in any extra parameters. This will result in anything outstanding being committed to the database. |
void |
createStoreStatement(string name, string tableName, string statementString, sequence<string> inputTypes, dictionary<integer, string> inputToNameMap, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)
If your application will use a prepared statement or a stored procedure then you need to first create a store statement on a relational database for the specified table. |
void |
deleteStoreStatement(string statementName, string tableName, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)
Remove the store statment from the system for this table. |
void |
forceCloseDatabase(action<com.apama.database.Connection, string> callback)
Closes a connection to the database, even if there are any Queries or commands still in progress. |
string |
getDatabaseURL()
Returns the URL of the open database. |
integer |
getDbId()
Returns the Id of the open database. |
string |
getServiceId()
Returns the service Id of the open database. |
void |
initPreSpawnContext(context preSpawnContext)
Set context that is current prior to spawning. |
void |
onConcludeRecovery()
OnConcludeRecovery is called after the recovery process has been completed, including all non persistent monitors having being re-loaded. |
void |
openDatabase(string serviceId, string databaseURL, string user, string password, string autoCommit, action<com.apama.database.Connection, string> callback)
Opens the connection to a database. |
void |
openDatabaseFull(string serviceId, string databaseURL, string user, string password, string autoCommit, boolean readOnly, dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)
Open a connection to a database. This action allows you to pass in any extra parameters. |
void |
openDatabaseShared(string serviceId, string databaseURL, string user, string password, string autoCommit, boolean readOnly, dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)
Open a shared connection to a database. |
void |
reopen()
Reopen the connection to a database.
|
void |
reopenWithACK(action<com.apama.database.Connection, string> callback)
Reopen the connection to a database. |
void |
reset()
Reset the state of the connection. |
integer |
rollbackRequest(action<com.apama.database.Connection, integer, string, string> callback)
Rollback uncommitted changes to database. |
integer |
rollbackRequestFull(string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, integer, string, string> callback)
Rollback uncommitted changes to database. This action allows you to pass in any extra parameters. |
void |
runCommand(string commandString, string token, action<com.apama.database.Connection, string, string> callback)
Run the supplied command against the database. |
void |
runCommandFull(string commandString, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)
Run the supplied command against the database. This action allows you to pass in any extra parameters. |
void |
setStoreErrorCallback(action<com.apama.database.Connection, integer, integer, string> callback)
To specify an action to be used when an error is reported. |
void |
stopAllQueries(action<com.apama.database.Connection, string> callback)
Stop all queries that are currently running. |
void |
stopAllQueriesFull(dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)
Stop all Queries that are currently running. This action allows you to pass in any extra parameters. |
integer |
storeData(string tableName, string statementName, dictionary<string, string> fields, dictionary<string, string> extraParams)
Store the data contained in the fields dictionary without an acknowledgement. |
void |
storeDataWithAck(string tableName, string statementName, dictionary<string, string> fields, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)
Store the data contained in the fields dictionary with an acknowledgement. |
integer |
storeDataWithAckId(string tableName, string statementName, dictionary<string, string> fields, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)
Store the data contained in the fields dictionary with an acknowledgement. |
integer |
storeEvent(float timestamp, string eventString, string tableName, string statementName, string timeColumn, dictionary<string, string> extraParams)
Store the event contained in the event Data without an acknowledgement. |
void |
storeEventWithAck(float timestamp, string eventString, string tableName, string statementName, string timeColumn, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)
Store the event contained in the event Data with an acknowledgement. |
Constant detail |
---|
string NOT_SET := "ADBC_NULL"Constant for param of open database actions.
Action detail |
---|
void closeDatabase(action<com.apama.database.Connection, string> callback)Closes a connection to the database.
void closeDatabaseFull(boolean force, dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)Close a connection to the database. This action allows you to pass in any extra parameters.
integer commitRequest(action<com.apama.database.Connection, integer, string, string> callback)Send a commit request to the database.
integer commitRequestFull(string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, integer, string, string> callback)Send a commit request to the database. This action allows you to pass in any extra parameters. This will result in anything outstanding being committed to the database.
void createStoreStatement(string name, string tableName, string statementString, sequence<string> inputTypes, dictionary<integer, string> inputToNameMap, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)If your application will use a prepared statement or a stored procedure then you need to first create a store statement on a relational database for the specified table.
void deleteStoreStatement(string statementName, string tableName, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)Remove the store statment from the system for this table.
void forceCloseDatabase(action<com.apama.database.Connection, string> callback)Closes a connection to the database, even if there are any Queries or commands still in progress.
string getDatabaseURL()Returns the URL of the open database.
integer getDbId()Returns the Id of the open database.
string getServiceId()Returns the service Id of the open database.
void initPreSpawnContext(context preSpawnContext)Set context that is current prior to spawning.
void onConcludeRecovery()OnConcludeRecovery is called after the recovery process has been completed, including all non persistent monitors having being re-loaded.
void openDatabase(string serviceId, string databaseURL, string user, string password, string autoCommit, action<com.apama.database.Connection, string> callback)Opens the connection to a database.
Requires (case insensitive values): default - Use setting from config file.
false - Disable auto-commit.
x.x - Value (seconds) for ADBC adapter timed auto-commit.
true - Enable data source specific auto-commit.
void openDatabaseFull(string serviceId, string databaseURL, string user, string password, string autoCommit, boolean readOnly, dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)Open a connection to a database. This action allows you to pass in any extra parameters.
default - Use setting from config file.
false - Disable auto-commit.
x.x - Value (seconds) for ADBC adapter timed auto-commit.
true - Enable data source specific auto-commit.
void openDatabaseShared(string serviceId, string databaseURL, string user, string password, string autoCommit, boolean readOnly, dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)Open a shared connection to a database.
default - Use setting from config file.
false - Disable auto-commit.
x.x - Value (seconds) for ADBC adapter timed auto-commit.
true - Enable data source specific auto-commit.
void reopen()
void reopenWithACK(action<com.apama.database.Connection, string> callback)Reopen the connection to a database.
void reset()Reset the state of the connection.
integer rollbackRequest(action<com.apama.database.Connection, integer, string, string> callback)Rollback uncommitted changes to database.
integer rollbackRequestFull(string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, integer, string, string> callback)Rollback uncommitted changes to database. This action allows you to pass in any extra parameters.
void runCommand(string commandString, string token, action<com.apama.database.Connection, string, string> callback)Run the supplied command against the database.
void runCommandFull(string commandString, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)Run the supplied command against the database. This action allows you to pass in any extra parameters.
void setStoreErrorCallback(action<com.apama.database.Connection, integer, integer, string> callback)To specify an action to be used when an error is reported.
void stopAllQueries(action<com.apama.database.Connection, string> callback)Stop all queries that are currently running.
void stopAllQueriesFull(dictionary<string, string> extraParams, action<com.apama.database.Connection, string> callback)Stop all Queries that are currently running. This action allows you to pass in any extra parameters.
integer storeData(string tableName, string statementName, dictionary<string, string> fields, dictionary<string, string> extraParams)Store the data contained in the fields dictionary without an acknowledgement.
void storeDataWithAck(string tableName, string statementName, dictionary<string, string> fields, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)Store the data contained in the fields dictionary with an acknowledgement.
integer storeDataWithAckId(string tableName, string statementName, dictionary<string, string> fields, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)Store the data contained in the fields dictionary with an acknowledgement.
integer storeEvent(float timestamp, string eventString, string tableName, string statementName, string timeColumn, dictionary<string, string> extraParams)Store the event contained in the event Data without an acknowledgement.
void storeEventWithAck(float timestamp, string eventString, string tableName, string statementName, string timeColumn, string token, dictionary<string, string> extraParams, action<com.apama.database.Connection, string, string> callback)Store the event contained in the event Data with an acknowledgement.
FRAMES NO FRAMES | |||||||
| |||||||
SUMMARY: IMPORT | CONSTANT | MEMBER | ACTION | DETAIL: IMPORT | CONSTANT | MEMBER | ACTION |