提供了solr到elasticsearch的语法翻译引擎：solr-to-es
jopen
9年前
提供了一套solr到elasticsearch的语法翻译引擎，兼容现有的solr语法。同时提供了基于注解的ORM功能，自动完成实体类对象与elasticsearch结果之间的转换。你只要进行简单的配置，系统便会会自动完成索引、type/mapping的创建工作。同时提供了比较常用的底层api。比如，通过这个工具，你可以用下面这条solr查询语句在elasticsearch上进行搜索：
q=name:"季度"~1 AND type:Q&fq=tgsType:2&start=0&rows=5&sort=name+desc,code+asc&fl=name,code,logicId,pinyin&hl=true&hl.fl=name,code &hl.simple.pre=<em>&hl.simple.post=</em>
工具特点
- 基于注解自动创建index、type/mapping
- 兼容solr语法
- 提供了ORM功能，实体类和"表"之间自动转换
- 提供了丰富的底层api
- 使用简单，只需简单配置
如何使用
1.进行相关环境设置：
请在你的classpath目录新建elasticsearch.properties文件，内容参考如下：
#elasticsearch集群名称 cluster.name = es_nrs_log #elasticsearch集群中的主机地址列表（多个主机，以","分隔） hosts = 183.136.163.88,183.136.162.194,183.136.162.71 #elasticsearch客户端连接端口号（默认9300） client.port = 9300 #每次运行前是否进行检测（检测相关的索引和type/mapping是否存在，不存在则根据实体类的注解自动生成） isCheck = true #设置实体类所在的包路径 models.package.dir = org.cnfire.elasticsearch.model
2.定义实体类:
eg:如下定义了一个实体类Student：
//@Document(index = "school", type = "student", settings = "school-settings.json") //OR @Document(index = "school", type = "student", replicas = 1, shards = 5) public class Student { @ID String id; @Field(type = FieldType.String, index = FieldIndex.analyzed, stored = true, analyzer = "ik") String name; @Field String sex; @Field(type = FieldType.Integer) int age; @Field(type = FieldType.Float) double score; @Field(type = FieldType.String) boolean isGraduated; @Field(analyzer = "ik") String description; 相关的setter和getter省略现在，你已经定义了一个实体类，其描述的索引为school，相应应的type为student
注：相关注解的详细配置参考说明，会在接下来的时间里提供说明文档
3.现在你可以进行相关操作了，参考如下：
public class TestAccessor { Class<Student> clazz = Student.class; IAccessor accessor = Beans.getAccessor(); /*添加单个对象*/ @Test public boolean add(){ Student model = new Student(); model.setId("1001"); model.setName("jack"); model.setAge(30); model.setSex("male"); model.setScore(99.5); model.setIsGraduated(true); model.setDescription("jack is a good boy..."); return accessor.add(model); } /*添加对象集合*/ @Test public boolean testAddList(){ Student model1 = new Student(); model1.setName("kobe"); Student model2 = new Student(); model2.setName("james"); Student model3 = new Student(); model3.setName("jodarn"); List<Student> list= new ArrayList<Student>(); list.add(model1); list.add(model2); list.add(model3); return accessor.add(list); } /*根据ID获取记录*/ @Test public void get(){ System.out.println(accessor.get(clazz,"1001")); } /*根据查询条件统计结果个数*/ @Test public void count(){ String params = "q=sex:male AND isGraduated:true"; System.out.println(accessor.count(clazz, params)); } /*根据条件进行搜索*/ @Test public void search(){ String params = "q=sex:male AND isGraduated:true&start=0&rows=15&sort=name+desc,age+asc&fl=name,score"; System.out.println(accessor.search(clazz, params)); } /*根据条件进行高亮查询*/ @Test public void searchWithHL(){ String params = "q=sex:male AND isGraduated:true&start=0&rows=15&sort=name+desc,age+asc&fl=name,score" + "&hl=true&hl.fl=name&hl.simple.pre=<em>&hl.simple.post=</em>"; System.out.println(accessor.search(clazz, params)); } /*根据ID删除一条记录*/ @Test public boolean deleteRecord(){ return accessor.delete("ID1001",clazz); } /*根据查询条件删除多条记录*/ @Test public boolean deleteAll(){ String params = "q=sex:male AND isGraduated:true"; return accessor.delete(clazz,params); } /*根据输入的索引名称创建相应索引*/ @Test public boolean createIndex(){ return accessor.createIndex("testIndexName"); } /*根据实体类自动解析注解，获取相应settings，创建相应索引*/ @Test public boolean createIndexWithSettings(){ return accessor.createIndex(clazz); } /*根据索引名删除相应索引*/ @Test public boolean deleteIndex(){ return accessor.deleteIndex("school"); } /*删除相应类型*/ @Test public boolean deleteType(){ /*根据索引名和类型名删除相应类型*/ return accessor.deleteType("school","student"); // OR /*根据实体类删除类型*/ //accessor.deleteType(clazz); } /*根据实体类创建相关表对应的mapping*/ @Test public void createMapping(){ accessor.createMapping(clazz); } /*测试是否存在指定的索引*/ @Test public boolean hasIndex(){ return accessor.hasIndex("school"); } /*测试是否存在指定的mapping/类型*/ @Test public boolean hasMapping(){ /*根据实体类判断*/ return accessor.hasMapping(clazz); /*根据索引名和类型名判断*/ // return accessor.hasMapping("school","student"); } }ok,当你运行程序时候，系统会自动检测elasticsearch中相关的index和type/mapping是否存在，如果不存在则会根据注解自动创建
更详细的使用请参考项目中的test
注：本系统所提供的查询相关API暂只能使用标准的Lucene查询语法，比如你要显示地使用match_all,term等，其实都可以通过标准的Lucene语法进行查询
https://github.com/cnfire/solr-to-es