/**
* @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转换成classentityClass = (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;
}
}