Вставка нескольких строк с помощью ContentProvider

Мне нужно сделать вставку нескольких строк в одну транзакцию. Могу ли я сделать это с помощью ContentProvider?


person earsonheart    schedule 27.07.2011    source источник
comment
Вопрос неясен... в любом случае вы можете посмотреть здесь developer.android. com/guide/topics/providers/   -  person Kartik Domadiya    schedule 27.07.2011
comment
stackoverflow.com/questions/5596354/   -  person Selvin    schedule 27.07.2011


Ответы (4)


На стороне клиента ContentResolver поддерживает метод bulkInsert(). Они не обязательно будут обрабатываться в одной транзакции ContentProvider просто потому, что ContentProvider может не выполнять никаких транзакций.

person CommonsWare    schedule 27.07.2011
comment
Как я понимаю, если он не переопределен - он просто вызовет несколько стандартных методов «вставки»? - person earsonheart; 28.07.2011
comment
Правильный. Вы понятия не имеете, переопределяет ли какой-либо заданный ContentProvider bulkInsert(), если только это не ваш собственный ContentProvider. - person CommonsWare; 28.07.2011
comment
Я думаю, вам следует использовать ContentProviderOperations, прочитайте этот учебник grokkingandroid.com/ - person Sandeep Dhull; 25.11.2016

Я реализовал это в своем приложении, и вот суть кода, который я использую.

В моем контент-провайдере я переопределил метод applyBatch(), и это очень простой метод для переопределения:

/**
 * Performs the work provided in a single transaction
 */
@Override
public ContentProviderResult[] applyBatch(
        ArrayList<ContentProviderOperation> operations) {
    ContentProviderResult[] result = new ContentProviderResult[operations
            .size()];
    int i = 0;
    // Opens the database object in "write" mode.
    SQLiteDatabase db = mOpenHelper.getWritableDatabase();
    // Begin a transaction
    db.beginTransaction();
    try {
        for (ContentProviderOperation operation : operations) {
            // Chain the result for back references
            result[i++] = operation.apply(this, result, i);
        }

        db.setTransactionSuccessful();
    } catch (OperationApplicationException e) {
        Log.d(TAG, "batch failed: " + e.getLocalizedMessage());
    } finally {
        db.endTransaction();
    }

    return result;
}

Результат передается следующей операции, потому что вы хотите поддерживать обратные ссылки. Когда я действительно хочу изменить что-то в базе данных в этой единственной транзакции, я перебираю свой контент и делаю что-то вроде этого:

operations.add(ContentProviderOperation
                    .newInsert(
                            Uri.withAppendedPath(
                                    NotePad.Notes.CONTENT_ID_URI_BASE,
                                    Long.toString(task.dbId)))
                    .withValues(task.toNotesContentValues(0, listDbId))
                    .build());
// Now the other table, use back reference to the id the note
// received
noteIdIndex = operations.size() - 1;

operations.add(ContentProviderOperation
                    .newInsert(NotePad.GTasks.CONTENT_URI)
                    .withValues(task.toGTasksContentValues(accountName))
                    .withValueBackReferences(
                            task.toGTasksBackRefContentValues(noteIdIndex))
                    .build());

Вам просто нужно не забыть закончить, позвонив:

provider.applyBatch(operations);

Это выполнит ваши действия за одну транзакцию и поддерживает обратные ссылки, если вам нужен идентификатор из более ранней вставки без проблем.

person Jonas Kalderstam    schedule 29.02.2012

Вот пример для bulkInsert:

/**
 * Perform bulkInsert with use of transaction
 */
@Override
public int bulkInsert(Uri uri, ContentValues[] values) {
    int uriType = 0;
    int insertCount = 0;
    try {

        uriType = sURIMatcher.match(uri);
        SQLiteDatabase sqlDB = dbHelper.getWritableDatabase();

        switch (uriType) {
        case MEASUREMENTS:
            try {
                sqlDB.beginTransaction();
                for (ContentValues value : values) {
                    long id = sqlDB.insert(Tab_Measurements.TABLE_NAME, null, value);
                    if (id > 0)
                        insertCount++;
                }
                sqlDB.setTransactionSuccessful();
            } catch (Exception e) {
                // Your error handling
            } finally {
                sqlDB.endTransaction();
            }
            break;
        default:
            throw new IllegalArgumentException("Unknown URI: " + uri);
        }
        // getContext().getContentResolver().notifyChange(uri, null);
    } catch (Exception e) {
      // Your error handling
    }

    return insertCount;
}

И в вашем коде что-то вроде:

/**
 * Inserts new measurement information.
 * 
 * @param ArrayList of measurements
 * @return number of inserted entries
 */
public static long bulkInsertEntries(ArrayList<Item_Measurement> readings) {
    // insert only if data is set correctly
    if (readings.size() == 0)
        return 0;

    long insertCount = 0;
    try {
        // insert new entries

        // ArrayList<ContentValues> valueList = new ArrayList<ContentValues>();
        ContentValues[] valueList = new ContentValues[readings.size()];
        int i = 0;
        for (Item_Measurement reading : readings) {
            ContentValues values = new ContentValues();
            values.put(COL_TIME_READING, reading.getTimeReading());
                            // ...
            valueList[i++] = values;
        }

        // returns ID
        insertCount = ContentProviderOwn.getAppContext().getContentResolver()
                .bulkInsert(ContentProviderOwn.MEASUREMENTS_URI_BASE, valueList);

    } catch (Exception e) {
        // Your error handling
    }
    return insertCount;
}
person Gunnar Bernstein    schedule 26.11.2013
comment
Чем это лучше, чем вызов обычной вставки в цикл из исходного массива данных? Есть ли преимущества в производительности при использовании BulkInsert? - person Andrew S; 04.08.2015
comment
@AndrewS bulkInsert() намного лучше подходит для больших операций. Только что закончил оптимизацию в моем приложении: applyBatch() с 2000 операциями на нескольких таблицах занимает 2000 мс, 10 bulkInsert занимает 100 мс. - person Sergey Glotov; 29.10.2015
comment
Я заметил, что вы закомментировали notifyChange. Какая польза делать это или нет? - person Suragch; 26.05.2018

Я также использую режим замены для вставки строки - db.insertWithOnConflict(EVENT_TABLE_NAME, null, value, SQLiteDatabase.CONFLICT_REPLACE); Это избавит от конфликта, если запись уже существует

В DatabaseHelper добавьте УНИКАЛЬНЫЙ ИНДЕКС

    public class DataProvider extends ContentProvider {

    private static class DatabaseHelper extends SQLiteOpenHelper {
        DatabaseHelper(Context context){
            super(context, DATABASE_NAME, null, DATABASE_VERSION);
        }

        @Override
        public void onCreate(SQLiteDatabase db){
            db.execSQL(CREATE_EVENT_TABLE);
            db.execSQL("CREATE UNIQUE INDEX event_idx ON " + EVENT_TABLE_NAME + " ( " + EventTable.EVENT_ID + " )");
// ...

        ...
        @Override
        public int bulkInsert(Uri uri, ContentValues[] values) {
            Log.i(TAG, "bulkInsert");
            if (values.length == 0)
                return 0;
            int insertCount = 0;
            try {
                switch (uriMatcher.match(uri)) {
                    case EVENT_LIST:
                        try {
                            db.beginTransaction();
                            for (ContentValues value : values) {
                                long id = db.insertWithOnConflict(EVENT_TABLE_NAME, null, value, SQLiteDatabase.CONFLICT_REPLACE);
                                if (id > 0)
                                    insertCount++;
                            }
                            db.setTransactionSuccessful();
                        } catch (Exception e) {
                            // Your error handling
                        } finally {
                            db.endTransaction();
                        }
                        break;
                    default:
                        throw new IllegalArgumentException("Unknown URI " + uri);
                }
                getContext().getContentResolver().notifyChange(uri, null);
            } catch (Exception e) {
                Log.i(TAG, "Exception : " + e);
            }
            return insertCount;
        }

И вызовите bulkInsert следующим образом:

            ContentValues[] cvArr = new ContentValues[eventList.size()];
            long insertCount = 0;
            int i = 0;
            for (Event event : eventList) {
                ContentValues cv = new ContentValues();
                cv.put(DataProvider.EventTable.EVENT_ID, event.id);
                cv.put(DataProvider.EventTable.SENSOR_ID, event.sensor_id);
                cv.put(DataProvider.EventTable.TIMESTAMP, event.time);
                cvArr[i++] = cv;
            }
            // returns ID
            insertCount = context.getContentResolver()
                    .bulkInsert(DataProvider.CONTENT_EVENT_LIST, cvArr);
person Appz    schedule 14.02.2015