SpringIOC和SpringAOC

1. lombok插件
2. <strong>XML</strong>

复制代码

2.     <!-- 加载资源文件 -->
3.     <context:property-placeholder location="classpath:jdbc.properties"></context:property-placeholder>
5.     <!-- 注入数据源 -->
6.     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
7.         <property name="driverClass" value="${msg1}"></property>
8.         <property name="jdbcUrl" value="${msg2}"></property>
9.         <property name="user" value="${msg3}"></property>
10.         <property name="password" value="${msg4}"></property>
11.     </bean>
13.     <!-- 注入QueryRunner -->
14.     <bean id="queryRunner" class="org.apache.commons.dbutils.QueryRunner">
15.         <constructor-arg name="ds" ref="dataSource"></constructor-arg>
16.     </bean>
18.     <!-- 连接工具类 -->
19.     <bean id="connectionUtil" class="com.xn.util.ConnectionUtil">
20.         <property name="dataSource" ref="dataSource"/>
21.     </bean>
23.     <!-- 事务工具类 -->
24.     <bean id="transactionUtil" class="com.xn.util.TransactionUtil">
25.         <property name="connectionUtil" ref="connectionUtil"/>
26.     </bean>
28.     <!-- 注入dao -->
29.     <bean id="mapperImp" class="com.xn.dao.AccountMapperImp">
30.         <property name="queryRunner" ref="queryRunner"></property>
31.         <property name="connectionUtil" ref="connectionUtil"></property>
32.     </bean>
34.     <!-- 注入service -->
35.     <bean id="service" class="com.xn.service.AccountServiceImp">
36.         <property name="mapper" ref="mapperImp"/>
37.         <property name="transactionUtil" ref="transactionUtil"></property>
38.     </bean>
40.     <!-- 注入controller -->
41.     <bean id="controller" class="com.xn.controller.AccountControllerImp">
42.         <property name="service" ref="service"/>
43.     </bean>

复制代码

1. 功能：对实体类自动，动态生成getset，无参有参.....
2. 步骤：
3.     1.idea安装插件(只做一次)
6.     2.添加坐标

复制代码

1.      <!-- lombok -->
2.         <dependency>
3.             <groupId>org.projectlombok</groupId>
4.             <artifactId>lombok</artifactId>
5.             <version>1.18.26</version>
6.         </dependency>
7.     </dependencies>

复制代码

1.    3.编写注解
3. dbUtil-阿帕奇提供操作数据库的插件
4. 核心类：QueryRunner
5.             .query()  查询
6.             .update() 增删改

复制代码

2.     //操作数据库的核心类
3.     QueryRunner queryRunner;
5.     public void setQueryRunner(QueryRunner queryRunner) {
6.         this.queryRunner = queryRunner;
7.     }
11. @Override
12.     public void save(Account account) {
13.         try {
14.             queryRunner.update(connectionUtil.createCon(),"insert into account(aname,amoney) value(?,?)",account.getAname(),account.getAmoney());
15.         } catch (SQLException throwables) {
16.             throwables.printStackTrace();
17.         }
18.     }
22. @Override
23.     public void updateById(Account account) {
24.         try {
25.             queryRunner.update(connectionUtil.createCon(),"update  account set aname=?,amoney=? where aid=?",account.getAname(),account.getAmoney(),account.getAid());
26.         } catch (SQLException throwables) {
27.             throwables.printStackTrace();
28.         }
29.     }
31.     @Override
32.     public void deleteById(int id) {
33.         try {
34.             queryRunner.update(connectionUtil.createCon(),"delete from account where aid=?",id);
35.         } catch (SQLException throwables) {
36.             throwables.printStackTrace();
37.         }
38.     }

复制代码

1. <!-- 注入QueryRunner -->
2.     <bean id="queryRunner" class="org.apache.commons.dbutils.QueryRunner">
3.         <constructor-arg name="ds" ref="dataSource"></constructor-arg>
4.     </bean>

复制代码

1. junit测试
2. 使用步骤：
3.     1.坐标

复制代码

1.      单元测试-->
2.         <dependency>
3.             <groupId>junit</groupId>
4.             <artifactId>junit</artifactId>
5.             <version>4.12</version>
6.             <scope>test</scope>
7.         </dependency>

复制代码

1.    2.注解(修饰方法)
2.         @Test======>可以运行的方法
3.         @Before====>@Test运行之前
4.         @After=====>@Test运行之后

复制代码

1. public class Test01 {
2.     ClassPathXmlApplicationContext applicationContext=null;
3.     IAccountController controller=null;
5.     @Before
6.     public void beforeMethod(){
7.         applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
8.         controller = (IAccountController) applicationContext.getBean("controller");
9.     }
12.     @After
13.     public void afterMethod(){
14.         applicationContext.close();
15.     }
18.     @Test
19.     public void show1(){
20.         controller.save(new Account("林航宇",2000));
21.         controller.save(new Account("杨文琪",2000));
22.     }
24.     @Test
25.     public void show2(){
26.         List<Account> all = controller.findAll();
27.         for (int i = 0; i < all.size(); i++) {
28.             Account account =  all.get(i);
29.             System.out.println(account);
30.         }
31.     }
33. }

复制代码

注解

1. <!-- 加载资源文件 -->    <context:property-placeholder location="classpath:jdbc.properties"></context:property-placeholder>    <!-- 注入数据源 -->    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">        <property name="driverClass" value="${msg1}"></property>        <property name="jdbcUrl" value="${msg2}"></property>        <property name="user" value="${msg3}"></property>        <property name="password" value="${msg4}"></property>    </bean>    <!-- 注入QueryRunner -->
2.     <bean id="queryRunner" class="org.apache.commons.dbutils.QueryRunner">
3.         <constructor-arg name="ds" ref="dataSource"></constructor-arg>
4.     </bean>
5.     <context:component-scan base-package="com.xn"></context:component-scan></beans>

复制代码

  

  

  

  设置工具
  

  

  

  

   

1. 项目总结：
2.     1.事务管理应该由service层进行实现
3. 代码优化：
4.     目的：业务层进行事务管理

复制代码

1. public class AccountServiceImp implements IAccountService{
3.     IAccountMapper mapper;
5.     public void setMapper(IAccountMapper mapper) {
6.         this.mapper = mapper;
7.     }
9.     //装配
10.     TransactionUtil transactionUtil;
12.     public void setTransactionUtil(TransactionUtil transactionUtil) {
13.         this.transactionUtil = transactionUtil;
14.     }
16.     @Override
17.     public void transfer(String sourceName, String targetName, int money) {
19.         try {
20.             transactionUtil.beginTx();
22.             //查询数据
23.             Account sourceAccount=mapper.findByName(sourceName);
24.             Account targetAccount=mapper.findByName(targetName);
26.             //转账
27.             sourceAccount.setAmoney(sourceAccount.getAmoney()-money);
28.             targetAccount.setAmoney(targetAccount.getAmoney()+money);
30.             //修改数据库
31.             mapper.updateById(sourceAccount);
32. //            int a=10/0;//模拟异常
33.             mapper.updateById(targetAccount);
35.             transactionUtil.commitTx();
37.         } catch (Exception e) {
38.             e.printStackTrace();
39.             transactionUtil.rollbackTx();
40.         } finally {
41.             transactionUtil.closeTx();
42.         }
43.     }

复制代码

1.     1.同一个业务方法的多个dao方法公用一个connection对象

复制代码

1. public class AccountMapperImp implements IAccountMapper{
3.     //操作数据库的核心类
4.     QueryRunner queryRunner;
6.     public void setQueryRunner(QueryRunner queryRunner) {
7.         this.queryRunner = queryRunner;
8.     }
10.     //注入连接工具类
11.      ConnectionUtil connectionUtil;
13.     public void setConnectionUtil(ConnectionUtil connectionUtil) {
14.         this.connectionUtil = connectionUtil;
15.     }
18.     @Override
19.     public void save(Account account) {
20.         try {
21.             queryRunner.update(connectionUtil.createCon(),"insert into account(aname,amoney) value(?,?)",account.getAname(),account.getAmoney());
22.         } catch (SQLException throwables) {
23.             throwables.printStackTrace();
24.         }
25.     }

复制代码

1.    2.ThreadLocal

复制代码

1. <!-- 事务工具类 -->
2.     <bean id="transactionUtil" class="com.xn.util.TransactionUtil">
3.         <property name="connectionUtil" ref="connectionUtil"/>
4.     </bean>
6.     <!-- 注入dao -->
7.     <bean id="mapperImp" class="com.xn.dao.AccountMapperImp">
8.         <property name="queryRunner" ref="queryRunner"></property>
9.         <property name="connectionUtil" ref="connectionUtil"></property>
10.     </bean>
12.     <!-- 注入service -->
13.     <bean id="service" class="com.xn.service.AccountServiceImp">
14.         <property name="mapper" ref="mapperImp"/>
15.         <property name="transactionUtil" ref="transactionUtil"></property>
16.     </bean>

复制代码

1.     3.通过连接对象进行事务的统一管理

复制代码

1. public class ConnectionUtil {
2.     //装配数据源
3.     DataSource dataSource;
5.     public void setDataSource(DataSource dataSource) {
6.         this.dataSource = dataSource;
7.     }
9.     //线程区域对象
10.     ThreadLocal<Connection> threadLocal=new ThreadLocal<Connection>();
12.     //获取连接
13.     public Connection createCon(){
15.         try {
16.             //获取线程内的连接对象
17.             Connection connection=threadLocal.get();
18.             //判断
19.             if(connection==null){
20.                 connection=dataSource.getConnection();//创建连接
21.                 threadLocal.set(connection);//保存
22.             }
23.             return  connection;
24.         } catch (SQLException throwables) {
25.             throwables.printStackTrace();
26.         }
28.         return null;
29.     }
31.     //移除连接
32.     public void removeCon(){
33.         threadLocal.remove();//一处连接对象
34.     }
35. }

复制代码

1. public class TransactionUtil {
2.     //注入连接工具类
3.     ConnectionUtil connectionUtil;
5.     public void setConnectionUtil(ConnectionUtil connectionUtil) {
6.         this.connectionUtil = connectionUtil;
7.     }
9.     //开启事务
10.     public void beginTx(){
11.         try {
12.             connectionUtil.createCon().setAutoCommit(false);
14.         } catch (SQLException throwables) {
15.             throwables.printStackTrace();
16.         }
17.     }
19.     //提交事务
20.     public void commitTx(){
21.         try {
22.             connectionUtil.createCon().commit();
23.         } catch (SQLException throwables) {
24.             throwables.printStackTrace();
25.         }
26.     }
28.     //回滚事务
29.     public void rollbackTx(){
30.         try {
31.             connectionUtil.createCon().rollback();
32.         } catch (SQLException throwables) {
33.             throwables.printStackTrace();
34.         }
35.     }
37.     //关闭事务
38.     public void closeTx(){
39.         try {
40.             connectionUtil.createCon().close();
41.             connectionUtil.removeCon();
42.         } catch (SQLException throwables) {
43.             throwables.printStackTrace();
44.         }
45.     }
47. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。