lucene---分页

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

创建测试数据的索引

Java代码    ![收藏代码][icon_star.png]

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));  
14.   
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代码    ![收藏代码][icon_star.png]

1.  **import** java.util.ArrayList;  
2.    
3.  **import** org.apache.lucene.document.Document;  
4.    
5.  **public** **class** Page\{  
6.      **private** **static** **int** DEFAULT\_PAGE\_SIZE = 5;  
7.    
8.      **private** **int** pageSize = DEFAULT\_PAGE\_SIZE; // 每页的记录数  
9.    
10.     **private** **long** start; // 当前页第一条数据在数据集合中的位置,从0开始  
11.   
12.     **private** Object data; // 当前页中存放的记录,类型一般为List  
13.   
14.     **private** **long** totalCount; // 总记录数  
15.   
16.     **public** Page() \{  
17.         **this**(0, 0, 5,**new** ArrayList<Document>());  
18.     \}  
19.   
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.     \}  
26.       
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.     \}  
41.       
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.     \}  
57.       
58.     /\*\* 
59.      \* 取当前的页号 
60.      \* @return 
61.      \*/  
62.     **public** **long** getCurrentPageNo()\{  
63.         **return** start/pageSize+1;  
64.     \}  
65.       
66.     /\*\* 
67.      \* 该页是否有下一页. 
68.      \*/  
69.     **public** **boolean** hasNextPage() \{  
70.         **return** **this**.getCurrentPageNo() < **this**.getTotalPageCount();  
71.     \}  
72.   
73.     /\*\* 
74.      \* 该页是否有上一页. 
75.      \*/  
76.     **public** **boolean** hasPreviousPage() \{  
77.         **return** **this**.getCurrentPageNo() > 1;  
78.     \}  
79.   
80.     /\*\* 
81.      \* 获取任一页第一条数据在数据集的位置，每页条数使用默认值. 
82.      \* 
83.      \* @see \#getStartOfPage(int,int) 
84.      \*/  
85.     **protected** **static** **int** getStartOfPage(**int** pageNo) \{  
86.         **return** getStartOfPage(pageNo, DEFAULT\_PAGE\_SIZE);  
87.     \}  
88.   
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代码    ![收藏代码][icon_star.png]

1.  **public** **class** PageSearcher \{  
2.    
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.         //显示页面内容  
18.           
19.         ArrayList<Document> docs = (ArrayList<Document>) page.getResult();  
20.         **for**(Document doc:docs)\{  
21.             System.out.println(doc.get("content"));  
22.         \}  
23.           
24.           
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<Document> result = **new** ArrayList<Document>();  
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.         \}  
56.           
57.         **return** **new** Page();  
58.     \}  
59. \}  
60.

[icon_star.png]: /images/20220722/4abf58465b254bc88005fae03f638e0f.png