Sending a Simple Message to a Datasource
Let’s try a simple scenario where a patient makes an inquiry specifying the doctor's specialization (category) to retrieve a list of doctors that match the specialization. The required information is stored in an H2 database that is shipped with this product. We will create a data service in the ESB profile of WSO2 Enterprise Integrator (WSO2 EI), which will expose the information in the database, thereby decoupling the client and the database layer in the back end. The client will then communicate with the data service hosted in WSO2 EI to get the required information instead of communicating directly with the backend.
In this tutorial, we will define a data service in the ESB profile of WSO2 EI to expose the back-end database. A client can then invoke the data service to send messages to the database. If you want to use a back-end service instead of a database, see the tutorial on sending a simple message to a service.
Let's get started!
This tutorial includes the following sections:
Downloading and set up WSO2 EI
Before you begin, download the product installer from here, and run the installer.
Let's call the installation location of your product the <EI_HOME> directory. This is located in a place specific to your OS as shown below:
OS | Home directory |
---|---|
Mac OS | /Library/WSO2/EnterpriseIntegrator/6.6.0 |
Windows | C:\Program Files\WSO2\EnterpriseIntegrator\6.6.0\ |
Ubuntu | /usr/lib/wso2/EnterpriseIntegrator/6.6.0 |
CentOS | /usr/lib64/EnterpriseIntegrator/6.6.0 |
Let's set up a back-end database for the healthcare service. We will create a database named DATA_SERV_QSG
in the <EI_HOME>/samples/data-services/database
directory for this purpose.
- Download the
dataServiceSample.zip
file and extract it to a location on your computer. Let's call this location<Dataservice_Home>
. This contains a DB script for updating the back-end database with the channeling information of the healthcare service. Open a terminal, navigate to the
<Dataservice_Home>
directory and execute the following command:When executing the below command, replace the
<PATH_TO_EI_HOME>
with the folder path of your WSO2 EI distribution. For example, if your WSO2 EI distribution (i.e.,<EI_HOME>
) is located in the/Users/Documents/
directory, execute the following command:ant -Ddshome=/Users/Documents/wso2ei-6.6.0
Also, you need to install Apache Ant to execute this command.
ant -Ddshome=<PATH_TO_EI_HOME>
The database is now updated with information on all available doctors in the healthcare service.
Starting WSO2 EI
Follow the steps given below to start the ESB runtime of WSO2 EI and create the data service.
Start the ESB profile:
- In your Web browser, navigate to the ESB profile's management console using the following URL:
https://localhost:9443/carbon/
. - Log into the management console using the following credentials:
- Username:
admin
- Password:
admin
- Username:
Exposing a datasource through a data service
Now, let's start creating the data service using the management console.
On the Main tab, click Create under Data Service.
In the Create Data Service screen, enter
DOCTORS_DataService
as the data service name, and click Next.Click Add New Datasource and enter the following details:
Field Value DatasourceID default
Datasource type Select RDBMS and default. Database Engine H2
Driver Class org.h2.Driver
URL jdbc:h2:file:./samples/data-services/database/DATA_SERV_QSG
User Name wso2ds
Password wso2ds
Click Save and then click Next to start defining a query.
Now, let's start writing a query to get data from the datasource.
First, you need to define a query to get the details of all the available doctors from the database.- Click Add New Query to open the Add New Query screen.
Enter the following values:
Field Value Query ID select_all_DOCTORS_query
Datasource default
SQL SELECT NAME, HOSPITAL, SPECIALITY, AVAILABILITY, CHARGE FROM PUBLIC.DOCTORS
Click Generate Response to automatically create mappings for the fields.
Under the Result (Output Mapping) section, change the values of the following fields.
Grouped by element DOCTORSCollection
Row name DOCTOR
The output mapping will be as shown below.
Output mapping specifies how the data that is fetched from your query will be shown in the response. Note that, by default, the output type is XML.
- Click Save.
- Now, let's create another query that can get the doctor information based on specialization.
- Click Add New Query to open the Add New Query screen.
Enter the following values:
Field Value Query ID select_DOCTORS_from_SPECIALITY_query
Datasource default
SQL SELECT NAME, HOSPITAL, SPECIALITY, AVAILABILITY, CHARGE FROM PUBLIC.DOCTORS WHERE SPECIALITY=?
Click Generate Input Mappings and a new input mapping record will be created.
Edit the record and change the Mapping Name to SPECIALITY, and click Save. You will now have the following input mapping:
Input mappings allow you to add parameters to a query so that you can set the parameter value when executing the query. According to the above definition, you need to provide the SPECIALTY as an input in order to retrieve the data corresponding to the SPECIALTY.
Click Main Configuration, to go back to the main configuration after adding the input mapping.
Click Generate Response to automatically create mappings for the fields.
Under the Result (Output Mapping) section, change the values of the following fields
Grouped by element DOCTORList
Row name DOCTOR
The output mapping will be as shown below.
Output mapping specifies how the data that is fetched from your query is shown in the response. Note that, by default, the output type is XML.
- Click Save and then click Next to open the Operations screen.
Since we are exposing the data as a REST resource, we do not need an operation. An operation is needed only if you are exposing the data as a SOAP operation. - Click Next to open the Resources screen.
Click Add New Resources to open the Add Resources screen.
Let's first create a resource to invoke theselect_all_DOCTORS_query
:Field Value Resource Path /getAllDoctors
Resource Method GET
Query ID select_all_DOCTORS_query
- Click Save to save the resource.
- Now, let's create another resource to invoke the
select_DOCTORS_from_SPECIALITY_query
.Click Add New Resources to open the Add Resources screen and enter the following details:
Field Value Resource Path /getDoctors
Resource Method GET
Query ID select_DOCTORS_from_SPECIALITY_query
- Click Save to save the resource.
- Click Finish after you have defined the resources to complete the data service creation process. You are now taken to the Deployed Services screen, which shows all the data services deployed on the server including the one you created.
Sending requests to the ESB
Let's send a request to the data service, which is now deployed in the ESB profile of WSO2 EI. You will need a REST client like curl for this.
Open a command line terminal and enter the following request (invoking the getDoctors resource) to get the information of all the doctors specializing under surgery.
curl -v http://localhost:8280/services/DOCTORS_DataService/getDoctors?SPECIALITY=surgery
You can also use the specialties listed below in your request:
cardiology
gynaecology
ent
paediatric
You see the following response message from data service with a list of all available doctors and relevant details.
<DOCTORSLIST xmlns="http://ws.wso2.org/dataservice"> <DOCTOR> <NAME>thomas collins</NAME> <HOSPITAL>grand oak community hospital</HOSPITAL> <SPECIALITY>surgery</SPECIALITY> <AVAILABILITY>9.00 a.m - 11.00 a.m</AVAILABILITY> <CHARGE>7000</CHARGE> </DOCTOR> <DOCTOR> <NAME>anne clement</NAME> <HOSPITAL>clemency medical center</HOSPITAL> <SPECIALITY>surgery</SPECIALITY> <AVAILABILITY>8.00 a.m - 10.00 a.m</AVAILABILITY> <CHARGE>12000</CHARGE> </DOCTOR> <DOCTOR> <NAME>seth mears</NAME> <HOSPITAL>pine valley community hospital</HOSPITAL> <SPECIALITY>surgery</SPECIALITY> <AVAILABILITY>3.00 p.m - 5.00 p.m</AVAILABILITY> <CHARGE>8000</CHARGE> </DOCTOR> </DOCTORSLIST>
You can execute the following request (invoking the getAllDoctors resource) to get the information of all the doctors:
curl -v http://localhost:8280/services/DOCTORS_DataService/getAllDoctors