streamserviceimpl.java

菲律宾的一个大学的图书管理系统 spring+hibernate+velocity

/*
 * 创建日期 2005-5-17
 */
package biz.bluesky.pts.service.impl;

import java.util.List;

import biz.bluesky.pts.model.TStream;
import biz.bluesky.pts.service.IStreamService;
import biz.bluesky.pts.service.dao.IStreamDAO;

import biz.bluesky.pts.util.ErrorCode;

import org.springframework.dao.DataIntegrityViolationException;
import org.springframework.orm.ObjectRetrievalFailureException;
import org.springframework.dao.DataAccessException;


public class StreamServiceImpl implements IStreamService {
    
    private IStreamDAO streamDAO;

    public void setStreamDAO(IStreamDAO streamDAO) {
        this.streamDAO = streamDAO;
    }

    public IStreamDAO getStreamDAO() {
        return this.streamDAO;
    }

    //根据流编号查询流
    public TStream findStream(int streamId) {
        TStream stream = null;
        
        try {
            stream = streamDAO.findStream(streamId);
        }
        catch(ObjectRetrievalFailureException excp) {
            
        }
        
        return stream;
    }

    //根据流名称查询流
    public TStream findStream(String streamName) {
        return streamDAO.findStream(streamName);
    }

    //查询所有的流
    public List findStreams() {
        return streamDAO.findStreams();
    }

    //保存流
    public int saveStream(TStream stream) {
        if((stream == null)||(stream.getStream().equals(""))) {
            return ErrorCode.ERR_STREAM_EMPTY;
        }
        
        try {
            streamDAO.saveObject(stream);
        }
        catch(DataIntegrityViolationException excp) {
            return ErrorCode.ERR_STREAM_REPEAT;
        }
        
        return ErrorCode.ERR_UNDISCOVERED;
    }

    //删除流	
    public int removeStream(int streamId) {
        try {
            streamDAO.removeStream(streamId);
        }
        catch(ObjectRetrievalFailureException excp) {
            return ErrorCode.ERR_STREAM_NOT_FIND;
        }
        catch(DataAccessException excp) {
            return ErrorCode.ERR_UNKNOW;
        }
        
        return ErrorCode.ERR_UNDISCOVERED;
    }

}