The Tor Browser: mobile/android/base/db/ReadingListProvider.java@b8a032363ba2 (annotated)

mobile/android/base/db/ReadingListProvider.java@b8a032363ba2 (annotated)

mobile/android/base/db/ReadingListProvider.java

Thu, 22 Jan 2015 13:21:57 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Thu, 22 Jan 2015 13:21:57 +0100
branch: TOR_BUG_9701
changeset 15: b8a032363ba2
permissions: -rw-r--r--

Incorporate requested changes from Mozilla in review:
https://bugzilla.mozilla.org/show_bug.cgi?id=1123480#c6

 /* This Source Code Form is subject to the terms of the Mozilla Public
  * License, v. 2.0. If a copy of the MPL was not distributed with this file,
  * You can obtain one at http://mozilla.org/MPL/2.0/. */
 package org.mozilla.gecko.db;
 import org.mozilla.gecko.db.BrowserContract.ReadingListItems;
 import org.mozilla.gecko.sync.Utils;
 import android.content.ContentUris;
 import android.content.ContentValues;
 import android.content.UriMatcher;
 import android.database.Cursor;
 import android.database.sqlite.SQLiteDatabase;
 import android.database.sqlite.SQLiteQueryBuilder;
 import android.net.Uri;
 import android.text.TextUtils;
 public class ReadingListProvider extends SharedBrowserDatabaseProvider {
     static final String TABLE_READING_LIST = ReadingListItems.TABLE_NAME;
     static final int ITEMS = 101;
     static final int ITEMS_ID = 102;
     static final UriMatcher URI_MATCHER = new UriMatcher(UriMatcher.NO_MATCH);
     static {
         URI_MATCHER.addURI(BrowserContract.READING_LIST_AUTHORITY, "items", ITEMS);
         URI_MATCHER.addURI(BrowserContract.READING_LIST_AUTHORITY, "items/#", ITEMS_ID);
     }
     /**
      * Updates items that match the selection criteria. If no such items is found
      * one is inserted with the attributes passed in. Returns 0 if no item updated.
      *
      * @return Number of items updated or inserted
      */
     public int updateOrInsertItem(Uri uri, ContentValues values, String selection, String[] selectionArgs) {
         int updated = updateItems(uri, values, selection, selectionArgs);
         if (updated <= 0) {
             updated = insertItem(uri, values) != -1 ? 1 : 0;
         }
         return updated;
     }
     /**
      * Updates items that match the selection criteria.
      *
      * @return Number of items updated or inserted
      */
     public int updateItems(Uri uri, ContentValues values, String selection, String[] selectionArgs) {
         trace("Updating ReadingListItems on URI: " + uri);
         final SQLiteDatabase db = getWritableDatabase(uri);
         if (!values.containsKey(ReadingListItems.DATE_MODIFIED)) {
             values.put(ReadingListItems.DATE_MODIFIED, System.currentTimeMillis());
         }
         return db.update(TABLE_READING_LIST, values, selection, selectionArgs);
     }
     /**
      * Inserts a new item into the DB. DATE_CREATED, DATE_MODIFIED
      * and GUID fields are generated if they are not specified.
      *
      * @return ID of the newly inserted item
      */
     long insertItem(Uri uri, ContentValues values) {
         long now = System.currentTimeMillis();
         if (!values.containsKey(ReadingListItems.DATE_CREATED)) {
             values.put(ReadingListItems.DATE_CREATED, now);
         }
         if (!values.containsKey(ReadingListItems.DATE_MODIFIED)) {
             values.put(ReadingListItems.DATE_MODIFIED, now);
         }
         if (!values.containsKey(ReadingListItems.GUID)) {
             values.put(ReadingListItems.GUID, Utils.generateGuid());
         }
         String url = values.getAsString(ReadingListItems.URL);
         debug("Inserting item in database with URL: " + url);
         return getWritableDatabase(uri)
                 .insertOrThrow(TABLE_READING_LIST, null, values);
     }
     /**
      * Deletes items. Item is marked as 'deleted' so that sync can
      * detect the change.
      *
      * @return Number of deleted items
      */
     int deleteItems(Uri uri, String selection, String[] selectionArgs) {
         debug("Deleting item entry for URI: " + uri);
         final SQLiteDatabase db = getWritableDatabase(uri);
         if (isCallerSync(uri)) {
             return db.delete(TABLE_READING_LIST, selection, selectionArgs);
         }
         debug("Marking item entry as deleted for URI: " + uri);
         ContentValues values = new ContentValues();
         values.put(ReadingListItems.IS_DELETED, 1);
         cleanUpSomeDeletedRecords(uri, TABLE_READING_LIST);
         return updateItems(uri, values, selection, selectionArgs);
     }
     @Override
     @SuppressWarnings("fallthrough")
     public int updateInTransaction(Uri uri, ContentValues values, String selection, String[] selectionArgs) {
         trace("Calling update in transaction on URI: " + uri);
         int updated = 0;
         int match = URI_MATCHER.match(uri);
         switch (match) {
             case ITEMS_ID:
                 debug("Update on ITEMS_ID: " + uri);
                 selection = DBUtils.concatenateWhere(selection, TABLE_READING_LIST + "._id = ?");
                 selectionArgs = DBUtils.appendSelectionArgs(selectionArgs,
                         new String[] { Long.toString(ContentUris.parseId(uri)) });
             case ITEMS: {
                 debug("Updating ITEMS: " + uri);
                 updated = shouldUpdateOrInsert(uri) ?
                           updateOrInsertItem(uri, values, selection, selectionArgs) :
                           updateItems(uri, values, selection, selectionArgs);
                 break;
             }
             default:
                 throw new UnsupportedOperationException("Unknown update URI " + uri);
         }
         debug("Updated " + updated + " rows for URI: " + uri);
         return updated;
     }
     @Override
     @SuppressWarnings("fallthrough")
     public int deleteInTransaction(Uri uri, String selection, String[] selectionArgs) {
         trace("Calling delete in transaction on URI: " + uri);
         int numDeleted = 0;
         int match = URI_MATCHER.match(uri);
         switch (match) {
             case ITEMS_ID:
                 debug("Deleting on ITEMS_ID: " + uri);
                 selection = DBUtils.concatenateWhere(selection, TABLE_READING_LIST + "._id = ?");
                 selectionArgs = DBUtils.appendSelectionArgs(selectionArgs,
                         new String[] { Long.toString(ContentUris.parseId(uri)) });
             case ITEMS:
                 debug("Deleting ITEMS: " + uri);
                 numDeleted = deleteItems(uri, selection, selectionArgs);
                 break;
             default:
                 throw new UnsupportedOperationException("Unknown update URI " + uri);
         }
         debug("Deleted " + numDeleted + " rows for URI: " + uri);
         return numDeleted;
     }
     @Override
     public Uri insertInTransaction(Uri uri, ContentValues values) {
         trace("Calling insert in transaction on URI: " + uri);
         long id = -1;
         int match = URI_MATCHER.match(uri);
         switch (match) {
             case ITEMS:
                 trace("Insert on ITEMS: " + uri);
                 id = insertItem(uri, values);
                 break;
             default:
                 throw new UnsupportedOperationException("Unknown insert URI " + uri);
         }
         debug("Inserted ID in database: " + id);
         if (id >= 0) {
             return ContentUris.withAppendedId(uri, id);
         }
         return null;
     }
     @Override
     public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, String sortOrder) {
         String groupBy = null;
         SQLiteDatabase db = getReadableDatabase(uri);
         SQLiteQueryBuilder qb = new SQLiteQueryBuilder();
         String limit = uri.getQueryParameter(BrowserContract.PARAM_LIMIT);
         final int match = URI_MATCHER.match(uri);
         switch (match) {
             case ITEMS_ID:
                 trace("Query on ITEMS_ID: " + uri);
                 selection = DBUtils.concatenateWhere(selection, ReadingListItems._ID + " = ?");
                 selectionArgs = DBUtils.appendSelectionArgs(selectionArgs,
                         new String[] { Long.toString(ContentUris.parseId(uri)) });
             case ITEMS:
                 trace("Query on ITEMS: " + uri);
                 if (!shouldShowDeleted(uri))
                     selection = DBUtils.concatenateWhere(ReadingListItems.IS_DELETED + " = 0", selection);
                 break;
             default:
                 throw new UnsupportedOperationException("Unknown query URI " + uri);
         }
         if (TextUtils.isEmpty(sortOrder)) {
             sortOrder = ReadingListItems.DEFAULT_SORT_ORDER;
         }
         trace("Running built query.");
         qb.setTables(TABLE_READING_LIST);
         Cursor cursor = qb.query(db, projection, selection, selectionArgs, groupBy, null, sortOrder, limit);
         cursor.setNotificationUri(getContext().getContentResolver(), uri);
         return cursor;
     }
     @Override
     public String getType(Uri uri) {
         trace("Getting URI type: " + uri);
         final int match = URI_MATCHER.match(uri);
         switch (match) {
             case ITEMS:
                 trace("URI is ITEMS: " + uri);
                 return ReadingListItems.CONTENT_TYPE;
             case ITEMS_ID:
                 trace("URI is ITEMS_ID: " + uri);
                 return ReadingListItems.CONTENT_ITEM_TYPE;
         }
         debug("URI has unrecognized type: " + uri);
         return null;
     }
 }

The Tor Browser / annotate

mobile/android/base/db/ReadingListProvider.java@b8a032363ba2 (annotated)

mobile/android/base/db/ReadingListProvider.java