用Lucene检索数据库.doc

上传人:土8路 文档编号:10222701 上传时间:2021-04-30 格式:DOC 页数:10 大小:33KB
返回 下载 相关 举报
用Lucene检索数据库.doc_第1页
第1页 / 共10页
用Lucene检索数据库.doc_第2页
第2页 / 共10页
用Lucene检索数据库.doc_第3页
第3页 / 共10页
用Lucene检索数据库.doc_第4页
第4页 / 共10页
用Lucene检索数据库.doc_第5页
第5页 / 共10页
点击查看更多>>
资源描述

《用Lucene检索数据库.doc》由会员分享,可在线阅读,更多相关《用Lucene检索数据库.doc(10页珍藏版)》请在三一文库上搜索。

1、用Lucene检索数据库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的索引库的查找,你可以快速找到对应记录的ID4.通过ID到数据库中查找相关记录 用Lucene索引数据库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) 地址City Varchar(20) 城市State Char(2) 省份Zip Char(5) 邮编contract Bit(1) 外键(关系不大)表中的部分内容:2为数据库建立索引首先建立一个

4、类TestLucene.java。这个类就是对数据库进行建立索引,编写查询条件等。当然,最开始就是建立数据库连接。连接代码这里就省略了。_接着,新建一个方法getResutl(String),它返回的是数据库表Authors的内容。具体代码如下: public ResultSet getResult(String sql) try Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(sql); return rs; catch(SQLException e) System.out.println(e

5、); return null; 然后,为数据库建立索引。首先要定义一个IndexWriter(),它是将索引写进Lucene自己的数据库中,它存放的位置是有你自己定义的。在定义 IndexWriter 是需要指定它的分析器。Lucene自己自带有几个分析器,例如:StandarAnalyzer(),SimpleAnalyzer(), StopAnalyzer()等。它作用是对文本进行分析,判断如何进行切词。接着,要定义一个Document。Document相当于二维表中一行数据一样。Document里包含的是Field字段,Field相当于数据库中一列,也就是一个属性,一个字段。最后应该对In

6、dexWriter进行优化,方法很简单,就是writer.optimize().具体代码如下: public void Index(ResultSet rs) try 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(

7、Field.UnIndexed(address,rs.getString(address); doc.add(Field.UnIndexed(phone,rs.getString(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 An

8、alyzer getAnalyzer() return new StandardAnalyzer(); 3为数据库建立查询功能在类TestLucene中建立一个新的方法searcher(String),它返回的是一个搜索的结构集,相当于数据库中的ResultSet一样。它代的参数是你要查询的内容。这里,我把要查询的字段写死了。你可以在添加一个参数表示要查询的字段。这里主要有两个对象IndexSearcher和Query。IndexSearcher是找到索引数据库,Query是处理搜索,它包含了三个参数:查询内容,查询字段,分析器。具体代码如下: public Hits seacher(Stri

9、ng 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.jsp进行搜索。在TestLucene.jsp页面中首先引入类 然后定义一个

10、LuceneTest对象,获取查询结果集: LucentTest lucent=new LucentTest(); Hits hits=lucent.seacher(request.getParameter(queryString);定义一个Form,建立一个查询环境: 显示查询结果: 作者号 作者名 地址 电话号码 % for(int i=0;i 用Lucene-1.3-final为网站数据库建立索引下是看了lnboy写的用lucene建立大富翁论坛的全文检索后写的测试代码。 为数据库cwb.mdb建立全文索引的indexdb.jsp 用于显示查询结果的aftsearch.jsp % Str

11、ingkeyword=request.getParameter(keyword); keyword=newString(keyword.getBytes(ISO8859_1); out.println(keyword); try Stringaa=getServletContext().getRealPath(/)+index; Searchersearcher=newIndexSearcher(aa); Queryquery=QueryParser.parse(keyword,Article_name,newStandardAnalyzer(); out.println(正在查找:+quer

12、y.toString(Article_name)+); Hitshits=searcher.search(query); System.out.println(hits.length()+totalmatchingdocuments); java.text.NumberFormatformat=java.text.NumberFormat.getNumberInstance(); for(inti=0;ihits.length();i+) /开始输出查询结果 Documentdoc=hits.doc(i); out.println(doc.get(Article_id); out.printl

13、n(准确度为:+format.format(hits.score(i)*100.0)+%); out.println(doc.get(Article_name)+); /out.println(doc.get(Article_intro); catch(Exceptione) out.println(出错了+e.getClass()+n错误信息为:+e.getMessage(); % 辅助类: packagelucene; importorg.apache.lucene.document.Document; importorg.apache.lucene.document.Field; imp

14、ortorg.apache.lucene.document.DateField; publicclassmydocument publicstaticDocumentDocument(StringArticle_id,StringArticle_name,StringArticle_intro) Documentdoc=newDocument(); doc.add(Field.Keyword(Article_id,Article_id); doc.add(Field.Text(Article_name,Article_name); doc.add(Field.Text(Article_intr

15、o,Article_intro); returndoc; publicmydocument() 用lucene为数据库搜索建立增量索引用lucene建立索引不可能每次都重新开始建立,而是按照新增加的记录,一次次的递增建立索引的IndexWriter类,有三个参数IndexWriterwriter=newIndexWriter(path,newStandardAnalyzer(),isEmpty);其中第三个参数是bool型的,指定它可以确定是增量索引,还是重建索引.对于从数据库中读取的记录,譬如要为文章建立索引,我们可以记录文章的id号,然后下次再次建立索引的时候读取存下的id号,从此id后往

16、下继续增加索引,逻辑如下.建立增量索引,主要代码如下publicvoidcreateIndex(Stringpath)StatementmyStatement=null;StringarticleId=0;/读取文件,获得文章id号码,这里只存最后一篇索引的文章idtryFileReaderfr=newFileReader(*.txt);BufferedReaderbr=newBufferedReader(fr);articleId=br.readLine();if(articleId=null|articleId=)articleId=0;br.close();fr.close();catc

17、h(IOExceptione)System.out.println(error343!);e.printStackTrace();try/sql语句,根据id读取下面的内容StringsqlText=*+articleId;myStatement=conn.createStatement();ResultSetrs=myStatement.executeQuery(sqlText);/写索引while(rs.next()Documentdoc=newDocument();doc.add(Field.Keyword(*,DateAdded);doc.add(Field.Keyword(*,art

18、icleid);doc.add(Field.Text(*,URL);doc.add(Field.Text(*,Content);doc.add(Field.Text(*,Title);trywriter.addDocument(doc);catch(IOExceptione)e.printStackTrace();/将我索引的最后一篇文章的id写入文件tryFileWriterfw=newFileWriter(*.txt);PrintWriterout=newPrintWriter(fw);out.close();fw.close();catch(IOExceptione)e.printSta

19、ckTrace();ind.Close();System.out.println(ok.end);catch(SQLExceptione)e.printStackTrace();finally/数据库关闭操作然后控制是都建立增量索引的时候根据能否都到id值来设置IndexWriter的第三个参数为true或者是falsebooleanisEmpty=true;tryFileReaderfr=newFileReader(*.txt);BufferedReaderbr=newBufferedReader(fr);if(br.readLine()!=null)isEmpty=false;br.close();fr.close();catch(IOExceptione)e.printStackTrace();writer=newIndexWriter(Directory,newStandardAnalyzer(),isEmpty);

展开阅读全文
相关资源
猜你喜欢
相关搜索

当前位置:首页 > 社会民生


经营许可证编号:宁ICP备18001539号-1