Exposing a Datasource as a Data Service
In this tutorial, we will run through the process of service enabling an RDBMS as a data service. For more information on the datasource types supported by WSO2 EI, see the What's Next section.
Before you begin!
Follow the steps given below to set up a MySQL database for this tutorial.
Install the MySQL server.
Download the product installer from here, and run the installer.
Download the JDBC driver for MySQL from here. Unzip it, get the
<MySQL_HOME>/mysql-connector-java-8.0.16.jarJAR, and place it in the<EI_HOME>/libdirectory.If the driver class does not exist in the relevant folders when you create the datasource, you will get an exception, such as '
Cannot load JDBC driver class com.mysql.jdbc.Driver'.Create a database named
Employees.CREATE DATABASE Employees;Create the Employee table inside the Employees database:
USE Employees; CREATE TABLE Employees (EmployeeNumber int(11) NOT NULL, FirstName varchar(255) NOT NULL, LastName varchar(255) DEFAULT NULL, Email varchar(255) DEFAULT NULL, Salary varchar(255));
Let's get started
Creating the data service
Follow the steps given below.
Start the WSO2 ESB profile.
Open the ESB profile's Management Console using https://localhost:9443/carbon, and log in using
adminas the username and the password.Click Data Service → Create, to start creating a data service.
Enter the following name for the data service.
Data Service Name
RDBMSDataService
Click Next to enter the datasource connection details.
Connecting to the datasource
Follow the steps given below.
Click Add New Datasource and enter the following details:
Datasource ID
Datasource
Datasource Type
RDBMS
Datasource Type (Default/External)
Leave Default selected.
Database Engine
MySQL
Driver Class
com.mysql.jdbc.DriverURL
User Name
Enter your MySQL server's username.
Password
Enter your MySQL server's password.
If you have not assigned a password, keep this field empty.If you enter External instead of the Default datasource type, your datasource should be supported by an external provider class, such as
com.mysql.jdbc.jdbc2.optional.MysqlXADataSource.You can select the External option and enter the name and value of connection properties by clicking Add Property. For example,
After an external datasource is created, it can be used as a usual datasource in queries. See the tutorial on handling distributed transactions for more information on using external datasources.Save the datasource.
Click Next, to start creating queries.
Creating a query to Get data
Let's create a query that can retrieve employee data, based on the employee number. That is, when the employee number is provided as an input, the data service should get the relevant employee details and present the result.
Click Add New Query to start creating a new query.
Enter the following details:
Query ID
GetEmployeeDetailsDatasource
Datasource
SQL
select EmployeeNumber, FirstName, LastName, Email, Salary from Employees where EmployeeNumber=:EmployeeNumberClick Generate Input Mapping to create the input mapping. The employee number is the input as shown below.
Click Generate Response to create the output mapping. This defines how the employee details retrieved from the datasource will be presented in the result. Note that, by default, the output type is XML.
If required, you can choose RDF, or JSON as the output type. See Using JSON with Data Services for more information on exposing data in JSON format.
Save the query.
Creating a query to Post data
Let's create another query to post new employee data to the datasource.
Click Add New Query to start creating a new query.
Enter the following details:
Query ID
AddEmployeeDetailsDatasource
Datasource
SQL
insert into Employees (EmployeeNumber, FirstName, LastName, Email, Salary) values(:EmployeeNumber,:FirstName,:LastName,:Email,:Salary)Click Generate Input Mapping to create the input mapping. You need to specify values for the following elements when posting new employee data.
Save the query.
Creating a query to Update data
Now, let's create a query that can update an existing employee record in the datasource.
Click Add New Query to start creating a new query.
Enter the following details:
Query ID
UpdateEmployeeDetailsDatasource
Datasource
SQL
update Employees set LastName=:LastName, FirstName=:FirstName, Email=:Email, Salary=:Salary where EmployeeNumber=:EmployeeNumberClick Generate Input Mapping to create the input mapping. You need to specify values for the following elements when posting new employee data.
Save the query.
You should now have the following three queries created:
Create SOAP operations to invoke queries
Now, let's create SOAP operations to invoke the queries created above. Alternatively, you can create REST resources to invoke the queries. See the next section for instructions.
Click Add New Operation and enter the details as shown below.
Operation Name
GetEmployeeOpQuery ID
GetEmployeeDetailsSave the operation.
Click Add New Operation and enter the details as shown below.
Operation Name
AddEmployeeOpQuery ID
AddEmployeeDetailsSave the operation.
Click Add New Operation and enter the details as shown below.
Operation Name
UpdateEmployeeOpQuery ID
UpdateEmployeeDetailsSave the operation.
You can now invoke the data service query using SOAP.
Create REST resources to invoke queries
Now, let's create REST resources to invoke the queries created above. Alternatively, you can create SOAP operations to invoke the queries. See the previous section, for instructions.
Click Add New Resource and enter the details as shown below.
Resource Path
Employee/{EmployeeNumber}Resource Method
GETQuery ID
GetEmployeeDetailsSave the resource.
Click Add New Resource and enter the details as shown below.
Resource Path
EmployeeResource Method
POSTQuery ID
AddEmployeeDetailsSave the resource.
Click Add New Resource and enter the details as shown below.
Resource Path
EmployeeResource Method
PUTQuery ID
UpdateEmployeeDetailsSave the resource.
Click Finish to complete creating the data service.
Once you have defined the operation, click Finish to complete the data service creation process. You will now be taken to the Deployed Services screen, which shows all the data services deployed on the server.
You can now invoke the data service query using REST.
Invoking your data service using SOAP
You can try the data service you created by using the TryIt tool that is in your product by default.
Go to the Deployed Services screen and refresh the page.
Click the Try this service link for the RDBMS data service. The TryIt Tool will open with the data service.
Post new data
Select the AddEmployeeOp operation you created earlier.
Provide the employee details by copying the code given below.
<p:AddEmployeeOp xmlns:p="http://ws.wso2.org/dataservice"> <!--Exactly 1 occurrence--> <xs:EmployeeNumber xmlns:xs="http://ws.wso2.org/dataservice">1</xs:EmployeeNumber> <!--Exactly 1 occurrence--> <xs:FirstName xmlns:xs="http://ws.wso2.org/dataservice">John</xs:FirstName> <!--Exactly 1 occurrence--> <xs:LastName xmlns:xs="http://ws.wso2.org/dataservice">Doe</xs:LastName> <!--Exactly 1 occurrence--> <xs:Email xmlns:xs="http://ws.wso2.org/dataservice">JohnDoe@gmail.com</xs:Email> <!--Exactly 1 occurrence--> <xs:Salary xmlns:xs="http://ws.wso2.org/dataservice">10000</xs:Salary> </p:AddEmployeeOp>Click Send.
The data is now added to the database.
Get data
Select the GetEmployeeOp operation you created earlier. You need to provide the employee number as an input. Enter '
1'.Click Send to see the details of the employee you added previously:
<Entries xmlns="http://ws.wso2.org/dataservice"> <Entry> <EmployeeNumber>1</EmployeeNumber> <FirstName>John</FirstName> <LastName>Doe</LastName> <Email>JohnDoe@gmail.com</Email> </Entry> </Entries>