事务的概念与Android中的事务类型

事务（Transaction）是数据库系统及业务逻辑中的核心概念，它保证一组操作要么全部成功，要么全部失败，从而维护数据的一致性和完整性。在Android应用开发中，事务不仅存在于SQLite数据库层面，还扩展到ContentProvider跨进程操作以及应用层的业务逻辑编排。不合理的事务实现会直接导致主线程阻塞、ANR（Application Not Responding）甚至数据损坏。

事务的ACID特性

任何符合事务概念的操作集合必须满足以下四个属性，这也是我们在Android优化中需要确保的基本契约：

Android中的三种事务类型

根据事务的作用域和实现方式，Android 事务可以归纳为以下三种类型，每类都直接影响主线程响应时间：

1. 数据库SQLite事务

最基础的事务类型，通过 beginTransaction() / setTransactionSuccessful() / endTransaction() 控制。典型优化目标是减少事务粒度、避免在主线程执行长时间写入。

// 低效写法：每条插入开启独立事务
SQLiteDatabase db = dbHelper.getWritableDatabase();
for (Record r : records) {
    db.beginTransaction();
    db.insert("table", null, r.toContentValues());
    db.setTransactionSuccessful();
    db.endTransaction(); // 循环内反复创建事务，I/O 剧增
}

// 优化写法：批量包裹在一个事务内
db.beginTransaction();
try {
    for (Record r : records) {
        db.insert("table", null, r.toContentValues());
    }
    db.setTransactionSuccessful();
} finally {
    db.endTransaction();
}

2. ContentProvider事务

ContentProvider 通过 applyBatch() 提供跨多个 URI 操作的原子性保证，底层通常对应 SQLite 事务。不当使用会使主线程等待 ContentProvider 进程的 Binder 响应，形成 ANR。

// 在主线程中调用 applyBatch（危险）
ContentProviderClient client = getContentResolver().acquireContentProviderClient("authority");
try {
    ArrayList<ContentProviderOperation> ops = new ArrayList<>();
    ops.add(ContentProviderOperation.newInsert("content://authority/table1").build());
    ops.add(ContentProviderOperation.newUpdate("content://authority/table2").build());
    // 以下调用会阻塞主线程，直到所有操作完成
    client.applyBatch(ops);
} finally {
    client.release();
}

// 优化方式：异步 + 取消能力
AsyncTask.execute(() -> {
    ContentProviderClient client = ...;
    try {
        ContentProviderResult[] results = client.applyBatch(ops);
    } catch (OperationApplicationException e) {
        // 合理处理回滚
    } finally {
        client.release();
    }
});

3. 业务事务

指跨多个组件（Activity、Service、Network、Database）的业务流程，例如“下单 → 扣库存 → 发送推送”。这类事务通常由开发者手动编排回滚逻辑，是最容易引发 ANR 的类型，因为单步失败可能导致重试或补偿操作在主线程执行。

// 伪代码：业务事务的典型结构（已优化，使用协程切换线程）
suspend fun placeOrder(order: Order) = withContext(Dispatchers.IO) {
    val dbTx = db.beginTransaction() // 数据库局部事务
    try {
        // 步骤1：写入订单表
        db.insert("orders", order.toValues())
        // 步骤2：调用远程库存接口（非主线程）
        val result = retrofit.updateInventory(order.itemId, -1)
        if (!result.isSuccess) throw BusinessException("库存不足")
        // 步骤3：发送推送通知（非主线程）
        pushService.sendOrderConfirmation(order.userId)
        db.setTransactionSuccessful()
    } catch (e: Exception) {
        // 回滚数据库写入 + 补偿远程操作（需幂等设计）
        rollbackRemoteInventory(order.itemId, 1) // 补偿请求
        throw e
    } finally {
        db.endTransaction()
    }
}