（转）见证spring jdbc
一直对Spring都处于一个略懂的阶段，最近在公司看到一个框架，是用spring搞的，写得蛮强大的！其中增删改主要用namedParameterJdbcTemplate 和BeanPropertySqlParameterSource两个类！
见证Spring Jdbc的强大
Spring 不仅仅是一个IoC container。
其提供的Spring Jdbc提供了一层对jdbc很薄的封装，功能却是异常强大。
不说多了，直接贴代码
1、Template模式的使用，使我们只关心，sql, 输入参数，输出映射。
2、new BeanPropertySqlParameterSource(t) 直接把bean转成输入参数。
3、ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class)直接将bean转成输出映射。
4、一个dao根据输入参数不同，动态生成多条sql语句。很有一点ibatis的味道。
5、学习曲线低，会sql和jdbc的可以直接写。适合“你请到了只会写jsp和sql的极品，又想让他明天开始干活..... ”
@Component
public class UserInfoDaoJdbcImpl extends SimpleJdbcDaoSupport implements UserInfoDao {
public int deleteEntity(UserInfo t) throws DataAccessException {
if (null != t.getId()) {
return super.getSimpleJdbcTemplate().update("delete from user_info where id=:id", t.getId());
} else if (null != t.getMap().get("ids")) {
return super.getSimpleJdbcTemplate().update(
"delete from user_info where id in (" + t.getMap().get("ids") + ")", t.getId());
} else {
return -1;
}
}
public Integer insertEntity(UserInfo t) throws DataAccessException {
String sql = "insert into user_info (user_name, password, birthday, age) values (:user_name, :password, :birthday, :age)";
return super.getSimpleJdbcTemplate().update(sql, new BeanPropertySqlParameterSource(t));
}
public UserInfo selectEntity(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
sqls.add("select * from user_info where 1=1");
if (null != t.getId()) {
sqls.add("and id=:id");
}
if (null != t.getUser_name()) {
sqls.add("and login_name=:login_name");
}
if (null != t.getPassword()) {
sqls.add("and password=:password");
}
String sql = StringUtils.join(sqls, " ");
List<UserInfo> userInfoList = super.getSimpleJdbcTemplate().query(sql,
ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class), new BeanPropertySqlParameterSource(t));
int listSize = userInfoList.size();
if (1 == listSize) {
return userInfoList.get(0);
} else {
return null;
}
}
public Long selectEntityCount(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
sqls.add("select count(*) from user_info where 1=1");
if (null != t.getId()) {
sqls.add("and id=:id");
}
if (null != t.getUser_name()) {
sqls.add("and login_name=:login_name");
}
if (null != t.getPassword()) {
sqls.add("and password=:password");
}
String sql = StringUtils.join(sqls, " ");
return super.getSimpleJdbcTemplate().queryForLong(sql, new BeanPropertySqlParameterSource(t));
}
public List<UserInfo> selectEntityList(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
sqls.add("select * from user_info where 1=1");
if (null != t.getId()) {
sqls.add("and id=:id");
}
if (null != t.getUser_name()) {
sqls.add("and login_name=:login_name");
}
if (null != t.getPassword()) {
sqls.add("and password=:password");
}
String sql = StringUtils.join(sqls, " ");
return super.getSimpleJdbcTemplate().query(sql, ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class),
new BeanPropertySqlParameterSource(t));
}
public List<UserInfo> selectEntityPaginatedList(UserInfo t) throws DataAccessException {
// TODO Auto-generated method stub
return null;
}
public int updateEntity(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
if (null != t.getAge()) {
sqls.add(" age=:age");
}
if (null != t.getBirthday()) {
sqls.add(" birthday=:birthday");
}
String sql = StringUtils.join(new String[] { "update user_info set ", StringUtils.join(sqls.toArray(), ","),
" where id=:id" });
return super.getSimpleJdbcTemplate().update(sql, new BeanPropertySqlParameterSource(t));
}
} 见证Spring Jdbc的强大
Spring 不仅仅是一个IoC container。
其提供的Spring Jdbc提供了一层对jdbc很薄的封装，功能却是异常强大。
不说多了，直接贴代码
1、Template模式的使用，使我们只关心，sql, 输入参数，输出映射。
2、new BeanPropertySqlParameterSource(t) 直接把bean转成输入参数。
3、ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class)直接将bean转成输出映射。
4、一个dao根据输入参数不同，动态生成多条sql语句。很有一点ibatis的味道。
5、学习曲线低，会sql和jdbc的可以直接写。适合“你请到了只会写jsp和sql的极品，又想让他明天开始干活..... ”
@Component
public class UserInfoDaoJdbcImpl extends SimpleJdbcDaoSupport implements UserInfoDao {
public int deleteEntity(UserInfo t) throws DataAccessException {
if (null != t.getId()) {
return super.getSimpleJdbcTemplate().update("delete from user_info where id=:id", t.getId());
} else if (null != t.getMap().get("ids")) {
return super.getSimpleJdbcTemplate().update(
"delete from user_info where id in (" + t.getMap().get("ids") + ")", t.getId());
} else {
return -1;
}
}
public Integer insertEntity(UserInfo t) throws DataAccessException {
String sql = "insert into user_info (user_name, password, birthday, age) values (:user_name, :password, :birthday, :age)";
return super.getSimpleJdbcTemplate().update(sql, new BeanPropertySqlParameterSource(t));
}
public UserInfo selectEntity(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
sqls.add("select * from user_info where 1=1");
if (null != t.getId()) {
sqls.add("and id=:id");
}
if (null != t.getUser_name()) {
sqls.add("and login_name=:login_name");
}
if (null != t.getPassword()) {
sqls.add("and password=:password");
}
String sql = StringUtils.join(sqls, " ");
List<UserInfo> userInfoList = super.getSimpleJdbcTemplate().query(sql,
ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class), new BeanPropertySqlParameterSource(t));
int listSize = userInfoList.size();
if (1 == listSize) {
return userInfoList.get(0);
} else {
return null;
}
}
public Long selectEntityCount(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
sqls.add("select count(*) from user_info where 1=1");
if (null != t.getId()) {
sqls.add("and id=:id");
}
if (null != t.getUser_name()) {
sqls.add("and login_name=:login_name");
}
if (null != t.getPassword()) {
sqls.add("and password=:password");
}
String sql = StringUtils.join(sqls, " ");
return super.getSimpleJdbcTemplate().queryForLong(sql, new BeanPropertySqlParameterSource(t));
}
public List<UserInfo> selectEntityList(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
sqls.add("select * from user_info where 1=1");
if (null != t.getId()) {
sqls.add("and id=:id");
}
if (null != t.getUser_name()) {
sqls.add("and login_name=:login_name");
}
if (null != t.getPassword()) {
sqls.add("and password=:password");
}
String sql = StringUtils.join(sqls, " ");
return super.getSimpleJdbcTemplate().query(sql, ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class),
new BeanPropertySqlParameterSource(t));
}
public List<UserInfo> selectEntityPaginatedList(UserInfo t) throws DataAccessException {
// TODO Auto-generated method stub
return null;
}
public int updateEntity(UserInfo t) throws DataAccessException {
List<String> sqls = new ArrayList<String>();
if (null != t.getAge()) {
sqls.add(" age=:age");
}
if (null != t.getBirthday()) {
sqls.add(" birthday=:birthday");
}
String sql = StringUtils.join(new String[] { "update user_info set ", StringUtils.join(sqls.toArray(), ","),
" where id=:id" });
return super.getSimpleJdbcTemplate().update(sql, new BeanPropertySqlParameterSource(t));
}
}<pre class="java" name="code">使用Spring的NamedParameterJdbcTemplate完成DAO操作
2009-06-30 12:42:24| 分类： 技术点滴 |字号 订阅
NamedParameterJdbcTemplate内部包含了一个JdbcTemplate，所以JdbcTemplate能做的事情NamedParameterJdbcTemplate都能干，NamedParameterJdbcTemplate相对于JdbcTemplate主要增加了参数可以命名的功能。
public Object queryForObject(String sql, Map paramMap, RowMapper rowMapper)
public Object queryForObject(String sql, SqlParameterSource paramSource, RowMapper rowMapper)
SqlParameterSource的两个主要实现MapSqlParameterSource
和BeanPropertySqlParameterSource
public int update(String sql, SqlParameterSource paramSource, KeyHolder generatedKeyHolder)保存数据获得主键。
实例说明：
/**
* 一、NamedParameterJdbcTemplate提供了命名参数，用:x代替了?
* NamedParameterJdbcTemplate传参数可以用map或者SqlParameterSource
* 用map的好处是:x,x的值可以自由取，但是所有参数的值都必须要放到map中去，其中的key为:后面的名称，value是你传的值
* 用SqlParameterSource的好处是不用一个个的赋值,但是:x中的x的值必须和对象的属性名称一样
* 二、使用KeyHolder keyholder=new GeneratedKeyHolder();
namedjdbctemp.update(sql, ps,keyholder);这个参数可以获得主键生成值
*/
public class StuDaoImple implements StuDaointer{
private NamedParameterJdbcTemplate namedjdbctemp;
public StuDaoImple(){
namedjdbctemp=new NamedParameterJdbcTemplate(SQLConnUtil.getDataSource());
}// SQLConnUtil为JDBC工具类，提供了得到数据源的静态方法
/*
* 这里会用到NamedParameterJdbcTemplate两个好处：
* 1，不用一个个的为参数赋值。
* 2，可以轻易的得到主键自动增长值
*/
public void addStu(Stu stu) {
String sql="insert into stu values(:sname,:ssex,:sbrith)";
//:后面的名称必须和stu属性名称一样
SqlParameterSource ps=new BeanPropertySqlParameterSource(stu);
KeyHolder keyholder=new GeneratedKeyHolder();
namedjdbctemp.update(sql, ps,keyholder);
//加上KeyHolder这个参数可以得到添加后主键的值
int m=keyholder.getKey().intValue();
System.out.println(m);
//Map map=keyholder.getKeys();//这样可以得到联合主键的值
//keyholder.getKeyList();//这样可以得到一些主主键值，若一次添加好几条记录
}
public int count() {
String sql="select count(*) from stu";
//可以通过NamedParameterJdbcTemplate得到JdbcTemplate
int m=namedjdbctemp.getJdbcOperations().queryForInt(sql);
return m;
}
/*
* 这里会用到NamedParameterJdbcTemplate另一个好处：
* 位置参数
*/
public void delStu(int sid) {
String sql="delete stu where s_id=:id";
Map map=new HashMap();
map.put("id", sid);
namedjdbctemp.update(sql, map);
}
public List getAllStu() {
String sql="select s_id as sid,s_name as sname,s_sex as ssex,s_brith as sbrith from stu";
List list=namedjdbctemp.getJdbcOperations().query(sql,new BeanPropertyRowMapper(Stu.class));
return list;
}
public List getAllStu(Stu stu) {
String sql="select s_id as sid,s_name as sname,s_sex as ssex,s_brith as sbrith from stu where s_id=:sid";
SqlParameterSource ps=new BeanPropertySqlParameterSource(stu);
return namedjdbctemp.query(sql, ps, new BeanPropertyRowMapper(Stu.class));
}
public Stu getOneStu(Stu stu) {
String sql="select s_id as sid,s_name as sname,s_sex as ssex,s_brith as sbrith from stu where s_id=:sid";
SqlParameterSource ps=new BeanPropertySqlParameterSource(stu);
return (Stu)namedjdbctemp.queryForObject(sql, ps, new BeanPropertyRowMapper(Stu.class));
}
public String getStuName(Stu stu) {
String sql="select s_name as sname from stu where s_name=:sname";
SqlParameterSource ps=new BeanPropertySqlParameterSource(stu);
return (String)namedjdbctemp.queryForObject(sql, ps, String.class);
}
public void updStu(Stu stu) {
String sql="update stu set s_name=:sname,s_sex=:ssex,s_brith=:sbrith where s_id=:sid";
SqlParameterSource ps=new BeanPropertySqlParameterSource(stu);
namedjdbctemp.update(sql, ps);
}
}</pre> 相关推荐
白净垃圾桶 2020-07-04
HappyHeng 2020-06-25
ASoc 2020-11-14
Andrea0 2020-09-18
Cherishyuu 2020-08-19
dongtiandeyu 2020-08-18
CoderYYN 2020-08-16
大黑牛 2020-08-15
Dullonjiang 2020-08-11
gaozhennan 2020-08-03
mcvsyy 2020-08-02
zbcaicai 2020-07-29
AscaryBird 2020-07-27
liulin0 2020-07-26
ldcwang 2020-07-26
helloxusir 2020-07-25
娜娜 2020-07-20
pengpengflyjhp 2020-07-19
点滴技术生活 2020-07-19