/*** */ package org.dao.impl;import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List;import org.dao.BaseDao; import org.entity.Dept; import org.entity.Emp;/*** * * 項目名稱：test_BaseDao * 類名稱：BaseDaoUtilImpl ,繼承BaseDao * 類描述： 公共的實現類 * 創建人：Mu Xiongxiong * 創建時間：2017-9-10 上午11:08:25 * 修改人：Mu Xiongxiong * 修改時間：2017-9-10 上午11:08:25 * 修改備注： * @version **/ public class BaseDaoUtilImpl<T> extends BaseDao {/*** * @Description: 該方法的主要作用：添加數據（Emp和Dept的）* @Title: save* @param @param entity 實體* @param @param tag 區分是Emp還是Dept* @param @return 設定文件 * @return 返回類型：int 大于0成功，否則失敗* @throws*/public int save(T entity,String tag) {int rel = 0;String sql = "";List<Object> prams = new ArrayList<Object>(); if(tag.equals("emp")){Emp emp = (Emp) entity; //初始化Emp對象//添加員工sql = "insert into emp(empno,ename,job,mgr,hiredate,sal,comm,deptno) values(?,?,?,?,to_date(?, 'YYYY-MM-DD HH24:MI:SS '),?,?,?)"; //sql語句try {prams.add(emp.getEmpno());prams.add(emp.getEname());prams.add(emp.getJob());prams.add(emp.getMgr());prams.add(emp.getHiredate());prams.add(emp.getSal());prams.add(emp.getComm());prams.add(emp.getDeptno());rel = executeUpdate(sql, prams);} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return rel;}else if (tag.equals("dept")) {//添加部門 Dept dept = (Dept) entity; //初始化Dept對象sql = "insert into dept values(?,?,?)"; //sql語句try {prams.add(dept.getDeptno());prams.add(dept.getDname());prams.add(dept.getLoc());rel = executeUpdate(sql, prams);} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return rel;}return 0; //此處執行不到，也可以寫成return null;}/*** * @Description: 該方法的主要作用：修改數據* @Title: update* @param @param entity* @param @return 設定文件 * @return 返回類型：int * @throws*/public int update(T entity,String tag) {int rel = 0;String sql = "";List<Object> prams = new ArrayList<Object>(); if(tag.equals("emp")){Emp emp = (Emp) entity; //初始化Emp對象//修改員工sql = "update emp set ename = ?,job=?,mgr=?,hiredate=to_date(?, 'YYYY-MM-DD HH24:MI:SS ') ,sal=?,comm=?,deptno=? where empno=?"; //sql語句try {prams.add(emp.getEname());prams.add(emp.getJob());prams.add(emp.getMgr());prams.add(emp.getHiredate());prams.add(emp.getSal());prams.add(emp.getComm());prams.add(emp.getDeptno());prams.add(emp.getEmpno());rel = executeUpdate(sql, prams);} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return rel;}else if (tag.equals("dept")) {//修改部門 Dept dept = (Dept) entity; //初始化Dept對象sql = "update dept set dname=?,loc=? where deptno =?"; //sql語句try {prams.add(dept.getDname());prams.add(dept.getLoc());prams.add(dept.getDeptno());rel = executeUpdate(sql, prams);} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return rel;}return 0; //此處執行不到，也可以寫成return null;}/*** * @Description: 該方法的主要作用：刪除數據* @Title: delete* @param @param id* @param @return 設定文件 * @return 返回類型：int * @throws*/public int delete(int id,String tag) {int rel = 0;String sql = "";List<Object> prams = new ArrayList<Object>(); if(tag.equals("emp")){//刪除員工sql = "delete from emp where empno = ?"; //sql語句try {prams.add(id);rel = executeUpdate(sql, prams);} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return rel;}else if (tag.equals("dept")) {//刪除部門 sql = "delete from dept where deptno =?"; //sql語句try {prams.add(id);rel = executeUpdate(sql, prams);} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return rel;}return 0; //此處執行不到，也可以寫成return null;}/*** * @Description: 該方法的主要作用：根據編號查詢* @Title: queryById* @param @param id* @param @return 設定文件 * @return 返回類型：T * @throws*/@SuppressWarnings("unchecked")public T queryById(int id,String tag) {String sql = "";List<Object> prams = new ArrayList<Object>(); if(tag.equals("emp")){//查詢員工Emp emp = null;sql = "select * from emp where empno = ?"; //sql語句try {prams.add(id);ResultSet rs = executeQuery(sql, prams);if(rs.next()){emp = new Emp(); emp.setEmpno(rs.getInt(1));emp.setEname(rs.getString(2));emp.setJob(rs.getString(3));emp.setMgr(rs.getInt(4));emp.setHiredate(rs.getString(5));emp.setSal(rs.getFloat(6));emp.setComm(rs.getFloat(7));emp.setDeptno(rs.getInt(8));}} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return (T) emp;}else if (tag.equals("dept")) {//查詢部門 sql = "select * from dept where deptno =?"; //sql語句Dept dept = null;try {prams.add(id);ResultSet rs = executeQuery(sql, prams);if(rs.next()){dept = new Dept(); dept.setDeptno(rs.getInt(1));dept.setDname(rs.getString(2));dept.setLoc(rs.getString(3));}} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return (T)dept;}return null; //此處執行不到，也可以寫成return null;}/*** * @Description: 該方法的主要作用：查詢全部* @Title: queryAll* @param @return 設定文件 * @return 返回類型：List<T> * @throws*/@SuppressWarnings("unchecked")public List<T> queryAll(String tag) {String sql = "";if(tag.equals("emp")){//查詢員工sql = "select * from emp"; //sql語句Emp emp = null;List<Emp> empList = new ArrayList<Emp>();try {ResultSet rs = executeQuery(sql, null);while(rs.next()){emp = new Emp(); emp.setEmpno(rs.getInt(1));emp.setEname(rs.getString(2));emp.setJob(rs.getString(3));emp.setMgr(rs.getInt(4));emp.setHiredate(rs.getString(5));emp.setSal(rs.getFloat(6));emp.setComm(rs.getFloat(7));emp.setDeptno(rs.getInt(8));empList.add(emp);}} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return (List<T>) empList;}else if (tag.equals("dept")) {//添加部門 sql = "select * from dept"; //sql語句Dept dept = null;List<Dept> deptList = new ArrayList<Dept>();try {ResultSet rs = executeQuery(sql, null);while(rs.next()){dept = new Dept(); dept.setDeptno(rs.getInt(1));dept.setDname(rs.getString(2));dept.setLoc(rs.getString(3));deptList.add(dept);}} catch (SQLException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}finally{closeConnnection(); //關閉連接}return (List<T>)deptList;}return null; //此處執行不到，也可以寫成return null;}}

總結

以上是生活随笔為你收集整理的Servlet使用适配器模式进行增删改查案例（BaseDaoUtilImpl.java）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。