O template de família de coluna é responsável para realizar a comunicação da entidade para um banco de dados do tipo família de coluna. Ele é subdividido em ColumnTemplate e ColumnTemplateAsync para trabalhos síncronos e assíncronos respectivamente.
ColumnTemplate
O ColumnTemplate é responsável pela persistência de uma Entidade em um banco de dados do tipo coluna. Ele é composto, basicamente, por três componentes:
ColumnEntityConverter: Responsável por converter da entidade, por exemplo, Person para ColumnEntity.
ColumnCollectionManager: Entidade manager de documentos do Diana.
ColumnWorkflow: Segue o fluxo de persistência durante os métodos de save e update.
ColumnTemplate template = //instance
Person person = new Person();
person.setAddress("Olympus");
person.setName("Artemis Good");
person.setPhones(Arrays.asList("55 11 94320121", "55 11 94320121"));
person.setNickname("artemis");
List<Person> people = Collections.singletonList(person);
Person personUpdated = template.insert(person);
template.insert(people);
template.insert(person, Duration.ofHours(1L));
template.update(person);
template.update(people);
Para a busca e a remoção da informação são utilizadas as mesmas classes do Diana para documentos, ou seja, ColumnQuery e ColumnDeleteQuery respectivamente.
O ColumnTemplateAsync é responsável pela persistência de uma Entidade em um banco de dados do tipo família de colunas de forma assíncrona. Ele é composto, basicamente, por dois componentes:
ColumnEntityConverter: Responsável por converter da entidade, por exemplo, Person para ColumnEntity.
ColumnFamilyManagerAsync: Entidade manager de documentos do Diana de forma assíncrona.
ColumnTemplateAsync templateAsync = //instance
Person person = new Person();
person.setAddress("Olympus");
person.setName("Artemis Good");
person.setPhones(Arrays.asList("55 11 94320121", "55 11 94320121"));
person.setNickname("artemis");
List<Person> people = Collections.singletonList(person);
Consumer<Person> callback = p -> {};
templateAsync.insert(person);
templateAsync.insert(person, Duration.ofHours(1L));
templateAsync.insert(person, callback);
templateAsync.insert(people);
templateAsync.update(person);
templateAsync.update(person, callback);
templateAsync.update(people);
Para a busca e a remoção da informação são utilizadas as mesmas classes do Diana para documentos, ou seja, ColumnQuery e ColumnDeleteQuery respectivamente também é possível o uso de callback.
Consumer<List<Person>> callBackPeople = p -> {};
Consumer<Void> voidCallBack = v ->{};
templateAsync.select(query, callBackPeople);
templateAsync.delete(deleteQuery);
templateAsync.delete(deleteQuery, voidCallBack);
Como o motor do Artemis é CDI para que se posso utilizar o ColumnTemplate basta dar um @Inject num campo.
@Inject
private ColumnTemplateAsync template;
Para isso é necessário que a aplicação injete um ColumnFamilyManagerAsync: