ｃｏｍｐａｓｓ的开发應用ＪＰＡ+Ｃｏｍｐａｓｓ整合

查询结果的高亮显示:

 

采用的是JPA的注解方式，

首先看实体类：User.java

package com.compass.model;

import org.compass.annotations.Index;
import org.compass.annotations.Searchable;
import org.compass.annotations.SearchableId;
import org.compass.annotations.SearchableProperty;
import org.compass.annotations.Store;

@Searchable
public class User {

private Integer id;
private String userName;
private String sex;
private Integer age;
private String address;

public User() {
}

public User(Integer id) {
   this.id = id;
}

@SearchableId
public Integer getId() {
   return id;
}

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

@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public String getUserName() {
   return userName;
}

public void setUserName(String userName) {
   this.userName = userName;
}

@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public String getSex() {
   return sex;
}

public void setSex(String sex) {
   this.sex = sex;
}

@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public Integer getAge() {
   return age;
}

public void setAge(Integer age) {
   this.age = age;
}

@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public String getAddress() {
   return address;
}

public void setAddress(String address) {
   this.address = address;
}

@Override
public int hashCode() {
   final int prime = 31;
   int result = 1;
   result = prime * result + ((id == null) ? 0 : id.hashCode());
   return result;
}

@Override
public boolean equals(Object obj) {
   if (this == obj)
    return true;
   if (obj == null)
    return false;
   if (getClass() != obj.getClass())
    return false;
   final User other = (User) obj;
   if (id == null) {
    if (other.id != null)
          return false;
   } else if (!id.equals(other.id))
       return false;
   return true;
}

@Override
public String toString() {
    return "id=" + id + ", userName=" + userName + ", sex=" + sex
        + ", age=" + age + ", address=" + address;
}
}

然后查询管理类，里面高亮什么的都设置这个里面

SearchManager.java

package com.compass.model;

import java.util.ArrayList;
import java.util.List;

import org.compass.core.Compass;
import org.compass.core.CompassCallback;
import org.compass.core.CompassException;
import org.compass.core.CompassHits;
import org.compass.core.CompassQuery;
import org.compass.core.CompassQueryBuilder;
import org.compass.core.CompassSession;
import org.compass.core.CompassTemplate;
import org.compass.core.CompassTransaction;
import org.compass.core.config.CompassConfiguration;

public class SearchManager {

protected Compass compass;

/**
* 初始化
*/
public void init() {
   CompassConfiguration cfg = new CompassConfiguration();
   cfg.setConnection("e:/test");
   cfg.setSetting(
     "compass.engine.highlighter.default.formatter.simple.pre",
     "<font color='red'>");
   cfg.setSetting(
     "compass.engine.highlighter.default.formatter.simple.post",
     "</font>");
   cfg.addClass(User.class);
   compass = cfg.buildCompass();
}

/**
* 创建索引
*/
public void createIndex(User user) {
   CompassSession session = compass.openSession();
   CompassTransaction tx = null;
   try {
   
   
    CompassQueryBuilder queryBuilder = session.queryBuilder();
    CompassHits hits = queryBuilder.bool()
       .addMust( queryBuilder.term("name", "jack") )
       .addMustNot( queryBuilder.term("familyName", "london") )
     .toQuery()
       .addSort("familyName", CompassQuery.SortPropertyType.STRING)
       .addSort("birthdate", CompassQuery.SortPropertyType.INT)
     .hits();
   
    tx = session.beginTransaction();
    session.create(user);
    tx.commit();
   } catch (Exception e) {
    if (tx != null) {
     tx.rollback();
    }
   } finally {
    if (session != null) {
     session.close();
    }
   }
}

/**
* 删除一条索引记录
*/
public void delete(User user) {
   CompassTemplate ct = new CompassTemplate(compass);
   ct.delete(user);
}

/**
* 更新（重新创建）一条索引记录
*/
public void update(final User user) {
   CompassTemplate ct = new CompassTemplate(compass);
   CompassCallback<Object> action = new CompassCallback<Object>() {

    public Object doInCompass(CompassSession session)
      throws CompassException {
     session.delete(user);
     session.create(user);
     return null;
    }
   };
   ct.execute(action);
}

/**
* 查询
*/

public List<User> find(final String key) {
   CompassTemplate ct = new CompassTemplate(compass);
   return ct.execute(new CompassCallback<List<User>>() {

    public List<User> doInCompass(CompassSession session)
      throws CompassException {

     List<User> result = new ArrayList<User>();

     CompassHits hits = session.find(key);

     for (int i = 0; i < hits.length(); i++) {
      User user = (User) hits.data(i);
      result.add(user);
     }
     return result;
    }
   });

}

/**
* 含有高亮的查询
*/
public List<User> find(final String key, final int start, final int end) {
   CompassTemplate ct = new CompassTemplate(compass);
   return ct.execute(new CompassCallback<List<User>>() {

    public List<User> doInCompass(CompassSession session)
      throws CompassException {

     List<User> result = new ArrayList<User>();

     CompassHits hits = session.find(key);
     int max=0;
     if(end<hits.length()){
      max=end;
     }else{
      max=hits.length();
     }
     for (int i = start; i < max; i++) {
      User user = (User) hits.data(i);

      String hit = hits.highlighter(i).fragment("userName");
      if (hit != null) {
       user.setUserName(hit);
      }
      String hc = hits.highlighter(i).fragment("address");
      if (hc != null) {
       user.setAddress(hc);
      }
      String hx = hits.highlighter(i).fragment("sex");
      if (hx != null) {
       user.setSex(hx);
      }
      result.add(user);
     }
     return result;
    }
   });

}
}

 

最后就是测试类TestMain.java

package com.compass.model;

import java.util.List;

import org.compass.core.CompassHits;
import org.compass.core.CompassQuery;
import org.compass.core.CompassQueryBuilder;
import org.junit.Test;

public class TestMain {

/**
* @param args
*/

private SearchManager searchManager;

public void setup() {
   searchManager = new SearchManager();
   searchManager.init();
}

public void insert() {
   User user = new User();
   user.setId(1);
   user.setUserName("吴琼");
   user.setAge(20);
   user.setSex("女");
   user.setAddress("北京");

   User user2 = new User();
   user2.setId(2);
   user2.setUserName("张舒");
   user2.setAge(20);
   user2.setSex("女");
   user2.setAddress("北京");

   searchManager.createIndex(user);
   searchManager.createIndex(user2);
}

@Test
public void insert2() {
   User user = new User();
   user.setId(1);
   user.setUserName("吴琼");
   user.setAge(20);
   user.setSex("女");
   user.setAddress("北京");

   User user2 = new User();
   user2.setId(2);
   user2.setUserName("张舒");
   user2.setAge(20);
   user2.setSex("女");
   user2.setAddress("哈尔滨");

   User user3 = new User();
   user3.setId(2);
   user3.setUserName("张舒");
   user3.setAge(20);
   user3.setSex("女");
   user3.setAddress("哈尔滨");

   searchManager.createIndex(user);
   searchManager.createIndex(user2);
   searchManager.createIndex(user3);
}

@Test
public void delete() {
   User user = new User(1);
   searchManager.delete(user);
}

@Test
public void search() {
   String key = "女";
   List<User> users = searchManager.find(key, 0,3);
   for (User user : users) {
    System.out.println(user.toString());
   }
}
public static void main(String[] args) {

   TestMain t = new TestMain();
   t.setup();
   t.insert();
   t.insert2();
   t.search();
   System.out.println("it's over...");
}

}

输出结果是：

2009-3-9 0:12:45 org.compass.core.config.CompassConfiguration addClass
信息: Mapping class [class com.compass.model.User]
2009-3-9 0:12:45 org.compass.core.lucene.engine.highlighter.LuceneHighlighterManager configure
信息: Building highlighter [default]
2009-3-9 0:12:46 org.compass.core.lucene.engine.optimizer.LuceneSearchEngineOptimizerManager start
信息: Starting scheduled optimizer [class org.compass.core.lucene.engine.optimizer.AdaptiveOptimizer] with period [10000ms]
2009-3-9 0:12:46 org.compass.core.lucene.engine.manager.DefaultLuceneSearchEngineIndexManager start
信息: Starting scheduled index manager with period [60000ms]
2009-3-9 0:12:46 org.compass.core.lucene.engine.manager.DefaultLuceneSearchEngineIndexManager start
信息: Starting scheduled refresh cache with period [5000ms]
i看到输出的没，是把标签给输出来了，如果到页面上就会高亮了

 

 

Ｓｐｒｉｎｇ　+ｈｉｂｅｒｎａｔｅ+ｃｏｍｐａｓｓ　注解整合

和整合Ｓｐｒｉｎｇ+ＪＰＡ+ｃｏｍｐａｓｓ整合一样不同点如下:

　ｈｉｂｅｒｎａｔｅ的注解的配置如下:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:p="http://www.springframework.org/schema/p"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:tx="http://www.springframework.org/schema/tx"
 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
  http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
  http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
      
 <!-- support annotation config -->
 <context:annotation-config/>
 <context:component-scan base-package="cn.com.unutrip.compass.search">
  <context:include-filter type="regex" expression=".model..*"/>
  <context:include-filter type="regex" expression=".dao..*"/>
  <context:include-filter type="regex" expression=".services..*"/>
  <context:include-filter type="regex" expression=".facade..*"/>
 </context:component-scan>
      
      
 <bean id="datasource"
  class="org.apache.commons.dbcp.BasicDataSource">
  <property name="driverClassName"
   value="com.mysql.jdbc.Driver">
  </property>
  <property name="url"
   value="jdbc:mysql://localhost:3306/search">
  </property>
  <property name="username" value="root"></property>
  <property name="password" value="123456"></property>
 </bean>
 <bean id="sessionFactory"
  class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
  <property name="dataSource">
   <ref bean="datasource" />
  </property>
  <property name="hibernateProperties">
   <props>
    <prop key="hibernate.dialect">
     org.hibernate.dialect.MySQLDialect
    </prop>
    <!--设置二级缓冲-->
    <prop key="hibernate.cache.provider_class">
     org.hibernate.cache.EhCacheProvider
    </prop>
    <!--设置二级缓冲，打开查询缓冲-->
    <prop key="hibernate.cache.use_query_cache">true</prop>
    <!--设置显示Hibernate操作的SQL语句-->
    <prop key="hibernate.show_sql">true</prop>
   </props>
  </property>
  <property name="annotatedClasses">
   <list>
    <value>cn.com.unutrip.compass.search.model.Blog</value>
   </list>
  </property>
 </bean>
 <!-- 配置事务管理器 --> 
 <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
  <property name="sessionFactory">
   <ref local="sessionFactory"/>
  </property>
 </bean>
    <!-- 配置事务特性 ，配置add、delete和update开始的方法，事务传播特性为required-->      
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
     <tx:attributes>
      <tx:method name="insert*" propagation="REQUIRED"/>
      <tx:method name="delete*" propagation="REQUIRED"/>
      <tx:method name="update*" propagation="REQUIRED"/>
      <tx:method name="*" read-only="true"/>
     </tx:attributes>
    </tx:advice>
   
 

</beans>

ｓｐｉｎｇ-search.xml配置如下:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation=" http://www.springframework.org/schema/beans  http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"
 default-lazy-init="true">
 <bean id="annotationConfiguration"
  class="org.compass.annotations.config.CompassAnnotationsConfiguration">
 </bean>
 <bean id="compass" class="org.compass.spring.LocalCompassBean">
  <property name="resourceDirectoryLocations">
   <list>
    <value>
     classpath:cn/com/unutrip/compass/search/model
    </value>
   </list>
  </property>
  <property name="classMappings">
   <list>
    <value>cn.com.unutrip.compass.search.model.Blog</value>
   </list>
  </property>
  <property name="compassConfiguration"
   ref="annotationConfiguration" />
  <property name="compassSettings">
   <props>
    <prop key="compass.transaction.factory">
     org.compass.spring.transaction.SpringSyncTransactionFactory
    </prop>
    <prop
     key="compass.engine.analyzer.MMAnalyzer.CustomAnalyzer">
     org.mira.lucene.analysis.IK_CAnalyzer
    </prop>
    <!-- 定义索引的存储位置  -->
    <prop key="compass.engine.connection">d:/compass</prop>
   </props>
  </property>
  <property name="transactionManager" ref="transactionManager" />
 </bean>

 <bean id="hibernateGpsDevice"
  class="org.compass.spring.device.hibernate.dep.SpringHibernate3GpsDevice">
  <property name="name">
   <value>hibernateDevice</value>
  </property>
  <property name="sessionFactory" ref="sessionFactory" />
  <property name="mirrorDataChanges">
   <value>true</value>
  </property>
 </bean>

 <!-- 同步更新索引 -->
 <bean id="compassGps" class="org.compass.gps.impl.SingleCompassGps"
  init-method="start" destroy-method="stop">
  <property name="compass">
   <ref bean="compass" />
  </property>
  <property name="gpsDevices">
   <list>
    <ref bean="hibernateGpsDevice" />
   </list>
  </property>
 </bean>
 <bean id="compassTemplate"
  class="org.compass.core.CompassTemplate">
  <property name="compass" ref="compass" />
 </bean>

 <!-- 定时重建索引(利用quartz)或随Spring ApplicationContext启动而重建索引 -->
 <bean id="compassIndexBuilder"
  class="cn.com.unutrip.compass.search.utils.CompassIndexBuilder"
  lazy-init="false">
  <property name="compassGps" ref="compassGps" />
  <property name="buildIndex" value="true" />
  <property name="lazyTime" value="10" />
 </bean>
</beans>

 

其他各类一样:ｃｏｍｐａｓｓ和其他框架整合不同点:ＸＸＸ3GpsDevice不同和管理器模板對象不同