問題タブ [spring-data-cassandra]

CassandraTemplate のさまざまな機能 (少なくとも最も使用されているメソッド) のコード サンプルを見つけることができる場所はありますか?

スタンドアロンの main() メソッドを使用して Cassandra @ localhost にアクセスしようとしています。main() メソッドは、spring-data-cassandra モジュールの DataStax ドライバーと CassandraOperations クラスを使用します。CassandraOperationのqueryForObject()メソッドは、エンティティ オブジェクトではなく常に主キーを返します。

Spring Data Documentationに記載されているコード例を使用しています。

クライアントコード:

ランタイム例外:

スレッド「メイン」の例外 java.lang.ClassCastException: com.prashanth.ts.client.CassandraApp.main(CassandraApp.java:40) で java.lang.String を com.prashanth.ts.entity.Person にキャストできませんsun.reflect.NativeMethodAccessorImpl.invoke0(ネイティブ メソッド) で sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) で、sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) で java.lang.reflect.Method で。 com.intellij.rt.execution.application.AppMain.main (AppMain.java:140) での呼び出し (Method.java:606)

Spring Data は初めてです。ここで私が間違っていることを特定するのに役立つ人は誰でもいます。

また、QueryBuilder を削除して、「select * from person」のような単純なクエリ文字列を queryForObject() メソッドに渡そうとしました。

注：挿入操作は完全に機能しています。

SpringPOJO クラスを使用して Cassandra UDT データを挿入する方法を教えてもらえますか?

Cassandra のテーブルをマップする POJO クラスを 1 つ作成し、Cassandra UDT 用に別のクラスを作成しましたが、Cassandra のテーブルをマップするメイン POJO クラスを挿入すると、別の POJO クラスが認識されません (Cassandra の UDT をマップします)。また、すべてのクラスとすべてのクラス オブジェクトに注釈を書きました。

これが私の1つのPOJOクラスです:-

別のPOJOクラス:-

Spring Data - Cassandra (SDC) で、同じ DataStax ドライバー セッションを再利用したいが、現在 Cassandra にアクセスしているテナント (マルチテナント SaaS モデル) に応じて異なるキースペースにアクセスしたい。とはいえ、私の調査では、キースペースを追加して完全修飾クエリを作成することが、これを達成するための好ましい方法であるようです。

SDC にはこれを行うためのフックがありますか? Hibernate のマルチテナンシー サポートに似たものを探しています。Hibernate では、同じ接続プールを再利用できます。このアプリは、どのテナントが現在のコンテキストにあるかを Hibernate に伝える方法を提供し、Hibernate のセッションの接続方法を制御できます。JDBC 接続などで "SET SCHEMA 'foo_tenant_schema' " を呼び出すことにより、テナントごとに異なるスキーマになる可能性があります。

そうでない場合は、自分で書く必要があります。それはいいです。「tenantID-to-keyspace」のマップをロードし、何らかの形で動的に追加して、完全修飾呼び出しを行うことを考えています。これが DataStax セッションの PreparedStatements などにどのように影響するかはわかりません。

より良い方法についての考えがあれば、教えてください。

私はカサンドラが初めてです。私はオンラインで多くの例を見ています。以下は、GitHub の JHipster Cassandra の例の 1 つです。

https://gist.github.com/jdubois/c3d3bedb869466731316

リポジトリの save(user) メソッドは、ユーザー データが変更されるたびに、(存在を探すために) 読み取りを行い、非正規化されたすべてのテーブルで既存のユーザーの削除と再挿入を行います。

これはベストプラクティスですか？これは、このサンプルのデータ モデルがどのように設計されているかだけによるものですか? このサンプルの設計は、POJO フレームワークを NoSQL データベース設計にねじ曲げた結果ですか?

Cassandra で更新を行いたいのはいつですか? フィールドレベルでの更新をサポートしているので、それが好まれるようです。

spring-data-cassandra (1.1.2.RELEASE) を使用しようとしていますが、JPA 用語に埋め込み可能な型マッピングがないという問題に直面しています。

次のようなエンティティクラスがあります。

および埋め込み可能な Address クラス:

私のカサンドラテーブル：

Address のプロパティをそれを含むエンティティにマップしたいのですが、アドレス用の別のテーブルは必要ありません。JPA では、@Embeddable アノテーションを使用すると思います。spring-data-cassandra に同様の構造はありますか?

私はこれを試してみて、うまくいきます。

しかし、クエリファイルを個別に記述できるように、値を文字列に渡したいと思います。このようなもの、

Spring-data-cassandra は初めてです。サンプルコードは次のようになります。

Customer.java

CustomerRepository.java

アプリケーション.java

pom.xml

コードを実行しようとすると、次の例外が発生します。

例外の要点は、「宣言型クエリ メソッドは todo です」ということです。ドキュメントは、何がサポートされていて何がサポートされていないかについて少し不明確です。誰かがこれに光を当てることができますか? ありがとう。

現在の GA バージョン 1.2.1 を使用すると、次の例外が発生します。私のサンプル コードでは、リポジトリ オブジェクトが自動接続されています。

これに対する修正または回避策はありますか?

マルチノード Cassandra をセットアップしました。アクセスに Spring Data Cassandra を使用しています。コンマ区切りのリストを Cassandra クラスターに渡すことはできますか?

2 番目の質問は、必須ですか? 今後、さらにノードを追加する可能性があります。