Lucene

核心示例代码：

package xyz.zerone.lucene.pojo;

public class Book {
    private Integer id;
    private String name;
    private Float price;
    private String pic;
    private String description;
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Float getPrice() {
        return price;
    }
    public void setPrice(Float price) {
        this.price = price;
    }
    public String getPic() {
        return pic;
    }
    public void setPic(String pic) {
        this.pic = pic;
    }
    public String getDescription() {
        return description;
    }
    public void setDescription(String description) {
        this.description = description;
    }
    @Override
    public String toString() {
        return "Book [id=" + id + ", name=" + name + ", price=" + price + ", pic=" + pic + ", description="
                + description + "]";
    }
    
}

---

package xyz.zerone.lucene.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.sql.PreparedStatement;


import xyz.zerone.lucene.pojo.Book;

public class BookDaoImp implements BookDao {
    private static String sql = "select * from book";

    @Override
    public List<Book> findBookAll() throws Exception {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        List<Book> list = new ArrayList<Book>();
        try {
            Class.forName("com.mysql.jdbc.Driver");
            connection = DriverManager.getConnection("jdbc:mysql://192.168.3.8:3306/lucenedb", "root", "123456");
            preparedStatement = connection.prepareStatement(sql);
            ResultSet rs = preparedStatement.executeQuery();
            while (rs.next()) {
                Book book = new Book();
                book.setId(rs.getInt("id"));
                book.setName(rs.getString("name"));
                book.setPrice(rs.getFloat("price"));
                book.setPic(rs.getString("pic"));
                book.setDescription(rs.getString("description"));
                list.add(book);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }

}

---

package xyz.zerone.lucene.first;

import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field.Store;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
import org.apache.lucene.queryparser.classic.ParseException;
import org.apache.lucene.queryparser.classic.QueryParser;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.ScoreDoc;
import org.apache.lucene.search.TopDocs;
import org.apache.lucene.document.FloatField;
import org.apache.lucene.document.StoredField;
import org.apache.lucene.document.StringField;
import org.apache.lucene.document.TextField;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
import org.apache.lucene.util.Version;
import org.apache.lucene.index.Term;
import org.junit.Test;

import xyz.zerone.lucene.dao.BookDaoImp;
import xyz.zerone.lucene.pojo.Book;

public class LuceneCore {
    // 创建索引库生成到指定目录中
    @Test
    public void createIndexFromDb() throws Exception {
        // 定义List存储document
        List<Document> docs = new ArrayList<Document>();
        // 从数据库获取book表的集合数据
        List<Book> bookList = new BookDaoImp().findBookAll();
        for (Book book : bookList) {
            // 创建Document
            Document doc = new Document();
            // 创建Field域
            // -创建book表字段id的field域
            // --参数：域名、域中的value值、是否存储到文件系统
            /**
             * 根据实际的需求： 这里的Field属性设置可以有三种（是否分词、是否索引、是否存储）； 详见createAutoIndexDate();
             */
            TextField id = new TextField("id", book.getId().toString(), Store.YES);
            TextField name = new TextField("name", book.getName(), Store.YES);
            FloatField price = new FloatField("price", book.getPrice(), Store.YES);
            TextField pic = new TextField("pic", book.getPic(), Store.YES);
            TextField description = new TextField("description", book.getDescription(), Store.YES);
            // 将field域加入到documet中
            doc.add(id);
            doc.add(name);
            doc.add(price);
            doc.add(pic);
            doc.add(description);
            // 将document加入集合
            docs.add(doc);
        }
        // 创建一个标准的分词器
        Analyzer analyzer = new StandardAnalyzer();
        // 创建索引目录的流对象，指定索引库存放位置
        Directory d = FSDirectory.open(new File("C:\Users\dangxiaopeng\Desktop\LuceneIndexData"));
        // IndexWriter配置对象
        // 参数：lucene版本、分词器
        IndexWriterConfig conf = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);
        // 创建索引操作对象，提供了很多方法操作索引文件（添加、修改、删除）
        IndexWriter indexWriter = new IndexWriter(d, conf);
        // 通过indexWriter创建索引
        for (Document doc : docs) {
            indexWriter.addDocument(doc);
        }
        indexWriter.commit();
        indexWriter.close();
    }

    // 根据实际需求创建索引库生成到指定目录中
    @Test
    public void createAutoIndexFromDb() throws Exception {
        // 定义List存储document
        List<Document> docs = new ArrayList<Document>();
        // 从数据库获取book表的集合数据
        List<Book> bookList = new BookDaoImp().findBookAll();
        for (Book book : bookList) {
            // 创建Document
            Document doc = new Document();
            // 创建Field域
            // -创建book表字段id的field域
            // --参数：域名、域中的value值、是否存储到文件系统
            // 图书id，不要分词，要索引，要存储
            StringField id = new StringField("id", book.getId().toString(), Store.YES);
            // 图书名称，要分词，要索引，要存储
            TextField name = new TextField("name", book.getName(), Store.YES);
            // 图书价格，要分词（Lucene需要的对价格数字特殊处理分词，以便处理范围查询），要索引，要存储
            FloatField price = new FloatField("price", book.getPrice(), Store.YES);
            // 图书图片，不要分词，不要索引，要存储
            StoredField pic = new StoredField("pic", book.getPic());
            // 图书描述，要分词，要索引，不要存储
            TextField description = new TextField("description", book.getDescription(), Store.YES);
            // 将field域加入到documet中
            doc.add(id);
            doc.add(name);
            doc.add(price);
            doc.add(pic);
            doc.add(description);
            // 将document加入集合
            docs.add(doc);
        }
        // 创建一个标准的分词器
        Analyzer analyzer = new StandardAnalyzer();
        // 创建索引目录的流对象，指定索引库存放位置
        Directory d = FSDirectory.open(new File("C:\Users\dangxiaopeng\Desktop\LuceneIndexData"));
        // IndexWriter配置对象
        // 参数：lucene版本、分词器
        IndexWriterConfig conf = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);
        // 创建索引操作对象，提供了很多方法操作索引文件（添加、修改、删除）
        IndexWriter indexWriter = new IndexWriter(d, conf);
        // 通过indexWriter创建索引
        for (Document doc : docs) {
            indexWriter.addDocument(doc);
        }
        indexWriter.commit();
        indexWriter.close();
    }

    // 删除索引
    @Test
    public void deleteIndex() throws IOException, ParseException {

        // 调用indexWriter中删除索引方法

        // 创建分词器
        Analyzer analyzer = new StandardAnalyzer();

        // 创建索引目录 的流对象,指定索引目录 的位置
        Directory d = FSDirectory.open(new File("C:\Users\dangxiaopeng\Desktop\LuceneIndexData"));

        // IndexWriter配置对象
        // 参数：lucene的版本，分词器
        IndexWriterConfig conf = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);

        // 创建indexWriter
        IndexWriter indexWriter = new IndexWriter(d, conf);

        // 删除全部索引
        // indexWriter.deleteAll();

        // 查询分析器
        // 第一个参数：指定默认搜索的域,第二个：分词器
        QueryParser queryParser = new QueryParser("description", analyzer);

        // 创建查询对象
        Query query = queryParser.parse("description:java");
        // 删除符合条件的索引，删除符合query查询的所有document
        indexWriter.deleteDocuments(query);
        // 提交
        indexWriter.commit();
        // 关闭资源
        indexWriter.close();

    }

    // 更新索引
    @Test
    public void updateIndex() throws IOException {
        // 调用indexWriter中更新索引方法
        // 创建分词器
        Analyzer analyzer = new StandardAnalyzer();

        // 创建索引目录 的流对象,指定索引目录 的位置
        Directory d = FSDirectory.open(new File("C:\Users\dangxiaopeng\Desktop\LuceneIndexData"));

        // IndexWriter配置对象
        // 参数：lucene的版本，分词器
        IndexWriterConfig conf = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);

        // 创建indexWriter
        IndexWriter indexWriter = new IndexWriter(d, conf);

        // 创建一个term作为查询条件
        // 参数：field域名称，值
        Term term = new Term("id", "1");

        // 创建document，新的document，替换id等的1的document
        Document doc = new Document();
        // 图书id，不要分词，要索引、要存储
        StringField id = new StringField("id", "1".toString(), Store.YES);

        // 图书名称：要分词，要索引，要存储
        TextField name = new TextField("name", "java编程思想第三版", Store.YES);

        doc.add(id);
        doc.add(name);

        // 更新思路：根据term的信息查询document，找到之后删除document，添加doc中的添加到索引库
        // 总之：先查询、再删除、再添加，建议根据主键field查询document。
        indexWriter.updateDocument(term, doc);
        // 提交
        indexWriter.commit();
        // 关闭资源
        indexWriter.close();
    }

    // 搜索索引
    @Test
    public void searchIndex() throws ParseException, IOException {
        // 分词，搜索过程使用的分词器要和创建索引时使用的分词器一致
        Analyzer analyzer = new StandardAnalyzer();
        // 查询分析器
        // 参数：指定默认搜索field域、分词器
        QueryParser queryParser = new QueryParser("description", analyzer);
        // 创建查询对象(这里是使用了查询语法指定了description域如果不指定按照上面默认的field域)
        Query query = queryParser.parse("description:java");
        // 创建索引目录的流对象，指定索引目录位置
        Directory d = FSDirectory.open(new File("C:\Users\dangxiaopeng\Desktop\LuceneIndexData"));
        // 索引读取对象
        // 指定读取索引的目录
        IndexReader indexReader = IndexReader.open(d);
        // 索引搜索对象
        IndexSearcher indexSearcher = new IndexSearcher(indexReader);
        // 执行搜索
        // 参数：query查询对象、取出匹配度高的前n条记录
        TopDocs topDocs = indexSearcher.search(query, 100);
        // 取出匹配上的文档
        ScoreDoc[] scoreDocs = topDocs.scoreDocs;
        for (ScoreDoc scoreDoc : scoreDocs) {
            // document的id
            int docId = scoreDoc.doc;
            // 从indexReader根据docId获取document
            Document doc = indexReader.document(docId);
            // 取出doc中field域的内容
            // 参数指定field域名
            String id = doc.get("id");
            String name = doc.get("name");
            Float price = Float.parseFloat(doc.get("price"));
            String pic = doc.get("pic");

            System.out.println(id + "-" + name + "-" + price + "-" + pic);
        }
        // 关闭资源
        indexReader.close();
    }
}

---

Lucene深入（Luke&&中文分词器&&查询语句见相关文档）