安科网

hibernate search 例子

oklinsong

oklinsong

2014-08-07

关注 关注

1、开发环境：spring2.5、hibernate3.3.1GA、hibernateSearch3.1.0GA;

2、开发是基于maven上开发的，首先新建一个web工程，添加maven支持，在pom.xml中添加一下几个依赖包：

 <dependencies>      
  <dependency>  
      <groupId>org.apache.openejb</groupId>  
      <artifactId>javaee-api</artifactId>  
      <version>5.0-1</version>  
      <scope>provided</scope>  
    </dependency>  
        <dependency>    
    <groupId>org.hibernate</groupId>    
    <artifactId>hibernate-search</artifactId>    
    <version>3.1.0.GA</version>    
    </dependency>    
    <dependency>    
        <groupId>org.hibernate</groupId>    
        <artifactId>hibernate-annotations</artifactId>    
        <version>3.4.0.GA</version>    
    </dependency>      
      
<!-- hibernate framework end -->    
       
<!-- lucene start -->    
<dependency>    
    <groupId>org.apache.lucene</groupId>    
    <artifactId>lucene-analyzers</artifactId>    
    <version>3.0.1</version>    
</dependency>    
<dependency>    
    <groupId>org.apache.lucene</groupId>    
    <artifactId>lucene-highlighter</artifactId>    
    <version>3.0.1</version>    
</dependency>    
  </dependencies>  
<dependencies>    
  <dependency>
      <groupId>org.apache.openejb</groupId>
      <artifactId>javaee-api</artifactId>
      <version>5.0-1</version>
      <scope>provided</scope>
    </dependency>
        <dependency>  
    <groupId>org.hibernate</groupId>  
    <artifactId>hibernate-search</artifactId>  
    <version>3.1.0.GA</version>  
	</dependency>  
	<dependency>  
	    <groupId>org.hibernate</groupId>  
	    <artifactId>hibernate-annotations</artifactId>  
	    <version>3.4.0.GA</version>  
	</dependency>    
	
<!-- hibernate framework end -->  
     
<!-- lucene start -->  
<dependency>  
    <groupId>org.apache.lucene</groupId>  
    <artifactId>lucene-analyzers</artifactId>  
    <version>3.0.1</version>  
</dependency>  
<dependency>  
    <groupId>org.apache.lucene</groupId>  
    <artifactId>lucene-highlighter</artifactId>  
    <version>3.0.1</version>  
</dependency>  
  </dependencies>



其他就是hibernate+spring的配置了；
注意一点的就是在配置文件hibernate的属性后面加上索引的监听和索引存放的位置，如：

<!-- Spring管理Hibernate的Mapping对象 -->  
    <bean id="sessionFactory"  
        class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">  
        <property name="dataSource">  
            <ref bean="dataSource" />  
        </property>  
        <property name="hibernateProperties">  
            <props>  
                <prop key="hibernate.dialect">  
                    ${hibernate.dialect}  
                </prop>  
                <prop key="hibernate.hbm2ddl.auto">  
                    ${hibernate.hbm2ddl.auto}  
                </prop>  
                <prop key="hibernate.show_sql">  
                    ${hibernate.show_sql}  
                </prop>  
                <prop key="hibernate.use_sql_comments">  
                    ${hibernate.use_sql_comments}  
                </prop>  
                <prop key="hibernate.use_outer_join">  
                    ${hibernate.use_outer_join}  
                </prop>  
                <prop key="hibernate.current_session_context_class">  
                    ${hibernate.current.session.context.class}  
                </prop>  
                <prop key="connection.autoReconnect">  
                    ${connection.autoReconnect}  
                </prop>   
                <prop key="connection.autoReconnectForPools">  
                    ${connection.autoReconnectForPools}  
                </prop>   
                <prop key="connection.is-connection-validation-required">  
                    ${connection.is-connection-validation-required}  
                </prop>   
                  
                <!-- 索引配置 -->  
                <prop key="hibernate.search.default.directory_provider">  
                    org.hibernate.search.store.FSDirectoryProvider  
                </prop>  
                <prop key="hibernate.search.default.indexBase">  
                    d:/JAVA/hibernateIndex  
                </prop>  
                   
            </props>  
        </property>  
          
        <!-- 索引配置-->  
        <property name="eventListeners">    
            <map>    
                <entry key="post-update">    
                    <bean class="org.hibernate.search.event.FullTextIndexEventListener" />    
                </entry>    
                <entry key="post-insert">    
                    <bean class="org.hibernate.search.event.FullTextIndexEventListener" />    
                </entry>    
                <entry key="post-delete">    
                    <bean class="org.hibernate.search.event.FullTextIndexEventListener" />    
                </entry>    
            </map>    
        </property>  
          
        <property name="mappingDirectoryLocations">  
            <list>  
                <value>${hibernate.mappingDirectoryLocations}</value>  
            </list>  
        </property>  
    </bean>  
<!-- Spring管理Hibernate的Mapping对象 -->
	<bean id="sessionFactory"
		class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
		<property name="dataSource">
			<ref bean="dataSource" />
		</property>
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">
					${hibernate.dialect}
				</prop>
				<prop key="hibernate.hbm2ddl.auto">
					${hibernate.hbm2ddl.auto}
				</prop>
				<prop key="hibernate.show_sql">
					${hibernate.show_sql}
				</prop>
				<prop key="hibernate.use_sql_comments">
					${hibernate.use_sql_comments}
				</prop>
				<prop key="hibernate.use_outer_join">
					${hibernate.use_outer_join}
				</prop>
				<prop key="hibernate.current_session_context_class">
					${hibernate.current.session.context.class}
				</prop>
				<prop key="connection.autoReconnect">
					${connection.autoReconnect}
				</prop> 
        		<prop key="connection.autoReconnectForPools">
        			${connection.autoReconnectForPools}
        		</prop> 
        		<prop key="connection.is-connection-validation-required">
        			${connection.is-connection-validation-required}
        		</prop> 
        		
        		<!-- 索引配置 -->
        		<prop key="hibernate.search.default.directory_provider">
					org.hibernate.search.store.FSDirectoryProvider
				</prop>
				<prop key="hibernate.search.default.indexBase">
					d:/JAVA/hibernateIndex
				</prop>
				 
			</props>
		</property>
		
		<!-- 索引配置-->
		<property name="eventListeners">  
            <map>  
                <entry key="post-update">  
                    <bean class="org.hibernate.search.event.FullTextIndexEventListener" />  
                </entry>  
                <entry key="post-insert">  
                    <bean class="org.hibernate.search.event.FullTextIndexEventListener" />  
                </entry>  
                <entry key="post-delete">  
                    <bean class="org.hibernate.search.event.FullTextIndexEventListener" />  
                </entry>  
            </map>  
		</property>
		
		<property name="mappingDirectoryLocations">
			<list>
				<value>${hibernate.mappingDirectoryLocations}</value>
			</list>
		</property>
	</bean>



这时启动如果报slf4j错误，可能是你的slf4j包冲突，需要把你lib里相关的jar包删了，在maven支持中还剩下slf4j-api-1.4.2.jar，需要导入slf4j-logging-1.4.2.jar包，如果导入更高版可能会报错，这个包在百度搜slf4j就能进入它的官网，很容易找到；

这个时候启动如果不报错，那成功一半了；接下来就是配置实体类了，比如一个商城系统要对订单建索引，实体类如（给出关键部分代码）：

@Entity  
@Indexed(index="shopOrders")  
public class ShopOrders  implements java.io.Serializable {  
  
  
    // Fields      
  
     @DocumentId  
     private String id;  
     private Integer uid;  
     @Field(index=Index.TOKENIZED,store=Store.YES)  
     private String username;  
     @Field(index=Index.UN_TOKENIZED,store=Store.YES)  
     private Integer isDelete;  
@Entity
@Indexed(index="shopOrders")
public class ShopOrders  implements java.io.Serializable {


    // Fields    

     @DocumentId
     private String id;
     private Integer uid;
     @Field(index=Index.TOKENIZED,store=Store.YES)
     private String username;
     @Field(index=Index.UN_TOKENIZED,store=Store.YES)
     private Integer isDelete;



这个时候启动你会发现你指定的路径下已经有了一个shopOrders文件夹，如果这个时候去搜索是搜索不到的，还没有初始化数据；
以下是数据初始化和查询的代码：

import java.util.Date;  
import java.util.List;  
  
import org.apache.lucene.analysis.standard.StandardAnalyzer;  
import org.apache.lucene.queryParser.MultiFieldQueryParser;  
import org.apache.lucene.queryParser.QueryParser;  
import org.apache.lucene.search.BooleanClause;  
import org.apache.lucene.search.BooleanQuery;  
import org.apache.lucene.search.Query;  
import org.hibernate.CacheMode;  
import org.hibernate.FlushMode;  
import org.hibernate.ScrollMode;  
import org.hibernate.ScrollableResults;  
import org.hibernate.Session;  
import org.hibernate.SessionFactory;  
import org.hibernate.search.FullTextQuery;  
import org.hibernate.search.FullTextSession;  
import org.hibernate.search.Search;  
import org.springframework.orm.hibernate3.LocalSessionFactoryBean;  
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;  
  
import com.china.fung.hibernate.pojo.shop.ShopOrders;  
  
public class Dao extends HibernateDaoSupport {  
  
    private static SessionFactory sessionFactory;  
    private static Session session = null;  
    private static LocalSessionFactoryBean factoryBean = null;  
  
    public void getMySession() throws Exception {  
        sessionFactory = this.getHibernateTemplate().getSessionFactory();  
        session = sessionFactory.openSession();  
    }  
  
    public List search(String keyword) throws Exception {  
        this.getMySession();  
        BooleanQuery.setMaxClauseCount(100000);  
        BooleanQuery booleanQuery = new BooleanQuery();  
        StandardAnalyzer analyzer=new StandardAnalyzer();  
        // 基本关键词搜索  
        String[] searchFields = new String[] { "username" };//成员变量  
        MultiFieldQueryParser queryParser = new MultiFieldQueryParser(  
                searchFields,analyzer);  
        queryParser.setDefaultOperator(QueryParser.Operator.AND);  
        Query query = queryParser.parse(keyword);  
        booleanQuery.add(query,BooleanClause.Occur.MUST);  
          
        QueryParser parse=new QueryParser("isDelete",analyzer);  
        Query query1=parse.parse("0");  
        parse.setDefaultOperator(QueryParser.Operator.AND);  
        booleanQuery.add(query1,BooleanClause.Occur.MUST);  
  
        FullTextSession fullSession = Search.getFullTextSession(session);  
        FullTextQuery fullQuery = fullSession.createFullTextQuery(booleanQuery,  
                ShopOrders.class);  
        int size = fullQuery.getResultSize();  
        System.out.println("size:" + size);  
          
        return fullQuery.list();  
    }  
      
     public void createIndexByHibernateSearch() throws Exception{  
         this.getMySession();  
          long startTime = new Date().getTime();  
          int BATCH_SIZE = 1000;  
          FullTextSession s = Search.getFullTextSession(session);  
  
          // Transaction tr = s.beginTransaction();  
          s.setFlushMode(FlushMode.MANUAL);  
          s.setCacheMode(CacheMode.IGNORE);  
          ScrollableResults results = s.createQuery("from ShopOrders").setFetchSize(BATCH_SIZE).scroll(ScrollMode.FORWARD_ONLY);  
          int index = 0;  
          while (results.next()) {  
           index++;  
           s.index(results.get(0)); // index each element  
           if (index % BATCH_SIZE == 0) {  
            // s.flushToIndexes(); //apply changes to indexes  
            s.clear(); // clear since the queue is processed  
           }  
          }  
          s.clear();  
          long endTime = new Date().getTime();  
          logger.warn("建立Product索引 ， 这花费了" + (endTime - startTime) + " 毫秒来把文档增加到索引里面去!");  
          // tr.commit();  
  
         }  
      
  
}  
import java.util.Date;
import java.util.List;

import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.queryParser.MultiFieldQueryParser;
import org.apache.lucene.queryParser.QueryParser;
import org.apache.lucene.search.BooleanClause;
import org.apache.lucene.search.BooleanQuery;
import org.apache.lucene.search.Query;
import org.hibernate.CacheMode;
import org.hibernate.FlushMode;
import org.hibernate.ScrollMode;
import org.hibernate.ScrollableResults;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.search.FullTextQuery;
import org.hibernate.search.FullTextSession;
import org.hibernate.search.Search;
import org.springframework.orm.hibernate3.LocalSessionFactoryBean;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.china.fung.hibernate.pojo.shop.ShopOrders;

public class Dao extends HibernateDaoSupport {

	private static SessionFactory sessionFactory;
	private static Session session = null;
	private static LocalSessionFactoryBean factoryBean = null;

	public void getMySession() throws Exception {
		sessionFactory = this.getHibernateTemplate().getSessionFactory();
		session = sessionFactory.openSession();
	}

	public List search(String keyword) throws Exception {
		this.getMySession();
		BooleanQuery.setMaxClauseCount(100000);
		BooleanQuery booleanQuery = new BooleanQuery();
		StandardAnalyzer analyzer=new StandardAnalyzer();
		// 基本关键词搜索
		String[] searchFields = new String[] { "username" };//成员变量
		MultiFieldQueryParser queryParser = new MultiFieldQueryParser(
				searchFields,analyzer);
		queryParser.setDefaultOperator(QueryParser.Operator.AND);
		Query query = queryParser.parse(keyword);
		booleanQuery.add(query,BooleanClause.Occur.MUST);
		
		QueryParser parse=new QueryParser("isDelete",analyzer);
		Query query1=parse.parse("0");
		parse.setDefaultOperator(QueryParser.Operator.AND);
		booleanQuery.add(query1,BooleanClause.Occur.MUST);

		FullTextSession fullSession = Search.getFullTextSession(session);
		FullTextQuery fullQuery = fullSession.createFullTextQuery(booleanQuery,
				ShopOrders.class);
		int size = fullQuery.getResultSize();
		System.out.println("size:" + size);
		
		return fullQuery.list();
	}
	
	 public void createIndexByHibernateSearch() throws Exception{
		 this.getMySession();
		  long startTime = new Date().getTime();
		  int BATCH_SIZE = 1000;
		  FullTextSession s = Search.getFullTextSession(session);

		  // Transaction tr = s.beginTransaction();
		  s.setFlushMode(FlushMode.MANUAL);
		  s.setCacheMode(CacheMode.IGNORE);
		  ScrollableResults results = s.createQuery("from ShopOrders").setFetchSize(BATCH_SIZE).scroll(ScrollMode.FORWARD_ONLY);
		  int index = 0;
		  while (results.next()) {
		   index++;
		   s.index(results.get(0)); // index each element
		   if (index % BATCH_SIZE == 0) {
		    // s.flushToIndexes(); //apply changes to indexes
		    s.clear(); // clear since the queue is processed
		   }
		  }
		  s.clear();
		  long endTime = new Date().getTime();
		  logger.warn("建立Product索引 ， 这花费了" + (endTime - startTime) + " 毫秒来把文档增加到索引里面去!");
		  // tr.commit();

		 }
	

}



好了，到这基本就完事了，只需要在service里调用就行了，别忘了，先调用createIndexByHibernateSearch方法初始化（一次就行），再调用search方法搜索；

apache hibernate lucene

oklinsong

oklinsong

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

MAC OS 10.15 Lucene 源码分析环境搭建

lucene-solr 的github 项目中的 README 其实已经讲得很清楚了，但搭一个大项目的环境还是耗时耗力的。如果出现下载失败的问题，不用担心，重试就好。3，安装ant，我这里安装的是：Apache Ant version 1.10.8 com

Jacry 2020-07-04

.NET Core下使用Kafka的方法步骤

# 修改每个topic的默认分区参数num.partitions，默认是1，具体合适的取值需要根据服务器配置进程确定，UCloud.ukafka = 3. Segment：partition物理上由多个segment组成，下面2.2和2.3有详细说明。pa

Kafka 2020-09-18

解决PHPstudy Apache无法启动的问题【亲测有效】

原因一是防火墙拦截，关闭防火墙。二是80端口已经被别的程序占用，如IIS，迅雷等；三是没有安装VC9运行库,php和apache都是VC9编译。解决以上三个问题，基本上都是可以一次安装完成的。但是，But，但是，上面的方法都试过之后还是无法启动呢？最有效，

Wepe0 2020-10-30

Web安全：文件解析漏洞

PHP是用C语言编写的，MySQL则是用C++编写的，而Apache则大部分是使用C语言编写的，少部分是使用C++编写的。所以，文件解析漏洞的本质还是需要我们挖掘C语言、C++的漏洞。文件解析漏洞是指中间件在解析文件时出现了漏洞，从而攻击者可以利用该漏洞实

杜倩 2020-10-29

终于有人把Nginx说清楚了，图文详解！

想必大家一定听说过 Nginx，若没听说过它，那么一定听过它的"同行"Apache 吧！这也使得各个 Web 服务器有着各自鲜明的特点。Apache 的发展时期很长，而且是毫无争议的世界第一大服务器。这些都决定了 Apache 不可能成

windle 2020-10-29

为什么Java仍将是未来的主流语言？

Java是一种通用编程语言，1995年由Sun Micro-systems公司开发。尽管已经有25年的历史，但它仍然统治着整个世界。根据Stack-overflow的开发者调查，它在2019年最受欢迎的语言中排名第5。超过41%的调查用户将Java标记为

minerd 2020-10-28

如何使用Apache Web服务器来安装和配置网站？

Apache可与MySQL、PHP及另外大量软件包无缝协作，以便您架设简单的静态或动态网站。如何安装和配置服务器?您将文件放置在哪里?不妨介绍这方面，每次一个步骤。我将在Ubuntu Server 20.04上进行演示。不过先介绍一点基础知识。比如说，在基

mengzuchao 2020-10-22

CentOS 8 Apache 安装后 SSL 重定向提示证书错误

在启用 SSL 后，我们也希望将主域名重定向到 www。如果我们按照 80 端口的 http 配置的，你可能会得到浏览器的安全配置。这是因为如果你在 HTTPS 的 SSL 中也这样配置是不允许的。因为这个可能会导致安全性问题和攻击。简单来说，出现这个问题

Junzizhiai 2020-10-10

如何使用 Apache Directory Studio 连接 JumpCloud

JumpCloud 是一个基于云的 LDAP 服务。如果你的项目小组成员在 10 个或者 10 个以下的话，你可以免费使用 JumpCloud 服务器。这篇文章假设的是你已经设置好了 JumpCloud 的云服务，并且已经注册了 JumpCloud 的管理

bxqybxqy 2020-09-30

初学者和专业技术人员使用的十大机器学习软件

现在，让我们详细讨论每个机器学习软件。Tensorflow是机器学习的免费开源工具。这些应用程序在高级C ++中执行。它用于图像识别，手写分类，递归神经网络等。Tensorflow可以在CPU和GPU上平稳运行。它提供了良好的库来防止长时间编码。它是全球

风之沙城 2020-09-24

每个Java开发人员都应该知道的10大Github仓库

Java是业务应用程序开发中排名第一的编程语言，它也是顶级编程语言之一。Java具有许多功能强大且丰富的仓库，尽管标准Java库功能强大，但是在专业软件开发领域你还需要其他Java库。它在业界广泛使用，如果你正在从事一个大型项目，并且没有使用任何Apach

kingszelda 2020-09-22

漫话：应用程序被拖慢？罪魁祸首竟然是Log4j！

之前一段时间，为我们发现的一个SaaS应用程序会间歇性地卡顿、变慢，因为很长时间都没有定位到原因，所以解决的办法就只能是重启。这个现象和之前我们遇到的程序变得卡顿不太一样，因为我们发现这个应用程序不仅在高流量期间时会变慢，有时在低流量时期也会变慢。所以这令

大唐帝国前营 2020-08-18

JSP动态网页开发原理详解

　 JSP全称是Java Server Pages，它和servle技术一样，都是SUN公司定义的一种用于开发动态web资源的技术。　　JSP这门技术的最大的特点在于，写jsp就像在写html，但它相比html而言，html只能为用户提供静态数据，而Jsp

yixu0 2020-08-17

centos8使用Apache httpd2.4.37安装web服务器的步骤详解

第四步：firewall-cmd --zone=public --add-port=80/tcp --permanent　　#开启防火墙的80端口，并永久生效，返回success 设置成功的意思。第六步：firewall-cmd --zone=public

TangCuYu 2020-08-15

Tomcat启动springboot项目war包报错：启动子级时出错的问题

今天公司springboot项目准备部署到测试服务器上进行测试，打包好war后放到tomcat里面启动后，前端文件能访问到，但是接口请求一直是404，一直找了很久的原因，tomcat启动是成功的，war打包的时候也提示build success了，tomc

xiaoboliu00 2020-08-15

如何通过Apache在本地配置多个虚拟主机

如何使用 Apache 在本地配置出多个虚拟主机呢？而且使用不同的“域名”来访问本地不同的站点呢？1，根目录中有一个 phpMyAdmin/ 的文件夹，它是一个网页版的数据库管理系统（肯定不会陌生的吧！），我想通过访问一个简单的:. 来进入这个系统；这样，

songshijiazuaa 2020-08-15

Apache Shiro 反序列化(CVE-2016-4437)复现

shiro默认使用CookieRememberMeManager，对rememberMe的cookie做了加密处理，在CookieRememberMeManaer类中将cookie中rememberMe字段内容先后进行序列化、AES加密、Base64编码操

xclxcl 2020-08-03

Apache Shiro 反序列化(CVE-2016-4437)复现

shiro默认使用CookieRememberMeManager，对rememberMe的cookie做了加密处理，在CookieRememberMeManaer类中将cookie中rememberMe字段内容先后进行序列化、AES加密、Base64编码操

zmzmmf 2020-08-03

Apache DolphinScheduler 诞生记

DolphinScheduler，简称”DS”, 中文名 “小海豚调度”。希望 DolphinScheduler 就像它的名字一样，成为一个“开箱即用”的灵活易用的调度系统。DAG 全称Directed Acyclic Graph，简称DAG。工作流中的T

newfarhui 2020-08-03

【Shiro】05 自定义Realm认证实现

Shiro默认使用自带的IniRealm，IniRealm从ini配置文件中读取用户的信息，大部分情况下需要从系统的数据库中读取用户信息，所以需要自定义realm。public abstract class CachingRealm implements

likesyour 2020-08-01
oklinsong

oklinsong

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号