cfgservinfodao.java

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

/**
*
* <p>Title: 访问数据库类</p>
* <p>Description: 实现对业务信息的查询</p>
* <p>Copyright: Copyright (c) 200７</p>
* <p>Company: 福富软件</p>
* @author chenxin
* @version 1.0 $Date 2007-10-10
*/


package ffcs.lbp.dao;

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

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


public class CfgServInfoDao {
    SqlExecutor sqlExecute = new SqlExecutor();
            
    /**
     * 默认的构告函数
     */
    public CfgServInfoDao() {
    }

  
    /**
     * 在数据库中查询业务信息
    */
    
public CfgServInfo getCfgServInfo(int serviceId,int chargeType) throws SQLException {
    	
    	String sql ="select  SERVICE_ID,FIX_FEE,SP_SERVICE_ID" 
    	    		+ " from CFG_SERVICE_INFO "
    	    		+ " where CHARGE_TYPE=" + chargeType + " and SERVICE_ID=" +serviceId;
    
    	Connection conn = null;
        ResultSet rs = null;
        CfgServInfo csi=null;
        
        try{
            conn = DBPool.getConnection();
            rs = sqlExecute.executeQuery(conn, sql);
            if (rs.next()) {
          
            	csi=maping(rs);
            }
           
        } catch (SQLException sqle) {
            System.err.println(sqle);
        } finally {
            JdbcUtil.closeResultSet(rs);
            JdbcUtil.closeConn(conn);
        }
        return csi;
    }
    
	private CfgServInfo maping(ResultSet rs){
		CfgServInfo csi=null;
		try{
		    csi = new CfgServInfo();
		    csi.setServiceId(rs.getInt("SERVICE_ID"));
		    csi.setFixFee(rs.getInt("FIX_FEE"));
		    csi.setSpServiceId(rs.getString("SP_SERVICE_ID"));
		   
		}catch(SQLException e){
			e.printStackTrace();
		}
		
	    return csi;
	}
	   
	
	public List getCfgServInfoList(String spServiceId) throws SQLException {
    	
    	String sql ="select  SERVICE_ID,FIX_FEE,SP_SERVICE_ID" 
    	    		+ " from CFG_SERVICE_INFO "
    	    		+ " where  SP_SERVICE_ID='" + spServiceId + "'";
    
    	Connection conn = null;
        ResultSet rs = null;
        LinkedList list = null;
        
        try{
            conn = DBPool.getConnection();
            rs = sqlExecute.executeQuery(conn, sql);
            
            if (rs.next()) {
            	list = new LinkedList();
                list.add(maping(rs));
            }
            while (rs.next()) {
            	list.add(maping(rs));
            }
            
            
           
        } catch (SQLException sqle) {
            System.err.println(sqle);
        } finally {
            JdbcUtil.closeResultSet(rs);
            JdbcUtil.closeConn(conn);
        }
        return list;
    }
	
}