Как запросить таблицу DynamoDB по хешу с использованием Spring Data - PullRequest
Новая
       61

Как запросить таблицу DynamoDB по хешу с использованием Spring Data

0 голосов
/ 21 декабря 2018

У меня есть таблица DynamoDB со следующим ключом [customerid (HASH), sku (RANGE)].

Я пытаюсь выполнить запрос только по customerid.В настоящее время я получаю эту ошибку: 

Caused by: java.lang.IllegalStateException: You have defined query method in the repository but you don't have any query lookup strategy defined. The infrastructure apparently does not support query methods!
    at org.springframework.data.repository.core.support.RepositoryFactorySupport$QueryExecutorMethodInterceptor.<init>(RepositoryFactorySupport.java:545) ~[spring-data-commons-2.1.0.RELEASE.jar:2.1.0.RELEASE]
    at org.springframework.data.repository.core.support.RepositoryFactorySupport.getRepository(RepositoryFactorySupport.java:324) ~[spring-data-commons-2.1.0.RELEASE.jar:2.1.0.RELEASE]
    at org.springframework.data.repository.core.support.RepositoryFactoryBeanSupport.lambda$afterPropertiesSet$5(RepositoryFactoryBeanSupport.java:297) ~[spring-data-commons-2.1.0.RELEASE.jar:2.1.0.RELEASE]
    at org.springframework.data.util.Lazy.getNullable(Lazy.java:211) ~[spring-data-commons-2.1.0.RELEASE.jar:2.1.0.RELEASE]
    at org.springframework.data.util.Lazy.get(Lazy.java:94) ~[spring-data-commons-2.1.0.RELEASE.jar:2.1.0.RELEASE]
    at org.springframework.data.repository.core.support.RepositoryFactoryBeanSupport.afterPropertiesSet(RepositoryFactoryBeanSupport.java:300) ~[spring-data-commons-2.1.0.RELEASE.jar:2.1.0.RELEASE]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1804) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1741) ~[spring-beans-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    ... 30 common frames omitted

Я добавил queryLookupStrategy в свое приложение в надежде, что это сработало.Пробовал несколько значений, но сообщение остается. 

@SpringBootApplication
@EnableDynamoDBRepositories(queryLookupStrategy = QueryLookupStrategy.Key.CREATE_IF_NOT_FOUND)
public class ProductItemApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProductItemApplication.class, args);
    }
}

Возможно ли это?Или это ограничение "Динамо"?Поскольку Кассандра может легко это сделать, я предполагаю, что «Динамо» тоже сможет это сделать, но может ошибаться.

Нужно ли мне определять индекс только с customerid для запроса этого?Если да, то как лучше всего это сделать в коде с данными о пружине?

Или это ограничение данных о пружине с помощью динамо, и для достижения этого мне нужно было бы явно использовать клиент динамо, а неданные весны?

Мой репозиторий определен так: 

interface CustomerItemRepository extends CrudRepository<CustomerItem, CustomerItemId> {
    List<CustomerItem> findByCustomerId(String customerId);
}

И мой ключ: 

@NoArgsConstructor
@AllArgsConstructor
public class CustomerItemId {
    private String customerId;
    private String sku;

    @DynamoDBHashKey(attributeName = "customerId")
    public String getCustomerId() {
        return customerId;
    }

    @SuppressWarnings("unused")
    public void setCustomerId(String customerId) {
        this.customerId = customerId;
    }

    @DynamoDBRangeKey(attributeName = "sku")
    public String getSku() {
        return sku;
    }

    @SuppressWarnings("unused")
    public void setSku(String sku) {
        this.sku = sku;
    }
}

Наконец, мой элемент: 

    @DynamoDBTable(tableName = "CustomerItem")
    @NoArgsConstructor
    public class CustomerItem {
        @Id
        private CustomerItemId id;

//... a few other non key fields...

        CustomerItem(String customerId, String sku) {
            this.id = new CustomerItemId(customerId, sku);
        }

        @DynamoDBHashKey(attributeName = "customerId")
        public String getCustomerId() {
            return id.getCustomerId();
        }

        @DynamoDBRangeKey(attributeName = "sku")
        public String getSku() {
            return id.getSku();
        }

        public void setCustomerId(String customerId) {
            this.id = new CustomerItemId(customerId, id != null ? id.getSku() : null);
        }

        public void setSku(String sku) {
            this.id = new CustomerItemId(id != null ? id.getCustomerId() : null, sku);
        }
    }

Какой самый элегантный способ решить эту проблему?Динамо казалось подходящей технологией для дешевого хранения таких простых данных, но теперь я думаю, что мне лучше использовать что-то другое.

1 Ответ

0 голосов
/ 07 января 2019

Я знаю, что это не решает ваш вопрос, но для проекта Java я бы использовал DynamoDBMapper для сохранения объектов, а не Spring.Он обеспечивает действительно простой способ сопоставления ваших простых объектов в DynamoDB и предоставляется и поддерживается AWS.Я использовал это много, и DynamoDBMapper отлично.

...