麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久99热浪潮_成人一区二区三区四区

首頁 > 開發(fā) > Java > 正文

spring 整合JDBC和AOP事務的方法

2024-07-14 08:41:53
字體:
來源:轉載
供稿:網(wǎng)友

spring整合JDBC

spring提供了很多模板整合Dao技術

 

ORM持久化技術 模板類
JDBC org.springframework.Jdbc.core.JdbcTemplate
Hibernate3.0 org.springframework.orm.hiberate3.HibernateTemplate
IBatis(MyBatis) org.springframework.orm.sqlMapClientTemplate
JPA org.springframework.orm.jpa.JpaTemplate

 

spring中提供了一個可以操作數(shù)據(jù)庫的對象.對象封裝了jdbc技術.

// JDBCTemplate => JDBC模板對象// 與DBUtils中的QueryRunner非常相似.// 0 準備連接池ComboPooledDataSource dataSource = new ComboPooledDataSource();dataSource.setDriverClass("com.mysql.jdbc.Driver");dataSource.setJdbcUrl("jdbc:mysql:///hibernate_32");dataSource.setUser("root");dataSource.setPassword("1234");// 1 創(chuàng)建JDBC模板對象JdbcTemplate jt = new JdbcTemplate();jt.setDataSource(dataSource);// 2 書寫sql,并執(zhí)行String sql = "insert into t_user values(null,'rose') ";jt.update(sql);

步驟

1.導包

  • 基礎包4 + 2
  • spring-test
  • spring-aop
  • junit4類庫
  • 新增c3p0連接池JDBC驅動包
  • spring-jdbc包
  • spring-tx事務包

2.準備數(shù)據(jù)庫

本地數(shù)據(jù)庫和表

3.書寫dao

// 使用JDBC模板實現(xiàn)增刪改查public class UserDaoImpl extends JdbcDaoSupport implements UserDao {  @Override  public void save(User u) {    String sql = "insert into t_user values(null,?) ";    super.getJdbcTemplate().update(sql, u.getName());  }  @Override  public void delete(Integer id) {    String sql = "delete from t_user where id = ? ";    super.getJdbcTemplate().update(sql,id);  }  @Override  public void update(User u) {    String sql = "update t_user set name = ? where id=? ";    super.getJdbcTemplate().update(sql, u.getName(),u.getId());  }  @Override  public User getById(Integer id) {    String sql = "select * from t_user where id = ? ";    return super.getJdbcTemplate().queryForObject(sql,new RowMapper<User>(){      @Override      public User mapRow(ResultSet rs, int arg1) throws SQLException {        User u = new User();        u.setId(rs.getInt("id"));        u.setName(rs.getString("name"));        return u;      }}, id);      }  @Override  public int getTotalCount() {    String sql = "select count(*) from t_user ";    Integer count = super.getJdbcTemplate().queryForObject(sql, Integer.class);    return count;  }  @Override  public List<User> getAll() {    String sql = "select * from t_user ";    List<User> list = super.getJdbcTemplate().query(sql, new RowMapper<User>(){      @Override      public User mapRow(ResultSet rs, int arg1) throws SQLException {        User u = new User();        u.setId(rs.getInt("id"));        u.setName(rs.getString("name"));        return u;      }});    return list;  }}

4.spring配置

<!-- 指定spring讀取db.properties配置 --><context:property-placeholder location="classpath:db.properties" /><!-- 1.將連接池放入spring容器 --><bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" >  <property name="jdbcUrl" value="${jdbc.jdbcUrl}" ></property>  <property name="driverClass" value="${jdbc.driverClass}" ></property>  <property name="user" value="${jdbc.user}" ></property>  <property name="password" value="${jdbc.password}" ></property></bean><!-- 2.將JDBCTemplate放入spring容器 --><bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" >  <property name="dataSource" ref="dataSource" ></property></bean><!-- 3.將UserDao放入spring容器 --><bean name="userDao" class="cn.zhli13.jdbctemplate.UserDaoImpl" >  <property name="jt" ref="jdbcTemplate" ></property></bean>// 若UserDao類繼承了JdbcDaoSupport,則無需將JDBCTemplate注入到容器中,省略第二步,第三步改為 <!-- 3.將UserDao放入spring容器 --><bean name="userDao" class="cn.zhli13.jdbctemplate.UserDaoImpl" >  <property name="dataSource" ref="dataSource" ></property></bean>

spring中aop事務

事務

事務特性:acid

事務并發(fā)問題:臟讀、不可重復讀、幻讀

事務的隔離級別:1 讀未提交、2 讀已提交、4 可重復讀、8 串行化

spring封裝了事務管理代碼

事務操作:1、打開事務、2、提交事務、3、回滾事務

事務操作對象

因為在不同平臺,操作事務的代碼各不相同.spring提供了一個接口

PlatformTransactionManager 接口

  • DataSourceTransactionManager
  • HibernateTransitionmanager

注意:在spring中玩事務管理.最為核心的對象就是TransactionManager對象

spring管理事務的屬性介紹

事務的隔離級別:1 讀未提交、2 讀已提交、4 可重復讀、8 串行化

是否只讀: true只讀 false可操作

事務的傳播行為:決定業(yè)務方法之間調用,事務應該如何處理

* 保證同一個事務中
PROPAGATION_REQUIRED 支持當前事務,如果不存在 就新建一個(默認、推薦99.99%用這種)
PROPAGATION_SUPPORTS 支持當前事務,如果不存在,就不使用事務
PROPAGATION_MANDATORY 支持當前事務,如果不存在,拋出異常

* 保證沒有在同一個事務中
PROPAGATION_REQUIRES_NEW 如果有事務存在,掛起當前事務,創(chuàng)建一個新的事務
PROPAGATION_NOT_SUPPORTED 以非事務方式運行,如果有事務存在,掛起當前事務
PROPAGATION_NEVER 以非事務方式運行,如果有事務存在,拋出異常
PROPAGATION_NESTED 如果當前事務存在,則嵌套事務執(zhí)行

spring管理事務方式

// 編碼式// 1.將核心事務管理器配置到spring容器<!-- 事務核心管理器,封裝了所有事務操作. 依賴于連接池 --><bean name="transactionManager"       class="org.springframework.jdbc.datasource.DataSourceTransactionManager" >  <property name="dataSource" ref="dataSource" ></property></bean>// 2.配置TransactionTemplate模板<!-- 事務模板對象 --><bean name="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate" >  <property name="transactionManager" ref="transactionManager" >  </property></bean>// 3.將事務模板注入Service<!-- 3.Service--><bean name="accountService" class="cn.itcast.service.AccountServiceImpl" >  <property name="ad" ref="accountDao" ></property>  <property name="tt" ref="transactionTemplate" ></property></bean>  

xml配置(aop)

 // 1.導包 // aop、aspect、aopliance、aspect.weaver // 2.導入新的約束(tx) // beans: 最基本、context:讀取properties配置、aop:配置aop、tx:配置事務通知 // 3.配置通知 <!-- 配置事務通知 --><tx:advice id="txAdvice" transaction-manager="transactionManager" >  <tx:attributes>    <!-- 以方法為單位,指定方法應用什么事務屬性      isolation:隔離級別      propagation:傳播行為      read-only:是否只讀     -->    <tx:method name="save*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />    <tx:method name="persist*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />    <tx:method name="update*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />    <tx:method name="modify*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />    <tx:method name="delete*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />    <tx:method name="remove*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />    <tx:method name="get*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="true" />    <tx:method name="find*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="true" />    <tx:method name="transfer" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />  </tx:attributes></tx:advice>// 4.配置將通知織入目標<!-- 配置織入 --><aop:config >  <!-- 配置切點表達式 -->  <aop:pointcut expression="execution(* cn.zhli13.service.*ServiceImpl.*(..))" id="txPc"/>  <!-- 配置切面 : 通知+切點       advice-ref:通知的名稱       pointcut-ref:切點的名稱   -->  <aop:advisor advice-ref="txAdvice" pointcut-ref="txPc" /></aop:config>

注解配置(aop)

// 1.導包(如xml配置一樣)// 2.導入約束(同上)// 3.開啟注解管理事務<!-- 開啟使用注解管理aop事務 --><tx:annotation-driven/>// 4.使用注解@Transactional(isolation=Isolation.REPEATABLE_READ,propagation=Propagation.REQUIRED,readOnly=true)public class AccountServiceImpl implements AccountService {@Transactional(isolation=Isolation.REPEATABLE_READ,propagation=Propagation.REQUIRED,readOnly=false)public void transfer(final Integer from,final Integer to,final Double money) {

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VeVb武林網(wǎng)。


注:相關教程知識閱讀請移步到JAVA教程頻道。
發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 久久久一区二区三区四区 | 久久艹综合 | 国产精品一区二av18款 | 欧美日韩亚洲一区二区三区 | 久久色播| 久久久久久久久久久影视 | 久久91久久久久麻豆精品 | 精品国产一区三区| 精品国产一区二区三区四区在线 | 日日操操| chinesexxxx刘婷hd| 麻豆视频国产在线观看 | 亚洲第一色片 | 国产精品久久久久久久久久久久午夜 | 日本高清一级片 | 青草久久久久 | 91精品久久香蕉国产线看观看 | 欧美视频在线一区二区三区 | 亚洲午夜久久久久 | 久久91久久 | 97超碰资源站 | av在线直播观看 | 久草在线综合 | 欧美成人性生活片 | 综合日韩欧美 | 伊人网站 | 国产精品999在线观看 | 黄色大片网 | 亚洲最新黄色网址 | 新久草在线视频 | 免费黄色大片网站 | 天天骑夜夜操 | 国产精品免费一区二区三区四区 | 国产精品视频一区二区三区四区国 | 色视频在线播放 | 国产毛片毛片毛片 | 中文字幕视频在线播放 | 国产一区二区三区在线观看视频 | 国产美女做爰免费视 | 成人精品一区二区 | av成人免费在线观看 |