elasticsearch之入门hello(java)一

Posted 2020-10-19 fjk

1.书写pom.xml文件

   　　 <dependencies>
		<dependency>
			<groupId>org.elasticsearch</groupId>
			<artifactId>elasticsearch</artifactId>
			<version>2.4.0</version>
		</dependency>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>fastjson</artifactId>
			<version>1.1.37</version>
		</dependency>
	</dependencies>

2.创建一个文档

@Test   //创建一个文档
	public void test01() throws Exception {
		// 创建连接elasticsearch服务器对象
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		// 描述json对象
		XContentBuilder xContentBuilder = XContentFactory
				.jsonBuilder()
				.startObject()
				.field("id", 1)
				.field("content",
						"QQ音乐是腾讯公司推出的一款网络音乐服务产品,海量音乐在线试听、新歌热歌在线首发、歌词翻译、手机铃声下载、高品质无损音乐试听、海量无损曲库、正版音乐下载、空间")
				.field("title", "QQ音乐-千万正版音乐海量无损曲库新歌热歌天天畅听的高").endObject();
		client.prepareIndex("jk1", "article", "1").setSource(xContentBuilder)
				.get();
		client.close();

	}

　　测试：

创建成功

检索数据（全文）

@Test//对全文进行搜索
	public void test02() throws Exception{
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		//搜索数据
		SearchResponse response = client.prepareSearch("jk1").setTypes("article").setQuery(QueryBuilders.matchAllQuery()).get();
		//获取命中次数
		SearchHits hits = response.getHits();
		System.out.println("命中的次数为："+hits.getTotalHits());
		for (Iterator iterator = hits.iterator(); iterator.hasNext();) {
			SearchHit searchHit = (SearchHit) iterator.next();
			System.out.println(searchHit.getSourceAsString());
		}
	}

　　

检索数据（字段检索）  会对需要查询的词进行分词的

@Test  //对所有字段进行分词查询
	public void test03() throws Exception{
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		//搜索数据
		SearchResponse response = client.prepareSearch("jk1").setTypes("article").setQuery(QueryBuilders.queryStringQuery("QQ腾讯")).get();
		//获取命中次数
		SearchHits hits = response.getHits();
		System.out.println("tes3t命中的次数为："+hits.getTotalHits());
		for (Iterator iterator = hits.iterator(); iterator.hasNext();) {
			SearchHit searchHit = (SearchHit) iterator.next();
			System.out.println(searchHit.getSourceAsString());
			
		}
	}

　查询结果

 

　检索数据（模糊查询）  不会对需要查询的词条进行重新分词

@Test  //模糊查询
	public void test04() throws Exception{
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		//搜索数据
		SearchResponse response = client.prepareSearch("jk1").setTypes("article").setQuery(QueryBuilders.wildcardQuery("content", "*QQ*")).get();
		//获取命中次数
		SearchHits hits = response.getHits();
		System.out.println("命中的次数为："+hits.getTotalHits());
		for (Iterator iterator = hits.iterator(); iterator.hasNext();) {
			SearchHit searchHit = (SearchHit) iterator.next();
			System.out.println(searchHit.getSourceAsString());
			
		}
	}

　　查询结果：命中的次数为：0

创建索引

@Test
	// 创建索引
	public void test01() throws IOException {
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		client.admin().indices().prepareCreate("jk2").get();

	}

　删除索引

@Test
	// 删除索引
	public void test02() throws IOException {
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		client.admin().indices().prepareDelete("jk2").get();
	}

　　创建映射

@Test
	// 映射文件 的操作
	public void test03() throws Exception {
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		// 描述json对象 创建连接搜索服务器对象
		XContentBuilder xContentBuilder = XContentFactory.jsonBuilder()
				.startObject().startObject("article").startObject("properties")
				.startObject("id").field("type", "String")
				.field("store", "yes").endObject().startObject("title")
				.field("type", "string").field("store", "yes")
				.field("analyzer", "ik").endObject().startObject("content")
				.field("type", "string").field("store", "yes")
				.field("analyzer", "ik").endObject().endObject().endObject()
				.endObject();
		PutMappingRequest mappingRequest = Requests.putMappingRequest("jk2")
				.type("article").source(xContentBuilder);
		client.admin().indices().putMapping(mappingRequest).get();
		// 关闭连接
		client.close();
	}

　　文档的操作

@Test
	// 映射文件 的操作
	public void test04() throws Exception {
		Client client = TransportClient
				.builder()
				.build()
				.addTransportAddress(
						new InetSocketTransportAddress(InetAddress
								.getByName("127.0.0.1"), 9300));
		// 描述json 数据
		/*
		 * {id:xxx, title:xxx, content:xxx}
		 */
		Article article = new Article();
		article.setId("2");
		article.setTitle("搜索工作其实很henbu快乐");
		article.setContent("我们希望我们的搜索解决方案要快，我们希望有一个零配置和一个完全免费的搜索模式，我们希望能够简单地使用JSON通过HTTP的索引数据，我们希望我们的搜索服务器始终可用，我们希望能够一台开始并扩展到数百，我们要实时搜索，我们要简单的多租户，我们希望建立一个云的解决方案。Elasticsearch旨在解决所有这些问题和更多的问题。");

		String jsonString = JSON.toJSONString(article);
		// 建立文档
		client.prepareIndex("jk2", "article", article.getId().toString())
				.setSource(jsonString).get();
		//修改文档
//		client.prepareUpdate("jk2", "article", article.getId().toString()).setDoc(jsonString).get();
//		client.update(new UpdateRequest("jk2", "article", article.getId().toString()).doc(jsonString)).get();
		
		//删除文档
//		client.prepareDelete("jk2", "article", article.getId().toString()).get();
	//	client.delete(new DeleteRequest("jk2", "article", article.getId().toString())).get();
		// 关闭连接
		client.close();
	}