RDBMS event publisher is used to publish events in map format to a RDBMS in two execution modes, which are insert and update-insert.
...
| | Configuration file Property | Example |
|---|
| Data Source Name | Name of the datasource | datasource.name | WSO2_CARBON_DB |
| Table Name | Name of the table | table.name | sensordata |
| Execution Mode | Type 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. | Info |
|---|
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 |
...
Advanced properties are configured to select attributes with IDs different to those defined in the event stream to which the publisher is connected. When advanced properties are defined, they are considered the only attributes to be published and the original attributes in the connected event stream are not considered.
e.g., If the event stream to which the publisher is connected has an attribute named ID, but you want the publisher to include attributes of which the name is formatted as id, you can define id as an advanced property as shown below.
| Tip |
|---|
An RDBMS publisher does not by default identify the persisted attributes of an event stream. You can define If you want only the persisted attributes in the connected event stream to be published, the persisted attributes can be defined as advanced properties to avoid an exception similar to the following example. | Expand |
|---|
|
| title | Click here to view the exception |
|---|
|
| Code Block |
|---|
|
TID: [-1234] [] [2015-10-10 07:17:20,968] ERROR {org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter} - Cannot Execute Insert/Update. Null value detected for attributemeta_referer Hence Event is dropped. {org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter}
org.wso2.carbon.event.output.adapter.core.exception.OutputEventAdapterException: Cannot Execute Insert/Update. Null value detected for attributemeta_referer
at org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter.populateStatement(RDBMSEventAdapter.java:372)
at org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter.executeDbActions(RDBMSEventAdapter.java:326)
at org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter.executeProcessActions(RDBMSEventAdapter.java:291)
at org.wso2.carbon.event.output.adapter.rdbms.RDBMSEventAdapter.publish(RDBMSEventAdapter.java:134)
at org.wso2.carbon.event.output.adapter.core.internal.OutputAdapterRuntime.publish(OutputAdapterRuntime.java:69)
at org.wso2.carbon.event.output.adapter.core.internal.CarbonOutputEventAdapterService.publish(CarbonOutputEventAdapterService.java:143)
at org.wso2.carbon.event.publisher.core.internal.EventPublisher.process(EventPublisher.java:361)
at org.wso2.carbon.event.publisher.core.internal.EventPublisher.sendEvent(EventPublisher.java:209)
at org.wso2.carbon.event.publisher.core.internal.EventPublisher.consumeEvent(EventPublisher.java:275)
at org.wso2.carbon.event.stream.core.internal.EventJunction.sendEvent(EventJunction.java:142)
at org.wso2.carbon.event.receiver.core.internal.management.InputEventDispatcher.onEvent(InputEventDispatcher.java:27)
at org.wso2.carbon.event.receiver.core.internal.EventReceiver.sendEvent(EventReceiver.java:259)
at org.wso2.carbon.event.receiver.core.internal.EventReceiver.processTypedEvent(EventReceiver.java:241)
at org.wso2.carbon.event.receiver.core.internal.EventReceiver$TypedEventSubscription.onEvent(EventReceiver.java:317)
at org.wso2.carbon.event.input.adapter.core.internal.InputAdapterRuntime.onEvent(InputAdapterRuntime.java:110)
at org.wso2.carbon.event.input.adapter.wso2event.internal.ds.WSO2EventAdapterServiceDS$1.receive(WSO2EventAdapterServiceDS.java:92)
at org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:81)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745). For more information about persisting attributes, see Configuring Data Persistence.
Related samples
For more information on rdbms event publisher type, see the following sample in WSO2 CEP Documentation.
...