www.pudn.com > ClientManager.rar > UserDaoImpl.java

package com.dao; 
 
import com.domain.UserForm; 
import com.tool.JDBConnection; 
import com.tool.SQLCode; 
import java.sql.*; 
import java.util.List; 
import java.util.ArrayList; 
 
import javax.management.j2ee.statistics.JDBCConnectionStats; 
/** 
 *  
 * 
Title: 客户管理系统
 
 * 
 * 
Description: 用户信息操作实现类
 
 * 
 * 
Copyright: Copyright (c) 2008
 
 * 
 * 
Company: 
 
 * 
 * @author yaoxj 
 * @version 1.0  2008-7-10 
 */ 
//操作员 
public class UserDaoImpl 
    implements UserDao { 
//  private JDBConnection connection = new JDBConnection(); 
 
//登陆操作 
  public UserForm checkUser(UserForm form) { 
    UserForm user = null; 
    String sql = SQLCode.getSQLCode("sql.user.check"); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_name()); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs=null; 
    try { 
//    	conn=JDBConnection.getConn(); 
//    	stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, 
//                ResultSet.CONCUR_READ_ONLY); 
//    	rs=stmt.executeQuery(sql); 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        user = new UserForm(); 
        user.setId(Integer.valueOf(rs.getString(1))); 
        user.setUser_id(rs.getString(2)); 
        user.setUser_name(rs.getString(3)); 
        user.setUser_mm(rs.getString(4)); 
        user.setUser_bs(rs.getString(5)); 
        user.setMenu_jcxx(rs.getString(6)); 
        user.setMenu_khxx(rs.getString(7)); 
        user.setMenu_khfw(rs.getString(8)); 
        user.setMenu_xxcx(rs.getString(9)); 
        user.setMenu_fzgj(rs.getString(10)); 
        user.setMenu_xtgl(rs.getString(11)); 
        user.setMenu_sjgl(rs.getString(12)); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
    return user; 
  } 
 
//修改操作员密码 
  public void updateUserPassword(UserForm form) { 
    String sql = SQLCode.getSQLCode("sql.user.updatePassword"); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_mm()); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_id()); 
    JDBConnection.executeUpdate(sql); 
  } 
 
//查询授权的操作 
  public List selectUserBs(UserForm form) { 
    List list = new ArrayList(); 
    UserForm user = null; 
    String sql = SQLCode.getSQLCode("sql.user.selectUser_bs"); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_bs()); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        user = new UserForm(); 
        user.setId(Integer.valueOf(rs.getString(1))); 
        user.setUser_id(rs.getString(2)); 
        user.setUser_name(rs.getString(3)); 
        user.setUser_mm(rs.getString(4)); 
        user.setUser_bs(rs.getString(5)); 
        user.setMenu_jcxx(rs.getString(6)); 
        user.setMenu_khxx(rs.getString(7)); 
        user.setMenu_khfw(rs.getString(8)); 
        user.setMenu_xxcx(rs.getString(9)); 
        user.setMenu_fzgj(rs.getString(10)); 
        user.setMenu_xtgl(rs.getString(11)); 
        user.setMenu_sjgl(rs.getString(12)); 
        list.add(user); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
    return list; 
 
  } 
 
//修改权利 
  public void updateUserRight(UserForm form) { 
    String sql = SQLCode.getSQLCode("sql.user.updateSelectRight"); 
    sql = JDBConnection.editSqlCode(sql, form.getMenu_jcxx()); 
    sql = JDBConnection.editSqlCode(sql, form.getMenu_khxx()); 
    sql = JDBConnection.editSqlCode(sql, form.getMenu_khfw()); 
    sql = JDBConnection.editSqlCode(sql, form.getMenu_xxcx()); 
    sql = JDBConnection.editSqlCode(sql, form.getMenu_fzgj()); 
    sql = JDBConnection.editSqlCode(sql, form.getMenu_sjgl()); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_id()); 
    JDBConnection.executeUpdate(sql); 
  } 
 
//帐号唯一性的操作 
  public int countID() { 
    int iCount = 0; 
    String sql = SQLCode.getSQLCode("sql.user.countID"); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs = null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
 
        iCount = rs.getInt("t"); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
    return iCount + 1; 
 
  } 
 
  public void insertUserRight(UserForm form) { 
    String sql = SQLCode.getSQLCode("sql.user.insert"); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_id()); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_name()); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_mm()); 
 
    JDBConnection.executeUpdate(sql); 
 
 
  } 
 
  public void deleteUserRight(UserForm form) { 
    String sql = SQLCode.getSQLCode("sql.user.delete"); 
    sql = JDBConnection.editSqlCode(sql, form.getUser_id()); 
    JDBConnection.executeUpdate(sql); 
  } 
}