1 簡介
之前我們在文章《K8ssandra入門-詳細記錄在Linux上部署K8ssandra到Kubernetes》成功地在Ubuntu上安裝了K8ssandra，現在我們來看看如何訪問Cassandra，
K8ssandra的組件Stargate提供了多種方式的資料訪問，對應埠如下：
- 8080：GraphQL interface
- 8081：REST Auth
- 8082：REST interface
- 9042：CQL service
我們使用最常用的9042埠，其它請參考官方檔案，
2 三種方式訪問
先暴露服務，然后找到對應的埠：
$ kubectl expose deployment k8ssandra-dc1-stargate --type=NodePort --name=stargate-out
$ kubectl get svc stargate-out
2.1 cqlsh命令
安裝clqsh命令：
$ pip install cqlsh
連接資料庫：
cqlsh -u k8ssandra-superuser -p YMEbXcPCW9xxxxxxx 127.0.0.1 30703
接著進行資料操作：
CREATE KEYSPACE pkslow WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1};
use pkslow;
CREATE TABLE users (username text primary key, password text, email text);
INSERT INTO users (username, password, email) values ('larry', 'larry123', '[email protected]');
INSERT INTO users (username, password, email) values ('admin', '123456', '[email protected]');
INSERT INTO users (username, password, email) values ('carol', '123456', '[email protected]');
INSERT INTO users (username, password, email) values ('david', '123456', '[email protected]');
寫入了資料后，我們查詢看看：
2.2 用IDEA連接
配置資料庫，選擇Cassandra，連接資訊如下：
接著就可以查看相關的資料了，如下：
2.3 通過Java程式訪問
引入依賴如下：
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-cassandra</artifactId>
<version>3.2.5</version>
</dependency>
準備物體類：
package com.pkslow.springboot.cassandra.entity;
import org.springframework.data.annotation.Id;
import org.springframework.data.cassandra.core.mapping.Table;
@Table(value = "https://www.cnblogs.com/larrydpk/p/users")
public class User {
@Id
private String username;
private String password;
private String email;
}
Reposity類：
package com.pkslow.springboot.cassandra.repository;
import com.pkslow.springboot.cassandra.entity.User;
import org.springframework.data.cassandra.repository.CassandraRepository;
import org.springframework.stereotype.Repository;
@Repository
public interface UserRepository extends CassandraRepository<User, String> {
}
同時需要在配置類中加上：
@EnableCassandraRepositories(basePackages = "com.pkslow.springboot.cassandra.repository")
配置一下資料庫連接屬性：
server.port=8080spring.data.cassandra.contact-points=8.134.124.38:30703spring.data.cassandra.username=k8ssandra-superuserspring.data.cassandra.password=YMEbXcPCW9xrfxxxxxspring.data.cassandra.local-datacenter=dc1spring.data.cassandra.keyspace-name=pkslow
這樣就基本可以了，
啟動程式，訪問測驗如下：
3 總結
代碼請查看：https://github.com/LarryDpk/pkslow-samples
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/304802.html
標籤：Java
上一篇：突發！LayUI 宣布下線。。。