spring3 jdbctemplate 注解实例

[java] view plain copy
 
  1. <aop:aspectj-autoproxy />  
  2.   
  3.     <!-- transaction manager, use JtaTransactionManager for global tx -->  
  4.     <bean id="txManager"  
  5.         class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  
  6.         <property name="dataSource" ref="dynamicDataSource" />  
  7.     </bean>  
  8.   
  9.     <!--  
  10.         enable component scanning (beware that this does not enable mapper  
  11.         scanning!)  
  12.     -->  
  13.     <context:component-scan base-package="com.shadow" />  
  14.   
  15.     <!-- enable autowire -->  
  16.     <context:annotation-config />  
  17.   
  18.     <!-- enable transaction demarcation with annotations -->  
  19.     <tx:annotation-driven transaction-manager="txManager" />  

第三步,配置jdbctemplate的实例,同样提供一个datasource就可以了

 

 

[java] view plain copy
 
  1. <!-- JDBC模板 -->  
  2.     <bean id="jdbcTemplate"  
  3.         class="org.springframework.jdbc.core.JdbcTemplate">  
  4.         <property name="dataSource" ref="dynamicDataSource" />  
  5.     </bean>  

第四步,写个BaseDao方便下面的dao层调用,由于时间转换经常用到,这里只写了个通用的时间转换

 

 

[java] view plain copy
 
  1. /** 
  2.  *  
  3.  * @author shadow 
  4.  * @email 124010356@qq.com 
  5.  * @create 2012.04.28 
  6.  *  
  7.  * @param <T> 
  8.  */  
  9. public abstract class AbstractBaseDao<T> implements DateFormatEntry {  
  10.   
  11.     // SPRING JDBC模板接口  
  12.     private JdbcTemplate jdbcTemplate;  
  13.   
  14.     public JdbcTemplate getJdbcTemplate() {  
  15.         return jdbcTemplate;  
  16.     }  
  17.   
  18.     @Resource  
  19.     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {  
  20.         this.jdbcTemplate = jdbcTemplate;  
  21.     }  
  22.   
  23.     /** 
  24.      * 获取日期 
  25.      *  
  26.      * @param timestamp 
  27.      * @return Date 
  28.      */  
  29.     public Date getDate(Timestamp timestamp) {  
  30.         return toDate(timestamp, null);  
  31.     }  
  32.   
  33.     /** 
  34.      * 获取日期 
  35.      *  
  36.      * @param timestamp 
  37.      * @param format 
  38.      * @return Date 
  39.      */  
  40.     public Date getDate(Timestamp timestamp, String format) {  
  41.         return toDate(timestamp, format);  
  42.     }  
  43.   
  44.     /** 
  45.      * Timestamp按格式转换成Date 
  46.      *  
  47.      * @param timestamp 
  48.      * @param format 
  49.      * @return Date 
  50.      */  
  51.     public Date toDate(Timestamp timestamp, String format) {  
  52.         Date date = null;  
  53.         if (null == format || "".equals(format))  
  54.             format = DEFAULT_FORMAT;  
  55.         SimpleDateFormat sdf = new SimpleDateFormat(format);  
  56.         try {  
  57.             date = sdf.parse(sdf.format(timestamp));  
  58.         } catch (ParseException e) {  
  59.             e.printStackTrace();  
  60.         }  
  61.         return date;  
  62.     }  
  63.   
  64. }  

第五步,写个UserDao接口跟实现类

 

 

[java] view plain copy
 
  1. public interface UserDao {  
  2.   
  3.     public List<User> queryByUserName(String username);  
  4.   
  5.     public int checkUser(String username);  
  6.       
  7.     public List<User> queryForAll();  
  8.       
  9. }  

 

这里使用@Component("userDao"),相当于在xml配置里做一个<bean id="userDao" class="xxxxxx.UserDaoImpl"/>,然后我们在service调用就直接Resource("userDao")就能自动匹配这个实现类了

[java] view plain copy
 
  1. @Component("userDao")  
  2. public class UserDaoImpl extends AbstractBaseDao<User> implements UserDao {  
  3.   
  4.     public int checkUser(String username) {  
  5.         // TODO Auto-generated method stub  
  6.         return 0;  
  7.     }  
  8.   
  9.     @SuppressWarnings("unchecked")  
  10.     public List<User> queryByUserName(String username) {  
  11.         String sql = "select t1.* from t_user t1 where t1.username = ?";  
  12.         List<User> list = this.getJdbcTemplate().query(sql,  
  13.                 new Object[] { username }, new UserMapper());  
  14.         return list;  
  15.     }  
  16.   
  17.     public List<User> queryForAll() {  
  18.         SqlRowSet rowSet = getJdbcTemplate().queryForRowSet(null);  
  19.         while (rowSet.next()) {  
  20.         }  
  21.         return null;  
  22.     }  
  23.   
  24.     @SuppressWarnings("unchecked")  
  25.     private class UserMapper implements RowMapper {  
  26.         public Object mapRow(ResultSet rs, int i) throws SQLException {  
  27.             User vo = new User();  
  28.             vo.setId(rs.getInt("id"));  
  29.             vo.setUsername(rs.getString("username"));  
  30.             vo.setPassword(rs.getString("password"));  
  31.             vo.setName(rs.getString("name"));  
  32.             return vo;  
  33.         }  
  34.     }  
  35.   
  36. }  

第六步,写service层调用dao的方法

 

 

[java] view plain copy
 
  1. public interface UserService {  
  2.   
  3.     /** 
  4.      * 更新登录信息 
  5.      *  
  6.      * @param user 
  7.      */  
  8.     public void LoginForUpdate(User user);  
  9.   
  10.     /** 
  11.      * 安全退出功能 
  12.      *  
  13.      * @return String 
  14.      */  
  15.     public String logout();  
  16.   
  17.     /** 
  18.      * 检测用户是否存在 
  19.      *  
  20.      * @param username 
  21.      * @return Boolean 
  22.      */  
  23.     public boolean checkUser(String username);  
  24.   
  25.     /** 
  26.      * 通过用户名获取账号 
  27.      *  
  28.      * @param username 
  29.      * @return List<User> 
  30.      */  
  31.     public List<User> findByUserName(String username);  

 

这里使用了的@Resource没有带参数就是默认使用接口类名首字母小写(例如接口是UserDao,默认匹配是userDao),@Transactional是事务的注解,可加各种参数设置,

具体请看帮助文档

[java] view plain copy
 
  1. @Transactional  
  2. @Component("userService")  
  3. public class UserServiceImpl implements UserService {  
  4.   
  5.     @Resource  
  6.     private UserDao userDao;  
  7.   
  8.     public void LoginForUpdate(User user) {  
  9.         // TODO Auto-generated method stub  
  10.     }  
  11.   
  12.     public boolean checkUser(String username) {  
  13.         // TODO Auto-generated method stub  
  14.         return false;  
  15.     }  
  16.   
  17.     public List<User> findByUserName(String username) {  
  18.         return this.userDao.queryByUserName(username);  
  19.     }  
  20.   
  21.     public String logout() {  
  22.         // TODO Auto-generated method stub  
  23.         return null;  
  24.     }  
  25.   
  26. }  

第七步,写junit测试

 

 

[java] view plain copy
 
  1. @RunWith(SpringJUnit4ClassRunner.class)  
  2. @ContextConfiguration("classpath:application.xml")  
  3. public class Junit {  
  4.   
  5.     @Resource  
  6.     private UserService userService;  
  7.   
  8.     @Test  
  9.     public void test() {  
  10.         for (int i = 0; i < 10; i++) {  
  11.             List<User> users = userService.findByUserName("3213231");  
  12.             System.out.println("当前用户数:" + users.size());  
  13.         }  
  14.     }  
  15.   
  16. }  

最后右键run as junit就ok了

 

 

附言,其实spring jdbctemplate是很灵活的,性能也很不错,你能使用queryForXX一类的方法返回map,也能返回原始ResultSet,当然也能使用回调接口映射成对象,我的例子里就是演示了如何把结果集映射成实体对象

 

上一篇:图形化方式和命令行方式创建KVM虚拟机


下一篇:字符文件具体操作——题1,2