lucene---分页

绝地灬酷狼 2022-08-23 00:48 113阅读 0赞

创建测试数据的索引

Java代码 收藏代码

  1. String path = “index”;//索引目录
  2. Analyzer analyzer = new IKAnalyzer();//采用的分词器
  3. IndexWriter iwriter = new IndexWriter(path, analyzer, true);
  4. File dir = new File(“data”);//
  5. File[] files = dir.listFiles();
  6. for(int i=0;i<files.length;i++){
  7. Document doc = new Document();
  8. File file = files[i];
  9. System.out.println(file.getName());
  10. System.out.println(file.getPath());
  11. FileInputStream fis = new FileInputStream(file);
  12. String content = “”;
  13. BufferedReader reader = new BufferedReader(new InputStreamReader(fis));
  15. StringBuffer buffer = new StringBuffer(“”);
  16. content = reader.readLine();
  17. while (content != null) {
  18. buffer.append(content);
  19. content = reader.readLine();
  20. }
  21. System.out.println(“content : “+buffer.toString());
  22. doc.add(new Field(“title”,file.getName(),Field.Store.YES,Field.Index.ANALYZED));
  23. doc.add(new Field(“content”,buffer.toString(),Field.Store.YES,Field.Index.ANALYZED));
  24. iwriter.addDocument(doc);
  25. }
  26. iwriter.close();

我们创建分页类，没什么说的一个bean

Java代码 收藏代码

  1. import java.util.ArrayList;
  3. import org.apache.lucene.document.Document;
  5. public class Page{
  6. private static int DEFAULT_PAGE_SIZE = 5;
  8. private int pageSize = DEFAULT_PAGE_SIZE; // 每页的记录数
  10. private long start; // 当前页第一条数据在数据集合中的位置,从0开始
  12. private Object data; // 当前页中存放的记录,类型一般为List
  14. private long totalCount; // 总记录数
  16. public Page() {
  17. this(0, 0, 5,new ArrayList());
  18. }
  20. public Page(long start, long totalCount, int pageSize, Object data) {
  21. this.start = start;
  22. this.totalCount = totalCount;
  23. this.pageSize = pageSize;
  24. this.data = data;
  25. }
  27. /**
  28. * 取得总记录数
  29. * @return
  30. */
  31. public long getTotalCount() {
  32. return this.totalCount;
  33. }
  34. /**
  35. * 取当前页中的数据
  36. * @return
  37. */
  38. public Object getResult() {
  39. return this.data;
  40. }
  42. /**
  43. * 取每页的数据容量
  44. * @return
  45. */
  46. public int getPageSize() {
  47. return this.pageSize;
  48. }
  49. /**
  50. * 取总页数
  51. * @return
  52. */
  53. public long getTotalPageCount() {
  54. return totalCount % pageSize == 0 ? totalCount / pageSize : totalCount
  55. / pageSize + 1;
  56. }
  58. /**
  59. * 取当前的页号
  60. * @return
  61. */
  62. public long getCurrentPageNo(){
  63. return start/pageSize+1;
  64. }
  66. /**
  67. * 该页是否有下一页.
  68. */
  69. public boolean hasNextPage() {
  70. return this.getCurrentPageNo() < this.getTotalPageCount();
  71. }
  73. /**
  74. * 该页是否有上一页.
  75. */
  76. public boolean hasPreviousPage() {
  77. return this.getCurrentPageNo() > 1;
  78. }
  80. /**
  81. * 获取任一页第一条数据在数据集的位置，每页条数使用默认值.
  82. *
  83. * @see #getStartOfPage(int,int)
  84. */
  85. protected static int getStartOfPage(int pageNo) {
  86. return getStartOfPage(pageNo, DEFAULT_PAGE_SIZE);
  87. }
  89. /**
  90. * 获取任一页第一条数据在数据集的位置.
  91. *
  92. * @param pageNo 从1开始的页号
  93. * @param pageSize 每页记录条数
  94. * @return 该页第一条数据
  95. */
  96. public static int getStartOfPage(int pageNo, int pageSize) {
  97. return (pageNo - 1) * pageSize;
  98. }
  99. }

下面我们做一个分页方法并进行测试

Java代码 收藏代码

  1. public class PageSearcher {
  3. @SuppressWarnings(“unchecked”)
  4. public static void main(String[] args) throws IOException {
  5. String path = “index”;//索引目录
  6. Directory dir = FSDirectory.open(new File(path));
  7. IndexSearcher searcher = new IndexSearcher(dir,true);
  8. Term term = new Term(“content”,”网友”);
  9. Query query = new TermQuery(term);
  10. Page page = getPageQuery(3, 3, query, searcher);
  11. System.out.println(“当前页号 “+page.getCurrentPageNo());
  12. System.out.println(“存在上一页? “ + page.hasPreviousPage());
  13. System.out.println(“存在下一页? “ + page.hasNextPage());
  14. System.out.println(“每页的记录数 “ + page.getPageSize());
  15. System.out.println(“总页数 “ + page.getTotalPageCount());
  16. System.out.println(“总记录数 “ + page.getTotalCount());
  17. //显示页面内容
  19. ArrayList docs = (ArrayList) page.getResult();
  20. for(Document doc:docs){
  21. System.out.println(doc.get(“content”));
  22. }
  25. }
  26. /**
  27. * 获取当前页
  28. * @param pageNo 页号 从1开始
  29. * @param pageSize 每页显示的最多记录条数
  30. * @param query Query
  31. * @param searcher Searcher
  32. * @return
  33. */
  34. public static Page getPageQuery(int pageNo,int pageSize,Query query,Searcher searcher){
  35. TopScoreDocCollector topCollector=null;
  36. List result = new ArrayList();
  37. try {
  38. //得到查询结果的总记录数
  39. topCollector = TopScoreDocCollector.create(searcher.maxDoc(), false);
  40. searcher.search(query, topCollector);
  41. //查询当页的记录
  42. ScoreDoc [] docs = topCollector.topDocs((pageNo-1)*pageSize,pageSize).scoreDocs;
  43. for(ScoreDoc scdoc : docs){
  44. try {
  45. result.add(searcher.doc(scdoc.doc));
  46. } catch (CorruptIndexException e) {
  47. e.printStackTrace();
  48. } catch (IOException e) {
  49. e.printStackTrace();
  50. }
  51. }
  52. return new Page(Page.getStartOfPage(pageNo,pageSize),topCollector.getTotalHits(),pageSize,result);
  53. } catch (IOException e1) {
  54. e1.printStackTrace();
  55. }
  57. return new Page();
  58. }
  59. }

发表评论

表情：
评论列表 （有 0 条评论，113人围观）

还没有评论，来说两句吧...

相关阅读