CassandraOperations
Para explotar nuestro datos de nuestro keyspace vamos a utilizar CasandraOperations.Creamos el paquete com.tutosoftware.mivacuna.util y en el creamos la clase CassandraUtil
package com.tutosoftware.mivacuna.util;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.cassandra.core.CassandraOperations;
import org.springframework.stereotype.Component;
@Component
public class CassandraUtil {
@Autowired
private CassandraOperations cassandraTemplate;
public <T> void create(T entity) {
cassandraTemplate.insert(entity);
}
public <T> void createList(List<T> entities) {
cassandraTemplate.insert(entities);
}
public <T> T update(T entity) {
cassandraTemplate.update(entity);
return entity;
}
public <T> void updateList(List<T> entities) {
cassandraTemplate.update(entities);
}
public <T> T findById(Object id, Class<T> claz) {
return cassandraTemplate.selectOneById(id,claz);
}
public <T> void deleteById(Object id, Class<T> claz) {
cassandraTemplate.deleteById(id,claz);
}
public void delete(Object entity) {
cassandraTemplate.delete(entity);
}
public <T> void delete(List<T> entities) {
cassandraTemplate.delete(entities);
}
public <T> T findOne(String cql,Class<T> claz){
return cassandraTemplate.selectOne(cql, claz);
}
public <T> List<T> findAll(String cql,Class<T> claz) {
return (List<T>) cassandraTemplate.select(cql,claz);
}
public <T> void truncate(Class<T> claz) {
cassandraTemplate.truncate(claz);
}
public <T> long getCount(Class<T> claz) {
return cassandraTemplate.count(claz);
}
public <T> boolean exists(Object id, Class<T> claz) {
return cassandraTemplate.exists(id,claz);
}
}
Ahora creamos el paquete com.tutosoftware.mivacuna.dao y creamos la Interface Poblacion2021DAO
package com.tutosoftware.mivacuna.dao;
import com.tutosoftware.mivacuna.entity.Poblacion2021;
public interface Poblacion2021DAO {
public void guardarPoblacion(Poblacion2021 poblacion2021);
}
Creamos el paquete com.tutosoftware.mivacuna.dao.impl y en este paquete creamos la clase Poblacion2021DAOImpl
package com.tutosoftware.mivacuna.dao.impl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import com.tutosoftware.mivacuna.dao.Poblacion2021DAO;
import com.tutosoftware.mivacuna.entity.Poblacion2021;
import com.tutosoftware.mivacuna.util.CassandraUtil;
@Repository
public class Poblacion2021DAOImpl implements Poblacion2021DAO {
@Autowired
CassandraUtil cassandraUtil;
@Override
public void guardarPoblacion(Poblacion2021 poblacion2021) {
// TODO Auto-generated method stub
cassandraUtil.create(poblacion2021);
}
}
Generamos el paquete com.tutosoftware.mivacuna.service y en el creamos la interface Poblacion2021Service
package com.tutosoftware.mivacuna.service;
import com.tutosoftware.mivacuna.entity.Poblacion2021;
public interface Poblacion2021Service {
public void guardarPoblacion(Poblacion2021 poblacion2021);
}
Creamos el paquete com.tutosoftware.mivacuna.service.impl creamos la clase Poblacion2021ServiceImpl
package com.tutosoftware.mivacuna.service.impl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.tutosoftware.mivacuna.dao.Poblacion2021DAO;
import com.tutosoftware.mivacuna.entity.Poblacion2021;
import com.tutosoftware.mivacuna.service.Poblacion2021Service;
@Service
@Transactional
public class Poblacion2021ServiceImpl implements Poblacion2021Service {
@Autowired
Poblacion2021DAO poblacion2021DAO;
@Override
public void guardarPoblacion(Poblacion2021 poblacion2021) {
// TODO Auto-generated method stub
poblacion2021DAO.guardarPoblacion(poblacion2021);
}
}