summaryrefslogtreecommitdiffstats
path: root/src/com/android/bookmarkstore/SQLiteContentProvider.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/com/android/bookmarkstore/SQLiteContentProvider.java')
-rw-r--r--src/com/android/bookmarkstore/SQLiteContentProvider.java250
1 files changed, 0 insertions, 250 deletions
diff --git a/src/com/android/bookmarkstore/SQLiteContentProvider.java b/src/com/android/bookmarkstore/SQLiteContentProvider.java
deleted file mode 100644
index c202a57..0000000
--- a/src/com/android/bookmarkstore/SQLiteContentProvider.java
+++ /dev/null
@@ -1,250 +0,0 @@
-/*
- * Copyright (C) 2009 The Android Open Source Project
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License
- */
-
-package com.android.bookmarkprovider;
-
-import android.content.ContentProvider;
-import android.content.ContentProviderOperation;
-import android.content.ContentProviderResult;
-import android.content.ContentResolver;
-import android.content.ContentValues;
-import android.content.Context;
-import android.content.OperationApplicationException;
-import android.database.sqlite.SQLiteDatabase;
-import android.database.sqlite.SQLiteOpenHelper;
-import android.net.Uri;
-
-import java.util.ArrayList;
-import java.util.HashSet;
-import java.util.Set;
-
-/**
- * General purpose {@link ContentProvider} base class that uses SQLiteDatabase for storage.
- */
-public abstract class SQLiteContentProvider extends ContentProvider {
-
- private static final String TAG = "SQLiteContentProvider";
-
- private SQLiteOpenHelper mOpenHelper;
- private Set<Uri> mChangedUris;
- protected SQLiteDatabase mDb;
-
- private final ThreadLocal<Boolean> mApplyingBatch = new ThreadLocal<Boolean>();
- private static final int SLEEP_AFTER_YIELD_DELAY = 4000;
-
- /**
- * Maximum number of operations allowed in a batch between yield points.
- */
- private static final int MAX_OPERATIONS_PER_YIELD_POINT = 500;
-
- @Override
- public boolean onCreate() {
- Context context = getContext();
- mOpenHelper = getDatabaseHelper(context);
- mChangedUris = new HashSet<Uri>();
- return true;
- }
-
- /**
- * Returns a {@link SQLiteOpenHelper} that can open the database.
- */
- public abstract SQLiteOpenHelper getDatabaseHelper(Context context);
-
- /**
- * The equivalent of the {@link #insert} method, but invoked within a transaction.
- */
- public abstract Uri insertInTransaction(Uri uri, ContentValues values,
- boolean callerIsSyncAdapter);
-
- /**
- * The equivalent of the {@link #update} method, but invoked within a transaction.
- */
- public abstract int updateInTransaction(Uri uri, ContentValues values, String selection,
- String[] selectionArgs, boolean callerIsSyncAdapter);
-
- /**
- * The equivalent of the {@link #delete} method, but invoked within a transaction.
- */
- public abstract int deleteInTransaction(Uri uri, String selection, String[] selectionArgs,
- boolean callerIsSyncAdapter);
-
- /**
- * Call this to add a URI to the list of URIs to be notified when the transaction
- * is committed.
- */
- protected void postNotifyUri(Uri uri) {
- synchronized (mChangedUris) {
- mChangedUris.add(uri);
- }
- }
-
- public boolean isCallerSyncAdapter(Uri uri) {
- return false;
- }
-
- public SQLiteOpenHelper getDatabaseHelper() {
- return mOpenHelper;
- }
-
- private boolean applyingBatch() {
- return mApplyingBatch.get() != null && mApplyingBatch.get();
- }
-
- @Override
- public Uri insert(Uri uri, ContentValues values) {
- Uri result = null;
- boolean callerIsSyncAdapter = isCallerSyncAdapter(uri);
- boolean applyingBatch = applyingBatch();
- if (!applyingBatch) {
- mDb = mOpenHelper.getWritableDatabase();
- mDb.beginTransaction();
- try {
- result = insertInTransaction(uri, values, callerIsSyncAdapter);
- mDb.setTransactionSuccessful();
- } finally {
- mDb.endTransaction();
- }
-
- onEndTransaction(callerIsSyncAdapter);
- } else {
- result = insertInTransaction(uri, values, callerIsSyncAdapter);
- }
- return result;
- }
-
- @Override
- public int bulkInsert(Uri uri, ContentValues[] values) {
- int numValues = values.length;
- boolean callerIsSyncAdapter = isCallerSyncAdapter(uri);
- mDb = mOpenHelper.getWritableDatabase();
- mDb.beginTransaction();
- try {
- for (int i = 0; i < numValues; i++) {
- Uri result = insertInTransaction(uri, values[i], callerIsSyncAdapter);
- mDb.yieldIfContendedSafely();
- }
- mDb.setTransactionSuccessful();
- } finally {
- mDb.endTransaction();
- }
-
- onEndTransaction(callerIsSyncAdapter);
- return numValues;
- }
-
- @Override
- public int update(Uri uri, ContentValues values, String selection, String[] selectionArgs) {
- int count = 0;
- boolean callerIsSyncAdapter = isCallerSyncAdapter(uri);
- boolean applyingBatch = applyingBatch();
- if (!applyingBatch) {
- mDb = mOpenHelper.getWritableDatabase();
- mDb.beginTransaction();
- try {
- count = updateInTransaction(uri, values, selection, selectionArgs,
- callerIsSyncAdapter);
- mDb.setTransactionSuccessful();
- } finally {
- mDb.endTransaction();
- }
-
- onEndTransaction(callerIsSyncAdapter);
- } else {
- count = updateInTransaction(uri, values, selection, selectionArgs, callerIsSyncAdapter);
- }
-
- return count;
- }
-
- @Override
- public int delete(Uri uri, String selection, String[] selectionArgs) {
- int count = 0;
- boolean callerIsSyncAdapter = isCallerSyncAdapter(uri);
- boolean applyingBatch = applyingBatch();
- if (!applyingBatch) {
- mDb = mOpenHelper.getWritableDatabase();
- mDb.beginTransaction();
- try {
- count = deleteInTransaction(uri, selection, selectionArgs, callerIsSyncAdapter);
- mDb.setTransactionSuccessful();
- } finally {
- mDb.endTransaction();
- }
-
- onEndTransaction(callerIsSyncAdapter);
- } else {
- count = deleteInTransaction(uri, selection, selectionArgs, callerIsSyncAdapter);
- }
- return count;
- }
-
- @Override
- public ContentProviderResult[] applyBatch(ArrayList<ContentProviderOperation> operations)
- throws OperationApplicationException {
- int ypCount = 0;
- int opCount = 0;
- boolean callerIsSyncAdapter = false;
- mDb = mOpenHelper.getWritableDatabase();
- mDb.beginTransaction();
- try {
- mApplyingBatch.set(true);
- final int numOperations = operations.size();
- final ContentProviderResult[] results = new ContentProviderResult[numOperations];
- for (int i = 0; i < numOperations; i++) {
- if (++opCount >= MAX_OPERATIONS_PER_YIELD_POINT) {
- throw new OperationApplicationException(
- "Too many content provider operations between yield points. "
- + "The maximum number of operations per yield point is "
- + MAX_OPERATIONS_PER_YIELD_POINT, ypCount);
- }
- final ContentProviderOperation operation = operations.get(i);
- if (!callerIsSyncAdapter && isCallerSyncAdapter(operation.getUri())) {
- callerIsSyncAdapter = true;
- }
- if (i > 0 && operation.isYieldAllowed()) {
- opCount = 0;
- if (mDb.yieldIfContendedSafely(SLEEP_AFTER_YIELD_DELAY)) {
- ypCount++;
- }
- }
- results[i] = operation.apply(this, results, i);
- }
- mDb.setTransactionSuccessful();
- return results;
- } finally {
- mApplyingBatch.set(false);
- mDb.endTransaction();
- onEndTransaction(callerIsSyncAdapter);
- }
- }
-
- protected void onEndTransaction(boolean callerIsSyncAdapter) {
- Set<Uri> changed;
- synchronized (mChangedUris) {
- changed = new HashSet<Uri>(mChangedUris);
- mChangedUris.clear();
- }
- ContentResolver resolver = getContext().getContentResolver();
- for (Uri uri : changed) {
- boolean syncToNetwork = !callerIsSyncAdapter && syncToNetwork(uri);
- resolver.notifyChange(uri, null, syncToNetwork);
- }
- }
-
- protected boolean syncToNetwork(Uri uri) {
- return false;
- }
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-04-24 18:41:32 +0000