Spring事務

Spring中事務的管理就是通過AOP將事務的程式碼進行抽取

XML配置

第一步 建立c3p0連線池
將sessionFactory中的資料庫相關屬性替換為c3p0

<bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
    <property name="jdbcUrl" value="jdbc:mysql:///MyDB"
 
></property>
    <property name="user" value="root"></property>
    <property name="password" value="123456"></property>
</bean>

第二步 建立事務管理物件

<bean name="transactionManager" class="org.springframework.orm.hibernate5.HibernateTransactionManager">
    <!-- 注入會話工廠 -->
 

    <property name="sessionFactory" ref="sessionFactory"></property>
</bean>

第三步 設定會話策略

<tx:advice id="advice" transaction-manager="transactionManager">
    <tx:attributes>
        <tx:method name="insert*" read-only="false"/>
        <tx:method name="select*"
 
 read-only="true"/>
        <tx:method name="update*" read-only="false"/>
        <tx:method name="delete*" read-only="false"/>
    </tx:attributes>
</tx:advice>

第四步 織入

<aop:config>
    <aop:pointcut expression="execution(* com.lanou.dao.impl.*.*(..))" id="point"/>
    <aop:advisor advice-ref="advice" pointcut-ref="point"/>
</aop:config>

註解配置

前兩步和註解一樣
第三步 啟動AOP事務註解

<tx:annotation-driven/>

第四步 添加註解

@Transactional
public class UserDaoImpl extends HibernateDaoSupport implements UserDao

SSH操作資料庫(HibernateDaoSupport)

為了節省程式碼 Spring提供模板類用於dao層操作資料庫
封裝了常用功能:獲取session 執行查詢等...
在SSH中 只要進行CRUD就繼承HibernateDaoSupport 它能幫我們管理session
注意:別忘記注入sessionFactory

實現步驟:
    1.直接將Dao實現類繼承自 HibernateDaoSupport類
    2.通過呼叫父類的getHibernateTemplate獲取模板物件
    3.面向物件的  save delete update get
    4.使用hql語句/使用離線查詢

使用HQL例項

public List<User> selectAllUser() {
    // 演示如何使用HQL
    return getHibernateTemplate().execute(new HibernateCallback<List<User>>() {

        // 將CRUD的操作放到這個方法中 模板物件會自動呼叫
        @Override
        public List<User> doInHibernate(Session session) throws HibernateException {
            String hql = "from User";
            Query query = session.createQuery(hql);
            List<User> list = query.list();
            return list;
        }
    });
}

離線查詢例項

public User selectUserByName(String name) {
    // 離線查詢物件
    DetachedCriteria criteria = DetachedCriteria.forClass(User.class);
    // 新增查詢條件
    criteria.add(Restrictions.eq("name", name));
    List<User> list = (List<User>) getHibernateTemplate().findByCriteria(criteria);
    if (list != null && list.size() > 0) {
        return list.get(0);
    }
    return null;
}