import org.springframework.data.elasticsearch.core.query.IndexQuery; //导入依赖的package包/类
default void index(Collection<? extends T> objects) {
    if (objects.isEmpty()) {
        return;
    }

    List<IndexQuery> queries = objects.stream()
            .map(obj -> {
                IndexQuery query = new IndexQuery();
                query.setId(obj.getId());

                query.setObject(this.toIndexObject(obj));

                return query;
            })
            .collect(Collectors.toList());

    getTemplate().bulkIndex(queries);
    getTemplate().refresh(getUType());
}
 

import org.springframework.data.elasticsearch.core.query.IndexQuery; //导入依赖的package包/类
@Before
public void before() {
	elasticsearchTemplate.deleteIndex(ArticleEntity.class);
	elasticsearchTemplate.createIndex(ArticleEntity.class);
	elasticsearchTemplate.putMapping(ArticleEntity.class);
	elasticsearchTemplate.refresh(ArticleEntity.class);

	IndexQuery article1 = new ArticleEntityBuilder("1").title("article four").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addAuthor(MOHSIN_HUSEN).addAuthor(JONATHAN_YAN).score(10).buildIndex();
	IndexQuery article2 = new ArticleEntityBuilder("2").title("article three").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addAuthor(MOHSIN_HUSEN).addPublishedYear(YEAR_2000).score(20).buildIndex();
	IndexQuery article3 = new ArticleEntityBuilder("3").title("article two").subject("computing").addAuthor(RIZWAN_IDREES).addAuthor(ARTUR_KONCZAK).addPublishedYear(YEAR_2001).addPublishedYear(YEAR_2000).score(30).buildIndex();
	IndexQuery article4 = new ArticleEntityBuilder("4").title("article one").subject("accounting").addAuthor(RIZWAN_IDREES).addPublishedYear(YEAR_2002).addPublishedYear(YEAR_2001).addPublishedYear(YEAR_2000).score(40).buildIndex();

	elasticsearchTemplate.index(article1);
	elasticsearchTemplate.index(article2);
	elasticsearchTemplate.index(article3);
	elasticsearchTemplate.index(article4);
	elasticsearchTemplate.refresh(ArticleEntity.class);
}
 

import org.springframework.data.elasticsearch.core.query.IndexQuery; //导入依赖的package包/类
public static IndexQuery buildIndex(Object object) {
	for (Field f : object.getClass().getDeclaredFields()) {
		if (ArrayUtils.isNotEmpty(f.getAnnotationsByType(org.springframework.data.annotation.Id.class))) {
			try {
				f.setAccessible(true);
				IndexQuery indexQuery = new IndexQuery();
				indexQuery.setId((String) f.get(object));
				indexQuery.setObject(object);
				return indexQuery;
			} catch (IllegalAccessException e) {
				e.printStackTrace();
			}
		}
	}
	throw new RuntimeException("Missing @Id field");
}
 

import org.springframework.data.elasticsearch.core.query.IndexQuery; //导入依赖的package包/类
@PostConstruct
private void initData() {
	List<IndexQuery> indexQueries = new ArrayList<IndexQuery>();
	LoremIpsum lorem = new LoremIpsum();
	for (int i = MINCOUNT; i < MAXCOUNT; i++) {
		String documentId = UUID.randomUUID().toString();
		Book book = new Book();
		book.setId(documentId);
		book.setName(lorem.randomWord());
		book.setMessage(lorem.sentence());
		book.setPrice(RandomUtils.nextDouble());
		IndexQuery indexQuery = new IndexQueryBuilder()
				.withId(book.getId()).withObject(book).build();
		indexQueries.add(indexQuery);
	}

	// bulk index
	elasticsearchTemplate.bulkIndex(indexQueries);
}
 

import org.springframework.data.elasticsearch.core.query.IndexQuery; //导入依赖的package包/类
@Override
public TYPE save(TYPE entity, Class<TYPE> entityClass) throws DataLayerException {
    if (!elasticsearchTemplate.indexExists(entityClass)) {
        elasticsearchTemplate.createIndex(entityClass);
        elasticsearchTemplate.putMapping(entityClass);
    }
    IndexQuery indexQuery = new IndexQuery();
    if (entity.getId() == null) {
        entity.setId(UUID.randomUUID().toString());
    }
    indexQuery.setId(entity.getId());
    indexQuery.setObject(entity);
    elasticsearchTemplate.index(indexQuery);
    elasticsearchTemplate.refresh(entityClass, true);
    return entity;
}
 

import org.springframework.data.elasticsearch.core.query.IndexQuery; //导入依赖的package包/类
@Test
public void testGeoBoundingBoxQueryForElasticsearchTemplate() throws Exception {

    elasticsearchTemplate.createIndex("universities");
    elasticsearchTemplate.putMapping(GeoBoundingBox.class);

    List<IndexQuery> indexQueryList = new ArrayList<>();
    GeoBoundingBox geoBoundingBox = new GeoBoundingBox("中国传媒大学",new Location(39.918054,116.56387));
    IndexQuery indexQuery  = new IndexQuery();
    indexQuery.setId(UUID.randomUUID().toString());
    indexQuery.setIndexName("universities");
    indexQuery.setType("university");
    indexQuery.setSource(JSON.toJSONString(geoBoundingBox));
    indexQuery.setObject(geoBoundingBox);
    indexQueryList.add(indexQuery);

    GeoBoundingBox geoBoundingBox1 = new GeoBoundingBox("北京邮电大学",new Location(39.967366,116.364695));
    IndexQuery indexQuery1  = new IndexQuery();
    indexQuery1.setId(UUID.randomUUID().toString());
    indexQuery1.setIndexName("universities");
    indexQuery1.setType("university");
    indexQuery1.setSource(JSON.toJSONString(geoBoundingBox1));
    indexQuery1.setObject(geoBoundingBox1);
    indexQueryList.add(indexQuery1);

    GeoBoundingBox geoBoundingBox2 = new GeoBoundingBox("北京航空航天大学",new Location(39.986069,116.35347));
    IndexQuery indexQuery2  = new IndexQuery();
    indexQuery2.setId(UUID.randomUUID().toString());
    indexQuery2.setIndexName("universities");
    indexQuery2.setType("university");
    indexQuery2.setSource(JSON.toJSONString(geoBoundingBox2));
    indexQuery2.setObject(geoBoundingBox2);
    indexQueryList.add(indexQuery2);

    elasticsearchTemplate.bulkIndex(indexQueryList);

    QueryBuilder queryBuilder =
            QueryBuilders.geoBoundingBoxQuery("location")
                    .setCorners(40.124125,113.493763,39.816239,117.237612);

    SearchQuery searchQuery = new NativeSearchQuery(queryBuilder);

    List<GeoBoundingBox> geoBoundingBoxes = elasticsearchTemplate.queryForList(searchQuery,GeoBoundingBox.class);
    System.out.println(JSON.toJSONString(geoBoundingBox));



}
 

import org.springframework.data.elasticsearch.core.query.IndexQuery; //导入依赖的package包/类
public IndexQuery buildIndex() {
	IndexQuery indexQuery = new IndexQuery();
	indexQuery.setId(result.getId());
	indexQuery.setObject(result);
	return indexQuery;
}