java连接es
可以的，不过查询处理的数据你要进行拼装，一般都是先查询es，如果找不到数据，再查询mysql
‘贰’ java连接数据库的详细步骤
JDBC:
java database connective
主要作用:
连接程序使用的数据库
使用步骤:
1. 引入外部jar包(mysql提供的Java使用者的连接器)
工程上右键-->build path --> config buildpath --> liberies
-->add external jars
-->选择对应的mysql-connectorXXXXXX.jar
看到工程上有jar文件则证明引入成功
2. 编程:
(1):注册数据库驱动
Class.forName("com.mysql.jdbc.Driver");
(2):创建连接
String url = "jdbc:mysql://192.168.0.243:3306/test";
String userName = "root";
String password = "root";
Connection conn = DriverManager.getConnection(url, userName, password);
(3):创建SQL信使
Statement stmt = conn.createStatement();
(4):执行SQL语句
int i = stmt.executeUpdate("insert into employee values ('10070004', '张三丰', 1, '2005-05-23', 0, 1001, '2007-02-02', 200)");
(5):异常捕获、关闭资源
‘叁’ java 操作es多索引查询的时候，可不可以首先指定一个索引的查询条件，然后在进行多索引查询
你建立的是联合索引，按照索引中字段顺序使用才会最大化的发挥索引的作用。
索引的建立不需要看主键有几个字段，而是看你的查询条件经常用到哪几列，
如果经常同时用到好几列，就可以在这几列上建联合索引，
如果查询条件经常都只是用到某一个字段，只需要在该字段上建一个单独索引
‘肆’ elasticsearch中,如何与java中TransportClient在断开后自动重连
不建议使用TransportClient，因为es官方自己都放弃了。建议使用java自身的http客户端，使用rest api进行操作即可。不存在断开重连，只存在api失败重试。
‘伍’ 在Idea中如何用java代码与es做连接的项目
下面介绍一下如何使用Idea连接TFS服务器，并提交变更的代码到TFS服务器。
一、连接TFS服务器，并下载代码
Figure 1
Figure 2
Figure 3 - 输入TFS服务器的地址，例如：http://tfs2013cn:8080/tfs/defaultcollection
Figure 4 - 选择服务器代码库地址和本地地址
Figure 5 - 代码下载中
Figure 6 - 选择创建项目
Figure 7
Figure 8 - 继续， 后面几项都是Idea导入代码的界面，省略截屏
Figure 9 - 打开的项目
‘陆’ search-guard 安装后 java 怎么访问es
能：法就是通过工具，将java代码转换成exe文件然后使用js调用exe文件这种法是可以的但是没有人这么用建议你讲html文件转成jsp，jsp中可以嵌入java代码的然后下载个tomcat部署一下
‘柒’ Java代码查询es 的索引是yellow的状态,怎么可以查询不报错
建议提前检查，为yellow直接提醒运维去维护为green。不过我这边用的es6.2.3yellow是正常查询的。建议你检查一下环境配置应该不是yellow的问题。试了一下；为red都可以正常查询的（java代码查询结果和下图es-head查询结果一致）
‘捌’ java中如何直接读取es语言
Elasticsearch不是java语言开发的，所以必须要通过api才能调用。你可以看看有没有第三方包可以直接操作。
‘玖’ java数据直接往es里存 会出现性能问题吗
java数据直接往es里存 会出现性能问题的，存多了会造成程序运行缓慢，卡顿。
‘拾’ java怎么连接到elastic search集群
package cn.test;
import java.net.InetAddress;
import java.net.UnknownHostException;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
public class ElkTest {
// private static final String CLUSTER_NAME = "cluster_name";
public static final String CLUSTER_NAME = "elasticsearch"; //实例名称
private static final String IP = "127.0.0.1";
//private static final String IP = "192.168.0.29";
private static final int PORT = 9300; //端口
//1.设置集群名称：默认是elasticsearch，并设置client.transport.sniff为true，使客户端嗅探整个集群状态，把集群中的其他机器IP加入到客户端中
/*
//对ES1.6有效
private static Settings settings = ImmutableSettings
.settingsBuilder()
.put("cluster.name",CLUSTER_NAME)
.put("client.transport.sniff", true)
.build();
*/
//对ES2.0有效
private static Settings settings = Settings
.settingsBuilder()
.put("cluster.name",CLUSTER_NAME)
.put("client.transport.sniff", true)
.build();
//创建私有对象
private static TransportClient client;
//反射机制创建单例的TransportClient对象 ES1.6版本
// static {
// try {
// Class<?> clazz = Class.forName(TransportClient.class.getName());
// Constructor<?> constructor = clazz.getDeclaredConstructor(Settings.class);
// constructor.setAccessible(true);
// client = (TransportClient) constructor.newInstance(settings);
// client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(IP), PORT));
// } catch (Exception e) {
// e.printStackTrace();
// }
// }
//ES2.0版本
static {
try {
client = TransportClient.builder().settings(settings).build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(IP), PORT));
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
//取得实例
public static synchronized TransportClient getTransportClient(){
return client;
}
//为集群添加新的节点
public static synchronized void addNode(String name){
try {
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(name),9300));
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
//删除集群中的某个节点
public static synchronized void removeNode(String name){
try {
client.removeTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(name),9300));
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
public static void main(String args[]){
String index="logstash-2016.02.16";
String type="logs";
SearchResponse response=ElkTest.getTransportClient().prepareSearch(index)//设置要查询的索引(index)
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setTypes(type)//设置type, 这个在建立索引的时候同时设置了, 或者可以使用head工具查看
.setQuery(QueryBuilders.matchQuery("message", "Accept")) //在这里"message"是要查询的field,"Accept"是要查询的内容
.setFrom(0)
.setSize(10)
.setExplain(true)
.execute()
.actionGet();
for(SearchHit hit:response.getHits()){
System.out.println(hit.getSourceAsString());
}
}
}