This site contains the documentation that is relevant to older WSO2 product versions and offerings.
For the latest WSO2 documentation, visit https://wso2.com/documentation/.

Skip to end of metadata
Go to start of metadata

You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 5 Next »

This tutorial will guide you on how to expose data stored in Cassandra as a data serviceAlso, see the samples in Data Integration Samples.

Install and start Cassandra

A Cassandra server of version 3.0 should be already running in the default port. For instructions, go to Apache Cassandra Documentation.

See the following links for setting up Cassandra as a data store:

Creating a data service

Now, let's start creating the data service from scratch:

  1. Log in to the management console of ESB profile of WSO2 EI using the following URL on your browser:  "https://localhost:9443/carbon/".
  2. Click Create under the Data Service menu to open the Create Data Service window.
  3. Enter the following data service name.

    Data Service NameCassandraDataService
  4. Leave the default values for the other fields.
  5. Click Next to go to the Datasources screen

Connecting to the datasource

Creating a query to a Keyspace to Cassandra

Follow the steps given below.

  1. Click Add New Query and enter the following details:

    Query IDEnter createKS as the query ID.
    DatasourceSelect the datasource for which you are going to write a query. Select the Cassandra datasource that you created previously.
    SQL

    In this field, enter the SQL statement describing the keyspace.

    CREATE KEYSPACE UsersKS WITH replication = {'class':'SimpleStrategy', 'replication_factor':3}
  2. Save the query.

Creating a query to add a table to the Keyspace

Follow the steps given below.

  1. Click Add New Query and enter the following details:

    Query IDEnter createTable as the query ID.
    DatasourceSelect the datasource for which you are going to write a query. Select the Cassandra datasource that you created previously.
    SQL

    In this field, enter the SQL statement describing the keyspace.

    CREATE TABLE UsersKS.Users (id uuid, name text, country text, age int, PRIMARY KEY (id))
  2. Save the query.

Creating a query to ADD user information

Now let's write a query for adding user information to the Users table of the UsersKS keyspace in your Cassandra server.

  1. Click Add New Query and enter the following details:

    Query IDEnter addUsers as the query ID.
    DatasourceSelect the datasource for which you are going to write a query. Select the Cassandra datasource that you created previously.
    SQL

    In this field, enter the SQL statement describing the data that should be added to the Cassandra datasource.

    INSERT INTO UsersKS.Users (id, name, country, age) values (:id, :name, :country, :age)
  2. Click Generate Input Mapping to create the input mappings.


  3. Edit the id column and change the Type to UUID.
  4. Save the mapping.
  5. Edit the age column and change the Type to integer.
  6. Save the mapping and click Main Configuration to return to the query. You will now have the following input mappings:

  7. Save the query.

Creating a query to GET data

Now let's start writing a query for getting data from the datasource. The query will specify the data that should be fetched by this query, and the format that should be used to display data when the query is invoked.

  1. Click Add New Query and enter the following details:

    Query IDEnter getUsersbyID as the query ID.
    DatasourceSelect the datasource for which you are going to write a query. Select the Cassandra datasource that you created previously.
    SQL

    In this field, enter the SQL statement describing the data that should be retrieved from the Cassandra datasource.

    SELECT id, age, country, name FROM UsersKS.Users WHERE id = :id
  2. Click Generate Input Mapping to create the input mapping. The id is the input as shown below.


  3. 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. 

  4. Save the query.
  5. Click Next to open the Operations screen.

Creating SOAP operationa to invoke the queries

To invoke the query, you need to define an operation.

  1. Click Add New Operation and enter the following information.

    Operation NamecreateKSOp
    Query IDcreateKS
  2. Save the operation.
  3. Click Add New Operation and enter the following information.

    Operation NamecreateTableOp
    Query IDcreateTable
  4. Save the operation.
  5. Click Add New Operation and enter the following information.

    Operation NameaddUsersOp
    Query IDaddUsers
  6. Save the operation.
  7. Click Add New Operation and enter the following information.

    Operation NamegetUsersbyIDop
    Query IDgetUsersbyID
  8. Save the operation.

You can now invoke the data service query using SOAP.

Creating a REST resource to invoke the query

Now, let's create REST resources to invoke the query created above. Alternatively, you can create SOAP operations to invoke the queries. See the previous section for instructions.

  1. Click Add New Resource and enter the following information.

    Resource PathKeyspace
    Resource MethodPOST
    Query ID createKS
  2. Save the resource.
  3. Click Add New Resource and enter the following information.

    Resource PathTable
    Resource MethodPOST
    Query IDcreateTable
  4. Save the resource.
  5. Click Add New Resource and enter the following information.

    Resource PathUsers
    Resource MethodPOST
    Query ID addUsers
  6. Save the resource.
  7. Click Add New Resource and enter the following information.

    Resource PathUsers/{id}
    Resource MethodGET
    Query ID getUsersbyID
  8. Save the resource.

You can now invoke the data service query using REST.

Finish 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.

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. 

  1. Go to the Deployed Services screen.
  2. Click the Try this service link for the Cassandra data service. The TryIt Tool will open with the data service.

Create the Keyspace

  1. Select the createKSOp operation you created earlier. 

  2. Click Send.

The UsersKS keyspace is now added to the database.

Create the table in the Keyspace

  1. Select the createTableOp operation you created earlier. 

  2. Click Send.

The Users keyspace is now added to the UsersKS keyspace.

Post new data

  1. Select the addUsersOp operation you created earlier. 
  2. You need to provide the user details. 

  3. Click Send.

The data is now added to the database.

Get data

  1. Select the getUsersbyIDop operation you created earlier. 
  2. Click Send to see the details of the user you added previously.

  • No labels