6.6 카산드라 스토리지 엔진

• 원격의 카산드라 서버로 접속하여 SQL 문법으로 데이터 조회 기능 제공

6.6.1 카산드라

• 카산드라 : NoSQL 데이터베이스, P2P 방식으로 노드간 통신 하는 클러스터
  
• 클러스상 자신의 위치가 정해져 있고 좌/우/임의 노드와 통신을 유지 하면서 전체 노드 상태 관리
• Gossip : 다른 노드들의 상태를 전파하는 프로토콜
• 클러스터 내 Ring 형태로 노드 존재, 데이터를 1/N 로 나누고 자신의 데이터에 대해서 서비스, 다른 노드 데이터에 대한 Proxy 서비스
• 다차원 Key/Value 로 정보 관리 - (Key(Key/Value))
  • 테이블이나 레코드 개념 데이터 조립 가능.

오브젝트

6.6.2 카산드라 스토리지 엔진

• 원격 서버에 있는 카산드라 클러스터 데이터에 대한 뷰 제공

INSTALL PLUGIN cassandra SONAME 'ha_cassandra.so';

-- my.cnf [mysqld]
plugin-load = ha_cassandra.so


$ cqlsh

create keyspace cassandra_se
... with strategy_class = 'org.apache.cassandra.locator.SimpleStrategy'
... and strategy_options:replication_factor='1';

use cassandra_se;

create columnfamily cf_friends (
... uid varchar primary key,
... friend_uid varchar) with compact storage;

insert into cf_friends (uid, friend_uid) values ('matt', 'pitt');
insert into cf_friends (uid, friend_uid) values ('matt', 'pott');

select * from cf_friends;

-- 카산드라 컬럼 패밀리와 컬럼 이름 및 데이터 타입 일치 필요
$ mysql

create table cass_friends (
  uid varchar(64) primary key,
  friend_uid varchar(64)
) ENGINE = cassandra THRIFT_HOST = '192.168.0.1' KEYSPACE='cassandra_se' COLUMN_FAMILY='CF_FRIENDS';

-- thrift_host : 테이블 별 접속 카산드라 클러스터 설정
-- cassandra_default_thrift_host : 전체 테이블 공통 카산드라 클러스터 설정||

insert into cass_friend (uid, friend_uid) values ('toto', 'pitt');
insert into cass_friend (uid, friend_uid) values ('toto', 'pott');

select * from cass_friends where uid = 'toto';