注册 登录
> 编程技术

Compass入门指南(二)

系统 2378 0

Compass框架的参考文档,Compass是在Lucene的基础上做了封装，支持索引事务控制和增量索引，同时也能够和主流的SSH框架完美地整合在一起,操作Compass类似于操作Hibernate，它们的类/方法等设计的非常相似。下面我们通过一个实例来看看Compass到底是怎样来索引数据库，操作索引库和实现搜索功能的。
步骤一：下载Compass，目前最新版本是2.2.0，可以到 http://www.compass-project.org/ 上下载。
步骤二：在Eclipse中新建一个Java Project，解压compass-2.2.0-with-dependencies.zip，将dist目录下的compass-2.2.0.jar，commons-logging.jar和dist/lucene目录下的lucene-analyzers.jar，lucene-core.jar，lucene-highlighter.jar拷贝在工程的构建路径下.
步骤三：新建一个Book（书籍）类，这个类就是我们要搜索的对象，其完整代码如下：

Java代码
  2. import org.compass.annotations.Index;
  3. import org.compass.annotations.Searchable;
  4. import org.compass.annotations.SearchableId;
  5. import org.compass.annotations.SearchableProperty;
  6. import org.compass.annotations.Store;
  8. @Searchable
  9. public class Book{
  10. private Stringid; //编号
  11. private Stringtitle; //标题
  12. private Stringauthor; //作者
  13. private float price; //价格
  15. public Book(){
  16. }
  18. public Book(Stringid,Stringtitle,Stringauthor, float price){
  19. super ();
  20. this .id=id;
  21. this .title=title;
  22. this .author=author;
  23. this .price=price;
  24. }
  26. @SearchableId
  27. public StringgetId(){
  28. return id;
  29. }
  31. @SearchableProperty (boost= 2 .0F,index=Index.TOKENIZED,store=Store.YES)
  32. public StringgetTitle(){
  33. return title;
  34. }
  36. @SearchableProperty (index=Index.TOKENIZED,store=Store.YES)
  37. public StringgetAuthor(){
  38. return author;
  39. }
  41. @SearchableProperty (index=Index.NO,store=Store.YES)
  42. public float getPrice(){
  43. return price;
  44. }
  46. public void setId(Stringid){
  47. this .id=id;
  48. }
  50. public void setTitle(Stringtitle){
  51. this .title=title;
  52. }
  54. public void setAuthor(Stringauthor){
  55. this .author=author;
  56. }
  58. public void setPrice( float price){
  59. this .price=price;
  60. }
  62. @Override
  63. public StringtoString(){
  64. return "[" +id+ "]" +title+ "-" +author+ "$" +price;
  65. }
  67. }


这里有几个要注意的地方：@Searchable表示该类的对象是可被搜索的；@SearchableId表示索引建立的id；@SearchableProperty表示此字段可以被索引、被检索；对于Index，Store在这里就不作介绍了，不熟悉的朋友可以去看看Lucene API。
步骤四：新建一个Searcher类，该类封装了对索引库的一些操作，包括新建索引，删除索引，重建索引，搜索等等。完整代码如下：

Java代码
  1. import java.util.ArrayList;
  2. import java.util.Collections;
  3. import java.util.List;
  5. import org.compass.annotations.config.CompassAnnotationsConfiguration;
  6. import org.compass.core.Compass;
  7. import org.compass.core.CompassHits;
  8. import org.compass.core.CompassSession;
  9. import org.compass.core.CompassTransaction;
  11. public class Searcher
  12. {
  13. protected Compasscompass;
  15. public Searcher()
  16. {
  17. }
  19. /**
  20. *初始化Compass
  21. *@parampath
  22. */
  23. public Searcher(Stringpath)
  24. {
  25. compass= new CompassAnnotationsConfiguration().setConnection(path).addClass(Book. class ).setSetting( "compass.engine.highlighter.default.formatter.simple.pre" , "<fontcolor='red'>" ).setSetting(
  26. "compass.engine.highlighter.default.formatter.simple.post" , "</font>" ).buildCompass();
  27. Runtime.getRuntime().addShutdownHook( new Thread()
  28. {
  29. public void run()
  30. {
  31. compass.close();
  32. }
  33. });
  35. }
  37. /**
  38. *新建索引
  39. *@parambook
  40. */
  41. public void index(Bookbook)
  42. {
  43. CompassSessionsession= null ;
  44. CompassTransactiontx= null ;
  45. try
  46. {
  47. session=compass.openSession();
  48. tx=session.beginTransaction();
  49. session.create(book);
  50. tx.commit();
  51. } catch (RuntimeExceptione)
  52. {
  53. if (tx!= null )
  54. tx.rollback();
  55. throw e;
  56. } finally
  57. {
  58. if (session!= null )
  59. {
  60. session.close();
  61. }
  62. }
  63. }
  65. /**
  66. *删除索引
  67. *@parambook
  68. */
  69. public void unIndex(Bookbook)
  70. {
  71. CompassSessionsession= null ;
  72. CompassTransactiontx= null ;
  73. try
  74. {
  75. session=compass.openSession();
  76. tx=session.beginTransaction();
  77. session.delete(book);
  78. tx.commit();
  79. } catch (RuntimeExceptione)
  80. {
  81. tx.rollback();
  82. throw e;
  83. } finally
  84. {
  85. if (session!= null )
  86. {
  87. session.close();
  88. }
  89. }
  90. }
  92. /**
  93. *重建索引
  94. *@parambook
  95. */
  96. public void reIndex(Bookbook)
  97. {
  98. unIndex(book);
  99. index(book);
  100. }
  102. /**
  103. *搜索
  104. *@paramqueryString
  105. *@return
  106. */
  107. public List<Book>search(StringqueryString)
  108. {
  109. CompassSessionsession= null ;
  110. CompassTransactiontx= null ;
  111. try
  112. {
  113. session=compass.openSession();
  114. tx=session.beginTransaction();
  115. CompassHitshits=session.find(queryString);
  116. int n=hits.length();
  117. if ( 0 ==n)
  118. {
  119. return Collections.emptyList();
  120. }
  121. List<Book>books= new ArrayList<Book>();
  122. for ( int i= 0 ;i<n;i++)
  123. {
  124. books.add((Book)hits.data(i));
  125. }
  126. hits.close();
  127. tx.commit();
  128. return books;
  129. } catch (RuntimeExceptione)
  130. {
  131. tx.rollback();
  132. throw e;
  133. } finally
  134. {
  135. if (session!= null )
  136. {
  137. session.close();
  138. }
  139. }
  140. }
  141. }


步骤五：新建一个测试类进行测试.完整源码如下：

Java代码
  1. import java.io.BufferedReader;
  2. import java.io.InputStreamReader;
  3. import java.util.ArrayList;
  4. import java.util.List;
  5. import java.util.UUID;
  7. public class Main
  8. {
  9. static List<Book>db= new ArrayList<Book>();
  10. static Searchersearcher= new Searcher( "E:/index" );
  12. public static void main(String[]args)
  13. {
  14. add( new Book(UUID.randomUUID().toString(), "ThinkinginJava" , "Bruce" , 109 .0f));
  15. add( new Book(UUID.randomUUID().toString(), "EffectiveJava" , "Joshua" , 12 .4f));
  16. add( new Book(UUID.randomUUID().toString(), "JavaThreadPrograming" , "Paul" , 25 .8f));
  17. int n;
  18. do
  19. {
  20. n=displaySelection();
  21. switch (n)
  22. {
  23. case 1 :
  24. listBooks();
  25. break ;
  26. case 2 :
  27. addBook();
  28. break ;
  29. case 3 :
  30. deleteBook();
  31. break ;
  32. case 4 :
  33. searchBook();
  34. break ;
  35. case 5 :
  36. return ;
  37. }
  38. } while (n!= 0 );
  39. }
  41. static int displaySelection()
  42. {
  43. System.out.println( "\n==select==" );
  44. System.out.println( "1.Listallbooks" );
  45. System.out.println( "2.Addbook" );
  46. System.out.println( "3.Deletebook" );
  47. System.out.println( "4.Searchbook" );
  48. System.out.println( "5.Exit" );
  49. int n=readKey();
  50. if (n>= 1 &&n<= 5 )
  51. return n;
  52. return 0 ;
  53. }
  55. /**
  56. *增加一本书到数据库和索引中
  57. *@parambook
  58. */
  59. private static void add(Bookbook)
  60. {
  61. db.add(book);
  62. searcher.index(book);
  63. }
  65. /**
  66. *打印出数据库中的所有书籍列表
  67. */
  68. public static void listBooks()
  69. {
  70. System.out.println( "==Database==" );
  71. int n= 1 ;
  72. for (Bookbook:db)
  73. {
  74. System.out.println(n+ ")" +book);
  75. n++;
  76. }
  77. }
  79. /**
  80. *根据用户录入，增加一本书到数据库和索引中
  81. */
  82. public static void addBook()
  83. {
  84. Stringtitle=readLine( "Title:" );
  85. Stringauthor=readLine( "Author:" );
  86. Stringprice=readLine( "Price:" );
  87. Bookbook= new Book(UUID.randomUUID().toString(),title,author,Float.valueOf(price));
  88. add(book);
  89. }
  91. /**
  92. *删除一本书，同时删除数据库，索引库中的
  93. */
  94. public static void deleteBook()
  95. {
  96. listBooks();
  97. System.out.println( "Bookindex:" );
  98. int n=readKey();
  99. Bookbook=db.remove(n- 1 );
  100. searcher.unIndex(book);
  101. }
  103. /**
  104. *根据输入的关键字搜索书籍
  105. */
  106. public static void searchBook()
  107. {
  108. StringqueryString=readLine( "Enterkeyword:" );
  109. List<Book>books=searcher.search(queryString);
  110. System.out.println( "====searchresults:" +books.size()+ "====" );
  111. for (Bookbook:books)
  112. {
  113. System.out.println(book);
  114. }
  115. }
  117. public static int readKey()
  118. {
  119. BufferedReaderreader= new BufferedReader( new InputStreamReader(System.in));
  120. try
  121. {
  122. int n=reader.read();
  123. n=Integer.parseInt(Character.toString(( char )n));
  124. return n;
  125. } catch (Exceptione)
  126. {
  127. throw new RuntimeException();
  128. }
  129. }
  131. public static StringreadLine(Stringpropt)
  132. {
  133. System.out.println(propt);
  134. BufferedReaderreader= new BufferedReader( new InputStreamReader(System.in));
  135. try {
  136. return reader.readLine();
  137. } catch (Exceptione)
  138. {
  139. throw new RuntimeException();
  140. }
  141. }
  142. }

Compass入门指南(二)


更多文章、技术交流、商务合作、联系博主

微信扫码或搜索：z360901061

微信扫一扫加我为好友

QQ号联系： 360901061

您的支持是博主写作最大的动力，如果您喜欢我的文章，感觉我的文章对您有帮助，请用微信扫描下面二维码支持博主2元、5元、10元、20元等您想捐的金额吧，狠狠点击下面给点支持吧，站长非常感激您！手机微信长按不能支付解决办法：请将微信支付二维码保存到相册，切换到微信，然后点击微信右上角扫一扫功能，选择支付二维码完成支付。

【本文对您有帮助就好】元

您的支持是博主写作最大的动力，如果您喜欢我的文章，感觉我的文章对您有帮助，请用微信扫描上面二维码支持博主2元、5元、10元、自定义金额等您想捐的金额吧，站长会非常 感谢您的哦！！！

发表我的评论
最新评论 总共0条评论