WSO2 Complex Event Processor is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.
||
Skip to end of metadata
Go to start of metadata

RDBMS event publisher is used to publish events in map format to a RDBMS in two execution modes, which are insert and update-insert.

Prerequisites

Follow the steps below to set up the prerequisites before starting the configurations.

  1. Create a datasource to connect to the selected database. For instructions on creating a datasource, see Adding Datasources.

    If selected database is H2, uncomment the following H2 database configurations in the <PRODUCT_HOME>/repository/config/carbon.xml file as follows, to browse through the database and see the changes. Keep the other properties of the H2DatabaseConfiguration element uncommented.

    <H2DatabaseConfiguration>
    	<property name="web"/>
    	<property name="webPort">8082</property>
    	<property name="webAllowOthers"/>
    </H2DatabaseConfiguration>

Creating a RDBMS event publisher

For instructions on creating a RDBMS event publisher, see Configuring CEP to Create Alerts.

Configuring global properties

You can change the queries used to perform the standard database operations by adding the customised queries in the <CEP_HOME>/repository/conf/output-event-adapters.xml file. This enables you to use RDBMS database types that use different queries. Customised values can be defined for the following used in standard queries.

Custom properties cannot be added as global properties.


Attribute/activityCurrent query
stringVARCHAR(255)
doubleDOUBLE
integerINT
longBIGINT
floatFLOAT
createTableCREATE TABLE $TABLE_NAME ($COLUMN_TYPES)
insertDataToTableINSERT INTO $TABLE_NAME ($COLUMNS) VALUES ($VALUES)
isTableExistSELECT * FROM $TABLE_NAME limit 1
updateTableRowUPDATE $TABLE_NAME SET $COLUMN_VALUES WHERE $CONDITION
comma,
questionMark?
equal=
andAND
selectAllColumnsDataTypeInTableSELECT COLUMN_NAME, DATA_TYPE FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '$TABLE_NAME'
selectFromTableSELECT $COLUMNS FROM $TABLE_NAME
oracle.stringvarchar2(255)
oracle.longCLOB
oracle.doubleBINARY_DOUBLE
oracle.isTableExistSELECT * FROM $TABLE_NAME WHERE ROWNUM = 1
oracle.selectAllColumnsDataTypeInTableSELECT COLUMN_NAME, DATA_TYPE FROM USER_TAB_COLS WHERE TABLE_NAME = '$TABLE_NAME'
mssql.stringvarchar2(255)
mssql.isTableExistSELECT TOP 1 * FROM $TABLE_NAME
mssql.selectAllColumnsDataTypeInTableSELECT COLUMN_NAME, DATA_TYPE FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = '$TABLE_NAME'
h2.integervarchar2(255)
h2.longREAL
h2.selectAllColumnsDataTypeInTableSHOW COLUMNS FROM $TABLE_NAME

Configuring adapter properties

Specify the Static Adapter Properties, when creating a RDBMS event publisher using the management console as shown below.

RDBMS event publisher

After entering the above adapter properties, select the Message Format that you want to apply on the published events. Also, click Advanced to define custom output mappings based on the Message Format you selected. For more information on custom output mapping types, see Output Mapping Types.

You can also define the respective adapter properties of the event publisher based on the transport type within the <to> element of the event publisher configuration in the <PRODUCT_HOME>/repository/deployment/server/eventpublishers/ directory as follows.

<eventPublisher name="RDBMSOutputEventAdapter" statistics="disable" trace="disable" xmlns="http://wso2.org/carbon/eventpublisher">
  ....................
  <to eventAdapterType="rdbms">
    <property name="datasource.name">WSO2_CARBON_DB</property>
    <property name="table.name">sensordata</property>
    <property name="execution.mode">insert</property>
    <property name="update.keys">sensor-key,sensor-group</property>
  </to>
</eventPublisher> 

The above adapter properties are described below.

Adapter Property
Description
Configuration file PropertyExample
Data Source NameName of the datasource
datasource.name
WSO2_CARBON_DB
Table NameName of the table
table.name
sensordata
Execution ModeType of the execution mode
execution.mode
insert/update or insert
Composite key columns

Attributes used for uniqueness checks for updates. Use commas to separate if you enter more than one attribute.

 

It is required to enter one or more attributes as composite key columns if you select update-or-insert for the Execution Mode property.


update.keys

sensor-key,sensor-group

Related samples

For more information on rdbms event publisher type, see the following sample.

  • No labels