Cassandra Studio Configuration - Mule 4

In Studio, create a Mule project.

Click the Exchange icon (X) in the upper-left of the Studio task bar.

In Exchange, click Login and supply your Anypoint Platform username and password.

In Exchange, search for "cassandra".

Select the connector and click Add to project.

Follow the prompts to install the connector.

In Studio, create a Mule project.

In the Mule Palette view, click (X) Search in Exchange.

In Add Modules to Project, type "cassandra" in the search field.

Click this connector’s name in Available modules.

Click Add.

Click Finish.

Create a new Mule Project in Anypoint Studio and fill in the Cassandra credentials in: src/main/resources/mule-app.properties.

config.host=<HOST>
config.port=<PORT>
config.keyspace=<KEY_SPACE>
config.username=<USERNAME>
config.password=<PASSWORD>

Drag an HTTP connector onto the canvas and leave the default values for Host and Port, then set the path to: /test/createKeyspace.

Drag a Transform Message component from the Mule palette to the right (process) side of the flow, select the component, and set the output payload. For example:

%dw 2.0
output application/java
---
{
 "keyspaceName": payload.keyspaceName,
 "replicationFactor": payload.replicationFactor,
 "replicationStrategyClass": payload.replicationStrategyClass
}
as Object {
 class: "org.mule.modules.cassandradb.api.CreateKeyspaceInput"
}

Drag a Cassandra component for Create Keyspace onto the canvas.

Click the Test Connection option to confirm that Mule can connect with the Cassandra instance. If the connection is successful, click OK to save the configuration. Otherwise, review and correct any invalid parameters and retest.

Run the application. In a browser, use the following URL to enter a query parameter for the keyspace name ks_name, replication factor rf, and replication strategy class rs_class:

Create a new Mule Project in Anypoint Studio and fill in the Cassandra credentials in src/main/resources/mule-app.properties.

config.host=<HOST>
config.port=<PORT>
config.keyspace=<KEY_SPACE>
config.username=<USERNAME>
config.password=<PASSWORD>

Drag an HTTP connector onto the canvas and leave the default values for Host and Port and set the path to /test/createTable.

Drag a Transform Message component from the Mule palette to the right (process) side of the flow, select the component, and set the output payload. For example:

%dw 2.0
output application/java
---
{
  "columns": payload.columns,
  "tableName": payload.tableName,
  "keyspaceName": payload.keyspaceName
} as Object {
  class : "org.mule.modules.cassandradb.api.CreateTableInput"
}

Drag a Cassandra component for the Create Table operation onto the canvas.

Click Test Connection to confirm that Mule can connect with the Cassandra instance. If the client test is successful, click OK to save the configuration. Otherwise, review and correct any invalid parameters and retest.

Run the Mule app. In Postman, select POST. Select Body > Raw, select the JSON (application/json) MIME type, and enter the following table description using uppercase for data types.

{
  "tableName": "users",
  "keyspaceName": "Excelsior",
  "columns":
  [
    {
      "name": "id",
      "type": "INT",
      "primaryKey": "true"
    },
    {
      "name": "username",
      "type": "TEXT",
      "primaryKey": "true"
    },
    {
      "name": "name",
      "type": "TEXT",
      "primaryKey": "false"
    },
    {
      "name": "email",
      "type": "TEXT",
      "primaryKey": "false"
    }
  ]
}

In Postman, click Send, and look for Status: 200 OK.