oracleoperatordao.java

中国移动系统 给了前台了

package db;

import java.sql.*;
import java.util.*;
import bean.Operator;


public class OracleOperatorDAO implements OperatorDAO
{
	private final String INSERT_AN_OPERATOR = "insert into TOperator values(?,?,?,?)";
	private final String GET_ALL_OPERATORS = "select * from TOperator order by operator_id";
	private final String GET_AN_OPERATOR = "select * from TOperator where operator_id=? and operator_pwd=?";
	

     /**
    *判断数据库中是否存在某个Operator
    */ 
    public boolean isExists(Operator operator)
    {
        Connection conn = null;
        PreparedStatement stmt = null;
        boolean tmp = true;
        
	    try
	    {    
           	conn = OracleDAOFactory.getConnection();
	        stmt = conn.prepareStatement(GET_AN_OPERATOR);
	        stmt.setString(1,operator.getOperator_ID());
	        stmt.setString(2,operator.getOperator_Pwd());
	        ResultSet result = stmt.executeQuery();
	        if(result.next())
	            tmp = true;	            
	    }
	    catch(SQLException e)
	    {
	        tmp = false;
	    }
	    finally
	    {
	        OracleDAOFactory.closeStatement(stmt);
	        OracleDAOFactory.closeConnection(conn);
	    }
	    
	    return tmp;
    }   
    /**
    *插入一条operator记录
    */
    public boolean createOperator(Operator operator)
    {
	    Connection conn = null;
            PreparedStatement stmt = null;
            boolean tmp = true;
	    try
	    {
	        conn = OracleDAOFactory.getConnection();
	        stmt = conn.prepareStatement(INSERT_AN_OPERATOR);
	        stmt.setString(1,operator.getOperator_ID());
	        stmt.setString(2,operator.getOperator_Name());
	        stmt.setString(3,operator.getOperator_Pwd());
	        stmt.setString(4,operator.getIs_Admin());
	        int result = stmt.executeUpdate();
	        if(result != 1)
	            tmp = false;
	            
	    }
	    catch(SQLException e)
	    {
	        tmp = false;
	    }
	    finally
	    {
	        OracleDAOFactory.closeStatement(stmt);
	        OracleDAOFactory.closeConnection(conn);
	    }
	    return tmp; 
    }
    /**
    *获得所有operator记录
    */
    public Iterator getAllOperators()
    {
        Connection conn = null;
        PreparedStatement stmt = null;
        try
	    {  
	        conn = OracleDAOFactory.getConnection();
	        stmt = conn.prepareStatement(GET_ALL_OPERATORS);
	        Operator operator = null;
	        ResultSet rs = stmt.executeQuery();
	        ArrayList operators = new ArrayList();
	        while(rs.next())
	        {
	            operator = new Operator();
	            operator.setOperator_ID(rs.getString("operator_id"));
	            operator.setOperator_Name(rs.getString("operator_name"));
	            operator.setOperator_Pwd(rs.getString("operator_pwd"));
	            operator.setIs_Admin(rs.getString("is_admin"));
	            operators.add(operator);
	        }
	        return operators.iterator();
	    }
	    catch(SQLException e)
	    {
	        e.printStackTrace();
	        return null;
	    }
	    finally
	    {
	        OracleDAOFactory.closeStatement(stmt);
	        OracleDAOFactory.closeConnection(conn);
	    }
    }    
}