lucene_03_索引的增删改查

 ?public <T extends Query> void printResult(Query query) throws Exception{ ???????IndexSearcher indexSearcher = getIndexSearcher(); ???????TopDocs topDocs = indexSearcher.search(query, 10); ???????ScoreDoc[] scoreDocs = topDocs.scoreDocs; ???????int i=0; ???????for (ScoreDoc doc : scoreDocs) { ???????????int docIndex = doc.doc; ???????????Document document = indexSearcher.doc(docIndex); ???????????String fileName = document.get("fileName"); ???????????System.out.println(fileName); ???????????String fileSize = document.get("fileSize"); ???????????System.out.println("size:=="+fileSize); ???????????String filePath = document.get("filePath"); ???????????System.out.println(filePath); ???????????String fileContent = document.get("fileContent"); ???????????System.out.println(fileContent); ???????????System.out.println("==========="+ ++i +"==============="); ???????} ???????indexSearcher.getIndexReader().close(); ???} public IndexSearcher getIndexSearcher() throws Exception{ ?????// ?第一步: 创建一个Directory 对象，也就是索引库存放的位置。 ???????Directory directory = FSDirectory.open(new File("F:\\lucene\\indexDatabase"));// ???????第二步: 创建一个indexReader 对象，需要指定Directory 对象。 ???????IndexReader indexReader = DirectoryReader.open(directory);// ???????第三步: 创建一个indexsearcher 对象，需要指定InclexReader 对象。 ???????IndexSearcher indexSearcher = new IndexSearcher(indexReader); ???????return indexSearcher; ???}

 @Test ???public void queryAll() throws Exception{ ???????Query query = new MatchAllDocsQuery(); ???????printResult(query); ???}

 ???@Test ???public void queryRange() throws Exception{ ???????Query query = ?NumericRangeQuery.newLongRange("fileSize",0L,800L,true,true); ???????printResult(query); ???}

 ???/** ????* 组合条件查询 ????*/ ???@Test ???public void queryBoolean() throws Exception{ ???????BooleanQuery query = new BooleanQuery(); ???????TermQuery query1 = new TermQuery(new Term("fileName", "java")); ???????TermQuery query2 = new TermQuery(new Term("fileName", "lucene")); ???????query.add(query1, BooleanClause.Occur.MUST); ???????query.add(query2, BooleanClause.Occur.MUST);// ???????Query query3 = query; ???????printResult(query); ???}

//增 ???@Test ???public void add() throws ?Exception{ ???????IndexWriter indexWriter = getIndexWriter(); ???????Document document = new Document(); ???????document.add(new TextField("fileContent","电话号码", Field.Store.YES)); ???????indexWriter.addDocument(document); ???????indexWriter.close(); ???}

 /** ????* 更新：删除原有的并增加需要更改的。 ????* 删掉一个添加一个 ????* @throws Exception ????*/ ???@Test ???public void update() throws Exception{ ???????IndexWriter indexWriter = getIndexWriter(); ???????Term term = new Term("fileContent", "电话号码"); ?????/* ?Document document = new Document(); ???????document.add(new TextField("fileContent","电话号码1", Field.Store.YES));*/ ???????Document document = getDocumentByFile(new File("F:\\lucene\\test.txt")); ???????indexWriter.updateDocument(term,document,new IKAnalyzer()); ???????indexWriter.close(); ???} ???public Document getDocumentByFile(File file) throws Exception{ ???????Document document = new Document(); ???????//获取文件的名称 ???????String fileName = file.getName(); ???????//创建textfield，保存文件名（key,value,是否存储） ???????TextField fileNameField = new TextField("fileName",fileName, Field.Store.YES); ???????//文件大小 ???????long fileSize = FileUtils.sizeOf(file);// ???????????????NumericDocValuesField fileSizeField = new NumericDocValuesField("fileSize", fileSize); ???????System.out.println(fileSize);// ???????????????SortedNumericDocValuesField fileSizeField = new SortedNumericDocValuesField("fileSize", fileSize);// ???????????????LongPoint fileSizeField = new LongPoint("fileSize", fileSize); ???????StringField fileSizeField = new StringField("fileSize", String.valueOf(fileSize), Field.Store.YES); ???????//文件路径 ???????String filePath = file.getPath(); ???????StoredField filePathField = new StoredField("filePath", filePath); ???????//文件内容 ???????String fileContent = FileUtils.readFileToString(file,"gbk"); ???????TextField fileContentField = new TextField("fileContent", fileContent, Field.Store.YES); ???????document.add(fileNameField); ???????document.add(fileSizeField); ???????document.add(filePathField); ???????document.add(fileContentField); ???????return document; ???}

 ?//删除全部 ???@Test ???public ?void deleteAll() throws Exception{ ???????IndexWriter indexWriter = getIndexWriter(); ???????indexWriter.deleteAll(); ???????indexWriter.close(); ???} ???//删除部分 ???@Test ???public void delete() throws ?Exception{ ???????IndexWriter indexWriter = getIndexWriter(); ???????Term term = new Term("fileContent", "电话号码"); //索引文件中包含的有电话号码，分词器也分析出了电话号码一词，删除之后就无法通过该关键词索引到文件了。 ???????indexWriter.deleteDocuments(term); ???????indexWriter.close(); ???}