2022年Lucene操作数据库 .pdf

《2022年Lucene操作数据库 .pdf》由会员分享，可在线阅读，更多相关《2022年Lucene操作数据库 .pdf（10页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、1.写一段传统的JDBC 程序，讲每条的用户信息从数据库读取出来2.针对每条用户记录，建立一个lucene document Document doc = new Document(); 并根据你的需要，将用户信息的各个字段对应luncene document中的 field 进行添加，如：doc.add(new Field(NAME,USERNAME,Field.Store.YES,Field.Index.UN_TOKENIZED); 然后将该条doc 加入到索引中，如： luceneWriter.addDocument(doc); 这样就建立了lucene 的索引库3.编写对索引库的搜索程

2、序（看lucene 文档），通过对lucene 的索引库的查找，你可以快速找到对应记录的ID 4.通过 ID 到数据库中查找相关记录Lucene ，作为一种全文搜索的辅助工具，为我们进行条件搜索， 无论是像 Google,Baidu之类的搜索引擎，还是论坛中的搜索功能，还是其它C/S 架构的搜索，都带来了极大的便利和比较高的效率。 本文主要是利用Lucene 对 MS Sql Server 2000进行建立索引，然后进行全文索引。至于数据库的内容，可以是网页的内容，还是其它的。本文中数据库的内容是图书馆管理系统中的某个作者表Authors 表。因为考虑到篇幅的问题，所以该文不会讲的很详细，也不

3、可能讲的很深。本文以这样的结构进行：1.介绍数据库中Authors 表的结构2.为数据库建立索引3.为数据库建立查询功能4.在 web 界面下进行查询并显示结果1介绍数据库中Authors 表的结构字段名称字段类型字段含义Au_id Varchar(11) 作者号Au_name Varchar(60) 作者名Phone Char(12) 电话号码Address Varchar(40) 地址名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 1 页，共 10 页 - - - - - - -

4、 - - City Varchar(20) 城市State Char(2) 省份Zip Char(5) 邮编contract Bit(1) 外键（关系不大）表中的部分内容：2为数据库建立索引首先建立一个类TestLucene.java 。这个类就是对数据库进行建立索引，编写查询条件等。当然，最开始就是建立数据库连接。连接代码这里就省略了。_ 接着，新建一个方法getResutl(String),它返回的是数据库表Authors 的内容。具体代码如下：public ResultSet getResult(String sql) try Statement stmt = conn.createSt

5、atement(); ResultSet rs = stmt.executeQuery(sql); return rs; catch(SQLException e) System.out.println(e); return null; 然后，为数据库建立索引。首先要定义一个IndexWriter （），它是将索引写进Lucene 自己的数据库中，它存放的位置是有你自己定义的。在定义IndexWriter 是需要指定它的分析器。Lucene 自己自带有几个分析器，例如：StandarAnalyzer(),SimpleAnalyzer(), StopAnalyzer()等。它作用是对文本进行分析

6、，判断如何进行切词。接着，要定义一个Document 。Document相当于二维表中一行数据一样。Document里包含的是Field 字段， Field 相当于数据库中一列，也就是一个属性，一个字段。名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 2 页，共 10 页 - - - - - - - - - 最后应该对IndexWriter进行优化，方法很简单，就是writer.optimize(). 具体代码如下：public void Index(ResultSet rs) tr

7、y IndexWriter writer = new IndexWriter(d:/index/, getAnalyzer(), true); while(rs.next() Document doc=new Document(); doc.add(Field.Keyword(id,rs.getString(au_id); doc.add(Field.Text(name,rs.getString(au_name); doc.add(Field.UnIndexed(address,rs.getString(address); doc.add(Field.UnIndexed(phone,rs.ge

8、tString(phone); doc.add(Field.Text(City,rs.getString(city); writer.addDocument(doc); writer.optimize(); writer.close(); catch(IOException e) System.out.println(e); catch(SQLException e) System.out.println(e); public Analyzer getAnalyzer() return new StandardAnalyzer(); 3为数据库建立查询功能在类 TestLucene中建立一个新

9、的方法searcher(String) ， 它返回的是一个搜索的结构集，相当于数据库中的ResultSet 一样。它代的参数是你要查询的内容。这里，我把要查询的字段写死了。你可以在添加一个参数表示要查询的字段。这里主要有两个对象IndexSearcher和 Query 。IndexSearcher是找到索引数据库，名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 3 页，共 10 页 - - - - - - - - - Query 是处理搜索，它包含了三个参数：查询内容，查询字段，分析

10、器。具体代码如下：public Hits seacher(String queryString) Hits hits=null; try IndexSearcher is = new IndexSearcher(D:/index/); Query query=QueryParser.parse(queryString,City,getAnalyzer(); hits=is.search(query); catch(Exception e) System.out.print(e); return hits; 4在 web 界面下进行查询并显示结果这里建立一个Jsp 页面 TestLucene.j

11、sp进行搜索。在 TestLucene.jsp页面中首先引入类 然后定义一个LuceneTest对象，获取查询结果集：LucentTest lucent=new LucentTest(); Hits hits=lucent.seacher(request.getParameter(queryString); 定义一个 Form ，建立一个查询环境： 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 4 页，共 10 页 - - - - - - - - - 显示查询结果： 作者号 作者名

12、 地址 电话号码 % for(int i=0;i 用 Lucene-1.3-final为网站数据库建立索引下是看了 lnboy 写的用 lucene 建立大富翁论坛的全文检索后写的测试代码。为数据库 cwb.mdb 建立全文索引的indexdb.jsp 用于显示查询结果的aftsearch.jsp 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 6 页，共 10 页 - - - - - - - - - % String keyword=request.getParameter(key

13、word); keyword=new String(keyword.getBytes(ISO8859_1); out.println(keyword); try String aa=getServletContext().getRealPath(/)+index; Searcher searcher = new IndexSearcher(aa); Query query = QueryParser.parse(keyword, Article_name, new StandardAnalyzer(); out.println( 正在查找 : + query.toString(Article_

14、name)+); Hits hits = searcher.search(query); System.out.println(hits.length() + total matching documents); java.text.NumberFormat format = java.text.NumberFormat.getNumberInstance(); for (int i = 0; i hits.length(); i+) / 开始输出查询结果 Document doc = hits.doc(i); out.println(doc.get(Article_id); out.prin

15、tln( 准确度为： + format.format(hits.score(i) * 100.0) + %); out.println(doc.get(Article_name)+); / out.println(doc.get(Article_intro); catch (Exception e) out.println( 出错了 + e.getClass() +n 错误信息为 : + e.getMessage(); % 辅助类：package lucene; import org.apache.lucene.document.Document; import org.apache.luce

16、ne.document.Field; import org.apache.lucene.document.DateField; 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 7 页，共 10 页 - - - - - - - - - public class mydocument public static Document Document(String Article_id,String Article_name,String Article_intro) Document do

17、c = new Document(); doc.add(Field.Keyword(Article_id, Article_id); doc.add(Field.Text(Article_name, Article_name); doc.add(Field.Text(Article_intro, Article_intro); return doc; public mydocument() 用 lucene 为数据库搜索建立增量索引用 lucene 建立索引不可能每次都重新开始建立,而是按照新增加的记录,一次次的递增建立索引的IndexWriter类,有三个参数IndexWriter writ

18、er = new IndexWriter(path, new StandardAnalyzer(),isEmpty); 其中第三个参数是bool 型的 ,指定它可以确定是增量索引,还是重建索引. 对于从数据库中读取的记录,譬如要为文章建立索引,我们可以记录文章的id 号,然后下次再次建立索引的时候读取存下的id 号,从此 id 后往下继续增加索引,逻辑如下 . 建立增量索引,主要代码如下public void createIndex(String path) Statement myStatement = null ; String articleId=0; /读取文件 ,获得文章id 号码

19、,这里只存最后一篇索引的文章id try FileReader fr = new FileReader(*.txt); BufferedReader br = new BufferedReader(fr); articleId=br.readLine(); if(articleId= null |articleId=) articleId=0; 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 8 页，共 10 页 - - - - - - - - - br.close(); fr.cl

20、ose(); catch (IOException e) System.out.println(error343!); e.printStackTrace(); try /sql 语句 ,根据 id 读取下面的内容 String sqlText = *+articleId; myStatement = conn.createStatement(); ResultSet rs = myStatement.executeQuery(sqlText); /写索引while (rs.next() Document doc = new Document(); doc.add(Field.Keyword(

21、*, DateAdded); doc.add(Field.Keyword(*, articleid); doc.add(Field.Text(*, URL); doc.add(Field.Text(*, Content); doc.add(Field.Text(*, Title); try writer.addDocument(doc); catch (IOException e) e.printStackTrace(); /将我索引的最后一篇文章的id 写入文件try FileWriter fw = new FileWriter(*.txt); PrintWriter out = new P

22、rintWriter(fw); out.close(); fw.close(); catch (IOException e) e.printStackTrace(); ind.Close(); 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 9 页，共 10 页 - - - - - - - - - System.out.println(ok.end); catch (SQLException e) e.printStackTrace(); finally /数据库关闭操作 然后控制是

23、都建立增量索引的时候根据能否都到id 值来设置 IndexWriter 的第三个参数为 true 或者是 false boolean isEmpty = true; try FileReader fr = new FileReader(*.txt); BufferedReader br = new BufferedReader(fr); if(br.readLine()!= null) isEmpty = false; br.close(); fr.close(); catch (IOException e) e.printStackTrace(); writer = new IndexWriter(Directory, new StandardAnalyzer(),isEmpty); 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 10 页，共 10 页 - - - - - - - - -