注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

无线时代辐射无穷

抓紧生宝宝,小心辐射

 
 
 

日志

 
 

Hibernate Search试验  

2009-09-23 18:26:13|  分类: hibernate |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |

 前几天看到Hibernate与Lucene的整合框架Hiberate Search3.0.0.GA版出来了,昨天试这写了一个Demo,感觉用起来的确很方便的,贴出来与大家分享一下。

1、创建POJO

java 代码

 

  1. @Entity  
  2. @Table(name = "employee", catalog = "hise", uniqueConstraints = {})  
  3. @Indexed(index = "indexes/employee")  
  4. public class Employee implements java.io.Serializable {  
  5.     private static final long serialVersionUID = 7794235365739814541L;  
  6.     private Integer empId;  
  7.     private String empName;  
  8.     private Department dept;  
  9.     private String empNo;  
  10.     private Double empSalary;  
  11.   
  12.     // Constructors  
  13.   
  14.     /** default constructor */  
  15.     public Employee() {  
  16.     }  
  17.   
  18.     /** minimal constructor */  
  19.     public Employee(Integer empId) {  
  20.         this.empId = empId;  
  21.     }  
  22.   
  23.     /** full constructor */  
  24.     public Employee(Integer empId, String empName,  
  25.             String empNo, Double empSalary) {  
  26.         this.empId = empId;  
  27.         this.empName = empName;  
  28.         this.empNo = empNo;  
  29.         this.empSalary = empSalary;  
  30.     }  
  31.   
  32.     // Property accessors  
  33.     @Id  
  34.     @GeneratedValue(strategy = GenerationType.AUTO)  
  35.     @Column(name = "emp_id", unique = true, nullable = false, insertable = true, updatable = true)  
  36.     @DocumentId  
  37.     public Integer getEmpId() {  
  38.         return this.empId;  
  39.     }  
  40.   
  41.     public void setEmpId(Integer empId) {  
  42.         this.empId = empId;  
  43.     }  
  44.   
  45.     @Column(name = "emp_name", unique = false, nullable = true, insertable = true, updatable = true, length = 30)  
  46.     @Field(name="name", index=Index.TOKENIZED, store=Store.YES)  
  47.     public String getEmpName() {  
  48.         return this.empName;  
  49.     }  
  50.   
  51.     public void setEmpName(String empName) {  
  52.         this.empName = empName;  
  53.     }  
  54.   
  55.     @Column(name = "emp_no", unique = false, nullable = true, insertable = true, updatable = true, length = 30)  
  56.     @Field(index=Index.UN_TOKENIZED)  
  57.     public String getEmpNo() {  
  58.         return this.empNo;  
  59.     }  
  60.   
  61.     public void setEmpNo(String empNo) {  
  62.         this.empNo = empNo;  
  63.     }  
  64.   
  65.     @Column(name = "emp_salary", unique = false, nullable = true, insertable = true, updatable = true, precision = 7)  
  66.     public Double getEmpSalary() {  
  67.         return this.empSalary;  
  68.     }  
  69.   
  70.     public void setEmpSalary(Double empSalary) {  
  71.         this.empSalary = empSalary;  
  72.     }  
  73.   
  74.     @ManyToOne(cascade = CascadeType.ALL)  
  75.     @JoinColumn(name="dept_id")  
  76.     @IndexedEmbedded(prefix="dept_")  
  77.     public Department getDept() {  
  78.         return dept;  
  79.     }  
  80.   
  81.     public void setDept(Department dept) {  
  82.         this.dept = dept;  
  83.     }  
  84. }  

java 代码

 

  1. @Entity  
  2. @Table(name = "department", catalog = "hise", uniqueConstraints = {})  
  3. @Indexed(index="indexes/department")  
  4. public class Department implements java.io.Serializable {  
  5.     private static final long serialVersionUID = 7891065193118612907L;  
  6.     private Integer deptId;  
  7.     private String deptNo;  
  8.     private String deptName;  
  9.     private List<Employee> empList;  
  10.   
  11.     // Constructors  
  12.   
  13.     @OneToMany(mappedBy="dept")  
  14.     @ContainedIn  
  15.     public List<Employee> getEmpList() {  
  16.         return empList;  
  17.     }  
  18.   
  19.     public void setEmpList(List<Employee> empList) {  
  20.         this.empList = empList;  
  21.     }  
  22.   
  23.     /** default constructor */  
  24.     public Department() {  
  25.     }  
  26.   
  27.     /** minimal constructor */  
  28.     public Department(Integer deptId) {  
  29.         this.deptId = deptId;  
  30.     }  
  31.   
  32.     /** full constructor */  
  33.     public Department(Integer deptId, String deptNo, String deptName) {  
  34.         this.deptId = deptId;  
  35.         this.deptNo = deptNo;  
  36.         this.deptName = deptName;  
  37.     }  
  38.   
  39.     // Property accessors  
  40.     @Id  
  41.     @GeneratedValue(strategy=GenerationType.AUTO)  
  42.     @Column(name = "dept_id", unique = true, nullable = false, insertable = true, updatable = true)  
  43.     @DocumentId  
  44.     public Integer getDeptId() {  
  45.         return this.deptId;  
  46.     }  
  47.   
  48.     public void setDeptId(Integer deptId) {  
  49.         this.deptId = deptId;  
  50.     }  
  51.   
  52.     @Column(name = "dept_no", unique = false, nullable = true, insertable = true, updatable = true, length = 30)  
  53.     public String getDeptNo() {  
  54.         return this.deptNo;  
  55.     }  
  56.   
  57.     public void setDeptNo(String deptNo) {  
  58.         this.deptNo = deptNo;  
  59.     }  
  60.   
  61.     @Column(name = "dept_name", unique = false, nullable = true, insertable = true, updatable = true, length = 30)  
  62.     @Field(name="name", index=Index.TOKENIZED,store=Store.YES)  
  63.     public String getDeptName() {  
  64.         return this.deptName;  
  65.     }  
  66.   
  67.     public void setDeptName(String deptName) {  
  68.         this.deptName = deptName;  
  69.     }  
  70. }  

       不了解Hibernate映射相关的Annotation的朋友可以到Hibernate的官方网站下载Hibernate Annotation Reference,有http://wiki.redsaga.com/翻译的中文文档。当然,也可以直接使用hbm.xml文件。

        Hibernate Search相关的Annotation主要有两个:

         @Indexed                标识需要进行索引的对象,

         属性        index         指定索引文件的路径

          @Field                     标注在类的get属性上,标识一个索引的Field

          属性       index         指定是否索引,与Lucene相同

                         store         指定是否索引,与Lucene相同

                         name        指定Field的name,默认为类属性的名称

                         analyzer    指定分析器

         另外@IndexedEmbedded  与  @ContainedIn 用于关联类之间的索引

          @IndexedEmbedded有两个属性,一个prefix指定关联的前缀,一个depth指定关联的深度

          如上面两个类中Department类可以通过部门名称name来索引部门,在Employee与部门关联的前缀为dept_,因此可以通过部门名称dept_name来索引一个部门里的所有员工。

2、配置文件

xml 代码

 

  1. <?xml version='1.0' encoding='UTF-8'?>  
  2. <!DOCTYPE hibernate-configuration PUBLIC  
  3.           "-//Hibernate/Hibernate Configuration DTD 3.0//EN"  
  4.           "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">  
  5.   
  6. <hibernate-configuration>  
  7.   
  8. <session-factory>  
  9.     <property name="hibernate.dialect">  
  10.         org.hibernate.dialect.MySQLDialect  
  11.     </property>  
  12.     <property name="hibernate.connection.url">  
  13.         jdbc:mysql://localhost:3306/hise  
  14.     </property>  
  15.     <property name="hibernate.connection.username">root</property>  
  16.     <property name="hibernate.connection.password">123456</property>  
  17.     <property name="hibernate.connection.driver_class">  
  18.         com.mysql.jdbc.Driver  
  19.     </property>  
  20.   
  21.     <property name="hibernate.search.default.directory_provider">  
  22.         org.hibernate.search.store.FSDirectoryProvider  
  23.     </property>  
  24.     <property name="hibernate.search.default.indexBase">e:/index</property>  
  25.       
  26.     <mapping class="com.yehui.Employee" />  
  27.     <mapping class="com.yehui.Department" />  
  28. </session-factory>  
  29.   
  30. </hibernate-configuration>  

如果使用JPA,配置文件为

xml 代码

 

  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <persistence xmlns="http://java.sun.com/xml/ns/persistence"  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  4.     xsi:schemaLocation="http://java.sun.com/xml/ns/persistence  
  5.     http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd" version="1.0">  
  6.       
  7.     <persistence-unit name="jpaPU" transaction-type="RESOURCE_LOCAL">  
  8.         <provider>org.hibernate.ejb.HibernatePersistence</provider>  
  9.         <class>com.yehui.Department</class>  
  10.         <class>com.yehui.Employee</class>  
  11.         <properties>  
  12.             <property name="hibernate.connection.driver_class"  
  13.                 value="com.mysql.jdbc.Driver" />  
  14.             <property name="hibernate.connection.url"  
  15.                 value="jdbc:mysql://localhost:3306/hise" />  
  16.             <property name="hibernate.connection.username" value="root" />  
  17.             <property name="hibernate.connection.password"  
  18.                 value="123456" />  
  19.             <property name="hibernate.search.default.directory_provider"   
  20.                 value="org.hibernate.search.store.FSDirectoryProvider"/>  
  21.             <property name="hibernate.search.default.indexBase"   
  22.                 value="e:/index"/>  
  23.         </properties>  
  24.     </persistence-unit>  
  25.   
  26. </persistence>  

       主要就是添加两个属性,hibernate.search.default.directory_provider指定Directory的代理,即把索引的文件保存在硬盘中(org.hibernate.search.store.FSDirectoryProvider)还是内存里(org.hibernate.search.store.RAMDirectoryProvider),保存在硬盘的话hibernate.search.default.indexBase属性指定索引保存的路径。

3、测试代码

java 代码

 

  1. public class SearchResultsHibernate {  
  2.     private static SessionFactory sf = null;  
  3.     private static Session session = null;  
  4.     private static Transaction tx = null;  
  5.   
  6.     @BeforeClass  
  7.     public static void setupBeforeClass() throws Exception {  
  8.         sf = new AnnotationConfiguration().configure("hibernate.cfg.xml").buildSessionFactory();  
  9.   
  10.         assertNotNull(sf);  
  11.     }  
  12.   
  13.     @Before  
  14.     public void setUp() throws Exception {  
  15.         session = sf.openSession();  
  16.         tx = session.beginTransaction();  
  17.         tx.begin();  
  18.     }  
  19.   
  20.     @After  
  21.     public void tearDown() throws Exception {  
  22.         tx.commit();  
  23.         session.close();  
  24.     }  
  25.   
  26.     public static void tearDownAfterClass() throws Exception {  
  27.         if (sf != null)  
  28.             sf.close();  
  29.     }  
  30.   
  31.     @Test  
  32.     public void testAddDept() throws Exception {  
  33.         Department dept = new Department();  
  34.         dept.setDeptName("Market");  
  35.         dept.setDeptNo("6000");  
  36.   
  37.         Employee emp = new Employee();  
  38.         emp.setDept(dept);  
  39.         emp.setEmpName("Kevin");  
  40.         emp.setEmpNo("KGP1213");  
  41.         emp.setEmpSalary(8000d);  
  42.           
  43.         session.save(emp);  
  44.     }  
  45.   
  46.     @Test  
  47.     public void testFindAll() throws Exception {  
  48.         Query query = session.createQuery("from Department");  
  49.   
  50.         List<Department> deptList = query.list();  
  51.   
  52.         assertTrue(deptList.size() > 0);  
  53.     }  
  54.       
  55.     @Test  
  56.     public void testIndex() throws Exception {  
  57.         FullTextSession fullTextSession = Search.createFullTextSession(session);  
  58.         assertNotNull(session);  
  59.   
  60.         QueryParser parser = new QueryParser("name", new StopAnalyzer());  
  61.         org.apache.lucene.search.Query luceneQuery = parser  
  62.                 .parse("name:Kevin");  
  63.         Query hibQuery = fullTextSession.createFullTextQuery(luceneQuery,  
  64.                 Employee.class);  
  65.   
  66.         List list = hibQuery.list();  
  67.         assertTrue(list.size() > 0);  
  68.     }  
  69. }  

    测试通过。OK

  评论这张
 
阅读(568)| 评论(0)
推荐 转载

历史上的今天

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017