2021-05-03 10:00  阅读(84)
文章分类:Spring 入门教程 文章标签:SpringSpring 教程
©  原文作者:一点教程 原文地址:http://www.yiidian.com/spring/

一、拷贝必要的jar包到工程的lib目录

202105031000375191.png

二、创建spring的配置文件并导入约束

    
    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xmlns:aop="http://www.springframework.org/schema/aop"
         xmlns:tx="http://www.springframework.org/schema/tx"
            xsi:schemaLocation="http://www.springframework.org/schema/beans 
                    http://www.springframework.org/schema/beans/spring-beans.xsd
                    http://www.springframework.org/schema/tx 
                    http://www.springframework.org/schema/tx/spring-tx.xsd
                    http://www.springframework.org/schema/aop 
                    http://www.springframework.org/schema/aop/spring-aop.xsd">    
    </beans>

三、准备数据库表和实体类

创建数据库:
create database spring;
use spring;
创建表:
create table account(
id int primary key auto_increment,
name varchar(40),
money float
)character set utf8 collate utf8_general_ci;

    
    package com.yiidian.domain;
    
    import java.io.Serializable;
    /**
     * @author http://www.yiidian.com
     * 
     */
    public class Account implements Serializable{
    	private Integer id;
    	private String name;
    	private Float money;
    	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 Float getMoney() {
    		return money;
    	}
    	public void setMoney(Float money) {
    		this.money = money;
    	}
    	@Override
    	public String toString() {
    		return "Account [id=" + id + ", name=" + name + ", money=" + money
    				+ "]";
    	}
    
    	
    }
    

四、编写业务层接口和实现类

AccountService:

    
    package com.yiidian.service;
    
    import com.yiidian.domain.Account;
    /**
     * @author http://www.yiidian.com
     * 
     */
    public interface AccountService {
    	/**
    	 * 根据id查询账户信息
    	 * @param id
    	 * @return
    	 */
    	Account findAccountById(Integer id);//查
    	
    	/**
    	 * 转账
    	 * @param sourceName	转出账户名称
    	 * @param targeName		转入账户名称
    	 * @param money			转账金额
    	 */
    	void transfer(String sourceName,String targeName,Float money);//增删改
    }
    

AccountServiceImpl:

    
    package com.yiidian.service.impl;
    
    import com.yiidian.dao.AccountDao;
    import com.yiidian.domain.Account;
    import com.yiidian.service.AccountService;
    /**
     * @author http://www.yiidian.com
     * 
     */
    public class AccountServiceImpl implements AccountService {
    	private AccountDao accountDao;
    
    	public void setAccountDao(AccountDao accountDao) {
    		this.accountDao = accountDao;
    	}
    
    	@Override
    	public Account findAccountById(Integer id) {
    		return accountDao.findAccountById(id);
    	}
    
    	@Override
    	public void transfer(String sourceName, String targeName, Float money) {
    		// 1.根据名称查询两个账户
    		Account source = accountDao.findAccountByName(sourceName);
    		Account target = accountDao.findAccountByName(targeName);
    		// 2.修改两个账户的金额
    		source.setMoney(source.getMoney() - money);// 转出账户减钱
    		target.setMoney(target.getMoney() + money);// 转入账户加钱
    		// 3.更新两个账户
    		accountDao.updateAccount(source);
    		//模拟异常
    		int i = 1 / 0;
    		accountDao.updateAccount(target);
    	}
    }
    

五、编写Dao接口和实现类

AccountDao:

    
    package com.yiidian.dao;
    
    import com.yiidian.domain.Account;
    
    /**
     * 
     * @author http://www.yiidian.com
     * 
     */
    public interface AccountDao {
    
    	/**
    	 * 根据id查询账户信息
    	 * @param id
    	 * @return
    	 */
    	Account findAccountById(Integer id);
    
    	/**
    	 * 根据名称查询账户信息
    	 * @return
    	 */
    	Account findAccountByName(String name);
    	
    	/**
    	 * 更新账户信息
    	 * @param account
    	 */
    	void updateAccount(Account account);
    }
    

AccountDaoImpl:

    
    package com.yiidian.dao.impl;
    
    import java.util.List;
    
    import org.springframework.jdbc.core.support.JdbcDaoSupport;
    
    import com.yiidian.dao.AccountDao;
    import com.yiidian.domain.Account;
    /**
     * 
     * @author http://www.yiidian.com
     * 
     */
    public class AccountDaoImpl extends JdbcDaoSupport  implements AccountDao{
    	@Override
    	public Account findAccountById(Integer id) {
    		List<Account> list = getJdbcTemplate().query("select * from account where id = ? ",new AccountRowMapper(),id);
    		return list.isEmpty()?null:list.get(0);
    	}
    
    	@Override
    	public Account findAccountByName(String name) {
    		List<Account> list =  getJdbcTemplate().query("select * from account where name = ? ",new AccountRowMapper(),name);
    		if(list.isEmpty()){
    			return null;
    		}
    		if(list.size()>1){
    			throw new RuntimeException("结果集不唯一,不是只有一个账户对象");
    		}
    		return list.get(0);
    	}
    
    	@Override
    	public void updateAccount(Account account) {
    		getJdbcTemplate().update("update account set money = ? where id = ? ",account.getMoney(),account.getId());
    	}
    }
    
    

AccountRowMapper:

    
    package com.yiidian.dao.impl;
    
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    import org.springframework.jdbc.core.RowMapper;
    
    import com.yiidian.domain.Account;
    /**
     * 账户的封装类RowMapper的实现类
     * @author http://www.yiidian.com
     *
     */
    public class AccountRowMapper implements RowMapper<Account>{
    	@Override
    	public Account mapRow(ResultSet rs, int rowNum) throws SQLException {
    		Account account = new Account();
    		account.setId(rs.getInt("id"));
    		account.setName(rs.getString("name"));
    		account.setMoney(rs.getFloat("money"));
    		return account;
    	}
    }
    

六、配置业务层和持久层,加上Spring事务管理

    
    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
    	xmlns:tx="http://www.springframework.org/schema/tx"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans 
        			http://www.springframework.org/schema/beans/spring-beans.xsd
        			http://www.springframework.org/schema/tx 
        			http://www.springframework.org/schema/tx/spring-tx.xsd
            		http://www.springframework.org/schema/aop 
            		http://www.springframework.org/schema/aop/spring-aop.xsd">
    
    	<bean
    		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    		<property name="location" value="classpath:jdbc.properties" />
    	</bean>
    
    	<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    		<property name="dataSource" ref="dataSource" />
    	</bean>
    
    	<bean id="dataSource"
    		class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    		<property name="driverClassName" value="${jdbc.driverClass}" />
    		<property name="url" value="${jdbc.url}" />
    		<property name="username" value="${jdbc.username}" />
    		<property name="password" value="${jdbc.password}" />
    	</bean>
    
    	<!-- 在AccountDaoImpl类直接注入dataSource即可 -->
    	<bean id="accountDao" class="com.yiidian.dao.impl.AccountDaoImpl">
    		<property name="dataSource" ref="dataSource" />
    	</bean>
    
    	<bean id="accountService" class="com.yiidian.service.impl.AccountServiceImpl">
    		<property name="accountDao" ref="accountDao"></property>
    	</bean>
    
    	<!-- 配置一个事务管理器 -->
    	<bean id="transactionManager"
    		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    		<!-- 注入DataSource -->
    		<property name="dataSource" ref="dataSource"></property>
    	</bean>
    
    	<!-- 事务的配置 -->
    	<tx:advice id="txAdvice" transaction-manager="transactionManager">
    		<!--在tx:advice标签内部 配置事务的属性 -->
    		<tx:attributes>
    			<!-- 指定方法名称:是业务核心方法 read-only:是否是只读事务。默认false,不只读。 isolation:指定事务的隔离级别。默认值是使用数据库的默认隔离级别。 
    				propagation:指定事务的传播行为。 timeout:指定超时时间。默认值为:-1。永不超时。 rollback-for:用于指定一个异常,当执行产生该异常时,事务回滚。产生其他异常,事务不回滚。没有默认值,任何异常都回滚。 
    				no-rollback-for:用于指定一个异常,当产生该异常时,事务不回滚,产生其他异常时,事务回滚。没有默认值,任何异常都回滚。 -->
    			<tx:method name="*" read-only="false" propagation="REQUIRED" />
    			<tx:method name="find*" read-only="true" propagation="SUPPORTS" />
    		</tx:attributes>
    	</tx:advice>
    
    	<!-- 配置aop -->
    	<aop:config>
    		<!-- 配置切入点表达式 -->
    		<aop:pointcut expression="execution(* com.yiidian.service.impl.*.*(..))"
    			id="pt1" />
    		<aop:advisor advice-ref="txAdvice" pointcut-ref="pt1"/>
    	</aop:config>
    
    
    </beans>

七、编写测试类

    
    package com.yiidian.test;
    
    import org.junit.Test;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import com.yiidian.service.AccountService;
    
    /**
     * @author http://www.yiidian.com
     * 
     */
    public class JdbcTemplateDemo {
    
    	/**
    	 * 添加操作
    	 */
    	@Test
    	public void test1() {
    		ApplicationContext ac = new ClassPathXmlApplicationContext(
    				"applicationContext.xml");
    		AccountService accountService = (AccountService)ac.getBean("accountService");
    		accountService.transfer("小苍", "小泽", 300f);
    	}
    
    
    }
    

源码下载:http://pan.baidu.com/s/1bpNelwr

点赞(0)
版权归原创作者所有,任何形式转载请联系作者; Java 技术驿站 >> Spring的Jdbc事务-XML
上一篇
JdbcTemplate实现增删改查
下一篇
Spring的Jdbc事务-注解