Document doc&＃61; new Document();//创建文档
doc.add(new StringField("id", ids[i], Field.Store.YES));//将id属性存入内存中
doc.add(new StringField("city", citys[i], Field.Store.YES));
doc.add(new TextField("desc", descs[i], Field.Store.NO));
writer.addDocument(doc);//添加文档
}
writer.close();
}/*** 测试写了几个文档
*
*&＃64;throwsException*/&＃64;Testpublic void testIndexWriter() throwsException {
IndexWriter writer&＃61;getWriter();
System.out.println("写入了" &＃43; writer.numDocs() &＃43; "个文档");
writer.close();
}/*** 测试读取文档
*
*&＃64;throwsException*/&＃64;Testpublic void testIndexReader() throwsException {
IndexReader reader&＃61;DirectoryReader.open(dir);
System.out.println("最大文档数&＃xff1a;" &＃43;reader.maxDoc());
System.out.println("实际文档数&＃xff1a;" &＃43;reader.numDocs());
reader.close();
}/*** 测试删除 在合并前
*
*&＃64;throwsException*/&＃64;Testpublic void testDeleteBeforeMerge() throwsException {
IndexWriter writer&＃61;getWriter();
System.out.println("删除前&＃xff1a;" &＃43;writer.numDocs());
writer.deleteDocuments(new Term("id", "1"));//term&＃xff1a;根据id找到为1的
writer.commit();
System.out.println("writer.maxDoc()&＃xff1a;" &＃43;writer.maxDoc());
System.out.println("writer.numDocs()&＃xff1a;" &＃43;writer.numDocs());
writer.close();
}/*** 测试删除 在合并后
*
*&＃64;throwsException*/&＃64;Testpublic void testDeleteAfterMerge() throwsException {
IndexWriter writer&＃61;getWriter();
System.out.println("删除前&＃xff1a;" &＃43;writer.numDocs());
writer.deleteDocuments(new Term("id", "1"));
writer.forceMergeDeletes();//强制删除
writer.commit();
System.out.println("writer.maxDoc()&＃xff1a;" &＃43;writer.maxDoc());
System.out.println("writer.numDocs()&＃xff1a;" &＃43;writer.numDocs());
writer.close();
}/*** 测试更新
*
*&＃64;throwsException*/&＃64;Testpublic void testUpdate() throwsException {
IndexWriter writer&＃61;getWriter();
Document doc&＃61; newDocument();
doc.add(new StringField("id", "1", Field.Store.YES));
doc.add(new StringField("city", "qingdao", Field.Store.YES));
doc.add(new TextField("desc", "dsss is a city.", Field.Store.NO));
writer.updateDocument(new Term("id", "1"), doc);
writer.close();
}
}
生成的索引文件如下&＃xff1a;
关于索引的搜索&＃xff1a;
这里有一个要注意的地方&＃xff1a;一定要先创建出索引后才能去进行查找&＃xff0c;否则会报
org.apache.lucene.index.IndexNotFoundException:
no segments* file found in MMapDirectory&＃64;D:\lucene lockFactory&＃61;org.apache.lucene.store.NativeFSLockFactory&＃64;753f67a9: files: [data, lucene-5.3.1, lucene-5.3.1.zip]
packagecom.wp.lucene;importjava.nio.file.Paths;importorg.apache.lucene.analysis.Analyzer;importorg.apache.lucene.analysis.standard.StandardAnalyzer;importorg.apache.lucene.document.Document;importorg.apache.lucene.index.DirectoryReader;importorg.apache.lucene.index.IndexReader;importorg.apache.lucene.queryparser.classic.QueryParser;importorg.apache.lucene.search.IndexSearcher;importorg.apache.lucene.search.Query;importorg.apache.lucene.search.ScoreDoc;importorg.apache.lucene.search.TopDocs;importorg.apache.lucene.store.Directory;importorg.apache.lucene.store.FSDirectory;public classSearcher {/***
*&＃64;paramindexDir
* 哪个目录
*&＃64;paramq
* 要查询的字段
*&＃64;throwsException*/
public static void search(String indexDir, String q) throwsException {
Directory dir&＃61; FSDirectory.open(Paths.get(indexDir));//打开目录
IndexReader reader &＃61; DirectoryReader.open(dir);//进行读取
IndexSearcher is &＃61; new IndexSearcher(reader);//索引查询器
Analyzer analyzer &＃61; new StandardAnalyzer(); //标准分词器
QueryParser parser &＃61; new QueryParser("contents", analyzer);//在哪查询&＃xff0c;第一个参数为查询的Document&＃xff0c;在Indexer中创建了
Query query &＃61; parser.parse(q);//对字段进行解析后返回给查询
long start &＃61;System.currentTimeMillis();
TopDocs hits&＃61; is.search(query, 10);//开始查询&＃xff0c;10代表前10条数据&＃xff1b;返回一个文档
long end &＃61;System.currentTimeMillis();
System.out.println("匹配 " &＃43; q &＃43; " &＃xff0c;总共花费" &＃43; (end - start) &＃43; "毫秒" &＃43; "查询到"
&＃43; hits.totalHits &＃43; "个记录");for(ScoreDoc scoreDoc : hits.scoreDocs) {
Document doc&＃61; is.doc(scoreDoc.doc);//根据文档的标识获取文档
System.out.println(doc.get("fullPath"));
}
reader.close();
}/*** 执行这个main方法进行查询之前&＃xff0c;必须要有索引&＃xff0c;即先执行Indexer这个类
*
*&＃64;paramargs*/
public static voidmain(String[] args) {
String indexDir&＃61; "D:\\lucene";
String q&＃61; "ADD";try{
search(indexDir, q);
}catch(Exception e) {
e.printStackTrace();
}
}
}
Java小生店铺&＃xff1a;
手机端&＃xff1a;搜索 java小生店铺
希望店铺的资料能帮助到你&＃xff01;&＃xff01;&＃xff01;
京公网安备 11010802041100号