SpringIOC和SpringAOC

石小疯  论坛元老 | 2024-8-12 05:17:15 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 1029|帖子 1029|积分 3087

马上注册，结交更多好友，享用更多功能，让你轻松玩转社区。

您需要 登录 才可以下载或查看，没有账号？立即注册

x
  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企服之家，中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

石小疯

论坛元老
这个人很懒什么都没写!

楼主热帖

标签云

AI 运维 CIO 存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表