«Apache Ignite с данными Spring»

«1. Обзор

В этом кратком руководстве мы сосредоточимся на том, как интегрировать Spring Data API с платформой Apache Ignite.

Чтобы узнать об Apache Ignite, ознакомьтесь с нашим предыдущим руководством.

2. Настройка Maven

В дополнение к существующим зависимостям мы должны включить поддержку Spring Data:

<dependency>
    <groupId>org.apache.ignite</groupId>
    <artifactId>ignite-spring-data</artifactId>
    <version>${ignite.version}</version>
</dependency>

Артефакт ignite-spring-data можно загрузить с Maven Central.

3. Модель и репозиторий

Чтобы продемонстрировать интеграцию, мы создадим приложение, которое сохраняет сотрудников в кэше Ignite с помощью Spring Data API.

POJO для EmployeeDTO будет выглядеть так:

public class EmployeeDTO implements Serializable {
 
    @QuerySqlField(index = true)
    private Integer id;
    
    @QuerySqlField(index = true)
    private String name;
    
    @QuerySqlField(index = true)
    private boolean isEmployed;

    // getters, setters
}

Здесь аннотация @QuerySqlField позволяет запрашивать поля с помощью SQL.

Далее мы создадим репозиторий для сохранения объектов Employee:

@RepositoryConfig(cacheName = "baeldungCache")
public interface EmployeeRepository 
  extends IgniteRepository<EmployeeDTO, Integer> {
    EmployeeDTO getEmployeeDTOById(Integer id);
}

Apache Ignite использует свой собственный IgniteRepository, который является продолжением CrudRepository Spring Data. Он также обеспечивает доступ к сетке SQL из Spring Data.

Это поддерживает стандартные методы CRUD, за исключением некоторых, которым не требуется идентификатор. Мы рассмотрим причины более подробно в нашем разделе тестирования.

Аннотация @RepositoryConfig сопоставляет EmployeeRepository с baeldungCache Ignite.

4. Конфигурация Spring

Давайте теперь создадим наш класс конфигурации Spring.

Мы будем использовать аннотацию @EnableIgniteRepositories, чтобы добавить поддержку репозиториев Ignite:

@Configuration
@EnableIgniteRepositories
public class SpringDataConfig {

    @Bean
    public Ignite igniteInstance() {
        IgniteConfiguration config = new IgniteConfiguration();

        CacheConfiguration cache = new CacheConfiguration("baeldungCache");
        cache.setIndexedTypes(Integer.class, EmployeeDTO.class);

        config.setCacheConfiguration(cache);
        return Ignition.start(config);
    }
}

Здесь метод igniteInstance() создает и передает экземпляр Ignite в IgniteRepositoryFactoryBean, чтобы получить доступ к кластеру Apache Ignite.

Мы также определили и установили конфигурацию baeldungCache. Метод setIndexedTypes() устанавливает схему SQL для кеша.

5. Тестирование репозитория

Чтобы протестировать приложение, давайте зарегистрируем SpringDataConfiguration в контексте приложения и получим из него EmployeeRepository:

AnnotationConfigApplicationContext context
 = new AnnotationConfigApplicationContext();
context.register(SpringDataConfig.class);
context.refresh();

EmployeeRepository repository = context.getBean(EmployeeRepository.class);

Затем мы хотим создать экземпляр EmployeeDTO и сохранить его в кеш:

EmployeeDTO employeeDTO = new EmployeeDTO();
employeeDTO.setId(1);
employeeDTO.setName("John");
employeeDTO.setEmployed(true);

repository.save(employeeDTO.getId(), employeeDTO);

Здесь мы использовали метод сохранения (ключ, значение) IgniteRepository. Причина этого в том, что стандартные операции CrudRepository save(entity), save(entities), delete(entity) пока не поддерживаются.

Проблема заключается в том, что идентификаторы, сгенерированные методом CrudRepository.save(), не уникальны в кластере.

Вместо этого мы должны использовать методы save(key, value), save(Map\u003cID, Entity\u003e values), deleteAll(Iterable\u003cID\u003e ids).

После этого мы можем получить объект сотрудника из кеша с помощью метода Spring Data getEmployeeDTOById():

EmployeeDTO employee = repository.getEmployeeDTOById(employeeDTO.getId());
System.out.println(employee);

Вывод показывает, что мы успешно извлекли исходный объект: получить тот же объект с помощью IgniteCache API:

EmployeeDTO{id=1, name='John', isEmployed=true}

Или с помощью стандартного SQL:

IgniteCache<Integer, EmployeeDTO> cache = ignite.cache("baeldungCache");
EmployeeDTO employeeDTO = cache.get(employeeId);

6. Резюме

SqlFieldsQuery sql = new SqlFieldsQuery(
  "select * from EmployeeDTO where isEmployed = 'true'");

В этом кратком руководстве показано, как интегрировать Spring Data Framework с проектом Apache Ignite. . С помощью практического примера мы научились работать с кешем Apache Ignite с помощью Spring Data API.

Как обычно, полный код для этой статьи доступен в проекте GitHub.

«