compass站内搜索

compass站内搜索：

1.去官方网站下载compass的jar包，我用的的2.1版本
http://www.compass-project.org/

ProductInfo.java

@Entity
@Searchable
public class ProductInfo implements Serializable{
private static final long serialVersionUID = -8860864584425256200L;
private Integer id;
/** 货号 **/
private String code;
/** 产品名称 **/
private String name;
/** 产品类型 **/
private ProductType type;
/** 产品样式 **/
private Set<ProductStyle> styles = new HashSet<ProductStyle>();

public ProductInfo() {}

@OneToMany(cascade={CascadeType.REMOVE,CascadeType.PERSIST}, mappedBy=”product”,fetch=FetchType.EAGER)
@OrderBy(“visible desc, id asc”)
@SearchableReference
public Set<ProductStyle> getStyles() {
return styles;
}
public void setStyles(Set<ProductStyle> styles) {
this.styles = styles;
}

@Id @GeneratedValue
@SearchableId
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
@Column(length=30)
@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
@Column(length=50,nullable=false)
@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}

@ManyToOne(cascade=CascadeType.REFRESH,optional=false)
@JoinColumn(name=”typeid”)
@SearchableReference
public ProductType getType() {
return type;
}
public void setType(ProductType type) {
this.type = type;
}

@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 ProductInfo other = (ProductInfo) obj;
if (id == null) {
if (other.id != null)
return false;
} else if (!id.equals(other.id))
return false;
return true;
}
}
@Entity
@Searchable
public class ProductInfo implements Serializable{
private static final long serialVersionUID = -8860864584425256200L;
private Integer id;
/** 货号 **/
private String code;
/** 产品名称 **/
private String name;
/** 产品类型 **/
private ProductType type;
/** 产品样式 **/
private Set<ProductStyle> styles = new HashSet<ProductStyle>();

public ProductInfo() {}

@OneToMany(cascade={CascadeType.REMOVE,CascadeType.PERSIST}, mappedBy=”product”,fetch=FetchType.EAGER)
@OrderBy(“visible desc, id asc”)
@SearchableReference
public Set<ProductStyle> getStyles() {
return styles;
}
public void setStyles(Set<ProductStyle> styles) {
this.styles = styles;
}
@Id @GeneratedValue
@SearchableId
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
@Column(length=30)
@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
@Column(length=50,nullable=false)
@SearchableProperty(index = Index.TOKENIZED, store = Store.YES)
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}

@ManyToOne(cascade=CascadeType.REFRESH,optional=false)
@JoinColumn(name=”typeid”)
@SearchableReference
public ProductType getType() {
return type;
}
public void setType(ProductType type) {
this.type = type;
}
@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 ProductInfo other = (ProductInfo) obj;
if (id == null) {
if (other.id != null)
return false;
} else if (!id.equals(other.id))
return false;
return true;
}
}


ProductType.java
@Entity
@Searchable
public class ProductType implements Serializable{
private static final long serialVersionUID = 8106351120886053881L;
/** 类别id **/
private Integer typeid;
/** 类别名称 **/
private String name;
/** 子类别 **/
private Set<ProductType> childtypes = new HashSet<ProductType>();
/** 所属父类 **/
private ProductType parent;

private Set<ProductInfo> products = new HashSet<ProductInfo>();

@OneToMany(mappedBy=”type”, cascade=CascadeType.REMOVE)
@SearchableReference
public Set<ProductInfo> getProducts() {
return products;
}

public void setProducts(Set<ProductInfo> products) {
this.products = products;
}

public ProductType() {}

@ManyToOne(cascade=CascadeType.REFRESH)
@JoinColumn(name=”parentid”)
public ProductType getParent() {
return parent;
}

public void setParent(ProductType parent) {
this.parent = parent;
}
@OneToMany(cascade={CascadeType.REFRESH,CascadeType.REMOVE},mappedBy=”parent”)
public Set<ProductType> getChildtypes() {
return childtypes;
}

public void setChildtypes(Set<ProductType> childtypes) {
this.childtypes = childtypes;
}

@Column(length=36,nullable=false)
public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

@Id @GeneratedValue(strategy=GenerationType.AUTO)
@SearchableId
public Integer getTypeid() {
return typeid;
}

public void setTypeid(Integer typeid) {
this.typeid = typeid;
}

@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((typeid == null) ? 0 : typeid.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 ProductType other = (ProductType) obj;
if (typeid == null) {
if (other.typeid != null)
return false;
} else if (!typeid.equals(other.typeid))
return false;
return true;
}
}

@Entity
@Searchable
public class ProductType implements Serializable{
private static final long serialVersionUID = 8106351120886053881L;
/** 类别id **/
private Integer typeid;
/** 类别名称 **/
private String name;
/** 子类别 **/
private Set<ProductType> childtypes = new HashSet<ProductType>();
/** 所属父类 **/
private ProductType parent;

private Set<ProductInfo> products = new HashSet<ProductInfo>();

@OneToMany(mappedBy=”type”, cascade=CascadeType.REMOVE)
@SearchableReference
public Set<ProductInfo> getProducts() {
return products;
}

public void setProducts(Set<ProductInfo> products) {
this.products = products;
}

public ProductType() {}
@ManyToOne(cascade=CascadeType.REFRESH)
@JoinColumn(name=”parentid”)
public ProductType getParent() {
return parent;
}

public void setParent(ProductType parent) {
this.parent = parent;
}
@OneToMany(cascade={CascadeType.REFRESH,CascadeType.REMOVE},mappedBy=”parent”)
public Set<ProductType> getChildtypes() {
return childtypes;
}

public void setChildtypes(Set<ProductType> childtypes) {
this.childtypes = childtypes;
}

@Column(length=36,nullable=false)
public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

@Id @GeneratedValue(strategy=GenerationType.AUTO)
@SearchableId
public Integer getTypeid() {
return typeid;
}

public void setTypeid(Integer typeid) {
this.typeid = typeid;
}

@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((typeid == null) ? 0 : typeid.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 ProductType other = (ProductType) obj;
if (typeid == null) {
if (other.typeid != null)
return false;
} else if (!typeid.equals(other.typeid))
return false;
return true;
}
}



ProductStyle.java
Java代码
1.
2.@Entity
3.@Searchable
4.public class ProductStyle implements Serializable{
5.    private static final long serialVersionUID = -4926119953511144279L;
6.    private Integer id;
7.    /** 样式的名称 **/
8.    private String name;
9.    /** 图片 **/
10.    private String imagename;
11.    private String image140FullPath;
12.    /** 是否可见 **/
13.    private Boolean visible = true;
14.    private ProductInfo product;
15.
16.    public ProductStyle() {}
17.
18.    public ProductStyle(Integer id) {
19.        this.id = id;
20.    }
21.
22.    public ProductStyle(String name, String imagename) {
23.        this.name = name;
24.        this.imagename = imagename;
25.    }
26.    @ManyToOne(cascade=CascadeType.REFRESH,optional=false)
27.    @JoinColumn(name=”productid”)
28.    @SearchableReference
29.    public ProductInfo getProduct() {
30.        return product;
31.    }
32.    public void setProduct(ProductInfo product) {
33.        this.product = product;
34.    }
35.    @Id @GeneratedValue
36.    @SearchableId
37.    public Integer getId() {
38.        return id;
39.    }
40.    public void setId(Integer id) {
41.        this.id = id;
42.    }
43.    @Column(length=30,nullable=false)
44.    public String getName() {
45.        return name;
46.    }
47.    public void setName(String name) {
48.        this.name = name;
49.    }
50.    @Column(length=40,nullable=false)
51.    @SearchableProperty(index = Index.UN_TOKENIZED, store = Store.YES)
52.    public String getImagename() {
53.        return imagename;
54.    }
55.    public void setImagename(String imagename) {
56.        this.imagename = imagename;
57.    }
58.    @Column(nullable=false)
59.    public Boolean getVisible() {
60.        return visible;
61.    }
62.    public void setVisible(Boolean visible) {
63.        this.visible = visible;
64.    }
65.    @Transient
66.    public String getImageFullPath(){
67.        return “/images/product/”+ this.getProduct().getType().getTypeid()+ “/”+
68.        this.getProduct().getId()+ “/prototype/”+ this.imagename;
69.    }
70.
71.    @Transient
72.    public String getImage140FullPath(){
73.        image140FullPath = “/images/product/”+ this.getProduct().getType().getTypeid()+ “/”+
74.        this.getProduct().getId()+ “/140x/”+ this.imagename;
75.        return image140FullPath;
76.    }
77.
78.    @Override
79.    public int hashCode() {
80.        final int prime = 31;
81.        int result = 1;
82.        result = prime * result + ((id == null) ? 0 : id.hashCode());
83.        return result;
84.    }
85.    @Override
86.    public boolean equals(Object obj) {
87.        if (this == obj)
88.            return true;
89.        if (obj == null)
90.            return false;
91.        if (getClass() != obj.getClass())
92.            return false;
93.        final ProductStyle other = (ProductStyle) obj;
94.        if (id == null) {
95.            if (other.id != null)
96.                return false;
97.        } else if (!id.equals(other.id))
98.            return false;
99.        return true;
100.    }
101.}

@Entity
@Searchable
public class ProductStyle implements Serializable{
private static final long serialVersionUID = -4926119953511144279L;
private Integer id;
/** 样式的名称 **/
private String name;
/** 图片 **/
private String imagename;
private String image140FullPath;
/** 是否可见 **/
private Boolean visible = true;
private ProductInfo product;

public ProductStyle() {}

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

public ProductStyle(String name, String imagename) {
this.name = name;
this.imagename = imagename;
}
@ManyToOne(cascade=CascadeType.REFRESH,optional=false)
@JoinColumn(name=”productid”)
@SearchableReference
public ProductInfo getProduct() {
return product;
}
public void setProduct(ProductInfo product) {
this.product = product;
}
@Id @GeneratedValue
@SearchableId
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
@Column(length=30,nullable=false)
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Column(length=40,nullable=false)
@SearchableProperty(index = Index.UN_TOKENIZED, store = Store.YES)
public String getImagename() {
return imagename;
}
public void setImagename(String imagename) {
this.imagename = imagename;
}
@Column(nullable=false)
public Boolean getVisible() {
return visible;
}
public void setVisible(Boolean visible) {
this.visible = visible;
}
@Transient
public String getImageFullPath(){
return “/images/product/”+ this.getProduct().getType().getTypeid()+ “/”+
this.getProduct().getId()+ “/prototype/”+ this.imagename;
}

@Transient
public String getImage140FullPath(){
image140FullPath = “/images/product/”+ this.getProduct().getType().getTypeid()+ “/”+
this.getProduct().getId()+ “/140x/”+ this.imagename;
return image140FullPath;
}

@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 ProductStyle other = (ProductStyle) obj;
if (id == null) {
if (other.id != null)
return false;
} else if (!id.equals(other.id))
return false;
return true;
}
}


这里要特别注意有集合类型要搜索或显示的时候，两边定义的@SearchableReference或 @SearchableComponent必须一致

2.再spring的配置文件中加入以下代码





Java代码
1.
2.<bean id=”annotationConfiguration”  >
3.</bean>
4. <!– compass Bean  –>
5.<bean id=”compass”>
6.        <property name=”compassConfiguration”
7.            ref=”annotationConfiguration” />
8.        <property name=”transactionManager” ref=”txManager” />
9.    <property name=”compassSettings”>
10.            <props>
11. <!– 定义索引的存储位置  –>
12.<prop key=”compass.engine.connection”>d:/compass</prop>
13.<prop key=”compass.transaction.factory”>
14.                    org.compass.spring.transaction.SpringSyncTransactionFactory
15.</prop>
16. <!– 定义分词器–>
17.<prop key=”compass.engine.analyzer.MMAnalyzer.CustomAnalyzer”>
18.org.mira.lucene.analysis.IK_CAnalyzer
19.</prop>
20.</props>
21.</property>
22.        <property name=”resourceDirectoryLocations”>
23.            <list>
24.                <value>classpath:net/shopin/bean/product</value>
25.            </list>
26.        </property>
27.
28.    </bean>
29.
30.    <bean id=”jpaGpsDevice”
31.       >
32.        <property name=”name”>
33.            <value>JpaGpsDevice</value>
34.        </property>
35.        <property name=”entityManagerFactory”
36.            ref=”entityManagerFactory” />
37.        <property name=”mirrorDataChanges”>
38.            <value>true</value>
39.        </property>
40.    </bean>
41.    <!– 数据库中的数据变化后同步更新索引 –>
42.    <bean id=”compassGps”
43.        init-method=”start” destroy-method=”stop”>
44.        <property name=”compass” ref=”compass” />
45.        <property name=”gpsDevices”>
46.            <list>
47.                <bean
48.                   >
49.                    <property name=”gpsDevice” ref=”jpaGpsDevice” />
50.                </bean>
51.            </list>
52.        </property>
53.    </bean>
54.
55.
56.    <bean id=”compassTemplate”
57.       >
58.        <property name=”compass” ref=”compass” />
59.    </bean>
60.
61.    <!– 定时重建索引(利用quartz)或随Spring ApplicationContext启动而重建索引 –>
62.    <bean id=”compassIndexBuilder”
63.
64.        lazy-init=”false”>
65.        <property name=”compassGps” ref=”compassGps” />
66.        <property name=”buildIndex” value=”true” />
67.        <property name=”lazyTime” value=”5″ />
68.    </bean>

<bean id=”annotationConfiguration”>
</bean>
<!– compass Bean  –>
<bean id=”compass”>
<property name=”compassConfiguration”
ref=”annotationConfiguration” />
<property name=”transactionManager” ref=”txManager” />
<property name=”compassSettings”>
<props>
<!– 定义索引的存储位置  –>
<prop key=”compass.engine.connection”>d:/compass</prop>
<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>
</props>
</property>
<property name=”resourceDirectoryLocations”>
<list>
<value>classpath:net/shopin/bean/product</value>
</list>
</property>

</bean>

<bean id=”jpaGpsDevice”
class=”org.compass.gps.device.jpa.JpaGpsDevice”>
<property name=”name”>
<value>JpaGpsDevice</value>
</property>
<property name=”entityManagerFactory”
ref=”entityManagerFactory” />
<property name=”mirrorDataChanges”>
<value>true</value>
</property>
</bean>
<!– 数据库中的数据变化后同步更新索引 –>
<bean id=”compassGps”
init-method=”start” destroy-method=”stop”>
<property name=”compass” ref=”compass” />
<property name=”gpsDevices”>
<list>
<bean
class=”org.compass.spring.device.SpringSyncTransactionGpsDeviceWrapper”>
<property name=”gpsDevice” ref=”jpaGpsDevice” />
</bean>
</list>
</property>
</bean>
<bean id=”compassTemplate”
class=”org.compass.core.CompassTemplate”>
<property name=”compass” ref=”compass” />
</bean>

<!– 定时重建索引(利用quartz)或随Spring ApplicationContext启动而重建索引 –>
<bean id=”compassIndexBuilder”
class=”net.shopin.service.search.impl.CompassIndexBuilder”
lazy-init=”false”>
<property name=”compassGps” ref=”compassGps” />
<property name=”buildIndex” value=”true” />
<property name=”lazyTime” value=”5″ />
</bean>



3.自动建立索引的java bean

Java代码
1.
2./**
3. * 通过quartz定时调度定时重建索引或自动随Spring ApplicationContext启动而重建索引的Builder.
4. * 会启动后延时数秒新开线程调用compassGps.index()函数.
5. * 默认会在Web应用每次启动时重建索引,可以设置buildIndex属性为false来禁止此功能.
6. * 也可以不用本Builder, 编写手动调用compassGps.index()的代码.
7. *
8. */
9.public class CompassIndexBuilder implements InitializingBean {
10.    // 是否需要建立索引，可被设置为false使本Builder失效.
11.    private boolean buildIndex = false;
12.
13.    // 索引操作线程延时启动的时间，单位为秒
14.    private int lazyTime = 10;
15.
16.    // Compass封装
17.    private CompassGps compassGps;
18.
19.    // 索引线程
20.    private Thread indexThread = new Thread() {
21.
22.        @Override
23.        public void run() {
24.            try {
25.                Thread.sleep(lazyTime * 1000);
26.                System.out.println(“begin compass index…”);
27.                long beginTime = System.currentTimeMillis();
28.                // 重建索引.
29.                // 如果compass实体中定义的索引文件已存在，索引过程中会建立临时索引，
30.                // 索引完成后再进行覆盖.
31.                compassGps.index();
32.                long costTime = System.currentTimeMillis() – beginTime;
33.                System.out.println(“compss index finished.”);
34.                System.out.println(“costed ” + costTime + ” milliseconds”);
35.            } catch (InterruptedException e) {
36.                e.printStackTrace();
37.            }
38.        }
39.    };
40.
41.    /**
42.     * 实现<code>InitializingBean</code>接口，在完成注入后调用启动索引线程.
43.     *
44.     * @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet()
45.     */
46.    public void afterPropertiesSet() throws Exception {
47.        if (buildIndex) {
48.            indexThread.setDaemon(true);
49.            indexThread.setName(“Compass Indexer”);
50.            indexThread.start();
51.        }
52.    }
53.
54.    public void setBuildIndex(boolean buildIndex) {
55.        this.buildIndex = buildIndex;
56.    }
57.
58.    public void setLazyTime(int lazyTime) {
59.        this.lazyTime = lazyTime;
60.    }
61.
62.    public void setCompassGps(CompassGps compassGps) {
63.        this.compassGps = compassGps;
64.    }
65.}

/**
* 通过quartz定时调度定时重建索引或自动随Spring ApplicationContext启动而重建索引的Builder.
* 会启动后延时数秒新开线程调用compassGps.index()函数.
* 默认会在Web应用每次启动时重建索引,可以设置buildIndex属性为false来禁止此功能.
* 也可以不用本Builder, 编写手动调用compassGps.index()的代码.
*
*/
public class CompassIndexBuilder implements InitializingBean {
// 是否需要建立索引，可被设置为false使本Builder失效.
private boolean buildIndex = false;

// 索引操作线程延时启动的时间，单位为秒
private int lazyTime = 10;

// Compass封装
private CompassGps compassGps;

// 索引线程
private Thread indexThread = new Thread() {

@Override
public void run() {
try {
Thread.sleep(lazyTime * 1000);
System.out.println(“begin compass index…”);
long beginTime = System.currentTimeMillis();
// 重建索引.
// 如果compass实体中定义的索引文件已存在，索引过程中会建立临时索引，
// 索引完成后再进行覆盖.
compassGps.index();
long costTime = System.currentTimeMillis() – beginTime;
System.out.println(“compss index finished.”);
System.out.println(“costed ” + costTime + ” milliseconds”);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};

/**
* 实现<code>InitializingBean</code>接口，在完成注入后调用启动索引线程.
*
* @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet()
*/
public void afterPropertiesSet() throws Exception {
if (buildIndex) {
indexThread.setDaemon(true);
indexThread.setName(“Compass Indexer”);
indexThread.start();
}
}

public void setBuildIndex(boolean buildIndex) {
this.buildIndex = buildIndex;
}

public void setLazyTime(int lazyTime) {
this.lazyTime = lazyTime;
}

public void setCompassGps(CompassGps compassGps) {
this.compassGps = compassGps;
}
}



4.建立索引Service 层代码

Java代码
1.
2.@Service
3.@Transactional
4.public class SearchServiceBean extends DaoSupport implements SearchService {
5.    @Resource(name = “compass”)
6.    Compass compass;
7.
8./** 创建索引 **/
9.public void index(ProductInfo p) {
10.
11.CompassSession session = compass.openSession();
12.CompassTransaction tx = null;
13.try {
14.    tx = session.beginTransaction();
15.    session.create(p);
16.    tx.commit();
17.} catch (Exception e) {
18.    if (tx != null) {
19.tx.commit();
20.    }
21.    throw new RuntimeException(e);
22.    } finally {
23.        if (session != null) {
24.        session.close();
25.    }
26.        }
27.    }
28.    /** 删除一条索引 **/
29.    public void delete(ProductInfo p) {
30.        CompassTemplate ct = new CompassTemplate(compass);
31.        ct.delete(p);
32.    }
33.    /** 更新(重新创建)一条索引 **/
34.    public void update(final ProductInfo p) {
35.        CompassTemplate ct = new CompassTemplate(compass);
36.
37.        CompassCallback<Object> action = new CompassCallback<Object>() {
38.
39.            public Object doInCompass(CompassSession session)
40.                    throws CompassException {
41.                session.delete(p);
42.                session.create(p);
43.                return null;
44.            }
45.
46.        };
47.
48.        ct.execute(action);
49.    }
50.    /** 索引查询 **/
51.    public List<ProductInfo> find(final String keywords) {
52.        CompassTemplate ct = new CompassTemplate(compass);
53.        return ct.execute(new CompassCallback<List<ProductInfo>>() {
54.
55.            public List<ProductInfo> doInCompass(CompassSession session)
56.                    throws CompassException {
57.                List<ProductInfo> result = new ArrayList<ProductInfo>();
58.                CompassQueryBuilder queryBuilder = session.queryBuilder();
59.                CompassHits hits = null; // session.find(query);
60.                /** 在所有字段中查询 **/
61.                CompassQuery allPropertyQuery = queryBuilder.queryString(keywords).toQuery();
62.                hits = allPropertyQuery.hits();
63.                /** 在指定字段中查询 **/
64.                // CompassQuery query = queryBuilder.term(“name”, keywords);
65.                // hits = query.hits();
66.                /** 指定范围查询  **/
67.//               CompassQuery dateRangeQuery =
68.//               queryBuilder.between(“postTime”,startTime, endTime, true);
69.//               hits = queryBuilder.bool()
70.//               .addMust(allPropertyQuery)
71.//               .addMust(dateRangeQuery)
72.//               .toQuery()
73.//               .hits();
74.//              System.out.println(“———”);
75.                for (int i = 0; i < hits.length(); i++) {
76.                    ProductInfo p = (ProductInfo) hits.data(i);
77.                    /** 如果进行高亮的属性中没有出现关键字, 则返回null  **/
78.//                  String ht = hits.highlighter(i).fragment(“name”);
79.//                  if (ht != null) {
80.//                      p.setName(ht);
81.//                  }
82.//                  String hc = hits.highlighter(i).fragment(“code”);
83.//                  if (hc != null) {
84.//                      p.setCode(hc);
85.//                  }
86.                    result.add(p);
87.                }
88.                return result;
89.            }
90.        });
91.    }

@Service
@Transactional
public class SearchServiceBean extends DaoSupport implements SearchService {
@Resource(name = “compass”)
Compass compass;

/** 创建索引 **/
public void index(ProductInfo p) {

CompassSession session = compass.openSession();
CompassTransaction tx = null;
try {
tx = session.beginTransaction();
session.create(p);
tx.commit();
} catch (Exception e) {
if (tx != null) {
tx.commit();
}
throw new RuntimeException(e);
} finally {
if (session != null) {
session.close();
}
}
}
/** 删除一条索引 **/
public void delete(ProductInfo p) {
CompassTemplate ct = new CompassTemplate(compass);
ct.delete(p);
}
/** 更新(重新创建)一条索引 **/
public void update(final ProductInfo p) {
CompassTemplate ct = new CompassTemplate(compass);

CompassCallback<Object> action = new CompassCallback<Object>() {

public Object doInCompass(CompassSession session)
throws CompassException {
session.delete(p);
session.create(p);
return null;
}

};

ct.execute(action);
}
/** 索引查询 **/
public List<ProductInfo> find(final String keywords) {
CompassTemplate ct = new CompassTemplate(compass);
return ct.execute(new CompassCallback<List<ProductInfo>>() {

public List<ProductInfo> doInCompass(CompassSession session)
throws CompassException {
List<ProductInfo> result = new ArrayList<ProductInfo>();
CompassQueryBuilder queryBuilder = session.queryBuilder();
CompassHits hits = null; // session.find(query);
/** 在所有字段中查询 **/
CompassQuery allPropertyQuery = queryBuilder.queryString(keywords).toQuery();
hits = allPropertyQuery.hits();
/** 在指定字段中查询 **/
// CompassQuery query = queryBuilder.term(“name”, keywords);
// hits = query.hits();
/** 指定范围查询  **/
// CompassQuery dateRangeQuery =
// queryBuilder.between(“postTime”,startTime, endTime, true);
// hits = queryBuilder.bool()
// .addMust(allPropertyQuery)
// .addMust(dateRangeQuery)
// .toQuery()
// .hits();
// System.out.println(“———”);
for (int i = 0; i < hits.length(); i++) {
ProductInfo p = (ProductInfo) hits.data(i);
/** 如果进行高亮的属性中没有出现关键字, 则返回null  **/
// String ht = hits.highlighter(i).fragment(“name”);
// if (ht != null) {
// p.setName(ht);
// }
// String hc = hits.highlighter(i).fragment(“code”);
// if (hc != null) {
// p.setCode(hc);
// }
result.add(p);
}
return result;
}
});
}
控制层

Java代码
1.@Controller(“/search/gosearch“)
2.public class SearchAction extends Action {
3.    @Resource(name = “searchServiceBean”)
4.    private SearchService SearchService;
5.
6.    @Override
7.    public ActionForward execute(ActionMapping mapping, ActionForm form,
8.            HttpServletRequest request, HttpServletResponse response)
9.            throws Exception {
10.        String keywords=request.getParameter(“word”).trim();
11.        if(keywords==null||”".equals(keywords)){
12.            return mapping.findForward(“noproduct”);
13.        }
14.        System.out.println(“——”+keywords);
15.        List<ProductInfo> list = SearchService.find(keywords);
16.        request.setAttribute(“word”, keywords);
17.        request.setAttribute(“product”,list);
18.        if(list.isEmpty()){
19.            return mapping.findForward(“noproduct”);
20.        }else{
21.            return mapping.findForward(“list”);
22.
23.        }
24.    }
25.}
@Controller(“/search/gosearch”)
public class SearchAction extends Action {
@Resource(name = “searchServiceBean”)
private SearchService SearchService;

@Override
public ActionForward execute(ActionMapping mapping, ActionForm form,
HttpServletRequest request, HttpServletResponse response)
throws Exception {
String keywords=request.getParameter(“word”).trim();
if(keywords==null||”".equals(keywords)){
return mapping.findForward(“noproduct”);
}
System.out.println(“——”+keywords);
List<ProductInfo> list = SearchService.find(keywords);
request.setAttribute(“word”, keywords);
request.setAttribute(“product”,list);
if(list.isEmpty()){
return mapping.findForward(“noproduct”);
}else{
return mapping.findForward(“list”);

}
}
}



junit测试

public class SearchTest {

3.    private static AbstractApplicationContext context;
4.    @BeforeClass
5.    public static void setUpBeforeClass() throws Exception {
6.        try {
7.            context = new ClassPathXmlApplicationContext(“beans.xml”);
8.        } catch (Exception e) {
9.            e.printStackTrace();
10.        }
11.    }
12.
13.    @Test
14.    public void testDelete() {
15.        SearchService searchService = (SearchService) context
16.        .getBean(“searchServiceBean”);
17.        ProductInfo p = new ProductInfo(2);
18.        searchService.delete(p);
19.    }
20.
21.    @Test
22.    public void createIndex(){
23.        SearchService searchService = (SearchService) context
24.        .getBean(“searchServiceBean”);
25.        ProductInfoService productInfoService = (ProductInfoService) context
26.        .getBean(“productInfoServiceBean”);
27.        List<ProductInfo> list=productInfoService.getAllProduct();
28.        for(ProductInfo productInfo:list){
29.//          System.out.println(“——-”+productInfo.getName());
30.            searchService.index(productInfo);
31.        }
32.    }
33.
34.    @Test
35.    public void testSearch() {
36.        SearchService searchService = (SearchService) context
37.        .getBean(“searchServiceBean”);
38.        String query = “手机”;
39.        List<ProductInfo> ProductInfos;
40.
41.            ProductInfos = searchService.find(query);
for (ProductInfo p : ProductInfos) {
System.out.println(p.getName());
}
System.out.println(“————”);
}
}