lucene和JDBC

项目结构：

运行效果：

1.搜索关键字"是"

2.搜索关键字"我"

==========================================

数据库中表信息：

CREATE TABLE `mymails` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',
  `name` varchar(50) DEFAULT NULL COMMENT '寄件人',
  `email` varchar(50) DEFAULT NULL COMMENT '件邮名称',
  `content` varchar(200) DEFAULT NULL COMMENT '内容',
  `attach` int(11) DEFAULT NULL COMMENT '附件数',
  `sendtime` varchar(20) DEFAULT NULL COMMENT '发送日期',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=14 DEFAULT CHARSET=utf8;

==========================================

代码部分：

==========================================

/lucene_0500_jdbc/src/com/b510/lucene/util/LuceneUtil.java

/**
 * 
 */
package com.b510.lucene.util;

import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
import org.apache.lucene.document.NumericField;
import org.apache.lucene.index.CorruptIndexException;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
import org.apache.lucene.index.Term;
import org.apache.lucene.search.IndexSearcher;
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.apache.lucene.store.LockObtainFailedException;
import org.apache.lucene.util.Version;

/**
 * @author Hongten <br />
 * @date 2013-1-31
 */
public class LuceneUtil {
    
    private static String driver = "com.mysql.jdbc.Driver";
    private static String dbName = "db_lucene";
    private static String passwrod = "root";
    private static String userName = "root";
    private static String url = "jdbc:mysql://localhost:3308/" + dbName;

    private Directory directory = null;
    /**
     * 评分
     */
    private Map<String, Float> scores = new HashMap<String, Float>();

    public LuceneUtil() {
        try {
            scores.put("sina.com", 1.0f);
            scores.put("foxmail.com", 1.1f);
            directory = FSDirectory.open(new File("D:/WordPlace/lucene/lucene_0500_jdbc/lucene/index"));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * 创建索引
     */
    public void index() {
        IndexWriter writer = null;
        try {
            writer = new IndexWriter(directory, new IndexWriterConfig(Version.LUCENE_35, new StandardAnalyzer(Version.LUCENE_35)));
            // 删除之前所建立的全部索引
            writer.deleteAll();
            // 创建文档
            Document document = null;

            String sql = "select * from mymails";
            ResultSet rs = null;
            try {
                Class.forName(driver);
                Connection conn = DriverManager.getConnection(url, userName, passwrod);
                PreparedStatement ps = conn.prepareStatement(sql);
                rs = ps.executeQuery();

                while (rs.next()) {
                    System.out.println("id:[" + rs.getString("id") + "] name:[" + rs.getString("name") + "] content:[" + rs.getString("content") + "]");

                    document = new Document();
                    document.add(new Field("id", rs.getString("id"), Field.Store.YES, Field.Index.NOT_ANALYZED_NO_NORMS));
                    document.add(new Field("email", rs.getString("email"), Field.Store.YES, Field.Index.NOT_ANALYZED));
                    document.add(new Field("content", rs.getString("content"), Field.Store.YES, Field.Index.ANALYZED));
                    document.add(new Field("name", rs.getString("name"), Field.Store.YES, Field.Index.NOT_ANALYZED_NO_NORMS));
                    document.add(new NumericField("attach", Field.Store.YES, true).setIntValue(Integer.valueOf(rs.getString("attach"))));
                    document.add(new Field("date", rs.getString("sendtime"), Field.Store.YES, Field.Index.ANALYZED));

                    // 这里进行加权处理
                    String et = rs.getString("email").substring(rs.getString("email").lastIndexOf("@") + 1);
                    System.out.println(et);
                    if (scores.containsKey(et)) {
                        document.setBoost(scores.get(et));
                    } else {
                        document.setBoost(0.6f);
                    }
                    writer.addDocument(document);

                }

                // 关闭记录集
                if (rs != null) {
                    try {
                        rs.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }

                // 关闭声明
                if (ps != null) {
                    try {
                        ps.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }

                // 关闭链接对象
                if (conn != null) {
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }

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

        } catch (CorruptIndexException e) {
            e.printStackTrace();
        } catch (LockObtainFailedException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (writer != null) {
                try {
                    writer.close();
                } catch (CorruptIndexException e) {
                    e.printStackTrace();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 搜索
     */
    public void search(String key) {
        try {
            IndexReader reader = IndexReader.open(directory);
            IndexSearcher searcher = new IndexSearcher(reader);
            TermQuery query = new TermQuery(new Term("content", key));
            TopDocs tds = searcher.search(query, 12);
            for (ScoreDoc sd : tds.scoreDocs) {
                Document doc = searcher.doc(sd.doc);
                System.out.println("文档序号：[" + sd.doc + "] 得分：[" + sd.score + "] 邮件名称：[" + doc.get("email") + "] 邮件人：[" + doc.get("name") + "] 附件数：[" + doc.get("attach") + "] 日期：[" + doc.get("date")
                        + "] 内容 : [" + doc.get("content") + "]");
            }
        } catch (CorruptIndexException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/lucene_0500_jdbc/src/com/b510/lucene/test/IndexTest.java

/**
 * 
 */
package com.b510.lucene.test;

import org.junit.Test;

import com.b510.lucene.util.LuceneUtil;

/**
 * @author Hongten <br />
 * @date 2013-1-31
 */
public class IndexTest {

    @Test
    public void testIndex(){
        LuceneUtil util = new LuceneUtil();
        util.index();
    }
    
    @Test
    public void testSearch(){
        LuceneUtil util = new LuceneUtil();
        util.search("我");
    }
    
}

I'm Hongten