DATAES-82 - findAll(Iterable<ID> ids) does not work with Collections

terms query does not support iterable, converted Iterable to Collection

Author: mohsinh

src/main/java/org/springframework/data/elasticsearch/repository/support/AbstractElasticsearchRepository.java

@@ -26,6 +26,7 @@
 import java.util.List;
 
 import org.elasticsearch.ElasticsearchException;
+import org.elasticsearch.common.collect.Lists;
 import org.elasticsearch.index.query.QueryBuilder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -118,7 +119,9 @@ public Iterable<T> findAll(Sort sort) {
 
 	@Override
 	public Iterable<T> findAll(Iterable<ID> ids) {
-		SearchQuery query = new NativeSearchQueryBuilder().withQuery(inQuery(entityInformation.getIdAttribute(), ids))
+		Assert.notNull(ids, "ids can't be null.");
+		SearchQuery query = new NativeSearchQueryBuilder()
+				.withQuery(inQuery(entityInformation.getIdAttribute(), Lists.newArrayList(ids)))
 				.build();
 		return elasticsearchOperations.queryForPage(query, getEntityClass());
 	}

src/test/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepositoryTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2013 the original author or authors.
+ * Copyright 2013-2014 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -24,8 +24,8 @@
 import java.util.Arrays;
 import java.util.List;
 
+import org.elasticsearch.common.collect.Lists;
 import org.junit.Before;
-import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -204,10 +204,11 @@ public void shouldSearchDocumentsGivenElasticsearchQuery() {
 		assertThat(page.getNumberOfElements(), is(greaterThanOrEqualTo(1)));
 	}
 
+	/*
+	DATAES-82
+	*/
 	@Test
-	@Ignore
 	public void shouldFindAllByIdQuery() {
-		// todo : find solution for findAll(Iterable<Ids> ids)
 		// given
 		String documentId = randomNumeric(5);
 		SampleEntity sampleEntity = new SampleEntity();
@@ -228,6 +229,8 @@ public void shouldFindAllByIdQuery() {
 
 		// then
 		assertNotNull("sample entities cant be null..", sampleEntities);
+		List<SampleEntity> entities = Lists.newArrayList(sampleEntities);
+		assertThat(entities.size(), is(2));
 	}
 
 	@Test