/** * @Title: BaseImpl.java * @Package org.dao.impl * @Description: TODO该方法的主要作用: * @author A18ccms A18ccms_gmail_com * @date 2017-6-6 下午4:12:02 * @version V1.0 */ package org.dao.impl; import java.io.Serializable; import java.lang.reflect.ParameterizedType; import java.util.List; import org.springframework.jdbc.core.BeanPropertyRowMapper; import org.springframework.jdbc.core.JdbcTemplate; /** * * 项目名称:spring_Cchop10 * 类名称:BaseImpl * 类描述: * 创建人:Mu Xiongxiong * 创建时间:2017-6-6 下午4:12:02 * 修改人:Mu Xiongxiong * 修改时间:2017-6-6 下午4:12:02 * 修改备注: * @version * */ public class BaseImpl<T> { private JdbcTemplate jdbcTemplate; //jdbcTemplate对象 private Class<T> entityClass; //将实体类转换成class /** * * 构造函数 * @discription * @author Mu Xiongxiong * @created 2017-6-6 下午4:58:40 */ @SuppressWarnings("unchecked") public BaseImpl() { //将T转换成class entityClass = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0]; } /** * * @Title: save * @Description: 该方法的主要作用:添加,修改,删除 * @param @param sql * @param @param objects 设定文件 * @return 返回类型:void * @throws */ public void update(String sql,Object[]objects){ jdbcTemplate.update(sql, objects); } /** * * @Title: getById * @Description: 该方法的主要作用:根据id查询信息 * @param @param sql * @param @param id 设定文件 * @return 返回类型:void * @throws */ public T getById(String sql,Serializable id){ return (T) jdbcTemplate.queryForObject(sql,new Object[]{id},new BeanPropertyRowMapper(entityClass)); } /** * * @Title: getAll * @Description: 该方法的主要作用:查询全部 * @param @param sql 设定文件 * @return 返回类型:void * @throws */ public List<T> getAll(String sql){ return jdbcTemplate.query(sql, new BeanPropertyRowMapper(entityClass)); } public JdbcTemplate getJdbcTemplate() { return jdbcTemplate; } public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { this.jdbcTemplate = jdbcTemplate; } /** * 创建添加一条员工记录的存储过程 * CREATE OR REPLACE PROCEDURE add_emp (myempno in NUMBER,myename VARCHAR2,myjob VARCHAR2,mymgr NUMBER,mydate DATE, mysal NUMBER,mycomm NUMBER) AS BEGIN INSERT INTO emp VALUES(myempno,myename,myjob,mymgr,mydate,mysal,mycomm); END; * * */ @SuppressWarnings("unchecked") public Integer testProcedure(final Emp emp) { Integer dno = jdbcTemplate.execute(new CallableStatementCreator(){ @Override public CallableStatement createCallableStatement(Connection con) throws SQLException { String procStr = "{call add_emp(?,?,?,?,?,?,?)}"; CallableStatement cs = con.prepareCall(procStr); cs.setInt(1, emp.getEmpno()); cs.setString(2, emp.getEname()); cs.setString(3, emp.getJob()); cs.setInt(4, emp.getMgr()); cs.setDate(5, (Date) emp.getHiredate()); cs.setDouble(6, emp.getSal()); cs.setDouble(7, emp.getComm()); cs.registerOutParameter(1, OracleTypes.NUMBER); return cs; } }, new CallableStatementCallback(){ @Override public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException { cs.execute(); return cs.getInt(1); } }) ; return dno; } }