Android：使用 ContentResolver 时的 SQLite 事务

Question

目标：从 XML 数据刷新数据库

过程：

• 启动事务
• 删除表中的所有现有行
• 根据解析的 XML 插入行的每个主要元素进入主表并获取 PK
• 每个主元素的每个子元素 插入 记录到第二个表中，提供上一步的 FK
• 提交事务

就数据库操作而言，这是相当标准的东西。问题是 CRUD 操作不是在 ContentProvider 内完成的，而是使用 ContentResolver 完成的，因此插入示例看起来像 resolver.insert(CONTENT_URI, contentValues)。 ContentResolver API 似乎没有与事务相关的任何内容，并且我无法使用 bulkInsert 因为我间歇性地插入 2 个表（另外我希望在交易也是如此）。

我正在考虑使用 registerContentObserver 将自定义的 ContentProvider 注册为侦听器，但由于 ContentResolver#acquireProvider 方法被隐藏，我如何获得正确的引用？

我运气不好吗？

Answer 1

我在 Google I/O 应用程序的源代码中看到，它们重写了 ContentProvider 的 applyBatch() 方法并在其中使用事务。因此，您创建一批 ContentProviderOperation ，然后调用 getContentResolver().applyBatch(uri_authority, batch)。

我打算使用这种方法来看看它是如何工作的。我很好奇是否还有其他人尝试过。

Answer 2

正如 kaciula 提到的，自 Android 2.1 以来，可以通过使用 ContentProviderOperation 相当干净地进行基于事务的多表插入。

构建 ContentProviderOperation 对象时，可以调用 .withValueBackReference(fieldName, refNr)。当使用 applyBatch 应用该操作时，结果是通过 insert() 调用提供的 ContentValues 对象将注入一个整数。该整数将使用 fieldName 字符串作为键控，其值是从先前应用的 ContentProviderOperation 的 ContentProviderResult 中检索的，由 refNr 索引。

请参考下面的代码示例。在示例中，在表 1 中插入一行，然后在表 2 中插入该行时，将生成的 ID（在本例中为“1”）用作值。为简洁起见，ContentProvider 未连接到数据库。在 ContentProvider 中，有适合添加事务处理的打印输出。

public class BatchTestActivity extends Activity {
    /** Called when the activity is first created. */
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);

        ArrayList<ContentProviderOperation> list = new
            ArrayList<ContentProviderOperation>();

        list.add(ContentProviderOperation.
            newInsert(BatchContentProvider.FIRST_URI).build());
        ContentValues cv = new ContentValues();
        cv.put("name", "second_name");
        cv.put("refId", 23);

        // In this example, "refId" in the contentValues will be overwritten by
        // the result from the first insert operation, indexed by 0
        list.add(ContentProviderOperation.
            newInsert(BatchContentProvider.SECOND_URI).
            withValues(cv).withValueBackReference("refId", 0).build());

        try {
            getContentResolver().applyBatch(
                BatchContentProvider.AUTHORITY, list);
        } catch (RemoteException e) {
            e.printStackTrace();
        } catch (OperationApplicationException e) {
            e.printStackTrace();
        }
    }
}

public class BatchContentProvider extends ContentProvider {

    private static final String SCHEME = "content://";
    public static final String AUTHORITY = "com.test.batch";

    public static final Uri FIRST_URI =
        Uri.parse(SCHEME + AUTHORITY + "/" + "table1");
    public static final Uri SECOND_URI =
        Uri.parse(SCHEME + AUTHORITY + "/" + "table2");


    public ContentProviderResult[] applyBatch(
        ArrayList<ContentProviderOperation> operations)
            throws OperationApplicationException {
        System.out.println("starting transaction");
        ContentProviderResult[] result;
        try {
            result = super.applyBatch(operations);
        } catch (OperationApplicationException e) {
            System.out.println("aborting transaction");
            throw e;
        }
        System.out.println("ending transaction");
        return result;
    }

    public Uri insert(Uri uri, ContentValues values) {
        // this printout will have a proper value when
        // the second operation is applied
        System.out.println("" + values);

        return ContentUris.withAppendedId(uri, 1);
    }

    // other overrides omitted for brevity
}

Answer 3

好吧 - 所以这不会漫无目的：我能想到的唯一方法是将 startTransaction 和 endTransaction 编码为基于 URL 的查询请求。类似于 ContentResolver.query(START_TRANSACTION, null, null, null, null)。然后在ContentProvider#query中根据注册的URL调用开始或结束事务

Answer 4

您可以获取内容提供程序对象本身的实现（如果在同一进程中，提示：您可以使用 multiprocess="true" 或 process="" http://developer.android.com/guide/topics/manifest/provider-element.html) 使用 ContentProviderClient.getLocalContentProvider () 可以转换为您的提供程序实现，它可以提供额外的功能，例如关闭和删除数据库的 Reset()，您还可以使用 save() 和 close() 方法返回自定义 Transaction 类实例。

public class Transaction {
    protected Transaction (SQLiteDatabase database) {
        this.database = database;
        database.beginTransaction ();
    }

    public void save () {
        this.database.setTransactionSuccessful ();
    }

    public void close () {
        this.database.endTransaction ();
    }

    private SQLiteDatabase database;
}

public Transaction createTransaction () {
    return new Transaction (this.dbHelper.getWritableDatabase ());
}

然后：

ContentProviderClient client = getContentResolver ().acquireContentProviderClient (Contract.authorityLocal);
Transaction tx = ((LocalContentProvider) client.getLocalContentProvider ()).createTransaction ();