SIMONE
posts - 495,comments - 227,trackbacks - 0
见证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的极品，又想让他明天开始干活..... ”

  3. @Component
  4. public class UserInfoDaoJdbcImpl extends SimpleJdbcDaoSupport implements UserInfoDao {
  6.     public int deleteEntity(UserInfo t) throws DataAccessException {
  7.         if (null != t.getId()) {
  8.             return super.getSimpleJdbcTemplate().update("delete from user_info where id=:id", t.getId());
  9.         } else if (null != t.getMap().get("ids")) {
  10.             return super.getSimpleJdbcTemplate().update(
  11.                     "delete from user_info where id in (" + t.getMap().get("ids") + ")", t.getId());
  12.         } else {
  13.             return -1;
  14.         }
  15.     }
  17.     public Integer insertEntity(UserInfo t) throws DataAccessException {
  18.         String sql = "insert into user_info (user_name, password, birthday, age) values (:user_name, :password, :birthday, :age)";
  19.         return super.getSimpleJdbcTemplate().update(sql, new BeanPropertySqlParameterSource(t));
  20.     }
  22.     public UserInfo selectEntity(UserInfo t) throws DataAccessException {
  23.         List<String> sqls = new ArrayList<String>();
  24.         sqls.add("select * from user_info where 1=1");
  25.         if (null != t.getId()) {
  26.             sqls.add("and id=:id");
  27.         }
  28.         if (null != t.getUser_name()) {
  29.             sqls.add("and login_name=:login_name");
  30.         }
  31.         if (null != t.getPassword()) {
  32.             sqls.add("and password=:password");
  33.         }
  34.         String sql = StringUtils.join(sqls, " ");
  35.         List<UserInfo> userInfoList = super.getSimpleJdbcTemplate().query(sql,
  36.                 ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class), new BeanPropertySqlParameterSource(t));
  37.         int listSize = userInfoList.size();
  38.         if (1 == listSize) {
  39.             return userInfoList.get(0);
  40.         } else {
  41.             return null;
  42.         }
  43.     }
  45.     public Long selectEntityCount(UserInfo t) throws DataAccessException {
  46.         List<String> sqls = new ArrayList<String>();
  47.         sqls.add("select count(*) from user_info where 1=1");
  48.         if (null != t.getId()) {
  49.             sqls.add("and id=:id");
  50.         }
  51.         if (null != t.getUser_name()) {
  52.             sqls.add("and login_name=:login_name");
  53.         }
  54.         if (null != t.getPassword()) {
  55.             sqls.add("and password=:password");
  56.         }
  57.         String sql = StringUtils.join(sqls, " ");
  58.         return super.getSimpleJdbcTemplate().queryForLong(sql, new BeanPropertySqlParameterSource(t));
  59.     }
  61.     public List<UserInfo> selectEntityList(UserInfo t) throws DataAccessException {
  62.         List<String> sqls = new ArrayList<String>();
  63.         sqls.add("select * from user_info where 1=1");
  64.         if (null != t.getId()) {
  65.             sqls.add("and id=:id");
  66.         }
  67.         if (null != t.getUser_name()) {
  68.             sqls.add("and login_name=:login_name");
  69.         }
  70.         if (null != t.getPassword()) {
  71.             sqls.add("and password=:password");
  72.         }
  73.         String sql = StringUtils.join(sqls, " ");
  74.         return super.getSimpleJdbcTemplate().query(sql, ParameterizedBeanPropertyRowMapper.newInstance(UserInfo.class),
  75.                 new BeanPropertySqlParameterSource(t));
  76.     }
  78.     public List<UserInfo> selectEntityPaginatedList(UserInfo t) throws DataAccessException {
  79.         // TODO Auto-generated method stub
  80.         return null;
  81.     }
  83.     public int updateEntity(UserInfo t) throws DataAccessException {
  84.         List<String> sqls = new ArrayList<String>();
  85.         if (null != t.getAge()) {
  86.             sqls.add(" age=:age");
  87.         }
  88.         if (null != t.getBirthday()) {
  89.             sqls.add(" birthday=:birthday");
  90.         }
  92.         String sql = StringUtils.join(new String[] { "update user_info set ", StringUtils.join(sqls.toArray(), ","),
  93.                 " where id=:id" });
  95.         return super.getSimpleJdbcTemplate().update(sql, new BeanPropertySqlParameterSource(t));
  96.     }
  98. }

posted on 2008-11-11 13:34 SIMONE 阅读(2068) 评论(0)  编辑  收藏 所属分类: JAVA

只有注册用户登录后才能发表评论。
网站导航:
 
Copyright ©2024 SIMONE Powered By博客园 模板提供：沪江博客