此处添加一个logmanager类
package net.skycity.blog;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import net.sf.hibernate.Criteria;
import net.sf.hibernate.Session;
import net.sf.hibernate.expression.Expression;
import net.sf.hibernate.expression.Order;
import net.skycity.model.LogForm;
import net.skycity.search.SearchEnginePlugIn;
import org.apache.commons.lang.StringUtils;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.Term;
import org.apache.lucene.queryParser.ParseException;
import org.apache.lucene.queryParser.QueryParser;
import org.apache.lucene.search.BooleanQuery;
import org.apache.lucene.search.Hits;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query;
import org.apache.lucene.store.FSDirectory;
public class LogManager extends SearchEnginePlugIn {
public static List searchFor(String logTypeId,String state,String author,String query) throws Exception{
List logs = new ArrayList();
List ids = searchFor(1,logTypeId,query,0,-1);
if(ids.size()>0){
Session ssn=ManagerBase.getSession();
Criteria crit = ssn.createCriteria(LogForm.class).add(Expression.eq("siteId", "1"));
crit = crit.add(Expression.in("logId",ids));
String orderField = "submitTime";
crit = crit.addOrder(Order.desc(orderField));
logs = crit.list();
ssn.close();
}
return logs;
}
public static List searchFor(String logTypeId,String state,String author) throws Exception {
Session ssn=ManagerBase.getSession();
List list = null;
try{
Criteria crit=ssn.createCriteria(LogForm.class).add(Expression.eq("author",author));
if(!logTypeId.equals("0"))
crit.add(Expression.eq("logTypeId",logTypeId));
if(!StringUtils.isEmpty(state))
crit.add(Expression.eq("state",state));
list=crit.list();
}finally{
ssn.close();
}
return list;
}
public static List searchFor(int site, String logTypeId, String word, int from, int count) throws IOException, ParseException {
List logs = new ArrayList();
//从文件目录中
FSDirectory searchDirectory = FSDirectory.getDirectory(SearchEnginePlugIn.getLogIndexPath(), false);
IndexReader reader = IndexReader.open(searchDirectory);
IndexSearcher searcher = new IndexSearcher(reader);
if (searcher == null) return logs;
if(!StringUtils.isEmpty(word)){
BooleanQuery comboQuery = new BooleanQuery();
Query query1 = QueryParser.parse(word,"logTitle",new StandardAnalyzer());
comboQuery.add(query1, false, false);
Query query2 = QueryParser.parse(word,"content",new StandardAnalyzer());
comboQuery.add(query2, false, false);
Hits hits = searcher.search(comboQuery);
int numResults = hits.length();
for (int i = 0; i < numResults; i++) {
if (count > 0 && logs.size() >= count) break;
if (i < from) continue;
logs.add(new Integer(((Document) hits.doc(i)).get("logId")));
}
}
reader.close();
return logs;
}
public static void delLog(int logId) throws Exception{
Session ssn=ManagerBase.getSession();
LogForm log=(LogForm) ssn.load(LogForm.class,String.valueOf(logId));
ssn.delete(log);
delLogIndex(logId);
}
public static int createLogIndex(Object obj) throws Exception{
LogForm log = (LogForm)obj;
Document doc = new Document();
doc.add(Field.Keyword("logId", String.valueOf(log.getLogId())));
doc.add(new Field("author", log.getAuthor(),false,true,false));
doc.add(new Field("siteId", log.getSiteId(),false,true,false));
doc.add(new Field("logTypeId",log.getLogTypeId(),false,true, false));
doc.add(Field.UnStored("logTitle", StringUtils.deleteWhitespace(log.getLogTitle())));
doc.add(Field.UnStored("content", log.getContent()));
doc.add(new Field("submitTime", log.getSubmitTime(),false,true,false));
IndexWriter writer = getLogIndexWriter();
try {
writer.addDocument(doc);
writer.optimize();
}finally {
writer.close();
}
return 1;
}
public static int createAllLogIndex() throws Exception{
String logPath=getLogIndexPath();
File file=new File(logPath);
delDirectory(file);
Session ssn=ManagerBase.getSession();
String hql="from "+LogForm.class.getName();
net.sf.hibernate.Query query=ssn.createQuery(hql);
List logs = query.list();
IndexWriter writer = getLogIndexWriter();
int logCount=0;
for(int i=0;i<logs.size();i++){
Document doc = new Document();
LogForm log = (LogForm)logs.get(i);
doc.add(Field.Keyword("logId", String.valueOf(log.getLogId())));
doc.add(new Field("author", log.getAuthor(),false,true,false));
doc.add(new Field("siteId", log.getSiteId(),false,true,false));
doc.add(new Field("logTypeId",log.getLogTypeId(),false,true, false));
doc.add(Field.UnStored("logTitle", StringUtils.deleteWhitespace(log.getLogTitle())));
doc.add(Field.UnStored("content", log.getContent()));
doc.add(new Field("submitTime", log.getSubmitTime(),false,true,false));
logCount++;
writer.addDocument(doc);
}
writer.optimize();
writer.close();
System.out.println("建立索引数目:"+logCount);
return logCount;
}
public static int delLogIndex(int logId) throws Exception{
IndexReader reader = IndexReader.open(getLogIndexPath());
if (reader == null)
return 0;
int dc = 0;
try {
Term logIdTerm;
logIdTerm = new Term("logId", Integer.toString(logId));
try {
dc += reader.delete(logIdTerm);
}catch (Exception e) {}
} finally {
try {
reader.close();
} catch (Exception e) {}
}
return dc;
}
/**重建索引、删除索引目录下的所有文件
*
*/
public static void delDirectory(File file) throws IOException{
if((file == null) || !file.isDirectory()){
throw new IllegalArgumentException(file+"不是一个目录.");
}
File[] entries = file.listFiles();
int sz = entries.length;
for(int i=0;i<sz;i++) {
if(entries[i].isDirectory()) {
delDirectory(entries[i]);
}else{
System.out.println(entries[i].getName());
System.out.println(entries[i].getAbsolutePath());
entries[i].delete();
}
}
file.delete();
}
}
程序运行时调用createAllLogIndex()则会创建所有的索引
现在实现jsp添加一个日志来新增一个索引：
<%@ page contentType="text/html;charset=GBK"%>
<style type="text/css">
body {
color: #333333;
font-size: 11px;
font-family: Tahoma, Verdana, sans-serif, "宋体";
margin: 0px;
padding: 0px;
background-position: center top;
}
table {font: 12px Verdana, Tahoma, sans-serif, "宋体";}
</style>
<body>
<table cellspacing="0" cellpadding="2" width="100%">
<tr>
<td>
<table width='100%' border='0' cellspacing='1' cellpadding='2'>
<tr>
<td align="left"><b><font color="#000000">新增日志:</font></b></td>
</tr>
</table>
<table width="100%" border="0" cellspacing="1" cellpadding="2">
<form action="addLog.do" name="log" method="post">
<tr>
<td align="center">日志标题</td>
<td><input type="text" name="logTitle"/><font color="#FF0000"></td>
</tr>
<tr bgcolor="#f8f8f8">
<td align="center">文章分类</td>
<td>
<select name="logTypeId">
<option value="1">JAVA</option>
<option value="2">AJAX</option>
<option value="3">STRUTS</option>
</select>
</td>
</tr>
<tr bgcolor="#f8f8f8">
<td align="center">文章类型</td>
<td>
<input type="text" name="comeForm">
<a onclick="comeForm.value='原创'">原创</a>
<a onclick="comeForm.value='转载'">转载</a>
</td>
</tr>
<tr bgcolor="#f8f8f8">
<td align="center">文章状态</td>
<td>
<select name="state">
<option value="0">公开</option>
<option value="1">草稿</option>
<option value="2">已删除</option>
</select>
</td>
</tr>
<tr bgcolor="#f8f8f8">
<td valign="top" align="center">内 容</td>
<td rowspan="2">
<textarea cols="50" rows="10" name="content"></textarea>
<font color="#FF0000">*</font>
</td>
</tr>
<tr bgcolor="#f8f8f8">
<td align="center"> </td>
</tr>
<tr bgcolor="#f8f8f8">
<td align="center">评 论</td>
<td><input type="radio" name="canComment" value="0">不允许<input type="radio" name="canComment" value="1" checked>允许</td>
</tr>
<tr bgcolor="#f8f8f8">
<td colspan="2" height="40" align="center">
<input type="button" class="button" name="eventSubmit_addLog" onclick="CheckForm()" value="发表"/>
<input type="reset" class="button" name="btn_reset" value="重填"/>
</td>
</tr>
</form>
</table></td>
</tr>
</table>
</body>
<script language="javascript">
function CheckForm()
{
with(document.log){
if(logTitle.value==""){
alert('日志标题不能为空');
logTitle.focus();
return false;
}
if(content.value==""){
alert('日志内容不能为空');
content.focus();
return false;
}
submit();
}
}
</script>
form的addLog.do在struts-config.xml中如下定义
<action path="/addLog" scope="request" name="LogForm" validate="false" type="net.skycity.action.LogAction" input="/index.jsp"/>
action的model层上面已经介绍过了，实现添加文档及索引的是LogAction
package net.skycity.action;
import java.util.Date;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import net.sf.hibernate.Session;
import net.skycity.blog.Globals;
import net.skycity.blog.LogManager;
import net.skycity.blog.ManagerBase;
import net.skycity.model.LogForm;
import net.skycity.util.WellsoonUtil;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
public class LogAction extends Action {
public ActionForward execute(ActionMapping mapping,
ActionForm form, HttpServletRequest request,
HttpServletResponse response) throws Exception
{
LogForm log=(LogForm)form;
Session ssn=ManagerBase.getSession();
try{
log.setAuthor("admin"); //这里为了简便，都取了默认值
log.setSiteId("1");
log.setLogTitle(WellsoonUtil.transfer(log.getLogTitle()));
log.setComeForm(WellsoonUtil.transfer(log.getComeForm()));
log.setSubmitTime(Globals.FORMAT_DT.format(new Date()));
log.setContent(WellsoonUtil.transfer(log.getContent()));
ssn.save(log);
LogManager.createLogIndex(log);
}finally{
ManagerBase.commitSession(ssn, true);
}
return mapping.findForward("success");
}
}
重点是：ssn.save(log); LogManager.createLogIndex(log);前一句，将提交的数据保存到数据库，后一句将提交的数据增加到索引中
通过这些程序，索引文件就已经创建了
Lyyb2001