Receiving Events via Simulator and Persisting in RDBMS Store
This application demonstrates how to perform RDBMS operations using Siddhi queries. The sample depicts a scenario in a sweet production factory. The sweet production details, such as the name of the raw material and amount used for production, can be stored using
insertSweetProductionStream. The following streams can be used to search, delete, update, or upsert (update or insert) the existing data in the store:
* search -
* insert -
* delete -
* update -
* update or insert -
* contains -
containsSweetProductionStream (verifies whether all the attributes that enter in the stream exist in the store)
- Ensure that MySQL is installed on your machine.
- Add the MySQL JDBC driver into
- Download the JDBC driver from: https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.45.tar.gz
- Unzip the archive.
- Create a database named
productionin MySQL. This database is referred to with the
- Create a table named
CREATE TABLE SweetProductionTable (name VARCHAR(20),amount double(10,2));
Insert some values into the table as follows.
Note: You can also use
INSERT INTO SweetProductionTable VALUES ('Sugar',23.50);
In the store configuration of this application, replace 'username' and 'password' values with your MySQL credentials.
- Save this sample.
Executing the Sample:¶
- Start the Siddhi application by clicking on 'Run'.
- If the Siddhi application starts successfully, the following message is shown on the console.
Store-rdbms.siddhi - Started Successfully!
If you want to edit this application while it's running, stop the application, make your edits and save the application, and then start it again.
Testing the Sample:¶
- Simulate single events:
- Click on 'Event Simulator' (double arrows on left tab) and click 'Single Simulation'
- Select 'Store-rdbms' as 'Siddhi App Name' and select 'searchSweetProductionStream' as 'Stream Name'.
- Provide attribute values, and then click Send.
- Send at least one event where the name matches a name value in the data you previously inserted into the SweetProductionTable. This will satisfy the 'on' condition of the join query.
- Optionally, send events to the other corresponding streams to add, delete, update, insert, and search events.
- After a change in the store, you can use the search stream to see whether the operation is successful.
- The Primary Key constraint in
SweetProductionTableis disabled, because the name cannot be used as a
- You can use Siddhi functions to create a unique ID for the received events, which can then be used to apply the Primary Key constraint on the data store records. (http://wso2.github.io/siddhi/documentation/siddhi-4.0/#function)
Viewing the Results:¶
See the output for raw materials on the console. You can use
searchSweetProductionStream to check for inserted, deleted, and updated events.
@App:name("Store-rdbms") @App:description('Receive events via simulator and persist the received data in the store.') define stream insertSweetProductionStream (name string, amount double); define stream deleteSweetProductionStream (name string); define stream searchSweetProductionStream (name string); define stream updateSweetProductionStream (name string, amount double); define stream updateOrInsertSweetProductionStream (name string, amount double); define stream containsSweetProductionStream (name string, amount double); @sink(type='log') define stream logStream(name string, amount double); @Store(type="rdbms", jdbc.url="jdbc:mysql://localhost:3306/production?useSSL=false", username="wso2", password="123" , jdbc.driver.name="com.mysql.jdbc.Driver") --@PrimaryKey("name") @index("amount") define table SweetProductionTable (name string, amount double); /* Inserting event into the mysql database */ @info(name='query1') from insertSweetProductionStream insert into SweetProductionTable; /* Deleting event from mysql database */ @info(name = 'query2') from deleteSweetProductionStream delete SweetProductionTable on SweetProductionTable.name == name ; /* Updating event from mysql database */ @info(name = 'query3') from updateSweetProductionStream update SweetProductionTable on SweetProductionTable.name == name ; /* Updating or inserting event from mysql database */ @info(name = 'query4') from updateOrInsertSweetProductionStream update or insert into SweetProductionTable on SweetProductionTable.name == name; /* Siddhi In in mysql database */ @info(name = 'query5') from containsSweetProductionStream [(SweetProductionTable.name == name and SweetProductionTable.amount == amount) in SweetProductionTable] insert into logStream; --Perform a join on raw material name so that the data in the store can be viewed @info(name='query6') from searchSweetProductionStream as s join SweetProductionTable as sp on s.name == sp.name select sp.name, sp.amount insert into logStream;