# mulesoft Apache Cassandra Connector (cassandra-connector) - Full Documentation # Anypoint Studio を使用した Apache Cassandra Connector 4.0 の設定 Anypoint Studio (Studio) エディターは、Mule アプリケーション、プロパティ、および設定ファイルの設計と更新に役立ちます。 Studio でコネクタを追加および設定する手順は、次のとおりです。 - [Mule プロジェクトを作成します](#create-mule-project)​。 - [コネクタを Mule プロジェクトに追加します](#add-connector-to-project)​。 - [コネクタのフローのソースを設定します](#configure-input-source)​。 - [フローにコネクタの操作を追加します](#add-connector-operation)​。 - [コネクタのグローバル要素を設定します](#configure-global-element)​。 - [その他のコネクタ項目を設定します](#configure-other-fields)​。 [「アプリケーションログの表示」](#view-app-log)​で説明されているように、コネクタを実行するときに、アプリケーションログを表示して問題を確認できます。 Studio で初めてコネクタを設定する場合は、​[「Anypoint Studio を使用したコネクタの設定」](https://docs.mulesoft.com/connectors/introduction/intro-config-use-studio)​を参照してください。このトピックを読んだ後でコネクタ項目に関する追加情報が必要な場合は、​[「リファレンス」](https://docs.mulesoft.com/jp/cassandra-connector/4.0/cassandra-connector-reference)​を参照してください。 ## [](#create-mule-project)Mule プロジェクトを作成する Studio で、コネクタを追加および設定する新しい Mule プロジェクトを作成します。 1. Studio で、​**\[File (ファイル)\] > \[New (新規)\] > \[Mule Project (Mule プロジェクト)\]**​ を選択します。 2. Mule プロジェクトの名前を入力して、​**\[Finish (完了)\]**​ をクリックします。 ## [](#add-connector-to-project)コネクタを Mule プロジェクトに追加する Apache Cassandra Connector を Mule プロジェクトに追加して、XML コードにコネクタの名前空間およびスキーマの場所を自動的に入力し、プロジェクトの ​`pom.xml`​ ファイルに必須の連動関係を追加します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[(X) Search in Exchange ((X) Exchange 内を検索)\]**​ をクリックします。 2. **\[Add Dependencies to Project (連動関係をプロジェクトに追加)\]**​ ウィンドウで、検索項目に「​`cassandra`​」と入力します。 3. **\[Available modules (使用可能なモジュール)\]**​ で、​**\[CassandraDB\]**​ をクリックします。 4. **\[Add (追加)\]**​ をクリックします。 5. **\[Finish (完了)\]**​ をクリックします。 Studio でコネクタを Mule プロジェクトに追加しても、Studio ワークスペースの他のプロジェクトはそのコネクタを使用できません。 ## [](#configure-input-source)ソースの設定 ソースは、指定された条件が満たされたときにフローを開始します。 次のソースのいずれかを設定して、Apache Cassandra Connector で使用できます。 - **HTTP Listener** 設定されたホストとポートで要求を受信するたびにフローを開始する - **Scheduler** 時間ベースの条件が満たされたときにフローを開始する たとえば、HTTP Listener を設定する手順は、次のとおりです。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[HTTP\] > \[Listener\]**​ を選択します。 2. **\[Listener\]**​ を Studio キャンバスにドラッグします。 3. **\[Listener (リスナー)\]**​ 設定画面で、必要に応じて ​**\[Display Name (表示名)\]**​ 項目の値を変更します。 4. **\[Path (パス)\]**​ 項目の値を指定します。 5. **\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックして、アプリケーション内の HTTP Listener のすべてのインスタンスで使用できるグローバル要素を設定します。 6. **\[General (一般)\]**​ タブで、リスナーの接続情報を指定します。 7. **\[TLS\]**​ タブで、必要に応じてリスナーの TLS 情報を指定します。 8. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 9. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 10. **\[OK\]**​ をクリックします。 ## [](#add-connector-operation)フローにコネクタの操作を追加する フローにコネクタの操作を追加すると、そのコネクタで実行する特定の操作をすぐに定義できます。 Apache Cassandra Connector の操作を追加するには、次の手順に従います。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで ​**\[CassandraDB\]**​ を選択し、目的の操作を選択します。 2. その操作を Studio キャンバスのソースの右にドラッグします。 ## [](#configure-global-element)コネクタのグローバル要素を設定する コネクタを設定する場合、アプリケーション内のそのコネクタのすべてのインスタンスで使用できるグローバル要素を設定することをお勧めします。Apache Cassandra データベースで認証が有効になっている場合、コネクタからアクセスするときにログイン情報を提供する必要があります。Apache Cassandra では基本認証のみがサポートされています。Apache Cassandra データベースにログイン情報を提供するには、Apache Cassandra Connector のグローバル要素に対応する値を入力します。 Apache Cassandra Connector のグローバル要素を設定する手順は、次のとおりです。 1. Studio キャンバスで操作を選択します。 2. 操作の設定画面で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックし、グローバル要素設定項目にアクセスします。 3. **\[General (一般)\]**​ タブで、次の項目を入力します。
項目 説明

Host (ホスト)

Apache Cassandra ノードのホスト名または IP アドレス。

Port (ポート)

ポート番号。デフォルトポートは ​9042​ です。
対象データベースで認証が有効になっている場合は、次の項目にも入力する必要があります。
項目 説明

Keyspace (キースペース)

Apache Cassandra キースペース

Username (ユーザー名)

Apache Cassandra ユーザー名

Password (パスワード)

Apache Cassandra パスワード
ANT スタイルのプロパティプレースホルダーを含む設定ファイルを参照するか (推奨)、グローバル設定プロパティに認証ログイン情報を入力できます。プロパティプレースホルダーを使用する利点とその設定方法については、​[「Anypoint Connector 設定」](https://docs.mulesoft.com/connectors/introduction/intro-connector-configuration-overview)​を参照してください。 4. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 5. 必要に応じて、\[Security (セキュリティ)\] タブの次の項目に入力して、相互 TLS を使用する接続を設定します。
項目 説明

Endpoint Identification Algorithm (エンドポイント識別アルゴリズム)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

TLS Configuration (TLS 設定)

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方から使用できる TLS の設定を定義します。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーは ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。
6. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 7. **\[OK\]**​ をクリックします。 ## [](#configure-other-fields)その他のコネクタ項目の設定 Apache Cassandra Connector のグローバル要素を設定したら、コネクタの他の必須項目を設定します。必須項目は、使用するコネクタ操作によって異なります。 ## [](#view-app-log)アプリケーションログの表示 問題を確認するため、アプリケーションログを次の方法で表示できます。 - アプリケーションを Anypoint Platform から実行している場合、出力は Anypoint Studio のコンソールウィンドウに表示される。 - コマンドラインから Mule を使用してアプリケーションを実行している場合、アプリケーションログは OS コンソールに表示される。 アプリケーションのログファイル (​`log4j2.xml`​) でログファイルパスがカスタマイズされていない場合、デフォルトの場所 ​`MULE_HOME/logs/.log`​ でアプリケーションログを表示することもできます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Anypoint Studio を使用した Apache Cassandra Connector 4.1 の設定 Anypoint Studio (Studio) エディターは、Mule アプリケーション、プロパティ、および設定ファイルの設計と更新に役立ちます。 Studio でコネクタを追加および設定する手順は、次のとおりです。 - [Mule プロジェクトを作成します](#create-mule-project)​。 - [コネクタを Mule プロジェクトに追加します](#add-connector-to-project)​。 - [コネクタのフローのソースを設定します](#configure-input-source)​。 - [フローにコネクタの操作を追加します](#add-connector-operation)​。 - [コネクタのグローバル要素を設定します](#configure-global-element)​。 - [その他のコネクタ項目を設定します](#configure-other-fields)​。 [「アプリケーションログの表示」](#view-app-log)​で説明されているように、コネクタを実行するときに、アプリケーションログを表示して問題を確認できます。 Studio で初めてコネクタを設定する場合は、​[「Anypoint Studio を使用したコネクタの設定」](https://docs.mulesoft.com/connectors/introduction/intro-config-use-studio)​を参照してください。このトピックを読んだ後でコネクタ項目に関する追加情報が必要な場合は、​[「リファレンス」](https://docs.mulesoft.com/jp/cassandra-connector/4.1/cassandra-connector-reference)​を参照してください。 ## [](#create-mule-project)Mule プロジェクトを作成する Studio で、コネクタを追加および設定する新しい Mule プロジェクトを作成します。 1. Studio で、​**\[File (ファイル)\] > \[New (新規)\] > \[Mule Project (Mule プロジェクト)\]**​ を選択します。 2. Mule プロジェクトの名前を入力して、​**\[Finish (完了)\]**​ をクリックします。 ## [](#add-connector-to-project)コネクタを Mule プロジェクトに追加する Apache Cassandra Connector を Mule プロジェクトに追加して、XML コードにコネクタの名前空間およびスキーマの場所を自動的に入力し、プロジェクトの ​`pom.xml`​ ファイルに必須の連動関係を追加します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[(X) Search in Exchange ((X) Exchange 内を検索)\]**​ をクリックします。 2. **\[Add Dependencies to Project (連動関係をプロジェクトに追加)\]**​ ウィンドウで、検索項目に「​`cassandra`​」と入力します。 3. **\[Available modules (使用可能なモジュール)\]**​ で、​**\[CassandraDB\]**​ をクリックします。 4. **\[Add (追加)\]**​ をクリックします。 5. **\[Finish (完了)\]**​ をクリックします。 Studio でコネクタを Mule プロジェクトに追加しても、Studio ワークスペースの他のプロジェクトはそのコネクタを使用できません。 ## [](#configure-input-source)ソースの設定 ソースは、指定された条件が満たされたときにフローを開始します。 次のソースのいずれかを設定して、Apache Cassandra Connector で使用できます。 - **HTTP Listener** 設定されたホストとポートで要求を受信するたびにフローを開始する - **Scheduler** 時間ベースの条件が満たされたときにフローを開始する たとえば、HTTP Listener を設定する手順は、次のとおりです。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[HTTP\] > \[Listener\]**​ を選択します。 2. **\[Listener\]**​ を Studio キャンバスにドラッグします。 3. **\[Listener (リスナー)\]**​ 設定画面で、必要に応じて ​**\[Display Name (表示名)\]**​ 項目の値を変更します。 4. **\[Path (パス)\]**​ 項目の値を指定します。 5. **\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックして、アプリケーション内の HTTP Listener のすべてのインスタンスで使用できるグローバル要素を設定します。 6. **\[General (一般)\]**​ タブで、リスナーの接続情報を指定します。 7. **\[TLS\]**​ タブで、必要に応じてリスナーの TLS 情報を指定します。 8. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 9. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 10. **\[OK\]**​ をクリックします。 ## [](#add-connector-operation)フローにコネクタの操作を追加する フローにコネクタの操作を追加すると、そのコネクタで実行する特定の操作をすぐに定義できます。 Apache Cassandra Connector の操作を追加するには、次の手順に従います。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで ​**\[CassandraDB\]**​ を選択し、目的の操作を選択します。 2. その操作を Studio キャンバスのソースの右にドラッグします。 ## [](#configure-global-element)コネクタのグローバル要素を設定する コネクタを設定する場合、アプリケーション内のそのコネクタのすべてのインスタンスで使用できるグローバル要素を設定することをお勧めします。Apache Cassandra データベースで認証が有効になっている場合、コネクタからアクセスするときにログイン情報を提供する必要があります。Apache Cassandra では基本認証のみがサポートされています。Apache Cassandra データベースにログイン情報を提供するには、Apache Cassandra Connector のグローバル要素に対応する値を入力します。 Apache Cassandra Connector のグローバル要素を設定する手順は、次のとおりです。 1. Studio キャンバスで操作を選択します。 2. 操作の設定画面で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックし、グローバル要素設定項目にアクセスします。 3. **\[General (一般)\]**​ タブで、次の項目を入力します。
項目 説明

Host (ホスト)

Apache Cassandra ノードのホスト名または IP アドレス。

Port (ポート)

ポート番号。デフォルトポートは ​9042​ です。
対象データベースで認証が有効になっている場合は、次の項目にも入力する必要があります。
項目 説明

Keyspace (キースペース)

Apache Cassandra キースペース

Username (ユーザー名)

Apache Cassandra ユーザー名

Password (パスワード)

Apache Cassandra パスワード
ANT スタイルのプロパティプレースホルダーを含む設定ファイルを参照するか (推奨)、グローバル設定プロパティに認証ログイン情報を入力できます。プロパティプレースホルダーを使用する利点とその設定方法については、​[「Anypoint Connector 設定」](https://docs.mulesoft.com/connectors/introduction/intro-connector-configuration-overview)​を参照してください。 4. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 5. 必要に応じて、\[Security (セキュリティ)\] タブの次の項目に入力して、相互 TLS を使用する接続を設定します。
項目 説明

Endpoint Identification Algorithm (エンドポイント識別アルゴリズム)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

TLS Configuration (TLS 設定)

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方から使用できる TLS の設定を定義します。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーは ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。
6. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 7. **\[OK\]**​ をクリックします。 ## [](#configure-other-fields)その他のコネクタ項目の設定 Apache Cassandra Connector のグローバル要素を設定したら、コネクタの他の必須項目を設定します。必須項目は、使用するコネクタ操作によって異なります。 ## [](#view-app-log)アプリケーションログの表示 問題を確認するため、アプリケーションログを次の方法で表示できます。 - アプリケーションを Anypoint Platform から実行している場合、出力は Anypoint Studio のコンソールウィンドウに表示される。 - コマンドラインから Mule を使用してアプリケーションを実行している場合、アプリケーションログは OS コンソールに表示される。 アプリケーションのログファイル (​`log4j2.xml`​) でログファイルパスがカスタマイズされていない場合、デフォルトの場所 ​`MULE_HOME/logs/.log`​ でアプリケーションログを表示することもできます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector Cassandra Connector v3.1 Apache Cassandra 用 Anypoint Connector (Cassandra Connector) は、企業全体で Cassandra データベースとサードパーティアプリケーション、システム、サービス (SAP、PeopleSoft、Workday など) および他のデータベース間の接続を作成します。 Apache Cassandra は、大量の商品、顧客、従業員データを管理するためのオープンソースの分散型 NoSQL データベースで、Apache Cassandra 3.1 用 DataStax Java ドライバーを実装します。 リリースノート: [Cassandra Connector リリースノート](https://docs.mulesoft.com/jp/release-notes/connector/cassandra-connector-release-notes-mule-4)​ Exchange: [Cassandra Connector](https://www.mulesoft.com/exchange/com.mulesoft.connectors/mule-cassandradb-connector/) ## [](#始める前に)始める前に 開始する前に、コネクタ、Anypoint Platform、または Anypoint Studio にアクセスできることを確認します。 このソフトウェアを使用するのに不可欠な Mule Enterprise Edition およびエンタイトルメントが必要になります。 Anypoint Platform、Anypoint Studio、Mule アプリケーションの使用に精通している必要があります。 このコネクタを使用するには、次の要件があります。 対象リソースへの接続をテストするための Cassandra ログイン情報。 ## [](#対象者)対象者 - 初級ユーザー - この「はじめに」を使用して、​[Anypoint Studio](https://docs.mulesoft.com/jp/cassandra-connector/3.1/cassandra-connector-studio)​ のどこで Mule アプリケーションを作成できるのかを確認できます。 - [設定に関するトピック](https://docs.mulesoft.com/jp/cassandra-connector/3.1/cassandra-connector-config-topics)​は、Cassandra アクションの理解を広げるのに役立ちます。 - 上級ユーザー - ​[「XML と Maven のサポート」](https://docs.mulesoft.com/jp/cassandra-connector/3.1/cassandra-connector-xml-maven)​、​[設定に関するトピック](https://docs.mulesoft.com/jp/cassandra-connector/3.1/cassandra-connector-config-topics)​、​[「例」](https://docs.mulesoft.com/jp/cassandra-connector/3.1/cassandra-connector-examples)​のドキュメントを参照してください。 ## [](#次のステップ)次のステップ 開始することができたので、​[Anypoint Studio](https://docs.mulesoft.com/jp/cassandra-connector/3.1/cassandra-connector-studio)​ を使用して Cassandra Connector を設定してみましょう。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Exchange を使用したコネクタ、テンプレート、およびサンプルの検出](https://docs.mulesoft.com/connectors/introduction/intro-use-exchange) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.0 Apache Cassandra 用 Anypoint Connector (Apache Cassandra Connector) は、企業全体で Apache Cassandra データベースとサードパーティアプリケーション、システム、サービス (SAP、PeopleSoft、Workday など) および他のデータベース間の接続を作成します。 Apache Cassandra は、大量の商品、顧客、従業員データを管理するためのオープンソースの分散型 NoSQL データベースで、Apache Cassandra 3.10.1 用 DataStax Java ドライバーを実装します。 ## [](#始める前に)始める前に このコネクタを使用するには、以下に精通している必要があります。 - Apache Cassandra API - Anypoint Connector - Mule Runtime Engine (Mule) - Mule フローの要素とグローバル要素 - Anypoint Studio (Studio) を使用した Mule アプリケーションの作成 アプリケーションを作成する前に、以下が必要です。 - Apache Cassandra 対象リソースにアクセスするためのログイン情報 - Anypoint Studio バージョン 4.1.1 以降 - このソフトウェアを使用するのに必要な Mule Enterprise Edition およびエンタイトルメント ## [](#次のステップ)次のステップ 開始することができたので、​[Anypoint Studio](https://docs.mulesoft.com/jp/cassandra-connector/4.0/cassandra-connector-studio)​ を使用して Cassandra Connector を設定してみましょう。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Exchange を使用したコネクタ、テンプレート、およびサンプルの検出](https://docs.mulesoft.com/connectors/introduction/intro-use-exchange) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.0 の XML と Maven のサポート XML で Mule アプリケーションを手動でコーディングすることもできますが、Anypoint Studio を使用した方が効率的です。 Anypoint Studio の XML エディターまたはテキストエディターから Mule Runtime Engine (Mule) アプリケーションを手動でコーディングする場合、参照ステートメントを XML Mule フローと Apache Maven ​`pom.xml`​ ファイルの両方に追加することで、アプリケーションからコネクタにアクセスできます。 Studio でコネクタを追加すると、Studio は自動的に XML コードにコネクタの名前空間およびスキーマの場所を入力し、​`pom.xml`​ ファイルに連動関係を追加します。 ## [](#コネクタの名前空間の追加)コネクタの名前空間の追加 次のコードを設定 XML のヘッダーの ​``​ タグ内に貼り付けます。 ```xml http://www.mulesoft.org/schema/mule/cassandra-db http://www.mulesoft.org/schema/mule/cassandra-db/current/mule-cassandra-db.xsd ``` 次の例は、​``​ XML ブロック内に名前空間ステートメントが配置される方法を示しています。 ```xml --- 項目 説明

Host (ホスト)

${cassandra.Host}

Port (ポート)

${cassandra.Port}

Keyspace (キースペース)

${cassandra.keySpace}

Username (ユーザー名)

${cassandra.userName}

Password (パスワード)

${cassandra.password}

4. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が Apache Cassandra インスタンスに接続できることを確認します。 正常に接続できた場合は、​**\[OK\]**​ をクリックして設定を保存します。それ以外の場合、無効なパラメーターを確認および修正して、再度テストします。 5. プロジェクトを保存します。 6. ポート ​`8081`​ で ​`test/createKeyspace`​ パスに REST 要求を送信してアプリケーションをテストします。 ### [](#新規テーブルを作成する)新規テーブルを作成する 次のフローは、対象 Apache Cassandra データベースに新規テーブルを作成します。 ![Create Table フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/cassandra-create-table.png) Figure 3. 新規テーブルの作成フロー #### [](#http-リスナーを設定する-3)HTTP リスナーを設定する ポート ​`8081`​ で ​`/test/createTable`​ パスへのコールが行われたときに Mule フローを開始するように HTTP リスナーを設定します。 1. Studio で新しい Mule プロジェクトを作成します。 2. Studio で ​**\[HTTP\]**​ をクリックし、​**\[Listener\]**​ 操作をキャンバスにドラッグします。 3. **\[Listener\]**​ 設定で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックしてグローバル要素を追加します。 4. デフォルトを受け入れます。 5. **\[Listener\]**​ 設定で、​**\[Path (パス)\]**​ 項目値を ​`/test/createTable`​ に設定します。 ### [](#transform-message-コンポーネントの追加-2)Transform Message コンポーネントの追加 **Transform Message**​ コンポーネントを追加して、​**HTTP Listener**​ から受信したペイロードに基づいて Java 変数を設定します。 1. \[Mule Palette (Mule パレット)\] ビューから、​**\[Transform Message\]**​ コンポーネントを ​**\[Listener\]**​ の右側にドラッグします。 2. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```dataweave %dw 2.0 output application/java --- { "columns": payload.columns, "tableName": payload.tableName, "keyspaceName": payload.keyspaceName } as Object { class : "org.mule.modules.cassandradb.api.CreateTableInput" } ``` #### [](#create-table-操作を追加する)Create Table 操作を追加する 前のフローで作成したキースペースに新規テーブルを作成するため、​**Create Table**​ 操作を追加します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューから、​**\[CassandDB\]**​ を選択して ​**\[Create Table\]**​ 操作を ​**\[Transform Message\]**​ コンポーネントの右側にドラッグします。 2. **\[Create Table\]**​ 設定で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックします。 3. **Create keyspace**​ 操作用に設定したグローバル要素を選択します。 4. **\[OK\]**​ をクリックします。 5. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が Cassandra インスタンスに接続できることを確認します。 クライアントテストに成功した場合は、​**\[OK\]**​ をクリックして設定を保存します。それ以外の場合、無効なパラメーターを確認および修正して、再度テストします。 6. 保存して Mule アプリケーションを実行します。 7. ポート ​`8081`​ で ​`/test/createTable`​ パスに ​**POST**​ コマンドを送信してアプリケーションをテストします。​`application/json`​ MIME タイプを使用して、データ型には大文字を使用し、コマンド本文にテーブルの説明を入力します。 ```text { "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" } ] } ``` ### [](#apache-cassandra-キースペースとテーブルの作成例の-xml)Apache Cassandra キースペースとテーブルの作成例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ## [](#manipulate-data)Apache Cassandra データベース内のデータの操作 この例は、Apache Cassandra データベース内のデータを操作するための次の方法を示しています。 - [キースペースからテーブル名を取得する。](#get-table-names) - Apache Cassandra テーブルのデータに対して次の CRUD 操作を実行する。 - [Insert](#insert) - [Select](#select) - [Update](#update) - [Delete](#delete) - Apache Cassandra テーブル列に対して次の操作を実行する。 - [列の値を削除。](#delete-columns) - [列の名前を変更。](#rename-columns) - [新しい列を追加。](#add-new-column) - [列を削除](#drop-columns)​。 - [Cassandra クエリ言語 (CQL) クエリを実行。](#execute-cql) - Apache Cassandra データベーステーブルからデータを削除する。 - [キースペースからテーブルを削除。](#drop-table) - [キースペースを削除。](#drop-keyspace) ### [](#get-table-names)キースペースからのテーブル名の取得 この Mule フローは、指定されたキースペースからすべてのテーブル名を返します。 ![Get Table Names from Keyspace 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/get-table-names.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Get Table Names from Keyspace**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-4)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/getTablesFromKeyspace`​ に設定します。 #### [](#get-table-names-from-keyspace-操作を追加する)Get Table Names from Keyspace 操作を追加する **Get Table Names from Keyspace**​ 操作は、指定されたキースペースからすべてのテーブル名を返します。 1. **Get Table Names from Keyspace**​ 操作を、キャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Get Table Names from Keyspace\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Get Table Names from Keyspace\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Keyspace name (キースペース名)

#[payload.keyspaceName]
#### [](#transform-message-コンポーネントを追加する)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**Get Table Names from Keyspace**​ 操作の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#insert)Insert この Mule フローは、キースペースのテーブルにエンティティを挿入します。 ![Insert Entity 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/insert-entity.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Insert Entity**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-5)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/insert`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-2)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "id": payload.id, "name": payload.name, "event": payload.event } ``` #### [](#insert-entity-操作を追加する)Insert Entity 操作を追加する **Insert Entity**​ 操作は、キースペースのテーブルにエンティティを挿入します。 1. **Insert Entity**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Insert Entity\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Insert Entity\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entity to insert (挿入するエンティティ)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Insert Entity\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#select)Select この Mule フローは ​**Select**​ クエリを実行します。 ![Select 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/select.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Select**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-6)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/insert`​ に設定します。 #### [](#select-操作を追加する)Select 操作を追加する **Select**​ 操作は、キースペースで ​**Select**​ クエリを実行します。 1. **Select**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Select\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**Cassandra​DB\_C​onfig**​ を選択します。 3. **\[Select\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Query (クエリ)

SELECT id, name, event FROM example_keyspace.example_table
#### [](#transform-message-コンポーネントを追加する-3)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Select\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#update)Update この Mule フローは、キースペースのテーブルのエンティティを更新します。 ![Update Entity 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/update-entity.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Update Entity**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-7)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/update`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-4)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "where":{ id: payload.where }, "columns":payload.columns } ``` #### [](#update-entity-操作を追加する)Update Entity 操作を追加する **Update Entity**​ 操作は、キースペースのテーブルのエンティティを更新します。 1. **Update Entity**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Update Entity\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Update Entity\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entity to insert (挿入するエンティティ)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-2)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Update Entity\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#delete)Delete この Mule フローは、キースペースのテーブルからエンティティを削除します。 ![Delete Rows 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/delete-row.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Delete Rows**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-8)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/deleteRows`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-5)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "where": { id: payload.ids } } ``` #### [](#delete-rows-操作を追加する)Delete Rows 操作を追加する **Delete Rows**​ 操作は、レコードを削除します。 1. **Delete Rows**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Delete Rows\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Delete Rows\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entity to insert (挿入するエンティティ)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-3)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Delete Rows\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#delete-columns)列値の削除 この Mule フローは、キースペースのテーブルから列の値を削除します。 ![Delete Columns Value 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/delete-column.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Delete Columns Value**​ 操作を追加する - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-9)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/deleteColumns`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-6)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "columns": payload.columns, "where": { id:payload.where } } ``` #### [](#delete-columns-value-操作を追加する)Delete Columns Value 操作を追加する **Delete Columns Value**​ 操作は、​**Where 句**​で指定されたオブジェクトから値を削除します。 1. **Delete Columns Value**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Delete Columns Value\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Delete Columns Value\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entities (エンティティ)

Edit inline

Value (値)

#[payload.entities]

Where clause (Where 句)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-4)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Delete Columns Value\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#rename-columns)列名の変更 この Mule フローは、指定されたキースペースのテーブルの列名を変更します。 ![Rename Column 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/rename-columns.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Rename Column**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-10)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/renameColumn`​ に設定します。 #### [](#rename-column-操作を追加する)Rename Column 操作を追加する **Rename Column**​ 操作は、キースペースのテーブルの列名を変更します。 1. **Rename Column**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Rename Column\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Rename Column\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

#[payload.tableName]

Keyspace name (キースペース名)

#[payload.keyspaceName]

Old column name (古い列名)

payload.oldName

New column name (新しい列名)

#[payload.newName]
#### [](#transform-message-コンポーネントを追加する-7)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Rename Column\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#add-new-column)新しい列の追加 この Mule フローは、キースペースのテーブルに新しい列を追加します。 ![Add New Table Column 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/add-new-column.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Set Variable**​ コンポーネント - 2 つ目の ​**Set Variable**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Add New Table Column**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-11)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/addNewColumn`​ に設定します。 #### [](#set-variable-コンポーネントを追加する)Set Variable コンポーネントを追加する 最初の ​**Set Variable**​ コンポーネントは、テーブル名の値を格納します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`set variable`​」を検索します。 2. **\[Set Variable\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **\[Set Variable\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

名前

tableName

Value (値)

#[payload.tableName]
#### [](#2-つ目の-set-variable-コンポーネントを追加する)2 つ目の Set Variable コンポーネントを追加する 2 つ目の ​**Set Variable**​ コンポーネントは、キースペース名の値を格納します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`set variable`​」を検索します。 2. **\[Set Variable\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **\[Set Variable\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

名前

keyspaceName

Value (値)

#[payload.keyspaceName]
#### [](#transform-message-コンポーネントを追加する-8)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Set Variable\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "column": payload.column, "type": payload.'type' } as Object { class : "org.mule.modules.cassandradb.api.AlterColumnInput" } ``` #### [](#add-new-table-column-操作を追加する)Add New Table Column 操作を追加する **Add New Table Column**​ 操作は、新しい列を追加します。 1. **Add New Table**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Add New Table Column\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Add New Table Column\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

#[vars['tableName']]

Keyspace name (キースペース名)

#[vars['keyspaceName']]

Alter column input (変更列の入力)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-5)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Add New Table Column\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#drop-columns)列の削除 この Mule フローは、キースペースのテーブルから列を削除します。 ![Drop Column 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/drop-columns.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Drop Column**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-12)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/dropColumn`​ に設定します。 #### [](#drop-column-操作を追加する)Drop Column 操作を追加する **Drop Column**​ 操作は、列を削除します。 1. **Drop Column**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Drop Column\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Drop Column\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

#[payload.tableName]

Keyspace name (キースペース名)

#[payload.keyspaceName]

Column name (列名)

payload.columnName
#### [](#transform-message-コンポーネントを追加する-9)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Drop Column\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#execute-cql)Cassandra クエリ言語 (CQL) クエリの実行 この Mule フローは、指定された未加工の入力クエリを実行します。 ![Execute CQL Query 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/execute-cql.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Execute CQL Query**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-13)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/executeCqlQuery`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-10)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "cqlQuery": payload.cqlQuery, "parameters": payload.parameters } as Object { class : "org.mule.modules.cassandradb.api.CQLQueryInput" } ``` #### [](#execute-cql-query-操作を追加する)Execute CQL Query 操作を追加する **Execute CQL Query**​ 操作は、未加工の入力クエリを実行します。 1. **Execute CQL Query**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Execute CQL Query\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 #### [](#2-つ目の-transform-message-コンポーネントを追加する-6)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Execute CQL Query\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#drop-table)テーブルの削除 この Mule フローは、指定されたキースペースからテーブルを削除します。 ![Drop Table 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/drop-table.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Drop Table**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-14)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/dropTable`​ に設定します。 #### [](#drop-table-操作を追加する)Drop Table 操作を追加する **Drop Table**​ 操作は、指定されたキースペースからテーブルを削除します。​**Drop Table**​ 操作でキースペースを指定しないと、接続パラメーターのキースペースでテーブルが作成されます。 1. **Drop Table**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Drop Table\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Drop Table\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table name (テーブル名)

payload.tableName

Keyspace name (キースペース名)

#[payload.keyspaceName]
#### [](#transform-message-コンポーネントを追加する-11)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Drop Table\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#drop-keyspace)キースペースの削除 この Mule フローは、指定されたキースペースとその値を削除します。 ![Drop Keyspace 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.0/_images/drop-keyspace.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Drop Keyspace**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-15)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/dropKeyspace`​ に設定します。 #### [](#drop-keyspace-操作を追加する)Drop Keyspace 操作を追加する **Drop Keyspace**​ 操作は、キースペースとその値を削除します。 1. **Drop Keyspace**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Drop Keyspace\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Drop Keyspace\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Keyspace name (キースペース名)

payload.keyspaceName
#### [](#transform-message-コンポーネントを追加する-12)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Drop Keyspace\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#apache-cassandra-データベースのデータの操作例)Apache Cassandra データベースのデータの操作例 この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml SELECT id, name, event FROM example_keyspace.example_table ``` ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.0 の追加設定情報 基本認証と DataSense 機能を備えた環境で動作するように、Apache Cassandra 用 Anypoint Connector (Apache Cassandra Connector) を設定します。 ## [](#enable-authentication)Apache Cassandra 認証の有効化 デフォルトでは、Apache Cassandra データベースへのアクセスにログイン情報は必要ありません。 認証を有効にするように Apache Cassandra を設定する必要があります。Apache Cassandra Connector の設定は、基本認証の Apache Cassandra の設定と一致する必要があります。 認証を有効にしたら、Apache Cassandra インストールのホームディレクトリから次の例のように ​`cqlsh`​ コマンドを実行します。次の例では、デフォルトのログイン情報 (ユーザー名 ​`cassandra`​、パスワード ​`cassandra`​) を使用しています。 ```text bin/cqlsh localhost -u cassandra -p cassandra Connected to Test Cluster at localhost:9042. [cqlsh 5.0.1 | Cassandra 3.10 | CQL spec 3.4.4 | Native protocol v4] Use HELP for help. ``` 1. Apache Cassandra をインストールしたら、編集目的で ​`conf\cassandra.yaml`​ ファイルを開きます。 2. 必要に応じて、​`AllowAllAuthenticator`​ の値を ​`PasswordAuthenticator`​ に変更します。 3. Apache Cassandra を再起動します。 4. 別の端末タブで、Apache Cassandra が実行されていることを確認します。 `bin/nodetool status` ## [](#pojo-設定)POJO 設定 このコネクタは、「Apache Cassandra Connector リファレンス」の複数の操作を公開します。 次の操作は、DataSense 機能で必要とされる一部の POJO を入力パラメーターとして受け入れます。 - `addNewColumn` - `changeColumnType` - `createKeyspace` - `createTable` - `deleteColumnsValue` - `deleteRows` - `dropColumn` - `dropKeyspace` - `dropTable` - `executeCQLQuery` - `getTableNamesFromKeyspace` - `renameColumn` - `select` - `update` ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.0 リファレンス Cassandra 用 Anypoint Connector (Cassandra Connector) は、Apache Cassandra 3.1 用 DataStax Java ドライバーを実装します。 ## [](#設定)設定 * * * ### [](#config)設定 #### [](#パラメーター)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

Connection (接続)

この設定に指定する接続認証種別。

x

Expiration Policy (有効期限ポリシー)

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。これは、インスタンスが有効期限の対象となった瞬間にプラットフォームでそのインスタンスが期限切れになるということではありません。必要に応じて、インスタンスがパージされます。
#### [](#接続種別)接続種別 ##### [](#config_connection)Connection (接続) ###### [](#パラメーター-2)パラメーター
名前 型 説明 デフォルト値 必須

Host (ホスト)

String (文字列)

ホスト名または IP アドレス。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

Enumeration (列挙)。次のいずれかになります。

  • HTTPS

  • LDAPS

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

HTTPS

Port (ポート)

String (文字列)

Port (ポート)

9042

Cassandra Keyspace (Cassandra キースペース)

String (文字列)

Cassandra キースペース。

Cassandra Cluster Name (Cassandra クラスター名)

String (文字列)

Cassandra クラスター名。

Cassandra Cluster Nodes (Cassandra クラスターノード)

String (文字列)

Cassandra クラスターノード (カンマで区切られた IP またはホストアドレスとポート。例: host1:port1, ​host2:port2​)。ポートが指定されていない場合、コネクタではデフォルトポート ​9042​ が使用されます。このパラメーターを指定した場合、一般設定のホストとポートは無視されます。

Username (ユーザー名)

String (文字列)

認証用のユーザー名。

Password (パスワード)

String (文字列)

認証用のパスワード。パスワードが null またはすべて空白の場合、コネクタで認証は使用されません。この場合、ユーザー名も空にする必要があります。

Protocol Version (プロトコルバージョン)

Enumeration (列挙)。次のいずれかになります。

  • V1

  • V2

  • V3

  • V4

ドライバーでサポートされるネイティブプロトコルのバージョン。

Max Schema Agreement Wait Seconds (スキーマ一致の最大待機時間)

Number (数値)

DDL クエリから戻るまでスキーマ一致を待機する最大時間。

0

Compression (圧縮)

Enumeration (列挙)。次のいずれかになります。

  • LZ4

  • None (なし)

  • SNAPPY

トランスポートで使用する圧縮。

TLS Configuration (TLS 設定)

TLS

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
## [](#サポートされている操作)サポートされている操作 - [Add New Table Column](#addNewColumn) - [Change Column Type](#changeColumnType) - [Create Keyspace](#createKeyspace) - [Create Table](#createTable) - [Delete Columns Value](#deleteColumnsValue) - [Delete Rows](#deleteRows) - [Drop Column](#dropColumn) - [Drop Keyspace](#dropKeyspace) - [Drop Table](#dropTable) - [Execute CQL Query](#executeCQLQuery) - [Get All Table Names From Keyspace](#getTableNamesFromKeyspace) - [Insert Entity](#insert) - [Rename Column](#renameColumn) - [Select](#select) - [Update Entity](#update) ### [](#制限事項)制限事項 Cassandra 操作では、固定列型や他のカスタム列型はサポートされていません。これらの列型を使用する場合は、未加工の CQL クエリで ​**Execute CQL Query**​ 操作を使用します。 ### [](#addNewColumn)Add New Table Column `` 新しい列を追加します。 #### [](#パラメーター-3)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Alter Column Input (Alter Column の入力)

Alter Column Input (Alter Column の入力)

新しい列の名前とそのデータ型を定義する POJO。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合)次の設定の場合 - [設定](#config) #### [](#スロー)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#changeColumnType)Change Column Type `` 列の型を変更します。互換性をチェックするには、 [「CQL type compatibility (CQL 型の互換性)」](http://docs.datastax.com/en/cql/3.1/cql/cql_reference/cql_data_types_c.html#concept_ds_wbk_zdt_xj__cql_data_type_compatibility)​を参照してください。 #### [](#パラメーター-4)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Alter Column Input (Alter Column の入力)

Alter Column Input (Alter Column の入力)

変更する列の名前と新しいデータ型を定義する POJO。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-2)次の設定の場合 - [設定](#config) #### [](#スロー-2)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#createKeyspace)Create Keyspace `` 新しいキースペースを作成します。 #### [](#パラメーター-5)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Input (入力)

Create Keyspace Input (Create Keyspace の入力)

キースペース名と複製の詳細を含む、操作の入力。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-3)次の設定の場合 - [設定](#config) #### [](#スロー-3)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#createTable)Create Table `` 特定のキースペース内にテーブル (列ファミリー) を作成します。キースペースを指定しない場合、コネクタではログイン用のキースペースが使用されます。 #### [](#パラメーター-6)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Create Table Input (Create Table の入力)

Create Table Input (Create Table の入力)

Create Table Input​ 操作。テーブル名、キースペース名、および列のリストを指定します。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-4)次の設定の場合 - [設定](#config) #### [](#スロー-4)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#deleteColumnsValue)Delete Columns Value `` Where 句で指定されたオブジェクトから値を削除します。 #### [](#パラメーター-7)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

テーブルの名前

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Entities (エンティティ)

Array of String (文字列の配列)

削除する列。

x

Where Clause (Where 句)

Object (オブジェクト)

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-5)次の設定の場合 - [設定](#config) #### [](#スロー-5)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#deleteRows)Delete Rows `` レコード全体を削除します。 #### [](#パラメーター-8)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

テーブルの名前

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Where Clause (Where 句)

Object (オブジェクト)

Delete​ 操作の Where 句。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-6)次の設定の場合 - [設定](#config) #### [](#スロー-6)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#dropColumn)Drop Column `` 列を削除します。 #### [](#パラメーター-9)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Column Name (列名)

String (文字列)

削除する列の名前。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-7)次の設定の場合 - [設定](#config) #### [](#スロー-7)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#dropKeyspace)Drop Keyspace `` キースペース全体を削除します。 #### [](#パラメーター-10)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Keyspace Name (キースペース名)

String (文字列)

削除するキースペースの名前。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-8)次の設定の場合 - [設定](#config) #### [](#スロー-8)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#dropTable)Drop Table `` 指定されたキースペースからテーブル全体を削除します。または、操作パラメーターとしてキースペースが指定されていない場合は、ログインで使用されるキースペースからテーブル全体を削除します。 #### [](#パラメーター-11)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table Name (テーブル名)

String (文字列)

削除するテーブルの名前。

#[payload]

Keyspace Name (キースペース名)

String (文字列)

削除するテーブルを含むキースペース。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-9)次の設定の場合 - [設定](#config) #### [](#スロー-9)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#executeCQLQuery)Execute CQL Query `` 指定された未加工の入力クエリを実行します。 #### [](#パラメーター-12)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Cql Input (CQL の入力)

CQL Query Input (CQL クエリの入力)

実行するパラメーター化されたクエリをクエリパラメーターと共に記述する CQL クエリ入力。

#[payload]

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力)出力

型

Array of Object (オブジェクトの配列)
### [](#次の設定の場合-10)次の設定の場合 - [設定](#config) #### [](#スロー-10)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#getTableNamesFromKeyspace)Get All Table Names From Keyspace `` 指定されたキースペースからすべてのテーブル名を返します。 #### [](#パラメーター-13)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Keyspace Name (キースペース名)

String (文字列)

操作で使用するキースペースの名前。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-2)出力

型

Array of String (文字列の配列)
### [](#次の設定の場合-11)次の設定の場合 - [設定](#config) #### [](#スロー-11)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#insert)Insert Entity `` エンティティの挿入操作を実行します。 #### [](#パラメーター-14)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

エンティティを挿入するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Entity To Insert (挿入するエンティティ)

Object (オブジェクト)

挿入するエンティティ。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-12)次の設定の場合 - [設定](#config) #### [](#スロー-12)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#renameColumn)Rename Column `` 列の名前を変更します。 #### [](#パラメーター-15)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Old Column Name (古い列名)

String (文字列)

変更する列の名前。

#[payload]

New Column Name (新しい列名)

String (文字列)

列の新しい名前。

x

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-13)次の設定の場合 - [設定](#config) #### [](#スロー-13)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#select)Select `` select クエリを実行します。 #### [](#パラメーター-16)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Query (クエリ)

String (文字列)

実行するクエリ。

#[payload]

パラメーター

Any の配列

クエリパラメーター。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-3)出力

型

Array of Object (オブジェクトの配列)
### [](#次の設定の場合-14)次の設定の場合 - [設定](#config) #### [](#スロー-14)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#update)Update Entity `` エンティティの更新操作を実行します。 #### [](#パラメーター-17)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

エンティティを更新するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

削除するテーブルを含むキースペース。

Entity To Update (更新するエンティティ)

Object (オブジェクト)

更新するエンティティ。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-15)次の設定の場合 - [設定](#config) #### [](#スロー-15)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#型)型 ### [](#Tls)TLS
項目 型 説明 デフォルト値 必須

Enabled Protocols (有効化されたプロトコル)

String (文字列)

このコンテキストで有効化されたプロトコルのカンマ区切りリスト。

Enabled Cipher Suites (有効化された暗号化スイート)

String (文字列)

このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。

Trust Store (トラストストア)

トラストストア

Key Store (キーストア)

Key Store (キーストア)

Revocation Check (取り消し確認)
### [](#TrustStore)トラストストア
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

トラストストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。

Password (パスワード)

String (文字列)

トラストストアを保護するために使用するパスワード。

Type (型)

String (文字列)

使用するストアの型。

Algorithm (アルゴリズム)

String (文字列)

トラストストアで使用するアルゴリズム。

Insecure (安全ではない)

Boolean (ブール)

true の場合、証明書の検証が行われず、攻撃に対して脆弱な接続がレンダリングされます。各自の責任で使用してください。
### [](#KeyStore)Key Store (キーストア)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

キーストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。

Type (型)

String (文字列)

使用するストアの型。

Alias (別名)

String (文字列)

キーストアに多数の非公開キーが含まれている場合は、この属性によって使用するキーの別名を示します。定義しない場合、ファイルにある最初のキーがデフォルトで使用されます。

Key Password (キーパスワード)

String (文字列)

非公開キーを保護するために使用するパスワード。

Password (パスワード)

String (文字列)

キーストアを保護するために使用するパスワード。

Algorithm (アルゴリズム)

String (文字列)

キーストアで使用するアルゴリズム。
### [](#standard-revocation-check)Standard Revocation Check (標準の取り消し確認)
項目 型 説明 デフォルト値 必須

Only End Entities (最後のエンティティのみ)

Boolean (ブール)

証明書チェーンの最後の要素のみを確認します。

Prefer Crls (CRL を優先)

Boolean (ブール)

最初に OCSP ではなく CRL を試みます。

No Fallback (代替なし)

Boolean (ブール)

第 2 の確認方法 (以前に選択されていない方法) を使用しません。

Soft Fail (ソフトフェール)

Boolean (ブール)

取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合に検証エラーを回避します。
### [](#custom-ocsp-responder)Custom Ocsp Responder (カスタム Ocsp レスポンダー)
項目 型 説明 デフォルト値 必須

Url

String (文字列)

OCSP レスポンダーの URL。

Cert Alias (証明書の別名)

String (文字列)

(トラストストアに含まれている) OCSP 応答の署名証明書の別名 (存在する場合)。
### [](#crl-file)Crl File (Crl ファイル)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

CRL ファイルへのパス。
### [](#Reconnection)Reconnection (再接続)
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

Reconnection Strategy (再接続戦略)

使用する再接続戦略。
### [](#reconnect)Reconnect (再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。

Count (数)

Number (数値)

再接続の試行回数。
### [](#reconnect-forever)Reconnect Forever (繰り返し再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。
### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー)
項目 型 説明 デフォルト値 必須

Max Idle Time (最大アイドル時間)

Number (数値)

有効期限の対象とみなされるまで、動的設定インスタンスがアイドル状態を維持できる最大時間のスカラー時間値

Time Unit (時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Max Idle Time (最大アイドル時間)] 属性の時間単位。
### [](#AlterColumnInput)Alter Column Input (Alter Column の入力)
項目 型 説明 デフォルト値 必須

Column (列)

String (文字列)

Type (型)

Enumeration (列挙)。次のいずれかになります。

  • ASCII

  • BIGINT

  • BLOB

  • BOOLEAN

  • COUNTER

  • DATE

  • DECIMAL

  • DOUBLE

  • FLOAT

  • INET

  • INT

  • SMALLINT

  • TEXT

  • TIME

  • TIMESTAMP

  • TIMEUUID

  • TINYINT

  • UUID

  • VARCHAR

  • VARINT
### [](#CreateKeyspaceInput)Create Keyspace Input (Create Keyspace の入力)
項目 型 説明 デフォルト値 必須

First Data Center (最初のデータセンター)

Data Center (データセンター)

Keyspace Name (キースペース名)

String (文字列)

Next Data Center (次のデータセンター)

Data Center (データセンター)

Replication Factor (複製係数)

Number (数値)

複製戦略クラス

Enumeration (列挙)。次のいずれかになります。

  • SimpleStrategy

  • NetworkTopologyStrategy
### [](#DataCenter)Data Center (データセンター)
項目 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

Value (値)

Number (数値)
### [](#CreateTableInput)Create Table Input (Create Table の入力)
項目 型 説明 デフォルト値 必須

Columns (列)

Column Input (列の入力)​ の配列

Keyspace Name (キースペース名)

String (文字列)

Table Name (テーブル名)

String (文字列)
### [](#ColumnInput)Column Input (列の入力)
項目 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

Primary Key (主キー)

Boolean (ブール)

Type (型)

Enumeration (列挙)。次のいずれかになります。

  • ASCII

  • BIGINT

  • BLOB

  • BOOLEAN

  • COUNTER

  • DATE

  • DECIMAL

  • DOUBLE

  • FLOAT

  • INET

  • INT

  • SMALLINT

  • TEXT

  • TIME

  • TIMESTAMP

  • TIMEUUID

  • TINYINT

  • UUID

  • VARCHAR

  • VARINT
### [](#CQLQueryInput)CQL Query Input (CQL クエリの入力)
項目 型 説明 デフォルト値 必須

Cql Query (CQL クエリ)

String (文字列)

パラメーター

Any の配列
## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.1 Apache Cassandra 用 Anypoint Connector (Apache Cassandra Connector) は、企業全体で Apache Cassandra データベースとサードパーティアプリケーション、システム、サービス (SAP、PeopleSoft、Workday など) および他のデータベース間の接続を作成します。 Apache Cassandra は、大量の商品、顧客、従業員データを管理するためのオープンソースの分散型 NoSQL データベースで、Apache Cassandra 3.10.1 用 DataStax Java ドライバーを実装します。 ## [](#始める前に)始める前に このコネクタを使用するには、以下に精通している必要があります。 - Apache Cassandra API - Anypoint Connector - Mule Runtime Engine (Mule) - Mule フローの要素とグローバル要素 - Anypoint Studio (Studio) を使用した Mule アプリケーションの作成 アプリケーションを作成する前に、以下が必要です。 - Apache Cassandra 対象リソースにアクセスするためのログイン情報 - Anypoint Studio バージョン 4.1.1 以降 - このソフトウェアを使用するのに必要な Mule Enterprise Edition およびエンタイトルメント ## [](#次のステップ)次のステップ 開始することができたので、​[Anypoint Studio](https://docs.mulesoft.com/jp/cassandra-connector/4.1/cassandra-connector-studio)​ を使用して Cassandra Connector を設定してみましょう。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Exchange を使用したコネクタ、テンプレート、およびサンプルの検出](https://docs.mulesoft.com/connectors/introduction/intro-use-exchange) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.1 の XML と Maven のサポート XML で Mule アプリケーションを手動でコーディングすることもできますが、Anypoint Studio を使用した方が効率的です。 Anypoint Studio の XML エディターまたはテキストエディターから Mule Runtime Engine (Mule) アプリケーションを手動でコーディングする場合、参照ステートメントを XML Mule フローと Apache Maven ​`pom.xml`​ ファイルの両方に追加することで、アプリケーションからコネクタにアクセスできます。 Studio でコネクタを追加すると、Studio は自動的に XML コードにコネクタの名前空間およびスキーマの場所を入力し、​`pom.xml`​ ファイルに連動関係を追加します。 ## [](#コネクタの名前空間の追加)コネクタの名前空間の追加 次のコードを設定 XML のヘッダーの ​``​ タグ内に貼り付けます。 ```xml http://www.mulesoft.org/schema/mule/cassandra-db http://www.mulesoft.org/schema/mule/cassandra-db/current/mule-cassandra-db.xsd ``` 次の例は、​``​ XML ブロック内に名前空間ステートメントが配置される方法を示しています。 ```xml --- 項目 説明

Host (ホスト)

${cassandra.Host}

Port (ポート)

${cassandra.Port}

Keyspace (キースペース)

${cassandra.keySpace}

Username (ユーザー名)

${cassandra.userName}

Password (パスワード)

${cassandra.password}

4. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が Apache Cassandra インスタンスに接続できることを確認します。 正常に接続できた場合は、​**\[OK\]**​ をクリックして設定を保存します。それ以外の場合、無効なパラメーターを確認および修正して、再度テストします。 5. プロジェクトを保存します。 6. ポート ​`8081`​ で ​`test/createKeyspace`​ パスに REST 要求を送信してアプリケーションをテストします。 ### [](#新規テーブルを作成する)新規テーブルを作成する 次のフローは、対象 Apache Cassandra データベースに新規テーブルを作成します。 ![Create Table フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/cassandra-create-table.png) Figure 3. 新規テーブルの作成フロー #### [](#http-リスナーを設定する-3)HTTP リスナーを設定する ポート ​`8081`​ で ​`/test/createTable`​ パスへのコールが行われたときに Mule フローを開始するように HTTP リスナーを設定します。 1. Studio で新しい Mule プロジェクトを作成します。 2. Studio で ​**\[HTTP\]**​ をクリックし、​**\[Listener\]**​ 操作をキャンバスにドラッグします。 3. **\[Listener\]**​ 設定で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックしてグローバル要素を追加します。 4. デフォルトを受け入れます。 5. **\[Listener\]**​ 設定で、​**\[Path (パス)\]**​ 項目値を ​`/test/createTable`​ に設定します。 ### [](#transform-message-コンポーネントの追加-2)Transform Message コンポーネントの追加 **Transform Message**​ コンポーネントを追加して、​**HTTP Listener**​ から受信したペイロードに基づいて Java 変数を設定します。 1. \[Mule Palette (Mule パレット)\] ビューから、​**\[Transform Message\]**​ コンポーネントを ​**\[Listener\]**​ の右側にドラッグします。 2. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```dataweave %dw 2.0 output application/java --- { "columns": payload.columns, "tableName": payload.tableName, "keyspaceName": payload.keyspaceName } as Object { class : "org.mule.modules.cassandradb.api.CreateTableInput" } ``` #### [](#create-table-操作を追加する)Create Table 操作を追加する 前のフローで作成したキースペースに新規テーブルを作成するため、​**Create Table**​ 操作を追加します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューから、​**\[CassandDB\]**​ を選択して ​**\[Create Table\]**​ 操作を ​**\[Transform Message\]**​ コンポーネントの右側にドラッグします。 2. **\[Create Table\]**​ 設定で、​**\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックします。 3. **Create keyspace**​ 操作用に設定したグローバル要素を選択します。 4. **\[OK\]**​ をクリックします。 5. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が Cassandra インスタンスに接続できることを確認します。 クライアントテストに成功した場合は、​**\[OK\]**​ をクリックして設定を保存します。それ以外の場合、無効なパラメーターを確認および修正して、再度テストします。 6. 保存して Mule アプリケーションを実行します。 7. ポート ​`8081`​ で ​`/test/createTable`​ パスに ​**POST**​ コマンドを送信してアプリケーションをテストします。​`application/json`​ MIME タイプを使用して、データ型には大文字を使用し、コマンド本文にテーブルの説明を入力します。 ```text { "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" } ] } ``` ### [](#apache-cassandra-キースペースとテーブルの作成例の-xml)Apache Cassandra キースペースとテーブルの作成例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ## [](#manipulate-data)Apache Cassandra データベース内のデータの操作 この例は、Apache Cassandra データベース内のデータを操作するための次の方法を示しています。 - [キースペースからテーブル名を取得する。](#get-table-names) - Apache Cassandra テーブルのデータに対して次の CRUD 操作を実行する。 - [Insert](#insert) - [Select](#select) - [Update](#update) - [Delete](#delete) - Apache Cassandra テーブル列に対して次の操作を実行する。 - [列の値を削除。](#delete-columns) - [列の名前を変更。](#rename-columns) - [新しい列を追加。](#add-new-column) - [列を削除](#drop-columns)​。 - [Cassandra クエリ言語 (CQL) クエリを実行。](#execute-cql) - Apache Cassandra データベーステーブルからデータを削除する。 - [キースペースからテーブルを削除。](#drop-table) - [キースペースを削除。](#drop-keyspace) ### [](#get-table-names)キースペースからのテーブル名の取得 この Mule フローは、指定されたキースペースからすべてのテーブル名を返します。 ![Get Table Names from Keyspace 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/get-table-names.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Get Table Names from Keyspace**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-4)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/getTablesFromKeyspace`​ に設定します。 #### [](#get-table-names-from-keyspace-操作を追加する)Get Table Names from Keyspace 操作を追加する **Get Table Names from Keyspace**​ 操作は、指定されたキースペースからすべてのテーブル名を返します。 1. **Get Table Names from Keyspace**​ 操作を、キャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Get Table Names from Keyspace\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Get Table Names from Keyspace\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Keyspace name (キースペース名)

#[payload.keyspaceName]
#### [](#transform-message-コンポーネントを追加する)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**Get Table Names from Keyspace**​ 操作の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#insert)挿入 この Mule フローは、キースペースのテーブルにエンティティを挿入します。 ![Insert Entity 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/insert-entity.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Insert Entity**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-5)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/insert`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-2)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "id": payload.id, "name": payload.name, "event": payload.event } ``` #### [](#insert-entity-操作を追加する)Insert Entity 操作を追加する **Insert Entity**​ 操作は、キースペースのテーブルにエンティティを挿入します。 1. **Insert Entity**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Insert Entity\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Insert Entity\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entity to insert (挿入するエンティティ)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Insert Entity\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#select)選択 この Mule フローは ​**Select**​ クエリを実行します。 ![Select 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/select.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Select**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-6)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/insert`​ に設定します。 #### [](#select-操作を追加する)Select 操作を追加する **Select**​ 操作は、キースペースで ​**Select**​ クエリを実行します。 1. **Select**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Select\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**Cassandra​DB\_C​onfig**​ を選択します。 3. **\[Select\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Query

SELECT id, name, event FROM example_keyspace.example_table
#### [](#transform-message-コンポーネントを追加する-3)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Select\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#update)更新 この Mule フローは、キースペースのテーブルのエンティティを更新します。 ![Update Entity 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/update-entity.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Update Entity**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-7)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/update`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-4)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "where":{ id: payload.where }, "columns":payload.columns } ``` #### [](#update-entity-操作を追加する)Update Entity 操作を追加する **Update Entity**​ 操作は、キースペースのテーブルのエンティティを更新します。 1. **Update Entity**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Update Entity\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Update Entity\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entity to insert (挿入するエンティティ)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-2)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Update Entity\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#delete)削除 この Mule フローは、キースペースのテーブルからエンティティを削除します。 ![Delete Rows 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/delete-row.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Delete Rows**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-8)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/deleteRows`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-5)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "where": { id: payload.ids } } ``` #### [](#delete-rows-操作を追加する)Delete Rows 操作を追加する **Delete Rows**​ 操作は、レコードを削除します。 1. **Delete Rows**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Delete Rows\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Delete Rows\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entity to insert (挿入するエンティティ)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-3)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Delete Rows\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#delete-columns)列値の削除 この Mule フローは、キースペースのテーブルから列の値を削除します。 ![Delete Columns Value 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/delete-column.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Delete Columns Value**​ 操作を追加する - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-9)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/deleteColumns`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-6)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "columns": payload.columns, "where": { id:payload.where } } ``` #### [](#delete-columns-value-操作を追加する)Delete Columns Value 操作を追加する **Delete Columns Value**​ 操作は、​**Where 句**​で指定されたオブジェクトから値を削除します。 1. **Delete Columns Value**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Delete Columns Value\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Delete Columns Value\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

example_table

Keyspace name (キースペース名)

example_keyspace

Entities (エンティティ)

Edit inline

値

#[payload.entities]

Where clause (Where 句)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-4)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Delete Columns Value\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#rename-columns)列名の変更 この Mule フローは、指定されたキースペースのテーブルの列名を変更します。 ![Rename Column 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/rename-columns.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Rename Column**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-10)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/renameColumn`​ に設定します。 #### [](#rename-column-操作を追加する)Rename Column 操作を追加する **Rename Column**​ 操作は、キースペースのテーブルの列名を変更します。 1. **Rename Column**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Rename Column\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Rename Column\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

#[payload.tableName]

Keyspace name (キースペース名)

#[payload.keyspaceName]

Old column name (古い列名)

payload.oldName

New column name (新しい列名)

#[payload.newName]
#### [](#transform-message-コンポーネントを追加する-7)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Rename Column\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#add-new-column)新しい列の追加 この Mule フローは、キースペースのテーブルに新しい列を追加します。 ![Add New Table Column 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/add-new-column.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Set Variable**​ コンポーネント - 2 つ目の ​**Set Variable**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Add New Table Column**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-11)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/addNewColumn`​ に設定します。 #### [](#set-variable-コンポーネントを追加する)Set Variable コンポーネントを追加する 最初の ​**Set Variable**​ コンポーネントは、テーブル名の値を格納します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`set variable`​」を検索します。 2. **\[Set Variable\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **\[Set Variable\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

名前

tableName

値

#[payload.tableName]
#### [](#2-つ目の-set-variable-コンポーネントを追加する)2 つ目の Set Variable コンポーネントを追加する 2 つ目の ​**Set Variable**​ コンポーネントは、キースペース名の値を格納します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`set variable`​」を検索します。 2. **\[Set Variable\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **\[Set Variable\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

名前

keyspaceName

値

#[payload.keyspaceName]
#### [](#transform-message-コンポーネントを追加する-8)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Set Variable\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "column": payload.column, "type": payload.'type' } as Object { class : "org.mule.modules.cassandradb.api.AlterColumnInput" } ``` #### [](#add-new-table-column-操作を追加する)Add New Table Column 操作を追加する **Add New Table Column**​ 操作は、新しい列を追加します。 1. **Add New Table**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Add New Table Column\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Add New Table Column\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

#[vars['tableName']]

Keyspace name (キースペース名)

#[vars['keyspaceName']]

Alter column input (変更列の入力)

payload
#### [](#2-つ目の-transform-message-コンポーネントを追加する-5)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Add New Table Column\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#drop-columns)列の削除 この Mule フローは、キースペースのテーブルから列を削除します。 ![Drop Column 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/drop-columns.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Drop Column**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-12)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/dropColumn`​ に設定します。 #### [](#drop-column-操作を追加する)Drop Column 操作を追加する **Drop Column**​ 操作は、列を削除します。 1. **Drop Column**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Drop Column\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Drop Column\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table (テーブル)

#[payload.tableName]

Keyspace name (キースペース名)

#[payload.keyspaceName]

Column name (列名)

payload.columnName
#### [](#transform-message-コンポーネントを追加する-9)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Drop Column\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#execute-cql)Cassandra クエリ言語 (CQL) クエリの実行 この Mule フローは、指定された未加工の入力クエリを実行します。 ![Execute CQL Query 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/execute-cql.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **\[Transform Message\]**​ コンポーネント - **Execute CQL Query**​ 操作 - 2 つ目の ​**\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-13)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/executeCqlQuery`​ に設定します。 #### [](#transform-message-コンポーネントを追加する-10)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/java --- { "cqlQuery": payload.cqlQuery, "parameters": payload.parameters } as Object { class : "org.mule.modules.cassandradb.api.CQLQueryInput" } ``` #### [](#execute-cql-query-操作を追加する)Execute CQL Query 操作を追加する **Execute CQL Query**​ 操作は、未加工の入力クエリを実行します。 1. **Execute CQL Query**​ 操作をキャンバスの ​**\[Transform Message\]**​ の横にドラッグします。 2. **\[Execute CQL Query\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 #### [](#2-つ目の-transform-message-コンポーネントを追加する-6)2 つ目の \[Transform Message\] コンポーネントを追加する 2 つ目の ​**\[Transform Message\]**​ コンポーネントは、キースペースのデータを Java から XML に変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Execute CQL Query\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#drop-table)テーブルの削除 この Mule フローは、指定されたキースペースからテーブルを削除します。 ![Drop Table 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/drop-table.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Drop Table**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-14)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/dropTable`​ に設定します。 #### [](#drop-table-操作を追加する)Drop Table 操作を追加する **Drop Table**​ 操作は、指定されたキースペースからテーブルを削除します。​**Drop Table**​ 操作でキースペースを指定しないと、接続パラメーターのキースペースでテーブルが作成されます。 1. **Drop Table**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Drop Table\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Drop Table\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Table name (テーブル名)

payload.tableName

Keyspace name (キースペース名)

#[payload.keyspaceName]
#### [](#transform-message-コンポーネントを追加する-11)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Drop Table\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#drop-keyspace)キースペースの削除 この Mule フローは、指定されたキースペースとその値を削除します。 ![Drop Keyspace 操作の Studio フロー](/mulesoft/current/ja-jp/cassandra-connector/4.1/_images/drop-keyspace.png) このフローでは、次を設定します。 - **HTTP Listener**​ コンポーネント - **Drop Keyspace**​ 操作 - **\[Transform Message\]**​ コンポーネント #### [](#http-リスナーを設定する-15)HTTP リスナーを設定する `localhost`​ のポート ​`8081`​ で ​`/`​ アカウントパスへのコールが行われたときに Mule フローを開始するように ​**HTTP Listener**​ を設定します。 Unresolved include directive in modules/ROOT/pages/cassandra-connector-examples.adoc - include::connectors::partial$configure-http-listener-partial.adoc\[\] . **\[Path (パス)\]**​ 項目を ​`/dropKeyspace`​ に設定します。 #### [](#drop-keyspace-操作を追加する)Drop Keyspace 操作を追加する **Drop Keyspace**​ 操作は、キースペースとその値を削除します。 1. **Drop Keyspace**​ 操作をキャンバスの ​**\[HTTP Listener\]**​ の横にドラッグします。 2. **\[Drop Keyspace\]**​ の設定で、 ​**\[Connector configuration (コネクタ設定)\]**​ ドロップダウンをクリックし、 ​**\[Cassandra​DB\_C​onfig\]**​ を選択します。 3. **\[Drop Keyspace\]**​ プロパティウィンドウで、次の項目を設定します。
項目 値

Keyspace name (キースペース名)

payload.keyspaceName
#### [](#transform-message-コンポーネントを追加する-12)\[Transform Message\] コンポーネントを追加する **\[Transform Message\]**​ コンポーネントは、キースペースのデータを変換します。 1. **\[Mule Palette (Mule パレット)\]**​ ビューで、「​`transform message`​」を検索します。 2. **\[Transform Message\]**​ コンポーネントをキャンバスの ​**\[Drop Keyspace\]**​ の横にドラッグします。 3. **Transform Message**​ 設定で、​**\[Output (出力)\]**​ セクションの括弧を次の XML で上書きします。 ```xml %dw 2.0 output application/json --- payload ``` ### [](#apache-cassandra-データベースのデータの操作例)Apache Cassandra データベースのデータの操作例 この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml SELECT id, name, event FROM example_keyspace.example_table ``` ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.1 の追加設定情報 基本認証と DataSense 機能を備えた環境で動作するように、Apache Cassandra 用 Anypoint Connector (Apache Cassandra Connector) を設定します。 ## [](#enable-authentication)Apache Cassandra 認証の有効化 デフォルトでは、Apache Cassandra データベースへのアクセスにログイン情報は必要ありません。 認証を有効にするように Apache Cassandra を設定する必要があります。Apache Cassandra Connector の設定は、基本認証の Apache Cassandra の設定と一致する必要があります。 認証を有効にしたら、Apache Cassandra インストールのホームディレクトリから次の例のように ​`cqlsh`​ コマンドを実行します。次の例では、デフォルトのログイン情報 (ユーザー名 ​`cassandra`​、パスワード ​`cassandra`​) を使用しています。 ```text bin/cqlsh localhost -u cassandra -p cassandra Connected to Test Cluster at localhost:9042. [cqlsh 5.0.1 | Cassandra 3.10 | CQL spec 3.4.4 | Native protocol v4] Use HELP for help. ``` 1. Apache Cassandra をインストールしたら、編集目的で ​`conf\cassandra.yaml`​ ファイルを開きます。 2. 必要に応じて、​`AllowAllAuthenticator`​ の値を ​`PasswordAuthenticator`​ に変更します。 3. Apache Cassandra を再起動します。 4. 別の端末タブで、Apache Cassandra が実行されていることを確認します。 `bin/nodetool status` ## [](#pojo-設定)POJO 設定 このコネクタは、「Apache Cassandra Connector リファレンス」の複数の操作を公開します。 次の操作は、DataSense 機能で必要とされる一部の POJO を入力パラメーターとして受け入れます。 - `addNewColumn` - `changeColumnType` - `createKeyspace` - `createTable` - `deleteColumnsValue` - `deleteRows` - `dropColumn` - `dropKeyspace` - `dropTable` - `executeCQLQuery` - `getTableNamesFromKeyspace` - `renameColumn` - `select` - `update` ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Apache Cassandra Connector 4.1 リファレンス Cassandra 用 Anypoint Connector (Cassandra Connector) は、Apache Cassandra 3.1 用 DataStax Java ドライバーを実装します。 ## [](#設定)設定 * * * ### [](#config)設定 #### [](#パラメーター)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

Connection (接続)

この設定に指定する接続認証種別。

x

Expiration Policy (有効期限ポリシー)

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。これは、インスタンスが有効期限の対象となった瞬間にプラットフォームでそのインスタンスが期限切れになるということではありません。必要に応じて、インスタンスがパージされます。
#### [](#接続種別)接続種別 ##### [](#config_connection)Connection (接続) ###### [](#パラメーター-2)パラメーター
名前 型 説明 デフォルト値 必須

Host (ホスト)

String (文字列)

ホスト名または IP アドレス。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

Enumeration (列挙)。次のいずれかになります。

  • HTTPS

  • LDAPS

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

HTTPS

Port (ポート)

String (文字列)

Port (ポート)

9042

Cassandra Keyspace (Cassandra キースペース)

String (文字列)

Cassandra キースペース。

Cassandra Cluster Name (Cassandra クラスター名)

String (文字列)

Cassandra クラスター名。

Cassandra Cluster Nodes (Cassandra クラスターノード)

String (文字列)

Cassandra クラスターノード (カンマで区切られた IP またはホストアドレスとポート。例: host1:port1, ​host2:port2​)。ポートが指定されていない場合、コネクタではデフォルトポート ​9042​ が使用されます。このパラメーターを指定した場合、一般設定のホストとポートは無視されます。

Username (ユーザー名)

String (文字列)

認証用のユーザー名。

Password (パスワード)

String (文字列)

認証用のパスワード。パスワードが null またはすべて空白の場合、コネクタで認証は使用されません。この場合、ユーザー名も空にする必要があります。

Protocol Version (プロトコルバージョン)

Enumeration (列挙)。次のいずれかになります。

  • V1

  • V2

  • V3

  • V4

ドライバーでサポートされるネイティブプロトコルのバージョン。

Max Schema Agreement Wait Seconds (スキーマ一致の最大待機時間)

Number (数値)

DDL クエリから戻るまでスキーマ一致を待機する最大時間。

0

Compression (圧縮)

Enumeration (列挙)。次のいずれかになります。

  • LZ4

  • None (なし)

  • SNAPPY

トランスポートで使用する圧縮。

Prepared Statements Cache Size (プリペアードステートメントのキャッシュサイズ)

Number (数値)

プリペアードステートメントのキャッシュサイズ。Mule アプリケーションで処理するさまざまなステートメントの数以上の値を設定します。

10

TLS Configuration (TLS 設定)

TLS

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
## [](#サポートされている操作)サポートされている操作 - [Add New Table Column](#addNewColumn) - [Change Column Type](#changeColumnType) - [Create Keyspace](#createKeyspace) - [Create Table](#createTable) - [Delete Columns Value](#deleteColumnsValue) - [Delete Rows](#deleteRows) - [Drop Column](#dropColumn) - [Drop Keyspace](#dropKeyspace) - [Drop Table](#dropTable) - [Execute CQL Query](#executeCQLQuery) - [Get All Table Names From Keyspace](#getTableNamesFromKeyspace) - [Insert Entity](#insert) - [Rename Column](#renameColumn) - [Select](#select) - [Update Entity](#update) ### [](#制限事項)制限事項 Cassandra 操作では、固定列型や他のカスタム列型はサポートされていません。これらの列型を使用する場合は、未加工の CQL クエリで ​**Execute CQL Query**​ 操作を使用します。 ### [](#addNewColumn)Add New Table Column `` 新しい列を追加します。 #### [](#パラメーター-3)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Alter Column Input (Alter Column の入力)

Alter Column Input (Alter Column の入力)

新しい列の名前とそのデータ型を定義する POJO。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合)次の設定の場合 - [設定](#config) #### [](#スロー)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#changeColumnType)Change Column Type `` 列の型を変更します。互換性をチェックするには、 [「CQL type compatibility (CQL 型の互換性)」](http://docs.datastax.com/en/cql/3.1/cql/cql_reference/cql_data_types_c.html#concept_ds_wbk_zdt_xj__cql_data_type_compatibility)​を参照してください。 #### [](#パラメーター-4)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Alter Column Input (Alter Column の入力)

Alter Column Input (Alter Column の入力)

変更する列の名前と新しいデータ型を定義する POJO。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-2)次の設定の場合 - [設定](#config) #### [](#スロー-2)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#createKeyspace)Create Keyspace `` 新しいキースペースを作成します。 #### [](#パラメーター-5)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Input (入力)

Create Keyspace Input (Create Keyspace の入力)

キースペース名と複製の詳細を含む、操作の入力。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-3)次の設定の場合 - [設定](#config) #### [](#スロー-3)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#createTable)Create Table `` 特定のキースペース内にテーブル (列ファミリー) を作成します。キースペースを指定しない場合、コネクタではログイン用のキースペースが使用されます。 #### [](#パラメーター-6)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Create Table Input (Create Table の入力)

Create Table Input (Create Table の入力)

Create Table Input​ 操作。テーブル名、キースペース名、および列のリストを指定します。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-4)次の設定の場合 - [設定](#config) #### [](#スロー-4)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#deleteColumnsValue)Delete Columns Value `` Where 句で指定されたオブジェクトから値を削除します。 #### [](#パラメーター-7)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

テーブルの名前

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Entities (エンティティ)

Array of String (文字列の配列)

削除する列。

x

Where Clause (Where 句)

Object (オブジェクト)

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-5)次の設定の場合 - [設定](#config) #### [](#スロー-5)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#deleteRows)Delete Rows `` レコード全体を削除します。 #### [](#パラメーター-8)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

テーブルの名前

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Where Clause (Where 句)

Object (オブジェクト)

Delete​ 操作の Where 句。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-6)次の設定の場合 - [設定](#config) #### [](#スロー-6)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#dropColumn)Drop Column `` 列を削除します。 #### [](#パラメーター-9)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Column Name (列名)

String (文字列)

削除する列の名前。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-7)次の設定の場合 - [設定](#config) #### [](#スロー-7)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#dropKeyspace)Drop Keyspace `` キースペース全体を削除します。 #### [](#パラメーター-10)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Keyspace Name (キースペース名)

String (文字列)

削除するキースペースの名前。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-8)次の設定の場合 - [設定](#config) #### [](#スロー-8)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#dropTable)Drop Table `` 指定されたキースペースからテーブル全体を削除します。または、操作パラメーターとしてキースペースが指定されていない場合は、ログインで使用されるキースペースからテーブル全体を削除します。 #### [](#パラメーター-11)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table Name (テーブル名)

String (文字列)

削除するテーブルの名前。

#[payload]

Keyspace Name (キースペース名)

String (文字列)

削除するテーブルを含むキースペース。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-9)次の設定の場合 - [設定](#config) #### [](#スロー-9)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#executeCQLQuery)Execute CQL Query `` 指定された未加工の入力クエリを実行します。 #### [](#パラメーター-12)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Cql Input (CQL の入力)

CQL Query Input (CQL クエリの入力)

実行するパラメーター化されたクエリをクエリパラメーターと共に記述する CQL クエリ入力。

#[payload]

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力)出力

型

Array of Object (オブジェクトの配列)
### [](#次の設定の場合-10)次の設定の場合 - [設定](#config) #### [](#スロー-10)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#getTableNamesFromKeyspace)Get All Table Names From Keyspace `` 指定されたキースペースからすべてのテーブル名を返します。 #### [](#パラメーター-13)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Keyspace Name (キースペース名)

String (文字列)

操作で使用するキースペースの名前。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-2)出力

型

Array of String (文字列の配列)
### [](#次の設定の場合-11)次の設定の場合 - [設定](#config) #### [](#スロー-11)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#insert)Insert Entity `` エンティティの挿入操作を実行します。 #### [](#パラメーター-14)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

エンティティを挿入するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Entity To Insert (挿入するエンティティ)

Object (オブジェクト)

挿入するエンティティ。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-12)次の設定の場合 - [設定](#config) #### [](#スロー-12)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#renameColumn)Rename Column `` 列の名前を変更します。 #### [](#パラメーター-15)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

使用するテーブルを含むキースペース。

Old Column Name (古い列名)

String (文字列)

変更する列の名前。

#[payload]

New Column Name (新しい列名)

String (文字列)

列の新しい名前。

x

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-13)次の設定の場合 - [設定](#config) #### [](#スロー-13)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#select)Select `` select クエリを実行します。 #### [](#パラメーター-16)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Query (クエリ)

String (文字列)

実行するクエリ。

#[payload]

パラメーター

Any の配列

クエリパラメーター。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-3)出力

型

Array of Object (オブジェクトの配列)
### [](#次の設定の場合-14)次の設定の場合 - [設定](#config) #### [](#スロー-14)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ### [](#update)Update Entity `` エンティティの更新操作を実行します。 #### [](#パラメーター-17)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

エンティティを更新するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

削除するテーブルを含むキースペース。

Entity To Update (更新するエンティティ)

Object (オブジェクト)

更新するエンティティ。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-15)次の設定の場合 - [設定](#config) #### [](#スロー-15)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CASSANDRA\_EXECUTION - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TLS\_CONFIGURATION - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#型)型 ### [](#Tls)TLS
項目 型 説明 デフォルト値 必須

Enabled Protocols (有効化されたプロトコル)

String (文字列)

このコンテキストで有効化されたプロトコルのカンマ区切りリスト。

Enabled Cipher Suites (有効化された暗号化スイート)

String (文字列)

このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。

トラストストア

トラストストア

Key Store (キーストア)

Key Store (キーストア)

Revocation Check (取り消し確認)
### [](#TrustStore)トラストストア
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

トラストストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。

Password (パスワード)

String (文字列)

トラストストアを保護するために使用するパスワード。

Type (型)

String (文字列)

使用するストアの型。

Algorithm (アルゴリズム)

String (文字列)

トラストストアで使用するアルゴリズム。

Insecure (安全ではない)

Boolean (ブール)

true の場合、証明書の検証が行われず、攻撃に対して脆弱な接続がレンダリングされます。各自の責任で使用してください。
### [](#KeyStore)Key Store (キーストア)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

キーストアの場所 (可能な場合、現在のクラスパスおよびファイルシステムに対して相対的に解決される場所)。

Type (型)

String (文字列)

使用するストアの型。

Alias (別名)

String (文字列)

キーストアに多数の非公開キーが含まれている場合は、この属性によって使用するキーの別名を示します。定義しない場合、ファイルにある最初のキーがデフォルトで使用されます。

Key Password (キーパスワード)

String (文字列)

非公開キーを保護するために使用するパスワード。

Password (パスワード)

String (文字列)

キーストアを保護するために使用するパスワード。

Algorithm (アルゴリズム)

String (文字列)

キーストアで使用するアルゴリズム。
### [](#standard-revocation-check)Standard Revocation Check (標準の取り消し確認)
項目 型 説明 デフォルト値 必須

Only End Entities (最後のエンティティのみ)

Boolean (ブール)

証明書チェーンの最後の要素のみを確認します。

Prefer Crls (CRL を優先)

Boolean (ブール)

最初に OCSP ではなく CRL を試みます。

No Fallback (代替なし)

Boolean (ブール)

第 2 の確認方法 (以前に選択されていない方法) を使用しません。

Soft Fail (ソフトフェール)

Boolean (ブール)

取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合に検証エラーを回避します。
### [](#custom-ocsp-responder)Custom Ocsp Responder (カスタム Ocsp レスポンダー)
項目 型 説明 デフォルト値 必須

Url

String (文字列)

OCSP レスポンダーの URL。

Cert Alias (証明書の別名)

String (文字列)

(トラストストアに含まれている) OCSP 応答の署名証明書の別名 (存在する場合)。
### [](#crl-file)Crl File (Crl ファイル)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

CRL ファイルへのパス。
### [](#Reconnection)Reconnection (再接続)
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

Reconnection Strategy (再接続戦略)

使用する再接続戦略。
### [](#reconnect)Reconnect (再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。

Count (数)

Number (数値)

再接続の試行回数。
### [](#reconnect-forever)Reconnect Forever (繰り返し再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。
### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー)
項目 型 説明 デフォルト値 必須

Max Idle Time (最大アイドル時間)

Number (数値)

有効期限の対象とみなされるまで、動的設定インスタンスがアイドル状態を維持できる最大時間のスカラー時間値

Time Unit (時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Max Idle Time (最大アイドル時間)] 属性の時間単位。
### [](#AlterColumnInput)Alter Column Input (Alter Column の入力)
項目 型 説明 デフォルト値 必須

Column (列)

String (文字列)

Type (型)

Enumeration (列挙)。次のいずれかになります。

  • ASCII

  • BIGINT

  • BLOB

  • BOOLEAN

  • COUNTER

  • DATE

  • DECIMAL

  • DOUBLE

  • FLOAT

  • INET

  • INT

  • SMALLINT

  • TEXT

  • TIME

  • TIMESTAMP

  • TIMEUUID

  • TINYINT

  • UUID

  • VARCHAR

  • VARINT
### [](#CreateKeyspaceInput)Create Keyspace Input (Create Keyspace の入力)
項目 型 説明 デフォルト値 必須

First Data Center (最初のデータセンター)

Data Center (データセンター)

Keyspace Name (キースペース名)

String (文字列)

Next Data Center (次のデータセンター)

Data Center (データセンター)

Replication Factor (複製係数)

Number (数値)

複製戦略クラス

Enumeration (列挙)。次のいずれかになります。

  • SimpleStrategy

  • NetworkTopologyStrategy
### [](#DataCenter)Data Center (データセンター)
項目 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

Value (値)

Number (数値)
### [](#CreateTableInput)Create Table Input (Create Table の入力)
項目 型 説明 デフォルト値 必須

Columns (列)

Column Input (列の入力)​ の配列

Keyspace Name (キースペース名)

String (文字列)

Table Name (テーブル名)

String (文字列)
### [](#ColumnInput)Column Input (列の入力)
項目 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

Primary Key (主キー)

Boolean (ブール)

Type (型)

Enumeration (列挙)。次のいずれかになります。

  • ASCII

  • BIGINT

  • BLOB

  • BOOLEAN

  • COUNTER

  • DATE

  • DECIMAL

  • DOUBLE

  • FLOAT

  • INET

  • INT

  • SMALLINT

  • TEXT

  • TIME

  • TIMESTAMP

  • TIMEUUID

  • TINYINT

  • UUID

  • VARCHAR

  • VARINT
### [](#CQLQueryInput)CQL Query Input (CQL クエリの入力)
項目 型 説明 デフォルト値 必須

Cql Query (CQL クエリ)

String (文字列)

パラメーター

Any の配列
## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Cassandra Connector のトラブルシューティング Apache Cassandra (Apache Cassandra Connector) のトラブルシューティングを行うには、冗長ログの有効化と、スローされる一般的なメッセージの解釈に関する情報を理解しておきます。 ## [](#冗長ログの有効化)冗長ログの有効化 アプリケーションと Cassandra Connector のやりとりが失敗する理由の理解を深めるには、モジュールの冗長ログを一時的に有効にします。 Mule アプリケーションのパフォーマンスに影響するため、トラブルシューティングが完了したら、必ず拡張された冗長性を無効にしてください。 設定ファイルで冗長ログを有効にする手順は、次のとおりです。 1. Anypoint Studio にアクセスし、​**\[Package Explorer\]**​ ビューに移動します。 2. アプリケーションのプロジェクト名を開きます。 3. `src/main/resources`​ パスフォルダーを開きます。 4. フォルダー内の ​`log4j2.xml`​ ファイルを開きます。 5. ``​ タグ内に ​``​ タグを追加します。 ```xml ... ... ``` 6. アプリケーションの変更を保存します。 7. **Package Explorer**​ でプロジェクト名をクリックし、​**\[Run (実行)\]**​ > ​**\[Run As (別のユーザーとして実行)\]**​ > ​**\[Mule Application (Mule アプリケーション)\]**​ をクリックします。 ## [](#プリペアードステートメントのキャッシュサイズのトラブルシューティング)プリペアードステートメントのキャッシュサイズのトラブルシューティング Mule アプリケーションの実行時に次の警告メッセージが表示された場合: * * * WARN com.datastax.driver.core.Cluster \[Test-Cluster-worker-23\] Re-preparing already prepared query is generally an anti-pattern and will likely affect performance. (すでに準備されたクエリを再準備することは一般にアンチパターンであり、パフォーマンスに影響する可能性があります。)Consider preparing the statement only once. (ステートメントは 1 回のみ準備することを検討してください。) --- 前述のメッセージを回避するには、​**\[Prepared Statement Cache Size (プリペアードステートメントのキャッシュサイズ)\]**​ パラメーターの値を大きくします。これにより、プリペアードステートメントのキャッシュサイズを設定できます。Mule アプリケーションで処理するさまざまなステートメントの数以上の値を設定します。 ## [](#関連情報)関連情報 - [MuleSoft ヘルプセンター](https://help.mulesoft.com) - [Known Issues](https://help.salesforce.com/s/issues) # Cassandra Connector のバージョン 4.x へのアップグレードおよび移行 Cassandra Connector をバージョン 4.x にアップグレードして相互 TLS 認証を使用します。 ## [](#サポートされているアップグレードパス)サポートされているアップグレードパス
開始バージョン 終了バージョン

3.x

4.x
## [](#このリリースの新機能)このリリースの新機能 このリリースでは、相互 TLS 認証がサポートされます。 ## [](#このリリースでの変更)このリリースでの変更 このリリースには、次の変更が含まれています。 - 設定から ​**\[SSL\]**​ 項目を削除し、​**\[TLS\]**​ に置換 - エラー処理とエラー種別をリファクタリング ## [](#アップグレード前提条件)アップグレード前提条件 アップグレードを実行する前に、復元する必要がある場合に備えて、ファイル、データ、および設定のバックアップを作成します。 ## [](#アップグレード手順)アップグレード手順 以下の手順でアップグレードを実行します。 1. Anypoint Studio で、Mule プロジェクトを作成します。 2. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[Search in Exchange (Exchange 内を検索)\]**​ をクリックします。 3. **\[Add Dependencies to Project (連動関係をプロジェクトに追加)\]**​ で、検索項目に「​`cassandra`​」と入力します。 4. **\[Available modules (使用可能なモジュール)\]**​ で、​**\[Cassandra\]**​ を選択して ​**\[Add (追加)\]**​ をクリックします。 5. **\[Finish (完了)\]**​ をクリックします。 6. Mule プロジェクトの ​`pom.xml`​ ファイルで Cassandra Connector 連動関係のバージョンが ​`<4.0.0>`​ であることを確認します。 Studio はコネクタを自動的にアップグレードします。 ### [](#アップグレードを確認する)アップグレードを確認する コネクタの最新バージョンをインストールしたら、次の手順に従ってアップグレードを確認します。 1. Studio の ​**\[Problems (問題)\]**​ または ​**\[Console (コンソール)\]**​ ビューでエラーがないことを確認します。 2. プロジェクトの ​`pom.xml`​ ファイルに問題がないことを確認します。 3. 接続をテストして、操作が機能することを確認します。 ## [](#アップグレードの復元)アップグレードの復元 以前のバージョンの Cassandra Connector に戻す必要がある場合、プロジェクトの ​`pom.xml`​ ファイルの ​`cassandra-connector`​ 連動関係バージョンを前のバージョンに変更します。 Anypoint Studio でプロジェクトの ​`pom.xml`​ ファイルを更新する必要があります。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Cassandra Connector のバージョン 4.x へのアップグレードおよび移行 Cassandra Connector をバージョン 4.x にアップグレードして相互 TLS 認証を使用します。 ## [](#サポートされているアップグレードパス)サポートされているアップグレードパス
開始バージョン 終了バージョン

3.x

4.x
## [](#このリリースの新機能)このリリースの新機能 このリリースでは、相互 TLS 認証がサポートされます。 ## [](#このリリースでの変更)このリリースでの変更 このリリースには、次の変更が含まれています。 - 設定から ​**\[SSL\]**​ 項目を削除し、​**\[TLS\]**​ に置換 - エラー処理とエラー種別をリファクタリング ## [](#アップグレード前提条件)アップグレード前提条件 アップグレードを実行する前に、復元する必要がある場合に備えて、ファイル、データ、および設定のバックアップを作成します。 ## [](#アップグレード手順)アップグレード手順 以下の手順でアップグレードを実行します。 1. Anypoint Studio で、Mule プロジェクトを作成します。 2. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[Search in Exchange (Exchange 内を検索)\]**​ をクリックします。 3. **\[Add Dependencies to Project (連動関係をプロジェクトに追加)\]**​ で、検索項目に「​`cassandra`​」と入力します。 4. **\[Available modules (使用可能なモジュール)\]**​ で、​**\[Cassandra\]**​ を選択して ​**\[Add (追加)\]**​ をクリックします。 5. **\[Finish (完了)\]**​ をクリックします。 6. Mule プロジェクトの ​`pom.xml`​ ファイルで Cassandra Connector 連動関係のバージョンが ​`<4.0.0>`​ であることを確認します。 Studio はコネクタを自動的にアップグレードします。 ### [](#アップグレードを確認する)アップグレードを確認する コネクタの最新バージョンをインストールしたら、次の手順に従ってアップグレードを確認します。 1. Studio の ​**\[Problems (問題)\]**​ または ​**\[Console (コンソール)\]**​ ビューでエラーがないことを確認します。 2. プロジェクトの ​`pom.xml`​ ファイルに問題がないことを確認します。 3. 接続をテストして、操作が機能することを確認します。 ## [](#アップグレードの復元)アップグレードの復元 以前のバージョンの Cassandra Connector に戻す必要がある場合、プロジェクトの ​`pom.xml`​ ファイルの ​`cassandra-connector`​ 連動関係バージョンを前のバージョンに変更します。 Anypoint Studio でプロジェクトの ​`pom.xml`​ ファイルを更新する必要があります。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Cassandra Connector リファレンス Cassandra Connector v3.1 Cassandra 用 Anypoint Connector (Cassandra Connector) は、Apache Cassandra 3.1 用 DataStax Java ドライバーを実装します。 リリースノート: [Cassandra Connector リリースノート](https://docs.mulesoft.com/jp/release-notes/connector/cassandra-connector-release-notes-mule-4) ## [](#設定)設定 * * * ### [](#config)設定 ### [](#パラメーター)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

Connection (接続)

この設定に指定できる接続種別。

x

Expiration Policy (有効期限ポリシー)

ExpirationPolicy

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Runtime で期限切れに相当するとみなされます。これは、インスタンスが有効期限の対象となった瞬間にプラットフォームでそのインスタンスが期限切れになるということではありません。インスタンスは必要に応じてランタイムによりパージされます。
## [](#接続種別)接続種別 ### [](#config_connection)Connection (接続) ### [](#パラメーター-2)パラメーター
名前 型 説明 デフォルト値 必須

Host (ホスト)

String (文字列)

ホスト名または IP アドレス。

localhost

Port (ポート)

String (文字列)

ポート (デフォルトは 9042)。

9042

Keyspace (キースペース)

String (文字列)

Cassandra キースペース。

Cluster Name (クラスター名)

String (文字列)

Cassandra クラスター名。

Cluster Nodes (クラスターノード)

String (文字列)

Cassandra クラスターノードがサポートされます。このアドレスは、カンマで区切られた IP またはホストアドレスとポート番号です。形式: host1:port1, host2:port2​、例: 127.0.0.1:9160, 127.0.0.2:9160​。ポートが指定されていない場合、デフォルトの 9042 が使用されます。このパラメーターを指定した場合、一般設定のホストとポートは無視されます。

Username (ユーザー名)

String (文字列)

Password (パスワード)

String (文字列)

認証に使用するパスワード。パスワードが null または空白のみの場合、コネクタは認証を使用せず、ユーザー名も空になっている必要があります。

Protocol Version (プロトコルバージョン)

Enumeration (列挙)。次のいずれかになります。

  • V1

  • V2

  • V3

  • V4

ドライバーでサポートされるネイティブプロトコルのバージョン。

Max Schema Agreement Wait Seconds (スキーマ一致の最大待機時間)

Number (数値)

DDL クエリから戻るまでスキーマ一致を待機する最大時間。

0

Compression (圧縮)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • SNAPPY

  • LZ4

トランスポートで使用する圧縮。

SSL

Boolean (ブール)

クラスターに対して SSL の使用を有効にします。

false

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
### [](#関連操作)関連操作 - addNewColumn - changeColumnType - createKeyspace - createTable - deleteColumnsValue - deleteRows - dropColumn - dropKeyspace - dropTable - executeCQLQuery - getTableNamesFromKeyspace - 挿入 - renameColumn - 選択 - 更新 ## [](#操作)操作 ## [](#addNewColumn)Add New Column `` 新しい列を追加します。 ### [](#パラメーター-3)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Alter Column Input (Alter Column の入力)

AlterColumnInput

新しい列の名前とその DataType を定義する POJO。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合)次の設定の場合 - config ### [](#スロー)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#changeColumnType)Change Column Type `` 列の型を変更します。 ### [](#パラメーター-4)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Alter Column Input (Alter Column の入力)

AlterColumnInput

変更する列の名前と新しい DataType を定義する POJO。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-2)次の設定の場合 - config ### [](#スロー-2)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#createKeyspace)Create Keyspace `` 新しいキースペースを作成します。 ### [](#パラメーター-5)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Input (入力)

CreateKeyspaceInput

キースペース名と複製の詳細を含む、操作の入力。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-3)次の設定の場合 - config ### [](#スロー-3)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#createTable)Create Table `` 特定のキースペース内にテーブル (列ファミリー) を作成します。キースペースが指定されていない場合、ログインで使用されるキースペースが使用されます。 ### [](#パラメーター-6)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Create Table Input (Create Table の入力)

CreateTableInput

テーブル名、キースペース名、および列のリストを記述します。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-4)次の設定の場合 - config ### [](#スロー-4)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#deleteColumnsValue)Delete Columns Value `` where 句で指定されたオブジェクトから値を削除します。 ### [](#パラメーター-7)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

テーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Entities (エンティティ)

Array of String (文字列の配列)

Operation input (操作の入力): 削除する列。

x

Where Clause (Where 句)

Object (オブジェクト)

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-5)次の設定の場合 - config ### [](#スロー-5)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#deleteRows)Delete Rows `` レコード全体を削除します。 ### [](#パラメーター-8)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

テーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Where Clause (Where 句)

Object (オブジェクト)

操作の入力: 削除操作の where 句。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-6)次の設定の場合 - config ### [](#スロー-6)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#dropColumn)Drop Column `` 列を削除します。 ### [](#パラメーター-9)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Column Name (列名)

String (文字列)

削除する列の名前。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-7)次の設定の場合 - config ### [](#スロー-7)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#dropKeyspace)Drop Keyspace `` キースペース全体を削除します。 ### [](#パラメーター-10)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Keyspace Name (キースペース名)

String (文字列)

削除するキースペースの名前。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-8)次の設定の場合 - config ### [](#スロー-8)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#dropTable)Drop Table `` 指定されたキースペースからテーブル全体を削除します。または、操作パラメーターとして何も指定されていない場合は、ログインで使用されるキースペースからテーブル全体を削除します。 ### [](#パラメーター-11)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table Name (テーブル名)

String (文字列)

削除するテーブルの名前。

#[payload]

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 削除するテーブルを含むキースペース。

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-9)次の設定の場合 - config ### [](#スロー-9)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#executeCQLQuery)Execute CQL Query `` 指定された未加工の入力クエリを実行します。 ### [](#パラメーター-12)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Cql Input (CQL の入力)

CQLQueryInput

実行するパラメーター化されたクエリをパラメーターと共に記述します。

#[payload]

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力に対して評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#出力)出力 | 型 | Array of Object (オブジェクトの配列)。 | | --- | --- | ### [](#次の設定の場合-10)次の設定の場合 - config ### [](#スロー-10)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#getTableNamesFromKeyspace)Get Table Names From Keyspace `` 指定されたキースペースからすべてのテーブル名を返します。 ### [](#パラメーター-13)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Keyspace Name (キースペース名)

String (文字列)

操作で使用するキースペースの名前。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力に対して評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#出力-2)出力 | 型 | Array of String (文字列の配列) | | --- | --- | ### [](#次の設定の場合-11)次の設定の場合 - config ### [](#スロー-11)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#insert)Insert `` エンティティの挿入操作を実行します。 ### [](#パラメーター-14)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

エンティティの挿入先のテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Entity To Insert (挿入するエンティティ)

Object (オブジェクト)

挿入するエンティティ。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-12)次の設定の場合 - config ### [](#スロー-12)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#renameColumn)Rename Column `` 列の名前を変更します。 ### [](#パラメーター-15)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

操作で使用するテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 使用するテーブルを含むキースペース。

Old Column Name (古い列名)

String (文字列)

変更する列の名前。

#[payload]

New Column Name (新しい列名)

String (文字列)

列の名前の新しい値。

x

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-13)次の設定の場合 - config ### [](#スロー-13)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#select)Select `` select クエリを実行します。 ### [](#パラメーター-16)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Query (クエリ)

String (文字列)

実行するクエリ。

#[payload]

パラメーター

Any の配列

クエリパラメーター。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力に対して評価する式。式の結果は対象変数に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#出力-3)出力 | 型 | Array of Object (オブジェクトの配列)。 | | --- | --- | ### [](#次の設定の場合-14)次の設定の場合 - config ### [](#スロー-14)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#update)Update `` エンティティの更新操作を実行します。 ### [](#パラメーター-17)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Table (テーブル)

String (文字列)

更新するエンティティを含むテーブルの名前。

x

Keyspace Name (キースペース名)

String (文字列)

(省略可能) 削除するテーブルを含むキースペース。

Entity To Update (更新するエンティティ)

Object (オブジェクト)

更新するエンティティ。

#[payload]

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。
### [](#次の設定の場合-15)次の設定の場合 - config ### [](#スロー-15)スロー - CASSANDRA-DB:ALREADY\_EXISTS - CASSANDRA-DB:AUTHENTICATION - CASSANDRA-DB:BOOTSTRAPPING - CASSANDRA-DB:BUSY\_CONNECTION - CASSANDRA-DB:BUSY\_POOL - CASSANDRA-DB:CassandraException - CASSANDRA-DB:CassandraExecution - CASSANDRA-DB:CODEC\_NOT\_FOUND - CASSANDRA-DB:CONNECTION - CASSANDRA-DB:CONNECTIVITY - CASSANDRA-DB:DRIVER\_INTERNAL\_ERROR - CASSANDRA-DB:FRAME\_TOO\_LONG - CASSANDRA-DB:FUNCTION\_EXECUTION - CASSANDRA-DB:INVALID\_CONFIGURATION\_IN\_QUERY - CASSANDRA-DB:INVALID\_QUERY - CASSANDRA-DB:INVALID\_TYPE - CASSANDRA-DB:NO\_HOST\_AVAILABLE - CASSANDRA-DB:OPERATION\_FAILED - CASSANDRA-DB:OPERATION\_NOT\_APPLIED - CASSANDRA-DB:OPERATION\_TIMED\_OUT - CASSANDRA-DB:OVERLOADED - CASSANDRA-DB:PAGING\_STATE - CASSANDRA-DB:PROTOCOL\_ERROR - CASSANDRA-DB:QUERY\_CONSISTENCY - CASSANDRA-DB:QUERY\_ERROR - CASSANDRA-DB:QUERY\_EXECUTION - CASSANDRA-DB:QUERY\_VALIDATION - CASSANDRA-DB:READ\_FAILURE - CASSANDRA-DB:READ\_TIMEOUT - CASSANDRA-DB:RETRY\_EXHAUSTED - CASSANDRA-DB:SERVER\_ERROR - CASSANDRA-DB:SYNTAX\_ERROR - CASSANDRA-DB:TRACE\_RETRIEVAL - CASSANDRA-DB:TRANSPORT - CASSANDRA-DB:TRUNCATE - CASSANDRA-DB:UNAUTHORIZED - CASSANDRA-DB:UNAVAILABLE - CASSANDRA-DB:UNKNOWN - CASSANDRA-DB:UNPREPARED - CASSANDRA-DB:UNRESOLVED\_USER\_TYPE - CASSANDRA-DB:UNSUPPORTED\_FEATURE - CASSANDRA-DB:UNSUPPORTED\_PROTOCOL\_VERSION - CASSANDRA-DB:WRITE\_FAILURE - CASSANDRA-DB:WRITE\_TIMEOUT ## [](#型)型 ### [](#Reconnection)Reconnection (再接続)
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

Reconnection Strategy (再接続戦略)

  • reconnect (再接続)

  • reconnect-forever (繰り返し再接続)

使用する再接続戦略。
### [](#reconnect)Reconnect (再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。

Count (数)

Number (数値)

再接続の試行回数。

blocking (ブロック)

Boolean (ブール)

false の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

true
### [](#reconnect-forever)Reconnect Forever (繰り返し再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。

blocking (ブロック)

Boolean (ブール)

false の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

true
### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー)
項目 型 説明 デフォルト値 必須

Max Idle Time (最大アイドル時間)

Number (数値)

有効期限の対象とみなされるまで、動的設定インスタンスがアイドル状態を維持できる最大時間のスカラー時間値。

Time Unit (時間単位)

Enumeration (列挙)。次のいずれかになります。

  • DAYS

  • HOURS

  • MICROSECONDS

  • MILLISECONDS

  • MINUTES

  • NANOSECONDS

  • SECONDS

maxIdleTime​ 属性の時間単位。
### [](#AlterColumnInput)Alter Column Input (Alter Column の入力)
項目 型 説明 デフォルト値 必須

Column (列)

String (文字列)

Type (型)

Enumeration (列挙)。次のいずれかになります。

  • ASCII

  • BIGINT

  • BLOB

  • BOOLEAN

  • COUNTER

  • DATE

  • DECIMAL

  • DOUBLE

  • FLOAT

  • INET

  • INT

  • SMALLINT

  • TEXT

  • TIME

  • TIMESTAMP

  • TIMEUUID

  • TINYINT

  • UUID

  • VARCHAR

  • VARINT
### [](#CreateKeyspaceInput)Create Keyspace Input (Create Keyspace の入力)
項目 型 説明 デフォルト値 必須

First Data Center (最初のデータセンター)

DataCenter

Keyspace Name (キースペース名)

String (文字列)

Next Data Center (次のデータセンター)

DataCenter

Replication Factor (複製係数)

Number (数値)

複製戦略クラス

Enumeration (列挙)。次のいずれかになります。

  • SimpleStrategy

  • NetworkTopologyStrategy
### [](#DataCenter)Data Center (データセンター)
項目 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

Value (値)

Number (数値)
### [](#CreateTableInput)Create Table Input (Create Table の入力)
項目 型 説明 デフォルト値 必須

Columns (列)

ColumnInput の配列

Keyspace Name (キースペース名)

String (文字列)

Table Name (テーブル名)

String (文字列)
### [](#ColumnInput)Column Input (列の入力)
項目 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

Primary Key (主キー)

Boolean (ブール)

Type (型)

Enumeration (列挙)。次のいずれかになります。

  • ASCII

  • BIGINT

  • BLOB

  • BOOLEAN

  • COUNTER

  • DATE

  • DECIMAL

  • DOUBLE

  • FLOAT

  • INET

  • INT

  • SMALLINT

  • TEXT

  • TIME

  • TIMESTAMP

  • TIMEUUID

  • TINYINT

  • UUID

  • VARCHAR

  • VARINT
### [](#CQLQueryInput)CQL Query Input (CQL クエリの入力)
項目 型 説明 デフォルト値 必須

Cql Query (CQL クエリ)

String (文字列)

パラメーター

Any の配列
## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Cassandra Studio 設定 Anypoint Studio で Cassandra 用 Anypoint Connector (Cassandra Connector) を設定する手順は、次のとおりです。 1. プロジェクトにコネクタを追加します。 2. コネクタを設定します。 3. コネクタの入力元を設定します。 ## [](#studio-プロジェクトへのコネクタの追加)Studio プロジェクトへのコネクタの追加 Anypoint Studio には、Studio プロジェクトにコネクタを追加する 2 つの方法があります。Studio タスクバーの Exchange ボタンから追加するか、\[Mule Palette (Mule パレット)\] ビューから追加します。 ### [](#exchange-を使用してコネクタを追加する)Exchange を使用してコネクタを追加する 1. Studio で Mule プロジェクトを作成します。 2. Studio タスクバーの左上にある Exchange アイコン ​**(X)**​ をクリックします。 3. Exchange で、​**\[Login (ログイン)\]**​ をクリックし、Anypoint Platform のユーザー名とパスワードを指定します。 4. Exchange で、「Cassandra」を検索します。 5. コネクタを選択して ​**\[Add to project (プロジェクトに追加)\]**​ をクリックします。 6. 画面の指示に従ってコネクタをインストールします。 ### [](#studio-でコネクタに追加する)Studio でコネクタに追加する 1. Studio で Mule プロジェクトを作成します。 2. \[Mule Palette (Mule パレット)\] ビューで、​**\[(X) Search in Exchange ((X) Exchange 内を検索)\]**​ をクリックします。 3. **\[Add Modules to Project (モジュールをプロジェクトに追加)\]**​ で、検索項目に「Cassandra」と入力します。 4. **\[Available modules (使用可能なモジュール)\]**​ で、このコネクタの名前をクリックします。 5. **\[Add (追加)\]**​ をクリックします。 6. **\[Finish (完了)\]**​ をクリックします。 ## [](#authentication-認証)Authentication (認証) Cassandra データベースで認証が有効になっている場合、Cassandra Connector からアクセスするときにログイン情報を提供する必要があります。Cassandra では基本認証のみがサポートされています。Cassandra データベースにログイン情報を提供するには、Cassandra Connector のグローバル要素に対応する値を入力します。 ## [](#studio-を使用した-cassandra-キースペースの作成)Studio を使用した Cassandra キースペースの作成 この例では、列ファミリーをグループ化する Cassandra キースペースを作成した後、Cassandra テーブルを作成します。 ### [](#キースペースを作成する)キースペースを作成する 1. Anypoint Studio で新しい Mule プロジェクトを作成し、​`src/main/resources/mule-app.properties`​ の Cassandra ログイン情報を入力します。 ```text config.host= config.port= config.keyspace= config.username= config.password= ``` 2. HTTP Connector をキャンバスにドラッグし、\[​`Host`​ (ホスト)\] と \[​`Port`​ (ポート)\] はデフォルト値のままにして、パスを ​`/test/createKeyspace`​ に設定します。 3. **\[Transform Message\]**​ コンポーネントを Mule パレットからフローの右 (プロセス) 側にドラッグし、コンポーネントを選択して、出力ペイロードを設定します。次に例を示します。 ```dataweave %dw 2.0 output application/java --- { "keyspaceName": payload.keyspaceName, "replicationFactor": payload.replicationFactor, "replicationStrategyClass": payload.replicationStrategyClass } as Object { class: "org.mule.modules.cassandradb.api.CreateKeyspaceInput" } ``` 4. **Create Keyspace**​ 用の Cassandra コンポーネントをキャンバスにドラッグします。
項目 説明

Host (ホスト)

Cassandra ノードのホスト名または IP アドレスを入力します。

Port (ポート)

ポート番号を入力します。デフォルトポートは 9042 です。

Keyspace (キースペース)

Cassandra キースペースを入力します。キースペースは列ファミリーをグループ化します。

Username (ユーザー名)

Cassandra YAML ファイルで PasswordAuthenticator を有効にしている場合、Cassandra ユーザー名を入力します。​AllowAllAuthenticator​ を有効にしている場合、この値を空白のままにします。

Password (パスワード)

PasswordAuthenticator​ を有効にした場合、パスワードを入力します。有効にしていない場合、この値を空白のままにします。
5. **\[Test Connection (接続をテスト)\]**​ オプションをクリックして、Mule が Cassandra インスタンスに接続できることを確認します。正常に接続できた場合は、​**\[OK\]**​ をクリックして設定を保存します。それ以外の場合、無効なパラメーターを確認および修正して、再度テストします。 6. アプリケーションを実行します。ブラウザーで、次の URL を使用して、キースペース名 ​`ks_name`​、複製係数 ​`rf`​、および複製戦略クラス ​`rs_class`​ のクエリパラメーターを入力します。 `http://localhost:8081/simple?ks_name=simple_keyspace&rf=3&rs_class=SimpleStrategy` ### [](#cassandra-テーブルを作成する)Cassandra テーブルを作成する 1. Anypoint Studio で新しい Mule プロジェクトを作成し、​`src/main/resources/mule-app.properties`​ の Cassandra ログイン情報を入力します。 ```text config.host= config.port= config.keyspace= config.username= config.password= ``` 2. HTTP Connector をキャンバスにドラッグし、\[​`Host`​ (ホスト)\] と \[​`Port`​ (ポート)\] はデフォルト値のままにして、パスを ​`/test/createTable`​ に設定します。 3. **\[Transform Message\]**​ コンポーネントを Mule パレットからフローの右 (プロセス) 側にドラッグし、コンポーネントを選択して、出力ペイロードを設定します。次に例を示します。 ```dataweave %dw 2.0 output application/java --- { "columns": payload.columns, "tableName": payload.tableName, "keyspaceName": payload.keyspaceName } as Object { class : "org.mule.modules.cassandradb.api.CreateTableInput" } ``` 4. **Create Table**​ 操作用の Cassandra コンポーネントをキャンバスにドラッグします。
項目 説明

Host (ホスト)

Cassandra ノードのホスト名または IP アドレスを入力します。

Port (ポート)

ポート番号を入力します。デフォルトポートは ​9042​ です。

Keyspace (キースペース)

Cassandra キースペースを入力します。キースペースは列ファミリーをグループ化します。

Username (ユーザー名)

Cassandra YAML ファイルで ​PasswordAuthenticator​ を有効にしている場合、Cassandra ユーザー名を入力します。​AllowAllAuthenticator​ を有効にしている場合、この値を空白のままにします。

Password (パスワード)

PasswordAuthenticator​ を有効にしている場合、パスワードを入力します。それ以外の場合、この値を空白のままにします。
5. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が Cassandra インスタンスに接続できることを確認します。クライアントテストに成功した場合は、​**\[OK\]**​ をクリックして設定を保存します。それ以外の場合、無効なパラメーターを確認および修正して、再度テストします。 6. Mule アプリケーションを実行します。Postman で ​**\[POST\]**​ を選択します。​**\[Body (本文)\] > \[Raw (未加工)\]**​ を選択し、​**JSON**​ (application/json) MIME タイプを選択して、大文字のデータ型を使用して次のテーブル記述を入力します。 ```text { "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" } ] } ``` 7. Postman で ​**\[Send (送信)\]**​ をクリックし、\[Status: `200 OK`​ (状況: `200 OK`​)\] を探します。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Cassandra の XML および Maven サポート Studio XML エディターまたはスタンドアロンから XML で Mule アプリケーションを手動でコーディングする場合、コネクタへのアクセス権を取得するには、次の操作を行う必要があります。 - コネクタの名前空間を XML フローに追加する。 - 連動関係情報を Maven ​`pom.xml`​ ファイルに追加する。 Studio ビジュアルエディターでパレットからキャンバスにコネクタをドラッグすると、コネクタの名前空間とスキーマの場所が自動的に XML コードに入力されます。 ## [](#コネクタの名前空間の追加)コネクタの名前空間の追加 Studio の XML エディターまたは別のテキストエディターで Mule アプリケーションを手動でコーディングする場合、次のコードを設定 XML のヘッダーの ​``​ タグ内に貼り付けます。 ```xml http://www.mulesoft.org/schema/mule/cassandra-db http://www.mulesoft.org/schema/mule/cassandra-db/current/mule-cassandra-db.xsd ``` ## [](#maven-pom-ファイルの設定)Maven POM ファイルの設定 pom.xml は、Anypoint Studio で生成される Maven ファイルで、Mule アプリケーションの連動関係が含まれます。Mule アプリケーションを手動でコーディングする場合、この XML スニペットを pom.xml ファイルに含め、このコネクタへのアクセスを有効にします。 XML でアプリケーションを手動で作成する場合は、プロジェクトの ​`pom.xml`​ をセットアップします。 ```xml mule-ee-releases MuleEE Releases Repository https://repository-master.mulesoft.org/nexus/content/repositories/releases-ee/ mule-ee-snapshots MuleEE Snapshots Repository https://repository-master.mulesoft.org/nexus/content/repositories/ci-snapshots/ ``` 次のスニペットは、特定のバージョンのプロジェクトの連動関係を示しています。 ```xml com.mulesoft.connectors mule-cassandradb-connector 3.1.1 mule-plugin ``` ``​ タグのコンテンツを、使用しているコネクタに対応するバージョンに置き換えます。 最新の ​`pom.xml`​ ファイル情報を取得するには、​ [Anypoint Exchange](https://www.mulesoft.com/exchange/)​ でコネクタにアクセスし、​**\[Dependency Snippets (連動関係スニペット)\]**​ をクリックします。 ## [](#次のステップ)次のステップ これで XML と Maven が完了したので、​[例](https://docs.mulesoft.com/jp/cassandra-connector/3.1/cassandra-connector-examples)​を試すことができます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Cassandra の例 ## [](#cassandra-データベーステーブルの作成)Cassandra データベーステーブルの作成 この例を使用して、Cassandra データベーステーブルを作成します。 ```xml ``` ## [](#cassandra-データベース内のデータの操作)Cassandra データベース内のデータの操作 この例を使用して、Apache Cassandra データベース内のデータを操作します。 - キースペースからテーブル名を取得する。 - Cassandra データベーステーブルのデータに対して次の CRUD 操作を実行する。 - Insert - Select - Update - Delete - Cassandra データベース列に対して次の操作を実行する。 - 列の値を削除 - 列の名前を変更 - 新しい列を追加 - 列を削除 - CQL クエリを実行する。 - Cassandra データベーステーブルからデータを削除する。 ```xml SELECT id, name, event FROM example_keyspace.example_table ``` ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Cassandra の追加設定 基本認証と DataSense 機能を備えた環境で動作するように、Cassandra 用 Anypoint Connector を設定します。 ## [](#cassandra-認証の有効化)Cassandra 認証の有効化 デフォルトでは、Cassandra データベースへのアクセスにログイン情報は必要ありません。 認証を有効にするように Cassandra を設定する必要があります。Cassandra Connector の設定は、基本認証の Cassandra の設定と一致する必要があります。 認証を有効にしたら、Cassandra インストールのホームディレクトリから次の例のように ​`cqlsh`​ コマンドを実行します。次の例では、デフォルトのログイン情報 (ユーザー名 ​`cassandra`​、パスワード ​`cassandra`​) を使用しています。 ```text bin/cqlsh localhost -u cassandra -p cassandra Connected to Test Cluster at localhost:9042. [cqlsh 5.0.1 | Cassandra 3.10 | CQL spec 3.4.4 | Native protocol v4] Use HELP for help. ``` 1. Cassandra をインストールしたら、編集目的で ​`conf\cassandra.yaml`​ ファイルを開きます。 2. 必要に応じて、​`AllowAllAuthenticator`​ の値を ​`PasswordAuthenticator`​ に変更します。 3. Cassandra を再起動します。 4. 別の端末タブで、Cassandra が実行されていることを確認します。 `bin/nodetool status` ## [](#pojo-設定)POJO 設定 このコネクタは、「Cassandra Connector リファレンス」の複数の操作を公開します。 以下の操作は、DataSense 機能で必要とされる一部の POJO を入力パラメーターとして受け入れます。 `addNewColumn`​、​`changeColumnType`​、​`createKeyspace`​、​`createTable`​、​`deleteColumnsValue`​、​`deleteRows`​、​`dropColumn`​、​`dropKeyspace`​、​`dropTable`​、​`executeCQLQuery`​、​`getTableNamesFromKeyspace`​、​`renameColumn`​、​`select`​、​`update`​。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com)