(转)见证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的极品，又想让他明天开始干活..... ”@Componentpublic 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的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 和BeanPropertySqlParameterSourcepublic 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); }}
页:
[1]