JarCasting
Elasticsearch extension for Mangoo I/O
This is an easly plugable extension for the mangoo I/O framework to work with Elasticsearch.
Setup
-
Add the mangooio-elasticsearch-extension dependency to your pom.xml:
com.markvink mangooio-elasticsearch-extension x.x.x -
Configure the Elasticsearch client inapplication.yaml
2.1) Node client
elasticsearch:
cluster:
name: elasticsearch
path:
home: /path/to/elasticsearch/home/dir
index:
store:
type: memory|simplefs|niofs|mmapfs|default
http:
enabled: true|false
2.1) Transport client
elasticsearch:
cluser:
name: elasticsearch
node:
host: 127.0.0.1
port: 9300
client:
transport:
sniff: true|false
ignore_cluster_name: true|false
ping_timeout: 5s
nodes_sampler_interval: 5s
-
Inject the Elasticsearch client where needed
@Inject Elasticsearch elasticsearch;
Basic usage
-
Adding and removing nodes on the transport client
elasticsearch.addNode(InetAddress address, int port); elasticsearch.removeNode(InetAddress address, int port);
-
Wrapper methods
elasticsearch.getClient(); elasticsearch.createIndex(String indexName); elasticsearch.indexDocument(String indexName, Document document); elasticsearch.getDocument(String indexName, String documentType, String documentId); elasticsearch.deleteDocument(String indexName, String documentType, String documentId);
Indexing documents
-
Indexing fields using jackson annotations
import com.fasterxml.jackson.annotation.JsonProperty; import com.markvink.mangooio.elasticsearch.document.Document;
public class User implements Document { @JsonProperty("username") private String username;
public User(String username) { this.username = username; }}
User user = new User("my-username"); elasticsearch.indexDocument("my-index", user); // Indexed username=my-username with generated ID
-
Specifing ID of the document
import com.fasterxml.jackson.annotation.JsonProperty; import com.markvink.mangooio.elasticsearch.document.DocumentWithId;
public class User implements DocumentWithId { @JsonProperty("username") private String username;
public User(String username) { this.username = username; } @Override public String getDocumentId() { return username; }}
User user = new User("my-username"); elasticsearch.indexDocument("my-index", user); // indexed using ID=my-username
-
Specifing source of the document
import com.markvink.mangooio.elasticsearch.document.DocumentWithSource;
public class User implements DocumentWithSource { private String username;
public User(String username) { this.username = username; } @Override public Map<String, Object> getDocumentSource() { Map<String, Object> map = new HashMap<String, Object>(); map.put("username", username); map.put("key1", "value1"); map.put("key2", "value2"); return map; }}
User user = new User("my-username"); elasticsearch.indexDocument("my-index", user); // indexed using provided source
Using client
-
Use the normal Java client for searching for example
SearchResponse response = elasticsearch.getClient().prepareSearch("my-index") .setTypes("User") .setSearchType(SearchType.DFS_QUERY_THEN_FETCH) .setQuery(QueryBuilders.termQuery("username", "my-username")) .setFrom(0).setSize(60).setExplain(true) .execute() .actionGet();
long hits = response.getHits().getTotalHits(); SearchHit[] results = response.getHits().getHits();