Java DAO如何處理事務

在Java中，DAO（Data Access Object）模式用于抽象和封裝對數據源的訪問。處理事務是確保數據一致性和完整性的關鍵部分。以下是如何在Java DAO中處理事務的一些步驟和最佳實踐：

1. 使用Spring框架管理事務

Spring框架提供了強大的事務管理功能，可以通過注解或XML配置來管理事務。

使用注解

在Spring中，可以使用@Transactional注解來聲明事務邊界。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {

    @Autowired
    private UserDao userDao;

    @Transactional
    public void createUser(User user) {
        userDao.save(user);
        // 其他數據庫操作
    }
}

使用XML配置

如果你更喜歡使用XML配置，可以在Spring配置文件中定義事務管理器和事務通知。

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"/>
</bean>

<tx:advice id="txAdvice" transaction-manager="transactionManager">
    <tx:attributes>
        <tx:method name="create*" propagation="REQUIRED" isolation="READ_COMMITTED"/>
        <tx:method name="update*" propagation="REQUIRED" isolation="READ_COMMITTED"/>
        <tx:method name="delete*" propagation="REQUIRED" isolation="READ_COMMITTED"/>
        <tx:method name="*" propagation="SUPPORTS" read-only="true"/>
    </tx:attributes>
</tx:advice>

<aop:config>
    <aop:pointcut id="serviceOperation" expression="execution(* com.example.service.*.*(..))"/>
    <aop:advisor advice-ref="txAdvice" pointcut-ref="serviceOperation"/>
</aop:config>

2. 手動管理事務

如果你不使用Spring框架，可以手動管理事務。這通常涉及使用JDBC的Connection對象來控制事務。

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class UserDao {

    private Connection connection;

    public UserDao(Connection connection) {
        this.connection = connection;
    }

    public void createUser(User user) throws SQLException {
        String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
        try (PreparedStatement stmt = connection.prepareStatement(sql)) {
            stmt.setString(1, user.getName());
            stmt.setString(2, user.getEmail());
            stmt.executeUpdate();
        }
    }

    public void beginTransaction() throws SQLException {
        connection.setAutoCommit(false);
    }

    public void commitTransaction() throws SQLException {
        connection.commit();
        connection.setAutoCommit(true);
    }

    public void rollbackTransaction() throws SQLException {
        connection.rollback();
        connection.setAutoCommit(true);
    }
}

在使用手動管理事務時，確保在try-catch塊中處理異常，并在發生異常時回滾事務。

public class UserService {

    private UserDao userDao;

    public UserService(UserDao userDao) {
        this.userDao = userDao;
    }

    public void createUser(User user) {
        try {
            userDao.beginTransaction();
            userDao.createUser(user);
            // 其他數據庫操作
            userDao.commitTransaction();
        } catch (SQLException e) {
            try {
                userDao.rollbackTransaction();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        }
    }
}

3. 使用JPA或Hibernate

如果你使用JPA（Java Persistence API）或Hibernate，它們也提供了事務管理功能。

JPA

import javax.persistence.EntityManager;
import javax.persistence.EntityTransaction;

public class UserService {

    private EntityManager entityManager;

    public UserService(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    public void createUser(User user) {
        EntityTransaction transaction = entityManager.getTransaction();
        try {
            transaction.begin();
            entityManager.persist(user);
            // 其他數據庫操作
            transaction.commit();
        } catch (Exception e) {
            if (transaction.isActive()) {
                transaction.rollback();
            }
            e.printStackTrace();
        }
    }
}

Hibernate

import org.hibernate.Session;
import org.hibernate.Transaction;

public class UserService {

    private Session session;

    public UserService(Session session) {
        this.session = session;
    }

    public void createUser(User user) {
        Transaction transaction = session.beginTransaction();
        try {
            session.save(user);
            // 其他數據庫操作
            transaction.commit();
        } catch (Exception e) {
            if (transaction.isActive()) {
                transaction.rollback();
            }
            e.printStackTrace();
        }
    }
}

總結

• Spring框架：使用@Transactional注解或XML配置來管理事務。
• 手動管理事務：使用JDBC的Connection對象來控制事務。
• JPA/Hibernate：使用JPA或Hibernate提供的事務管理功能。

選擇哪種方法取決于你的項目需求和偏好。Spring框架提供了最簡單和最強大的事務管理解決方案，而手動管理和JPA/Hibernate則提供了更多的靈活性和控制。