Android: транзакции SQLite при использовании ContentResolver

Question

Цель: обновить базу данных из данных XML

Процесс:

• Начало транзакции
• Удалить все существующие строки из таблиц
• Для каждого основного элемента анализируемого XML вставить строку в основную таблицу и получить PK
• Для каждого дочернего элемента основного элемента вставить запись во 2-ю таблицу, предоставляя FK из предыдущего шага
• Совершить транзакцию

Довольно стандартный материал для операций с БД. Проблема в том, что CRUD-операции выполняются не в ContentProvider, а в ContentResolver, поэтому вставка, например, выглядит как resolver.insert(CONTENT_URI, contentValues). Похоже, что в ContentResolver API нет ничего относящегося к транзакции, и я не могу использовать bulkInsert, так как я периодически вставляю в 2 таблицы (плюс я хочу, чтобы внутри транзакции также было delete).

Я думал о регистрации моего настроенного ContentProvider в качестве слушателя с использованием registerContentObserver, но поскольку методы ContentResolver#acquireProvider скрыты, как мне получить правильную ссылку?

Мне не повезло?

Answer 1

Я видел, что в исходном коде приложения ввода / вывода Google они переопределяют метод ContentProvider applyBatch() и используют внутри него транзакции. Итак, вы создаете партию ContentProviderOperation с и затем вызываете getContentResolver().applyBatch(uri_authority, batch).

Я планирую использовать этот подход, чтобы увидеть, как он работает. Мне любопытно, попробовал ли кто-нибудь еще.

Answer 2

Начиная с Android 2.1 можно довольно аккуратно вставлять транзакции из нескольких таблиц, используя ContentProviderOperation, как упомянуто kaciula.

Когда вы создаете объект ContentProviderOperation, вы можете вызвать .withValueBackReference (fieldName, refNr). Когда операция применяется с применением applyBatch, результатом является то, что объекту ContentValues, предоставленному с вызовом insert (), будет вставлено целое число. Целое число будет связано с fieldName String, и его значение будет получено из ContentProviderResult ранее примененной ContentProviderOperation, проиндексированного refNr.

Пожалуйста, обратитесь к примеру кода ниже. В этом примере строка вставляется в table1, а результирующий идентификатор (в данном случае «1») затем используется в качестве значения при вставке строки в таблицу 2. Для краткости 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 (), которая закрывает и удаляет базу данных, и вы также можете вернуть пользовательский экземпляр класса Transaction с помощью методов save () и close ().

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 ();