Spring整合hibernate(1)之基础整合源代码

package org.oms.spring.dao; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Iterator; import java.util.List; import javax.annotation.Resource; import javax.sql.DataSource; import org.oms.spring.model.Group; import org.oms.spring.model.User; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.RowMapper; import org.springframework.stereotype.Repository; @Repository("userJdbcDao") public class UserDao implements IUserDao { private JdbcTemplate JdbcTemplate; /** * Set the JDBC DataSource to obtain connections from. */ @Resource public void setDataSource(DataSource dataSource) { JdbcTemplate = new JdbcTemplate(dataSource); } @Override public void add(User user, int gid) { JdbcTemplate .update("insert into t_user(username,password,gid,age,birthday,createdate) value (?,?,?,?,?,?)", user.getUsername(), user.getPassword(), gid, user.getAge(), user.getBirthDay(), user.getCreateDate()); } @Override public void update(User user, int gid) { JdbcTemplate .update("update t_user set username=?,password=?,gid=?,age=?,birthday=?,createdate=? where id=?", user.getUsername(), user.getPassword(), gid, user.getAge(), user.getBirthDay(), user.getCreateDate(), user.getId()); } @Override public void delete(int id) { JdbcTemplate.update("delete from t_user where id =?", id); } @Override public User load(int id) { String sql="select t1.id uid ,t1.*,t2.* from t_user t1 left join `group` t2 on (t1.gid=t2.id) where t1.id=?"; /** * 第一个参数是SQL语句 * 第二个参数是SQL语句中参数值，需要传入一个对象数组 * 第三个是一个RowMapper，这个RowMapper可以完成一个对象和数据库字段的对应，实现这个RowMapper需要实现mapRow方法， * 在这个mapRow方法中有rs这个参数，通过rs可以有效的获取数据库的字段 * 如果这个方法在DAO中会被重复使用，建议通过内部类来解决，而不要使用匿名的内部类 */ User u=(User)JdbcTemplate.queryForObject(sql,new Object[]{id} ,new RowMapper<User>(){ @Override public User mapRow(ResultSet rs, int rowNum) throws SQLException { Group group=new Group(); group.setName(rs.getString("name")); group.setId(rs.getInt("gid")); User user=new User(); user.setGroup(group); user.setId(rs.getInt("uid")); user.setUsername(rs.getString("username")); user.setPassword(rs.getString("password")); user.setAge(rs.getInt("age")); user.setBirthDay(rs.getDate("birthday")); user.setCreateDate(rs.getDate("createdate")); return user; } }); return u; } /** * 上面方法简化 * @param id * @return */ public User loadOther(int id) { String sql="select t1.id uid ,t1.*,t2.* from t_user t1 left join `group` t2 on (t1.gid=t2.id) where t1.id=?"; User u=(User)JdbcTemplate.queryForObject(sql,new Object[]{id} ,new UserMapper()); return u; } @Override public List<User> list(String sql,Object[] args) { //查询总条数，获取整数值 String sqlCount="select count(1) from user"; int count=JdbcTemplate.queryForInt(sqlCount); System.out.println(count); //查询单列，获取String类型的列表 String sqlCol="select username from t_user"; List<String> cols=JdbcTemplate.queryForList(sqlCol, String.class); for (int i = 0; i < cols.size(); i++) { System.out.println(cols.get(i)); } //查询多列 String sqlCols="select username,password from t_user"; List<User> users=JdbcTemplate.query(sqlCols,new RowMapper<User>(){ @Override public User mapRow(ResultSet rs, int rowNum) throws SQLException { User user=new User(); user.setUsername(rs.getString("username")); user.setPassword(rs.getString("password")); return user; } }); for (int i = 0; i < users.size(); i++) { System.out.println(users.get(i).toString()); } //查询列表 return JdbcTemplate.query(sql, args,new UserMapper()); } /** * 建议通过内部类来解决，而不要使用匿名的内部类 * @author sunlight * */ private class UserMapper implements RowMapper<User>{ @Override public User mapRow(ResultSet rs, int rowNum) throws SQLException { Group group=new Group(); group.setName(rs.getString("name")); group.setId(rs.getInt("gid")); User user=new User(); user.setGroup(group); user.setId(rs.getInt("uid")); user.setUsername(rs.getString("username")); user.setPassword(rs.getString("password")); user.setAge(rs.getInt("age")); user.setBirthDay(rs.getDate("birthday")); user.setCreateDate(rs.getDate("createdate")); return user; } } }