userdaoimpl.java

使用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;
/**
 * 
 * <p>Title: 客户管理系统</p>
 *
 * <p>Description: 用户信息操作实现类</p>
 *
 * <p>Copyright: Copyright (c) 2008</p>
 *
 * <p>Company: </p>
 *
 * @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);
  }
}