Lucene学习笔记（一）

package my.dizang.po;

/**
 * 
 * @Title: Book.java
 * @Package my.dizang.po
 * @Description: TODO(用一句话描述该文件做什么)
 * @author 地藏 1281782012@qq.com
 * @date 2016-4-19 下午6:48:15
 * @version V1.0
 */
public class Book {
    // 图书ID
    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;
    }

}

package my.dizang.dao;

import java.util.List;

import my.dizang.po.Book;

/**
 * 
 * @Title: BookDao.java 
 * @Package my.dizang.dao 
 * @Description: 接口
 * @author 地藏 1281782012@qq.com   
 * @date 2016-4-19 下午6:54:25 
 * @version V1.0
 */
public interface BookDao {

    public List<Book> queryBookList();
}

package my.dizang.dao;

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

import my.dizang.po.Book;


/**
 * 
 * @Title: BookDaoImpl.java
 * @Package my.dizang.dao
 * @Description: BookDao实现类
 * @author 地藏 1281782012@qq.com
 * @date 2016-4-19 下午6:57:17
 * @version V1.0
 */
public class BookDaoImpl implements BookDao {

    @Override
    public List<Book> queryBookList() {
        // 使用JDBC获取采集数据
        // 数据库连接
        Connection connection = null;
        // 预编译statement
        PreparedStatement preparedStatement = null;
        // 结果集
        ResultSet resultSet = null;
        // 图书列表
        List<Book> list = new ArrayList<Book>();
        try {
            // 加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 连接数据库
            connection = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/mybatis", "root", "1234");

            // SQL语句
            String sql = "SELECT * FROM book";
            // 创建preparedStatement
            preparedStatement = connection.prepareStatement(sql);

            // 获取结果集
            resultSet = preparedStatement.executeQuery();

            // 结果集解析
            while (resultSet.next()) {
                Book book = new Book();
                book.setId(resultSet.getInt("id"));
                book.setName(resultSet.getString("name"));
                book.setPrice(resultSet.getFloat("price"));
                book.setPic(resultSet.getString("pic"));
                book.setDescription(resultSet.getString("description"));
                list.add(book);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }

        return list;
    }

}

package my.dizang.index;

import java.io.File;

import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.Term;
import org.apache.lucene.queryparser.classic.MultiFieldQueryParser;
import org.apache.lucene.queryparser.classic.QueryParser;
import org.apache.lucene.search.BooleanClause.Occur;
import org.apache.lucene.search.BooleanQuery;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.NumericRangeQuery;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.ScoreDoc;
import org.apache.lucene.search.TermQuery;
import org.apache.lucene.search.TopDocs;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
import org.junit.Test;

/**
 * 
 * @Title: IndexSearch.java
 * @Package my.dizang.index
 * @Description: 搜索测试类 注意：搜索时的分词器必须和索引的分词器一致
 * @author 地藏 1281782012@qq.com
 * @date 2016-4-20 上午10:50:57
 * @version V1.0
 */
public class IndexSearch {

    @Test
    public void createIndex() throws Exception{
        
        //采集数据
        BookDao dao = new BookDaoImpl();
        List<Book> bookList = dao.queryBookList();
        //创建Document
        List<Document> docList = new ArrayList<>();
        Document document;
        for (Book book : bookList) {
            document = new Document();
            
            //创建Field域
            //Store ：表示是否存储到文档域
            //商品ID
            Field idField = new TextField("id",book.getId().toString(),Store.YES);
            
            //商品名称
            Field nameField = new TextField("name",book.getName(),Store.YES);
            
            //商品价格
            Field priceField = new TextField("price",book.getPrice().toString(),Store.YES);
            
            //商品图片地址
            Field picField = new TextField("pic",book.getPic(),Store.YES);
            
            //商品描述
            Field descField = new TextField("description",book.getDescription(),Store.YES);
            
            document.add(idField);
            document.add(nameField);
            document.add(priceField);
            document.add(picField);
            document.add(descField);
            
            docList.add(document);
        }
        
        //进行分词处理
        Analyzer analyzer = new StandardAnalyzer();
        
        //创建Directory
        //指定索引库所在的路径
        Directory directory = FSDirectory.open(new File("E:\\11-index\\1223\\"));
        //创建IndexWriterConfig
        IndexWriterConfig cfg = new IndexWriterConfig(Version.LUCENE_4_10_3, analyzer);
        //创建IndexWriter
        IndexWriter writer = new IndexWriter(directory, cfg);
        //通过IndexWriter经做过分词处理的Document对象存储到索引库
        for (Document doc : docList) {
            writer.addDocument(doc);
        }
        //关闭资源
        writer.close();
    }

}