Go语言视频零基础入门到精通

javalearner

1. import java.io.IOException;
   
2. import java.io.InputStreamReader;
   
3. import java.sql.*;
   
4. import java.util.Date;
   
5. import org.apache.lucene.analysis.Analyzer;
   
6. import org.apache.lucene.analysis.standard.StandardAnalyzer;
   
7. import org.apache.lucene.document.Document;
   
8. import org.apache.lucene.document.Field;
   
9. import org.apache.lucene.index.IndexWriter;
   
10. import org.apache.lucene.queryParser.ParseException;
    
11. import org.apache.lucene.queryParser.QueryParser;
    
12. import org.apache.lucene.search.Hits;
    
13. import org.apache.lucene.search.IndexSearcher;
    
14. import org.apache.lucene.search.Query;
    
15. public class SqlCon {
    
16. public static void main(String[] args) {
    
17.   Date date1 = new Date();
    
18.   String connectionUrl = "jdbc:sqlserver://localhost:1433;" + "databaseName=pubs;user=sa;password=";
    
19.   Connection con = null;
    
20.   Statement stmt = null;
    
21.   ResultSet rs = null;
    
22.   try {
    
23.    Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
    
24.    con = DriverManager.getConnection(connectionUrl);
    
25.    String SQL = "SELECT TOP 10 * FROM users";
    
26.    stmt = con.createStatement();
    
27.    rs = stmt.executeQuery(SQL);
    
28.     IndexWriter writer = new IndexWriter("c://bat//index", new StandardAnalyzer());
    
29.    while (rs.next()) {
    
30.     Document doc = new Document();
    
31.     doc.add(new Field("id", rs.getString("id"), Field.Store.YES, Field.Index.TOKENIZED));
    
32.     doc.add(new Field("name", rs.getString("name"), Field.Store.YES, Field.Index.TOKENIZED));
    
33.     doc.add(new Field("sex", rs.getString("sex"), Field.Store.YES, Field.Index.TOKENIZED));
    
34.     doc.add(new Field("age", rs.getString("age"), Field.Store.YES, Field.Index.TOKENIZED));
    
35.     writer.addDocument(doc);
    
36.    }
    
37.    writer.close();
    
38.    Date date2 = new Date();
    
39.    System.out.println("用时" + (date2.getTime() - date1.getTime()) + "毫秒索引已建立");
    
40.    DoSearch();
    
41.   } catch (Exception e) {
    
42.    e.printStackTrace();
    
43.   }
    
44.   finally {
    
45.    if (rs != null)
    
46.     try {
    
47.      rs.close();
    
48.     } catch (Exception e) {}
    
49.    if (stmt != null)
    
50.     try {
    
51.      stmt.close();
    
52.     } catch (Exception e) {}
    
53.    if (con != null)
    
54.     try {
    
55.      con.close();
    
56.     } catch (Exception e) {}
    
57.   }
    
58.   
    
59. }
    
60. public static void DoSearch() throws IOException,ParseException{
    
61.   IndexSearcher indexSearcher = new IndexSearcher("C://index");
    
62.   QueryParser queryParser = new QueryParser("name",new StandardAnalyzer());
    
63.   Query query = queryParser.parse("yxy");// 这个地方Query是抽象类大家也注意一下
    
64.   Hits hits = indexSearcher.search(query);
    
65.   //Document doc = null;
    
66.   System.out.print("正搜索................");
    
67.   System.out.println("找到了"+hits.length()+"个结果");
    
68.   for (int i = 0;i < hits.length();i++)
    
69.   {
    
70.     Document doc = hits.doc(i);
    
71.    System.out.println("内容是：" + doc.get("name"));// 注意这里输出的是什么
    
72.   }
    
73. }
    
74. }

复制代码

   
     
     
      
      

        
      

        
      
     
   

  


源码下载：http://file.javaxxz.com/2014/11/4/000027390.zip