daofactory.java

来自「一个用struts tiles的在线影院web系统」· Java 代码 · 共 44 行

package com.eline.vod.dao;

import java.sql.SQLException;

import com.eline.vod.exceptions.GroupDAOSysException;

public class DAOFactory {
	public static MovieDAO getMovieDAO(String dataProvider) throws SQLException {
		// Default case
		if (dataProvider == null || dataProvider.equals("") || dataProvider.equalsIgnoreCase("SQLServer"))
			return new MSSqlMovieDAO();
		else if (dataProvider.equalsIgnoreCase("Oracle"))
			throw new SQLException("当前版本不支持Oracle数据库");
		else if (dataProvider.equalsIgnoreCase("MySQL"))
			throw new SQLException("当前版本不支持MySQL数据库");
		
		return null;
	}
	
	public static MovieChapterDAO getMovieChapterDAO(String dataProvider) throws SQLException {
		// Default case
		if (dataProvider == null || dataProvider.equals("") || dataProvider.equalsIgnoreCase("SQLServer"))
			return new MSSqlMovieChapterDAO();
		else if (dataProvider.equalsIgnoreCase("Oracle"))
			throw new SQLException("当前版本不支持Oracle数据库");
		else if (dataProvider.equalsIgnoreCase("MySQL"))
			throw new SQLException("当前版本不支持MySQL数据库");
		
		return null;
	}
	
	static public GroupDAO getGroupDAO() throws GroupDAOSysException {
        GroupDAO groupDao = null;
        try {
            groupDao = new MSSqlGroupDAO();
        } catch (GroupDAOSysException e) {
            throw new GroupDAOSysException("DAOFactory.getGroupDAO:  GroupDAOSysException while getting DAO type : \n" + e.getMessage());
        } catch (Exception e) {
            throw new GroupDAOSysException("DAOFactory.getGroupDAO:  Exception while getting DAO type : \n" + e.getMessage());
        }
        return groupDao;
    }
}