emseinfodao.java

中国移动定位引擎的客户端

package ffcs.lbp.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.LinkedList;
import java.util.List;

import ffcs.db.DBPool;
import ffcs.db.JdbcUtil;

/**
* <p>Title: 小区推送LBP项目</p>
* <p>Description:
*   访问实体信息DAO，提供实体查询功能
* </p>
* <p>Copyright: 2007 福建福富软件技术股份有限公司 </p>
* <p>Company: 福建福富软件技术股份有限公司</p>
* @author chenxin
* @version $Rev:1.0 $Date: 2007-06-28
*/
public class EmseInfoDao {
    private String sqlEmseInfo ="select emse_no,type_id,emse_id,emse_ip,emse_port,inte_user,Inte_password,entity_user, entity_password,support_version,emse_status,alarm_flag,max_rece_link,max_rece_rate, max_send_link,max_send_rate,conn_status,login_mode,synch_port,synch_login_mode,run_intf_seq from emse_info";
	/**
	 * 根据实体类型条件得到实体信息列表
	 * @param typeId　实体类型
	 * @return　实体列表，如果没记录返回null
	 * @throws SQLException
	 */
    public List getEmseInfoList(int typeId) throws SQLException {
    	return getEmseInfoList(typeId,null,null);
    }

	/**
	 * 根据"实体类型"和"实体运行接口序号"条件得到实体信息列表
	 * @param typeId　实体类型
	 * @param runIntfSeq
	 * @return　实体记录列表，如果没记录返回null
	 * @throws SQLException
	 */
    public List getEmseInfoList(int typeId,int runIntfSeq) throws SQLException {
    	return getEmseInfoList(typeId,runIntfSeq,null,null);
    }
    /**
     * 查询实体信息列表
     * @param typeId 实体类型
     * @param emseUser　实体用户名
     * @param emsePass　实体密码
     * @return　实体记录列表，如果没记录返回null
     * @throws SQLException
     */
    public List getEmseInfoList(int typeId,String emseUser,String emsePass) throws SQLException {
    	return getEmseInfoList(typeId,-1,emseUser,emsePass);
    }
    	   
    /**
     * 查询实体信息列表
     * @param typeId 实体类型
     * @param runIntfSeq 运行接口编号
     * @param emseUser　实体用户名
     * @param emsePass　实体密码
     * @return　实体记录列表，如果没记录返回null
     * @throws SQLException
     */
    public List getEmseInfoList(int typeId,int runIntfSeq,String emseUser,String emsePass) throws SQLException {
    	StringBuffer  sql = new StringBuffer(sqlEmseInfo);
    	sql.append(" where 1=1");
    	if(typeId!=0){
    		sql.append(" and type_id=" + typeId ) ;
    	}
    	if(runIntfSeq>-1){
    		sql.append(" and run_intf_seq=" + runIntfSeq ) ;
    	}
    	if(emseUser != null ){
    		sql.append(" and entity_user='" + emseUser +"'") ;
    	}
    	if(emsePass!=null){
    		sql.append(" and entity_password='" + emsePass + "'") ;
    	}
    	sql.append(" order by emse_id");
    	
    	//System.out.println(sql.toString());
    	Connection conn = null;
    	Statement st =null;
        ResultSet rs = null;
        LinkedList list = null;
        try{
            conn = DBPool.getConnection();
            st = conn.createStatement();
            rs = st.executeQuery(sql.toString());
            if (rs.next()) {
            	list = new LinkedList();
                list.add(maping(rs));
            }
            while (rs.next()) {
            	list.add(maping(rs));
            }
        } finally {
            JdbcUtil.closeResultSet(rs);
            JdbcUtil.closeStat(st);
            JdbcUtil.closeConn(conn);
        }
        return list;
    }

    /**
     * 从数据库中读取配置信息,更新系统配置参数
     */
    public LocInfoMgr getEmseInfo(int typeId) throws SQLException {
    	return getEmseInfo(typeId,null,null);
    }
    /**
     * 从数据库中读取配置信息,更新系统配置参数
     */
    public LocInfoMgr getEmseInfo(int typeId,String emseUser,String emsePass) throws SQLException {
    	List list  = getEmseInfoList(typeId,emseUser,emsePass);
    	if(list==null || list.size()==0){
    		return null;
    	}
    	return (LocInfoMgr)list.get(0);
    }
	private LocInfoMgr maping(ResultSet rs){
		LocInfoMgr emse=null;
		try{
			emse = new LocInfoMgr();
			emse.setEmseNo(rs.getString("emse_no"));
			emse.setEmseId(rs.getInt("emse_id"));
			emse.setTypeId(rs.getInt("type_id"));
			emse.setEmseIp(rs.getString("emse_ip"));
			emse.setEmsePort(rs.getInt("emse_port"));			
			emse.setInteUser(rs.getString("inte_user"));
			emse.setIntePassword(rs.getString("inte_password"));
			emse.setEntityUser(rs.getString("entity_user"));
			emse.setEntityPassword(rs.getString("entity_password"));
			emse.setSupportVersion("support_version");
			emse.setEmseStatus(rs.getInt("emse_status"));
			emse.setAlarmFlag(rs.getInt("alarm_flag"));
			emse.setMaxReceLink(rs.getInt("max_rece_link"));
			emse.setMaxReceRate(rs.getInt("max_rece_rate"));
			emse.setMaxSendLink(rs.getInt("max_send_link"));
			emse.setMaxSendRate(rs.getInt("max_send_rate"));
			emse.setLoginMode(rs.getInt("login_mode"));
			emse.setConnStatus(rs.getInt("conn_status"));
			emse.setSynchPort(rs.getInt("synch_port"));
			emse.setSynchLoginMode(rs.getInt("synch_login_mode"));
			emse.setRunIntfSeq(rs.getInt("run_intf_seq"));
			
		}catch(SQLException e){
			e.printStackTrace();
		}
	    return emse;
	}
}