java模糊查询任意两个字段_基于数据库lucence3.6.2多字段配合多关键字的模糊查询...

一、首先是从数据库查询数据并添加索引

class&＃61;"java" name&＃61;"code">

/**

* 写入数据库索引

* &＃64;param sql　查询的sql语句

* &＃64;param indexPath 保存索引的硬盘绝对路径

* &＃64;return

*/

private int createDBIndex(String sql,String indexPath){

log.info("DBIndex is creating,wait a moment!");

long start&＃61;new Date().getTime();

IndexWriter writer;

Directory directory &＃61; null;

int numberindex &＃61; 0;

try {

File indexFile &＃61; new File(indexPath);

directory &＃61; new SimpleFSDirectory(indexFile);

writer &＃61; new IndexWriter(directory, new IKAnalyzer(),true, IndexWriter.MaxFieldLength.LIMITED);

ResultSet rs &＃61; getResultSet(sql);

while (rs.next()) {

Document doc &＃61; new Document();

String PATIENT_NAME &＃61; rs.getString("PATIENT_NAME") &＃61;&＃61; null?"":rs.getString("PATIENT_NAME");

String PATIENT_SEX &＃61; rs.getString("PATIENT_SEX") &＃61;&＃61; null ? "-1":rs.getString("PATIENT_SEX");

String PATIENT_AGE &＃61; rs.getString("PATIENT_AGE") &＃61;&＃61; null ? "0":rs.getString("PATIENT_AGE");

String SENDED_DEPT &＃61; rs.getString("SENDED_DEPT") &＃61;&＃61; null ? "":rs.getString("SENDED_DEPT");

String SENDED_DOCTOR &＃61; rs.getString("SENDED_DOCTOR") &＃61;&＃61; null ?"":rs.getString("SENDED_DOCTOR");

String BODY_OF_CASE &＃61; rs.getString("BODY_OF_CASE") &＃61;&＃61; null ? "":rs.getString("BODY_OF_CASE");

String SENDED_HOSPITAL &＃61; rs.getString("SENDED_HOSPITAL") &＃61;&＃61; null ? "":rs.getString("SENDED_HOSPITAL");

String CHECK_METHOD &＃61; rs.getString("CHECK_METHOD")&＃61;&＃61;null ? "":rs.getString("CHECK_METHOD");

String REPORT_DOCNAME &＃61; rs.getString("REPORT_DOCNAME")&＃61;&＃61;null ? "":rs.getString("REPORT_DOCNAME");

String AUDIT_DOCNAME &＃61; rs.getString("AUDIT_DOCNAME")&＃61;&＃61;null?"":rs.getString("AUDIT_DOCNAME");

String REPORT_DATE &＃61; rs.getString("REPORT_DATE")&＃61;&＃61;null?"":rs.getString("REPORT_DATE");

String POSITIVE_FLAG &＃61; rs.getString("POSITIVE_FLAG")&＃61;&＃61;null?"":rs.getString("POSITIVE_FLAG");

String REPORT_DESC_TXT &＃61; rs.getString("REPORT_DESC_TXT")&＃61;&＃61;null?"":rs.getString("REPORT_DESC_TXT");

String REPORT_DIAG_TXT &＃61; rs.getString("REPORT_DIAG_TXT")&＃61;&＃61;null?"":rs.getString("REPORT_DIAG_TXT");

String CLINIC_DESC &＃61; rs.getString("CLINIC_DESC")&＃61;&＃61;null?"":rs.getString("CLINIC_DESC");

String CLINIC_DIAG &＃61; rs.getString("CLINIC_DIAG")&＃61;&＃61;null?"":rs.getString("CLINIC_DIAG");

String CLINICAL_ADVICE &＃61; rs.getString("CLINIC_ADVICE")&＃61;&＃61;null?"":rs.getString("CLINIC_ADVICE");

String HOSPITAL_CARDID &＃61; rs.getString("HOSPITAL_CARDID")&＃61;&＃61;null?"":rs.getString("HOSPITAL_CARDID");

String CLINIC_HOSPITALNO &＃61; rs.getString("CLINIC_HOSPITALNO")&＃61;&＃61;null?"":rs.getString("CLINIC_HOSPITALNO");

String FTPPATH &＃61; rs.getString("FTPPATH")&＃61;&＃61;null?"":rs.getString("FTPPATH");

String SENDED_DATE &＃61; rs.getString("SENDED_DATE")&＃61;&＃61;null?"":rs.getString("SENDED_DATE");

doc.add(new Field("PATIENT_NAME", PATIENT_NAME, Field.Store.YES,Field.Index.ANALYZED));

doc.add(new Field("PATIENT_SEX", PATIENT_SEX,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("PATIENT_AGE", PATIENT_AGE,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("SENDED_DEPT", SENDED_DEPT,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("SENDED_DOCTOR",SENDED_DOCTOR,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("BODY_OF_CASE",BODY_OF_CASE,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("SENDED_HOSPITAL",SENDED_HOSPITAL,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("CHECK_METHOD", CHECK_METHOD,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("REPORT_DOCNAME", REPORT_DOCNAME,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("AUDIT_DOCNAME", AUDIT_DOCNAME,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("REPORT_DATE",REPORT_DATE,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("POSITIVE_FLAG",POSITIVE_FLAG,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("REPORT_DESC_TXT",REPORT_DESC_TXT,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("REPORT_DIAG_TXT",REPORT_DIAG_TXT,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("CLINIC_DESC",CLINIC_DESC,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("CLINIC_DIAG",CLINIC_DIAG,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("CLINICAL_ADVICE",CLINICAL_ADVICE,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("HOSPITAL_CARDID",HOSPITAL_CARDID,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("CLINIC_HOSPITALNO",CLINIC_HOSPITALNO,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("FTPPATH",FTPPATH,Field.Store.YES, Field.Index.ANALYZED));

doc.add(new Field("SENDED_DATE",SENDED_DATE,Field.Store.YES, Field.Index.ANALYZED));

writer.addDocument(doc);

}

numberindex &＃61; writer.numDocs();

writer.optimize();

writer.close();

if(IndexWriter.isLocked(directory)){

IndexWriter.unlock(directory);

}

long end&＃61;new Date().getTime();

log.info("Opration sql: \n " &＃43; sql &＃43; " \n success,Create index " &＃43; numberindex &＃43; " sucess,spend time is " &＃43; (end-start) &＃43; " ms!");

} catch (Exception e) {

e.printStackTrace();

log.info("Create index failed......");

}

return numberindex;

}

二、从索引中查询数据

/**

* 从本地索引文件中搜索相关关键字

* &＃64;param indexDir 所要查询的索引文件保存地址

* &＃64;param fieldString 需要搜索出来的字段

* &＃64;param search 搜索关键字的字符串数组

* &＃64;throws CorruptIndexException

* &＃64;throws IOException

* &＃64;throws ParseException

* return List

*/

&＃64;SuppressWarnings({ "deprecation", "resource" })

public List searchData(File indexDir,String[] fieldString, List search) throws CorruptIndexException, IOException, ParseException{

List docList &＃61; new ArrayList();

long start&＃61;new Date().getTime();

IndexSearcher searcher&＃61; new IndexSearcher(FSDirectory.open(indexDir),true);

BooleanQuery bQuery &＃61; new BooleanQuery(); //组合查询

WildcardQuery w1 &＃61; null;

for (int i &＃61; 0; i

for (int j &＃61; 0; j

w1 &＃61; new WildcardQuery(new Term(fieldString[i], "*" &＃43;search.get(j).getKeyName() &＃43; "*"));//加通配符才能正常查询完整的模糊查询数据

bQuery.add(w1,BooleanClause.Occur.SHOULD);//or关系

}

}

TopDocs topDocs &＃61; searcher.search(bQuery,TOP_NUM);//

ScoreDoc[] hits &＃61; topDocs.scoreDocs;

for (int j &＃61; 0; j

int DocId &＃61; hits[j].doc;

Document document &＃61; searcher.doc(DocId);

docList.add(document);

}

long end&＃61;new Date().getTime();

// log.info("\n\n Query "&＃43;docList.size()&＃43;" result on "&＃43;(end-start)&＃43;" ms!");

System.out.println("\n\n Query "&＃43;docList.size()&＃43;" result on "&＃43;(end-start)&＃43;" ms!");

return docList;

}

以上返回Document的集合&＃xff0c;再将每个Document中值遍历

document.getField("BODY_OF_CASE").stringValue();

IKAnalyzer2012.jar (1.1 MB)

下载次数: 0

lucene-highlighter-3.6.2.jar (87.1 KB)

下载次数: 0

lucene-memory-3.6.2.jar (29.1 KB)

下载次数: 0

lucene-analyzers-3.6.2.jar (1.1 MB)

下载次数: 0

lucene-core-3.6.2.jar (1.5 MB)

下载次数: 0