ElasticSearch入门-结构定义之Mapping

相当于数据库的表结构的定义，elasticsearch的mapping 也很重要。直接关系到性能及搜索结果的准确性。elasticsearch的java api的例子太少，我在这儿就献丑了。

为了说明mapping的定义，我这里定义了一个简单的模型，就ID,type,和catIds 3个属性，重在说明如何使用java api来定义mapping,具体各field应该如何定义，这里不做讨论。

public class TestModel implements Serializable {
	private static final long serialVersionUID = 3174577828007649745L;
	//主ID
	private long id;
	//类型，为types之一
	private String type;
	/**
	 * 这里是一个列表
	 */
	private List<Integer> catIds;
	
	
	public long getId() {
		return id;
	}
	public void setId(long id) {
		this.id = id;
	}
	public String getType() {
		return type;
	}
	public void setType(String type) {
		this.type = type;
	}
	public List<Integer> getCatIds() {
		return catIds;
	}
	public void setCatIds(List<Integer> catIds) {
		this.catIds = catIds;
	}
}

 我们假设id就存储为long类型，type存储为字符串类型，catIds为一个列表，其实际类型为integer类型。定义的mapping如下：

/**
	 * mapping 一旦定义，之后就不能修改。
	 * @return
	 * @throws Exception
	 */
	private static XContentBuilder getMapping() throws Exception{
		XContentBuilder mapping = jsonBuilder()  
			       .startObject()  
			         .startObject("test")  
			         .startObject("properties")         
			           .startObject("id")
			           		.field("type", "long")
			           		.field("store", "yes")
			           	.endObject()    
			           	
			           .startObject("type")
			           		.field("type", "string")
			           		.field("index", "not_analyzed")
			           	.endObject()  
			           	
			           .startObject("catIds")
			           		.field("type", "integer")
			           .endObject()  
			         .endObject()  
			        .endObject()  
			      .endObject();  
		return mapping;
	}

 注意：elasticsearch的field一旦定义后就无法修改，你想增加一个store属性，都不行。

 

下面就是调用JAVA API了，注意，在定义mapping之前，还需要先创建一个index库。这里，我index库和mapping 写到一个方法里面了。

Client client = ESUtils.getClient();
		//首先创建索引库
		CreateIndexResponse  indexresponse = client.admin().indices()
		//这个索引库的名称还必须不包含大写字母
		.prepareCreate("testindex").execute().actionGet();
		System.out.println(indexresponse.acknowledged());;
		//如果是在两台机器上，下面直接putMapping可能会报异常
		PutMappingRequestBuilder builder = client.admin().indices().preparePutMapping("testindex");
		//testType就像当于数据的table
		builder.setType("testType");
		XContentBuilder mapping = getMapping();
		builder.setSource(mapping);
		PutMappingResponse  response = builder.execute().actionGet();
		System.out.println(response.isAcknowledged());

 其中，这个代码在我本机出现一点问题，当我创建完index后，直接创建mapping 的时候，报index missing。我把两个es Node停掉一个就没有问题了。可见，ES将create index和putMapping放到了两个不同的es Node下面，导致了上面那个异常。

 

好了，有时为了测试，可能需要删除某个索引，代码如下：

Client client = ESUtils.getClient();
		client.admin().indices()
		//这个索引库的名称还必须不包含大写字母
		.prepareDelete("testindex").execute().actionGet();

 

 

 

对这类话题感兴趣？欢迎发送邮件至[e-mail]

关于我：邯郸人，擅长Java，Javascript，Extjs，oracle sql。

更多我之前的文章，可以访问 我的空间

 

评论

2 楼 cookey0 2013-10-09  

LZ  我有两个服务器，同时直接创建mapping 的时候，报index missing你是怎么解决的？是把两台服务器分别设成：
“负载器”
node.master: false
node.data: true

“协调器”
node.master: true
node.data: false

这样能解决吗？

1 楼 last_forever 2013-08-14  

class A{
   private Integer aid;
   private String aname;
   //xxxx//
}

class B{
  private Integer bid;
  private String bname;
  private List<A> alist;
  //xxxx//
}
请问博主，上述这种情况下，我要对b的bid,bname,及alist里面的aid,aname进行search，该怎么query呢