oracletoperatordao.java

这是我在东方标准学习的时候做的一个项目

package dao.product.oracle;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import dao.product.DbUtil;
import dao.product.TOperatorDAO;

import bean.TOperator;

public class OracleTOperatorDAO implements TOperatorDAO {

	/*
	 * this method verify whether the login is successfull
	 * return
	 *   common.Constant.ERROR
	 *   common.Constant.ADMIN
	 *   common.Constant.OPERATOR
	 */
	public int verifyOperator(String operator_id, String operator_pwd) {
		int result = common.Constant.ERROR;
		DbUtil db = new OracleDbUtil();
		Connection conn = db.getConnection();
		String sql = "select * from TOPERATOR where operator_id=? and operator_pwd=?";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1, operator_id);
			prepStmt.setString(2, operator_pwd);
			ResultSet rs = prepStmt.executeQuery();
			while(rs.next()) {
				String role = rs.getString("is_admin");
				if("Y".equalsIgnoreCase(role)) {
					result = common.Constant.ADMIN;
				}
				if("N".equalsIgnoreCase(role)) {
					result = common.Constant.OPERATOR;
				}
			}
			return result;
		} catch (SQLException e) {
			e.printStackTrace();
			return common.Constant.ERROR;
		} finally {
			db.close();
		}		
		
	}
	
	public boolean add(TOperator operator) {
		DbUtil db = new OracleDbUtil();
		Connection conn = db.getConnection();
		String sql = "INSERT INTO TOPERATOR VALUES(?,?,?,?)";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1, operator.getOperator_id());
			prepStmt.setString(2, operator.getOperator_name());
			prepStmt.setString(3, operator.getOperator_pwd());
			prepStmt.setString(4, operator.getIs_admin());
			prepStmt.execute();
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		} finally {
			db.close();
		}
	}
	
	public boolean delete(String id) {
		id = fillVacancy(id);
		DbUtil db = new OracleDbUtil();
		Connection conn = db.getConnection();
		String sql = "delete TOperator where operator_id=?";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1, id);
			prepStmt.execute();
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		} finally {
			db.close();
		}
	}
	
	public boolean update(TOperator operator) {
		DbUtil db = new OracleDbUtil();
		Connection conn = db.getConnection();
		String sql = "update TOperator set operator_name=?,operator_pwd=?,is_admin=? where operator_id=?";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1, operator.getOperator_name());
			prepStmt.setString(2, operator.getOperator_pwd());
			prepStmt.setString(3, operator.getIs_admin());
			prepStmt.setString(4, operator.getOperator_id());
			prepStmt.execute();
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		} finally {
			db.close();
		}
	}
	
	public TOperator findByID(String id) {
		id = fillVacancy(id);
		TOperator operator = new TOperator();
		DbUtil db = new OracleDbUtil();
		Connection conn = db.getConnection();
		String sql = "select operator_id,operator_name,operator_pwd,is_admin from TOperator where operator_id=?";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1, id);
			ResultSet rs = prepStmt.executeQuery();
			while(rs.next()) {
				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"));
			}
			return operator;
		} catch (SQLException e) {
			e.printStackTrace();
			return null;
		} finally {
			db.close();
		}
	}
	
	public List findAll() {
		List<TOperator> list = new ArrayList<TOperator>();
		DbUtil db = new OracleDbUtil();
		Connection conn = db.getConnection();
		String sql = "select operator_id,operator_name,operator_pwd,is_admin from TOperator";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			ResultSet rs = prepStmt.executeQuery();
			while(rs.next()) {
				TOperator operator = new TOperator();
				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"));
				list.add(operator);
			}
			return list;
		} catch (SQLException e) {
			e.printStackTrace();
			return null;
		} finally {
			db.close();
		}
	}
	
	public static String fillVacancy(String str) {
		if(str.length()==10) {
			return str;
		}
		if(str.length() > 10) {
			return null;
		}
		StringBuffer sb = new StringBuffer(str);
		for(int i = 0; i< 10-str.length(); i++) {
			sb.append(" ");
		}
		return sb.toString();
	}
	
	public static void main(String[] args) {
		TOperatorDAO test = new OracleTOperatorDAO();
		TOperator operator = new TOperator();
		operator.setOperator_id("seeafafa");
		operator.setOperator_name("Shit2");
		operator.setOperator_pwd("123");
		test.add(operator);
//		operator = test.findByID("a87gha ");
//		System.out.println(operator.getOperator_name());
//		
//		//test.delete("f33333    ");
//		List list = test.findAll();
//		System.out.println(((TOperator)list.get(0)).getOperator_name());
		
		
//		List list = new ArrayList();
//		list = test.findAll();
//		System.out.println(((TOperator)list.get(2)).getOperator_pwd());
//		System.out.println(((TOperator)list.get(2)).getOperator_name());
	}

}