CassandraをJavaで使用するにはDataStaxのライブラリを使用するのが手っ取り早いです。
Thriftを使用する例などが紹介されていますが、外部ライブラリを使用したくないなど特別な事情がない場合は、このページで紹介する方法で接続すれば問題ないと思います。
Cassandraは既にダウンロードしていることを前提に進めていきます。
使用環境
- Eclipse
- Java
- Maven
- Cassandra
1.MavenでDataStaxを導入する
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
<dependency> <groupId>com.datastax.oss</groupId> <artifactId>java-driver-core</artifactId> <version>4.6.1</version> </dependency> <dependency> <groupId>com.datastax.oss</groupId> <artifactId>java-driver-mapper-runtime</artifactId> <version>4.6.1</version> </dependency> <dependency> <groupId>com.datastax.oss</groupId> <artifactId>java-driver-query-builder</artifactId> <version>4.6.1</version> </dependency> |
これをMavenプロジェクト（使用したいプロジェクト）内のpom.xmlに記述します。
※バージョンは記事作成時のものです。最新バージョンを使い方は公式ドキュメントを参照してください。
2. コネクションを確立する
あとは任意のクラスでセッションを貼るだけです。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
try (CqlSession session = CqlSession.builder() .addContactPoint(new InetSocketAddress("127.0.0.1", 9042)) .withKeyspace("keyspace") // キースペース名 .withLocalDatacenter("datacenter1") // データセンター名 .build()) { } catch(Exception e) { e.printStackTrace(); } finally { System.out.println("finally処理"); } |
コンタクトポイント（ポート番号とIPアドレス）、キースペース名、データセンター名は各自で編集してください。
これで接続は完了です。
後はこのtry文中に処理を記述することでCassandraを利用することができます。
参考URL
https://github.com/beccam/quickstart-java
https://gist.github.com/beccam/d8491990895fe659e0584a4bc31d1df3
コメントを残す