ChinaMobile.rar_chinamobile_中国移动

package dao.product.mysql; 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 MySQLTOperatorDAO 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 MySQLDbUtil(); 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 MySQLDbUtil(); 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 MySQLDbUtil(); 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 MySQLDbUtil(); 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 MySQLDbUtil(); 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 MySQLDbUtil(); 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()); } }