[스프링] CassandraTemplate을 이용한 데이터 액세스

18 Dec 2023

스프링

소개
CassandraTemplate 설정
데이터 삽입 및 조회
요약

1. 소개

스프링에서 Cassandra를 사용하여 데이터베이스에 액세스할 때 CassandraTemplate은 매우 유용한 도구입니다. 이를 사용하면 Cassandra 데이터베이스에 쉽게 액세스하고 조작할 수 있습니다.

2. CassandraTemplate 설정

먼저, CassandraTemplate을 사용하기 위해 Cassandra 세션을 설정해야 합니다. 다음은 스프링 구성을 통해 CassandraTemplate을 설정하는 방법입니다.

@Configuration
public class CassandraConfig extends AbstractCassandraConfiguration {

    // ... 다른 구성 내용 생략 ...

    @Override
    public CassandraCustomConversions customConversions() {
        return new CassandraCustomConversions(Collections.singletonList(new CustomConversionsConfig()));
    }

    @Bean
    public CassandraTemplate cassandraTemplate(Session session, CassandraConverter converter) {
        return new CassandraTemplate(session, converter);
    }
}

CassandraConfig 클래스는 AbstractCassandraConfiguration를 확장하며, cassandraTemplate 빈을 정의하여 CassandraTemplate을 구성합니다.

3. 데이터 삽입 및 조회

CassandraTemplate을 사용하여 데이터를 삽입하고 조회하는 방법은 다음과 같습니다.

데이터 삽입

@Autowired
private CassandraTemplate cassandraTemplate;

public void insertData(MyEntity data) {
    cassandraTemplate.insert(data);
}

데이터 조회

@Autowired
private CassandraTemplate cassandraTemplate;

public MyEntity fetchDataById(UUID id) {
    return cassandraTemplate.selectOneById(id, MyEntity.class);
}

4. 요약

이것으로 CassandraTemplate을 사용하여 데이터 액세스하는 방법에 대해 알아보았습니다. 이를 통해 스프링 애플리케이션에서 Cassandra 데이터베이스를 효율적으로 활용할 수 있습니다.

많은 도움이 되기를 바랍니다!