Elasticsearch - Learn JBStrap

Jpa Datadescriptor

ElasticSearch is a distributed search and analytics engine that ensures extremely fast searches even in large data sets. We integrated ElasticSearch into JBStrap as an alternative database, allowing fast searches in the JBStrap framework. In JBStrap, you can use ElasticSearch to quickly search in structured and unstructured data sets and search for text, numbers, dates or even IDs.

Please note: The ElasticSearch plugin only works with a 6.1.2 version ElasticSearch server!

Connecting to the ElasticSearch server

In order to access the data in an ElasticSearch server, first you have to connect to the server. You only have to connect to the server once, since once a connection is open, it remains active until it is closed. Implement the connection in the Startup class.

To implement the connection, specify the server name, IP address and port. The default address and port for the ElasticSearch is localhost:9300. Write the following code to implement the connection:

        try {
	ElasticSearchDaoAPI.connect("localhost", 9300);
} catch (final Exception e2) {
	LOG.error("Can not connect to ElasticSearch!");
}
       

Disconnecting from an ElasticSearch server

Just like all database server connections, you have to close an ElasticSearch server connection before you quit the application. Do this in the shutdown() method of the Startup class, as this method is executed before each application shutdown. Use the following statement to disconnect from the server:

ElasticSearch entity class

The entity class used by the ElasticSearch plugin is very similar to that used by the JPA DAO. You have to create a POJO class and describe the physical data structure (ElasticSearch index attributes and the corresponding parameters).

Here's an example for an ElasticSearch entity class:

        package com.jbstrap.sample.domain.es;

import com.jbstrap.elasticsearch.annotation.Column;
import com.jbstrap.elasticsearch.annotation.Id;
import com.jbstrap.elasticsearch.annotation.Index;

@Index(name="product")
public class Product {

	@Id
	@Column(name="id")
	private Long id;

	@Column(name="product_name")
	private String productName;

	private String country;

	private String city;

	@Column(name="company_name")
	private String companyName;

	@Column(name="unit_price")
	private Double unitPrice;

	@Column(name="PACKAGE")
	private String packageDescription;

	private Boolean discontinued;

	public Long getId() {
		return id;
	}

	public void setId(final Long id) {
		this.id = id;
	}

	public String getProductName() {
		return productName;
	}

	public void setProductName(final String productName) {
		this.productName = productName;
	}

	public String getCountry() {
		return country;
	}

	public void setCountry(final String country) {
		this.country = country;
	}

	public String getCity() {
		return city;
	}

	public void setCity(final String city) {
		this.city = city;
	}

	public String getCompanyName() {
		return companyName;
	}

	public void setCompanyName(final String companyName) {
		this.companyName = companyName;
	}

	public Double getUnitPrice() {
		return unitPrice;
	}

	public void setUnitPrice(final Double unitPrice) {
		this.unitPrice = unitPrice;
	}

	public String getPackageDescription() {
		return packageDescription;
	}

	public void setPackageDescription(final String packageDescription) {
		this.packageDescription = packageDescription;
	}

	public Boolean getDiscontinued() {
		return discontinued;
	}

	public void setDiscontinued(final Boolean discontinued) {
		this.discontinued = discontinued;
	}
}
       