userinfodao.java

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

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


package ffcs.lbp.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.Vector;

import ffcs.db.DBPool;
import ffcs.db.JdbcUtil;
import ffcs.db.SqlExecutor;
import ffcs.lbp.SagClient.SagCycLoc;
import ffcs.logging.Log;
import ffcs.logging.LogFactory;


public class UserInfoDao {
	private static Log log = LogFactory.getLog(UserInfoDao.class);
    SqlExecutor sqlExecute = new SqlExecutor();
    private String sqlUserInfo ="select ms_isdn from user_attribute_info";
            
    /**
     * 默认的构告函数
     */
    public UserInfoDao() {
    }

    
    /**
     * 匹配数据记录中的用户信息，返回用户信息类对象
    */
    
	private UserInfo maping(ResultSet rs){
		UserInfo userInfo=null;
		try{
			userInfo = new UserInfo();
			userInfo.setMsIsdn(rs.getString("ms_isdn"));
//			userInfo.setPassword(rs.getString("password"));
//			userInfo.setUserName(rs.getString("user_name"));
//			userInfo.setServiceFlag(rs.getString("service_flag"));
//			userInfo.setAreaId(rs.getInt("area_id"));
//			userInfo.setStatus(rs.getInt("status"));
			
		}catch(SQLException e){
			e.printStackTrace();
		}
		
	    return userInfo;
	}
	
	
	
	 /**
     * 从数据库中读取用户信息
     */
    public LinkedList getUserByRange(String Range) throws SQLException {
    	
    	String sql =sqlUserInfo;
    	if(!Range.equals("")){
    		sql +=" where ms_isdn like '" + Range + "%'";
    	}
    	
    // 	System.out.println(sql);
    	Connection conn = null;
        ResultSet rs = null;
        LinkedList<String> list = null;
        
        try{
            conn = DBPool.getConnection();
            rs = sqlExecute.executeQuery(conn, sql);
            if (rs.next()) {
            	list = new LinkedList<String>();
            	list.add(rs.getString("msisdn"));
            }
            while (rs.next()) {
            	list.add(rs.getString("msisdn"));
            }
          
        } catch (SQLException sqle) {
            System.err.println(sqle);
            return null;
        } finally {
            JdbcUtil.closeResultSet(rs);
            JdbcUtil.closeConn(conn);
        }
        return list;
      
    }
    /**
     * 输入一个号段的集合，输出真实号码的列表
     * @param it 号段的集合
     * @return load出来的一个个真实号码的列表
     */
 public LinkedList getUserByRangesFromDB(Iterator it) {
		Connection conn = null;
        ResultSet rs = null;
        LinkedList<String> list = new LinkedList<String>();
    	String sql =sqlUserInfo+" where 1=1 ";
    	try{
    	while (it.hasNext()){
    		sql+=" and ms_isdn like '"+(String)it.next()+"%' ";
            conn = DBPool.getConnection();
            rs = sqlExecute.executeQuery(conn, sql);
            while (rs!=null&&rs.next()) {
              	list.add(rs.getString("msisdn"));
            }
    	}//end while
        } catch (SQLException sqle) {
            log.error("用号段load用户时，SQL异常"+sqle);
            return null;
        } finally {
            JdbcUtil.closeResultSet(rs);
            JdbcUtil.closeConn(conn);
        }
    	
        return list;
      
    }
 public Vector<String> getUserByRangesFromDB(String it)  {
 	
 	String sql =sqlUserInfo+" where 1=1 ";
 
 		sql+=" and ms_isdn like '"+it+"%' ";

// 	System.out.println(sql);
     // 	System.out.println(sql);
 	Connection conn = null;
     ResultSet rs = null;
     Vector<String> list = null;

     
     try{
         conn = DBPool.getConnection();
         rs = sqlExecute.executeQuery(conn, sql);
       while (rs!=null&&rs.next()) {
         	list = new Vector<String>();
         	list.add(rs.getString("msisdn"));
         }
   
       
     } catch (SQLException sqle) {
    	  log.error("用号段load用户时，SQL异常"+sqle);
         return null;
     } finally {
         JdbcUtil.closeResultSet(rs);
         JdbcUtil.closeConn(conn);
     }
     return list;
   
 }

	public boolean addUser(String isdn,long availtime){
		return true;
	}
	public boolean delUser(String isdn){
		return true;
	}
}