messagedaodecorator.java

非常有影响的 j道 论 坛 源码 国外很有明的专家编写的 ....对java爱好者很有参考价值

/*
 * Copyright 2003-2005 the original author or authors.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * 
 */
package com.jdon.jivejdon.dao.filter;

import org.apache.log4j.Logger;

import com.jdon.jivejdon.Constants;
import com.jdon.jivejdon.dao.AccountDao;
import com.jdon.jivejdon.dao.PropertyDao;
import com.jdon.jivejdon.dao.UploadFileDao;
import com.jdon.jivejdon.dao.search.MessageSearchProxy;
import com.jdon.jivejdon.dao.sql.JdbcTempSource;
import com.jdon.jivejdon.dao.sql.MessageDaoSql;
import com.jdon.jivejdon.dao.util.MessagePageIteratorSolver;
import com.jdon.jivejdon.model.ForumMessage;
import com.jdon.jivejdon.model.ForumMessageReply;
import com.jdon.jivejdon.model.ForumThread;
import com.jdon.jivejdon.repository.builder.MessageInitFactory;
import com.jdon.jivejdon.service.util.ContainerUtil;
import com.jdon.model.query.PageIteratorSolver;

/**
 * Cache decorator
 * 
 * @author <a href="mailto:[e-mail]">banq</a>
 *
 */
public class MessageDaoDecorator extends MessageDaoSql {
	private final static Logger logger = Logger.getLogger(MessageDaoDecorator.class);

	private ContainerUtil containerUtil;
	protected PageIteratorSolver pageIteratorSolver;
	protected MessageSearchProxy messageSearchProxy;

	public MessageDaoDecorator(MessagePageIteratorSolver messagePageIteratorSolver, JdbcTempSource jdbcTempSource, ContainerUtil containerUtil,
			AccountDao accountDao, PropertyDao propertyDao, UploadFileDao uploadFileDao, MessageSearchProxy messageSearchProxy,
			MessageInitFactory messageFactory, Constants constants) {
		super(jdbcTempSource, messageFactory, constants);
		this.containerUtil = containerUtil;
		this.pageIteratorSolver = messagePageIteratorSolver.getPageIteratorSolver();
		this.messageSearchProxy = messageSearchProxy;
	}

	/**
	 * active the cache
	 */
	public ForumMessage getMessage(Long messageId) {
		logger.debug("MessageDaoDecorator's getMessage, id=" + messageId);

		ForumMessage forumMessage = (ForumMessage) containerUtil.getModelFromCache(messageId, ForumMessageReply.class);
		if (forumMessage != null)
			return forumMessage;

		forumMessage = (ForumMessage) containerUtil.getModelFromCache(messageId, ForumMessage.class);
		if (forumMessage != null)
			return forumMessage;

		logger.debug("not found the forumMessage in the cache, id=" + messageId);
		forumMessage = super.getMessage(messageId);
		containerUtil.addModeltoCache(messageId, forumMessage);
		return forumMessage;
	}

	public ForumThread getThread(Long threadId) {
		ForumThread forumThread = (ForumThread) containerUtil.getModelFromCache(threadId, ForumThread.class);
		if (forumThread != null)
			return forumThread;

		forumThread = super.getThread(threadId);
		if (forumThread == null) {
			return null;
		}
		saveCache(forumThread);
		return (ForumThread) containerUtil.getModelFromCache(threadId, ForumThread.class);
	}

	//check again put it if absent ensure the thread is only singleton, because it shared with many message.
	private void saveCache(ForumThread forumThread) {
		ForumThread forumThreadOld = (ForumThread) containerUtil.getModelFromCache(forumThread.getThreadId(), ForumThread.class);
		//check again put it if absent
		if (forumThreadOld == null)
			containerUtil.addModeltoCache(forumThread.getThreadId(), forumThread);

	}

	public void createMessage(ForumMessage forumMessage) throws Exception {
		super.createMessage(forumMessage);//db
		messageSearchProxy.createMessage(forumMessage);//

		//refresh the batch inquiry cache
		pageIteratorSolver.clearCache();
	}

	public void createMessageReply(ForumMessageReply forumMessageReply) throws Exception {
		super.createMessageReply(forumMessageReply);
		messageSearchProxy.createMessageReply(forumMessageReply);

		//refresh the batch inquiry cache
		pageIteratorSolver.clearCache();
	}

	public void updateMessage(ForumMessage forumMessage) throws Exception {
		super.updateMessage(forumMessage);
		messageSearchProxy.updateMessage(forumMessage);

		containerUtil.clearCache(forumMessage.getMessageId());
		//refresh the batch inquiry cache
		pageIteratorSolver.clearCache();
	}

	/**
	 * if this deleted message is the last message, we must
	 * refresh the forum state.
	 */
	public void deleteMessage(Long forumMessageId) throws Exception {
		//second  delete the message from database
		super.deleteMessage(forumMessageId);
		messageSearchProxy.deleteMessage(forumMessageId);

		containerUtil.clearCache(forumMessageId);
		pageIteratorSolver.clearCache();
	}

	public void updateThread(ForumThread forumThread) throws Exception {
		super.updateThread(forumThread);
		//refresh the batch inquiry cache
		pageIteratorSolver.clearCache();
	}

	/**
	 * deleteThread always combined with deleteMessage.
	 */
	public void deleteThread(Long forumThreadId) throws Exception {
		super.deleteThread(forumThreadId);
		containerUtil.clearCache(forumThreadId);
		//refresh the batch inquiry cache
		pageIteratorSolver.clearCache();
	}

}