随笔 - 251  文章 - 504  trackbacks - 0
<2006年12月>
262728293012
3456789
10111213141516
17181920212223
24252627282930
31123456

本博客系个人收集材料及学习记录之用,各类“大侠”勿扰!

留言簿(14)

随笔分类

收藏夹

My Favorite Web Sites

名Bloger

非著名Bloger

搜索

  •  

积分与排名

  • 积分 - 200061
  • 排名 - 285

最新评论

近日在看台湾人林信良的《Spring技术手册》,这本书总体上简单易懂,适合初学者。但是在声明性JDBC事务管理这节中的例子程序写的不够详细。下来看看并略加修改了下。
首先,在MySQL中建立一个表myuser。注意要让MySQL支持事务,要选择InnoDB类型的表。
Create table myuser(
 id int (11) not null auto_increment primary key,
name varchar(100) not null default '',
age int
)type=InnoDB;

这里有个实体类user.java:
package onlyfun.caterpillar;

public class User {
    
private Integer id;
    
private String name;
    
private Integer age;

    
public Integer getId() {
        
return id;
    }


    
public void setId(Integer id) {
        
this.id = id;
    }


    
public String getName() {
        
return name;
    }


    
public void setName(String name) {
        
this.name = name;
    }

    
    
public Integer getAge() {
        
return age;
    }


    
public void setAge(Integer age) {
        
this.age = age;
    }

}
为了面向接口编程,我们实现一个接口,让DAO类实现这个接口。
package onlyfun.caterpillar;

public interface IUserDAO {
    
public void insert(User user);
    
public User find(Integer id);
}

具体的DAO类如下:在这个类中我们模拟事务处理。

package onlyfun.caterpillar;

import java.util.Iterator;
import java.util.List;
import java.util.Map;

import javax.sql.DataSource;

import org.springframework.jdbc.core.JdbcTemplate;

public class UserDAO implements IUserDAO {
    
private JdbcTemplate jdbcTemplate;
    
    
public void setDataSource(DataSource dataSource) {
        jdbcTemplate 
= new JdbcTemplate(dataSource);
    }

    
    
public void insert(User user) {//在这个方法中我们执行了数据插入和数据查询两个操作,用来模拟事务操作。我们故意在查询的语句中把数据库表写成smyuser。
                                   
//这样,在insert方法执行过程中,会由于查询语句出错而撤销之前的插入语句的效果。
       String name = user.getName();
       
int age = user.getAge().intValue();
       
       jdbcTemplate.update(
"INSERT INTO myuser (name,age) " 
               
+ "VALUES('" + name + "'," + age + ")");
       
       
       List rows 
= jdbcTemplate.queryForList(
         
"SELECT * FROM smyuser WHERE id=4");
       
       Iterator it 
= rows.iterator();
       
if(it.hasNext()) {
           Map userMap 
= (Map) it.next();
           Integer i 
= new Integer(userMap.get("id").toString());
           String names 
= userMap.get("name").toString();
           Integer ages 
= new Integer(userMap.get("age").toString());

           User users 
= new User();
           
           users.setId(i);
           users.setName(name);
           users.setAge(age);
           System.out.println(
"names: " + users.getName());
          
       }


     
  
    }


    
public User find(Integer id) {
        
        
         
        List rows 
= jdbcTemplate.queryForList(
          
"SELECT * FROM myuser WHERE id=" + id.intValue());
        
        Iterator it 
= rows.iterator();
        
if(it.hasNext()) {
            Map userMap 
= (Map) it.next();
            Integer i 
= new Integer(userMap.get("id").toString());
            String name 
= userMap.get("name").toString();
            Integer age 
= new Integer(userMap.get("age").toString());

            User user 
= new User();
            
            user.setId(i);
            user.setName(name);
            user.setAge(age);
            
            
return user;
        }


        
return null;
    }

}

然后,在具体测试类中我们这样:
package onlyfun.caterpillar;

import org.springframework.context.ApplicationContext;
import org.springframework.context.
              support.FileSystemXmlApplicationContext;

public class SpringDAODemo {
    
public static void main(String[] args) {
        ApplicationContext context 
= 
            
new FileSystemXmlApplicationContext(
                    
"beans-config.xml");
        
        User user 
= new User();
        
        user.setName(
"1matthew");
        user.setAge(
new Integer(30));
        
        IUserDAO userDAO 
= 
            (IUserDAO) context.getBean(
"userDAOProxy");
        
        userDAO.insert(user);
        
        user 
= userDAO.find(new Integer(16));
        
        System.out.println(
"name: " + user.getName());
    }

}

最后,我们来看配置文件:在这个文件中我们注入事务管理。
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING/DTD BEAN/EN" 
  "http://www.springframework.org/dtd/spring-beans.dtd"
>

<beans>
    
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        
<property name="driverClassName">
            
<value>com.mysql.jdbc.Driver</value>
        
</property>
        
<property name="url">
            
<value>jdbc:mysql://localhost:3306/test</value>
        
</property>
        
<property name="username">
            
<value>root</value>
        
</property>
        
<property name="password">
            
<value>131421</value>
        
</property>
    
</bean>

    
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        
<property name="dataSource">
            
<ref bean="dataSource" />
        
</property>
    
</bean>

    
<bean id="userDAO" class="onlyfun.caterpillar.UserDAO">
        
<property name="dataSource">
            
<ref bean="dataSource" />
        
</property>
    
</bean>

    
<bean id="userDAOProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
        
<property name="proxyInterfaces">
            
<list>
                
<value>onlyfun.caterpillar.IUserDAO</value>
            
</list>
        
</property>
        
<property name="target">
            
<ref bean="userDAO" />
        
</property>
        
<property name="transactionManager">
            
<ref bean="transactionManager" />
        
</property>
        
<property name="transactionAttributes">
            
<props>
                
<prop key="insert*">PROPAGATION_REQUIRED</prop>

            
</props>
            
        
</property>
    
</bean>
</beans>
datasource这个bean中我们配置了数据源的相关属性。在userDAOProxy这个bean中,我们配置了target、transactionManager、transactionAttributes属性。在transactionAttributes中,我们指定所有insert*方法中操作会注入事务管理。

程序的运行结果是,由于在insert方法中的查询语句出错,会引起之前的insert语句效果被撤销。你也可以把查询语句先设置正确,看看效果。
posted on 2006-12-30 11:17 matthew 阅读(949) 评论(0)  编辑  收藏 所属分类: 阅读笔记

只有注册用户登录后才能发表评论。


网站导航: