/**
* @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;
}
}
