basicdaoimpl.java

基本功能都实现了,对财务的增加,删除财务的信息,修改信息,查出财务的详细信息

package com.cn.cms.dao.impl;
import java.sql.SQLException;
import com.cn.cms.dao.BasicDao;
import com.cn.cms.util.DBConnection;
import java.sql.PreparedStatement;
import java.sql.Statement;
import java.sql.ResultSet;
import com.cn.cms.javabean.UserBean;
import java.util.List;
import java.util.ArrayList;
public class BasicDaoImpl
    implements BasicDao {
  private DBConnection connect = null;
  private ResultSet rst = null;
  private PreparedStatement pstmt = null;
  private Statement stmt = null;
  public BasicDaoImpl() {
    connect = new DBConnection();
  }

  public UserBean FindByuserName(String userName) {
    UserBean usebean = new UserBean();
    try {
      String sql =
          "select userName,password,user_right from users where userName ='" +
          userName + "'";
      stmt = connect.getDBConnection().createStatement();
      rst = stmt.executeQuery(sql);
      while (rst.next()) {
       usebean.setUserName(rst.getString("userName"));
       usebean.setPassword(rst.getString("password"));
       usebean.setUser_right(rst.getString("user_right"));
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    finally {
      if (connect != null) {
        connect.closeConnection();
      }
      if (stmt != null) {
        connect.closeStatement(stmt);
      }
      if (rst != null) {
        connect.closeResultSet(rst);
      }
    }
    return usebean;
  }

  public List FindbyAll() {
    List uselist = new ArrayList();
    try {
      String sql = "select userName,password,user_right from users";
      stmt = connect.getDBConnection().createStatement();
      rst = stmt.executeQuery(sql);
      while (rst.next()) {
        UserBean usebean = new UserBean();
        usebean.setUserName(rst.getString("userName"));
        usebean.setPassword(rst.getString("password"));
        usebean.setUser_right(rst.getString("user_right"));
        uselist.add(usebean);
      }
    }
    catch (SQLException ex) {
      ex.printStackTrace();
    }
    finally {
      if (connect != null) {
        connect.closeStatement(stmt);
      }
      if (connect != null) {
        connect.closeResultSet(rst);
      }
      if (connect != null) {
        connect.closeConnection();
      }
    }
    return uselist;
  }

  public boolean deluseByuserName(String userName) {
    try{
      String sql = "delete  from users where userName='"+userName+"'";
      stmt = connect.getDBConnection().createStatement();
      int result =0;
     result  = stmt.executeUpdate(sql);
      if(result!=0)return true;
      else return false;
    }catch(Exception ex){
    ex.printStackTrace();
    return false;
    }finally{
    if(connect!=null)connect.closeStatement(stmt);
    if(connect!=null)connect.closeConnection();
    }
  }

  public boolean modifyByuseName(UserBean usebean) {
    try{

      String sql ="update users set password='"+usebean.getPassword()+"' where userName='"+usebean.getUserName()+"'";
      stmt = connect.getDBConnection().createStatement();
      int result =0;
      result = stmt.executeUpdate(sql);
      if(result!=0)return true;
      else return false;

    }catch(SQLException ex){
      ex.printStackTrace();
    }finally{
      if(connect!=null)connect.closeStatement(stmt);
      if(connect!=null)connect.closeConnection();
    }
    return false;
  }

  public boolean Insertuse(UserBean usebean) {
    try{
     String sql ="insert into users values(?,?,?)";
     pstmt = connect.getDBConnection().prepareStatement(sql);
     int iLoop=1;
     pstmt.setString(iLoop++,usebean.getUserName());
     pstmt.setString(iLoop++,usebean.getPassword());
     pstmt.setString(iLoop++,usebean.getUser_right());
     int result = 0;
     result = pstmt.executeUpdate();
     if(result!=0)return true;
     else return false;
    }catch(SQLException ex){
     ex.printStackTrace();
    }
    return false;
  }

  public boolean modifyRight(UserBean usebean) {
    try{
      String sql ="update users set user_right='"+usebean.getUser_right()+"' where userName='"+usebean.getUserName()+"'";
      stmt = connect.getDBConnection().createStatement();
      int result =0;
      result = stmt.executeUpdate(sql);
      if(result!=0)return true;
      else return false;
    }catch(SQLException ex){
      ex.printStackTrace();
    }finally{
      if(connect!=null)connect.closeStatement(stmt);
        if(connect!=null)connect.closeConnection();
    }
    return false;
  }
}