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中提供了一個可以操作數據庫的對象.對象封裝了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 創建JDBC模板對象JdbcTemplate jt = new JdbcTemplate();jt.setDataSource(dataSource);// 2 書寫sql,并執行String sql = "insert into t_user values(null,'rose') ";jt.update(sql);步驟
1.導包
2.準備數據庫
本地數據庫和表
3.書寫dao
// 使用JDBC模板實現增刪改查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
事務并發問題：臟讀、不可重復讀、幻讀
事務的隔離級別：1 讀未提交、2 讀已提交、4 可重復讀、8 串行化
spring封裝了事務管理代碼
事務操作：1、打開事務、2、提交事務、3、回滾事務
事務操作對象
因為在不同平臺,操作事務的代碼各不相同.spring提供了一個接口
PlatformTransactionManager 接口
注意:在spring中玩事務管理.最為核心的對象就是TransactionManager對象
spring管理事務的屬性介紹
事務的隔離級別：1 讀未提交、2 讀已提交、4 可重復讀、8 串行化
是否只讀： true只讀 false可操作
事務的傳播行為：決定業務方法之間調用，事務應該如何處理
* 保證同一個事務中
PROPAGATION_REQUIRED 支持當前事務，如果不存在 就新建一個(默認、推薦99.99%用這種)
PROPAGATION_SUPPORTS 支持當前事務，如果不存在，就不使用事務
PROPAGATION_MANDATORY 支持當前事務，如果不存在，拋出異常* 保證沒有在同一個事務中
PROPAGATION_REQUIRES_NEW 如果有事務存在，掛起當前事務，創建一個新的事務
PROPAGATION_NOT_SUPPORTED 以非事務方式運行，如果有事務存在，掛起當前事務
PROPAGATION_NEVER 以非事務方式運行，如果有事務存在，拋出異常
PROPAGATION_NESTED 如果當前事務存在，則嵌套事務執行
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武林網。
新聞熱點
疑難解答
圖片精選
