src/com/owncloud/android/providers/FileContentProvider.java

   1 /* ownCloud Android client application
   2  *
   3  *   @author Bartek Przybylski
   4  *   @author David A. Velasco
   5  *   Copyright (C) 2011  Bartek Przybylski
   6  *   Copyright (C) 2012-2013 ownCloud Inc.
   7  *
   8  *   This program is free software: you can redistribute it and/or modify
   9  *   it under the terms of the GNU General Public License version 2,
  10  *   as published by the Free Software Foundation.
  11  *
  12  *   This program is distributed in the hope that it will be useful,
  13  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
  14  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15  *   GNU General Public License for more details.
  16  *
  17  *   You should have received a copy of the GNU General Public License
  18  *   along with this program.  If not, see <http://www.gnu.org/licenses/>.
  19  *
  20  */
  21
  22 package com.owncloud.android.providers;
  23
  24 import java.util.ArrayList;
  25 import java.util.HashMap;
  26
  27 import com.owncloud.android.R;
  28 import com.owncloud.android.db.ProviderMeta;
  29 import com.owncloud.android.db.ProviderMeta.ProviderTableMeta;
  30 import com.owncloud.android.lib.common.utils.Log_OC;
  31 import com.owncloud.android.lib.resources.shares.ShareType;
  32
  33 import android.content.ContentProvider;
  34 import android.content.ContentProviderOperation;
  35 import android.content.ContentProviderResult;
  36 import android.content.ContentUris;
  37 import android.content.ContentValues;
  38 import android.content.Context;
  39 import android.content.OperationApplicationException;
  40 import android.content.UriMatcher;
  41 import android.database.Cursor;
  42 import android.database.SQLException;
  43 import android.database.sqlite.SQLiteDatabase;
  44 import android.database.sqlite.SQLiteOpenHelper;
  45 import android.database.sqlite.SQLiteQueryBuilder;
  46 import android.net.Uri;
  47 import android.text.TextUtils;
  48
  49 /**
  50  * The ContentProvider for the ownCloud App.
  51  */
  52 public class FileContentProvider extends ContentProvider {
  53
  54     private DataBaseHelper mDbHelper;
  55
  56     // Projection for filelist table
  57     private static HashMap<String, String> mFileProjectionMap;
  58     static {
  59         mFileProjectionMap = new HashMap<String, String>();
  60         mFileProjectionMap.put(ProviderTableMeta._ID, ProviderTableMeta._ID);
  61         mFileProjectionMap.put(ProviderTableMeta.FILE_PARENT,
  62                 ProviderTableMeta.FILE_PARENT);
  63         mFileProjectionMap.put(ProviderTableMeta.FILE_PATH,
  64                 ProviderTableMeta.FILE_PATH);
  65         mFileProjectionMap.put(ProviderTableMeta.FILE_NAME,
  66                 ProviderTableMeta.FILE_NAME);
  67         mFileProjectionMap.put(ProviderTableMeta.FILE_CREATION,
  68                 ProviderTableMeta.FILE_CREATION);
  69         mFileProjectionMap.put(ProviderTableMeta.FILE_MODIFIED,
  70                 ProviderTableMeta.FILE_MODIFIED);
  71         mFileProjectionMap.put(ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA,
  72                 ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA);
  73         mFileProjectionMap.put(ProviderTableMeta.FILE_CONTENT_LENGTH,
  74                 ProviderTableMeta.FILE_CONTENT_LENGTH);
  75         mFileProjectionMap.put(ProviderTableMeta.FILE_CONTENT_TYPE,
  76                 ProviderTableMeta.FILE_CONTENT_TYPE);
  77         mFileProjectionMap.put(ProviderTableMeta.FILE_STORAGE_PATH,
  78                 ProviderTableMeta.FILE_STORAGE_PATH);
  79         mFileProjectionMap.put(ProviderTableMeta.FILE_LAST_SYNC_DATE,
  80                 ProviderTableMeta.FILE_LAST_SYNC_DATE);
  81         mFileProjectionMap.put(ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA,
  82                 ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA);
  83         mFileProjectionMap.put(ProviderTableMeta.FILE_KEEP_IN_SYNC,
  84                 ProviderTableMeta.FILE_KEEP_IN_SYNC);
  85         mFileProjectionMap.put(ProviderTableMeta.FILE_ACCOUNT_OWNER,
  86                 ProviderTableMeta.FILE_ACCOUNT_OWNER);
  87         mFileProjectionMap.put(ProviderTableMeta.FILE_ETAG,
  88                 ProviderTableMeta.FILE_ETAG);
  89         mFileProjectionMap.put(ProviderTableMeta.FILE_SHARE_BY_LINK,
  90                 ProviderTableMeta.FILE_SHARE_BY_LINK);
  91         mFileProjectionMap.put(ProviderTableMeta.FILE_PUBLIC_LINK,
  92                 ProviderTableMeta.FILE_PUBLIC_LINK);
  93         mFileProjectionMap.put(ProviderTableMeta.FILE_PERMISSIONS,
  94                 ProviderTableMeta.FILE_PERMISSIONS);
  95         mFileProjectionMap.put(ProviderTableMeta.FILE_REMOTE_ID,
  96                 ProviderTableMeta.FILE_REMOTE_ID);
  97         mFileProjectionMap.put(ProviderTableMeta.FILE_UPDATE_THUMBNAIL,
  98                 ProviderTableMeta.FILE_UPDATE_THUMBNAIL);
  99         mFileProjectionMap.put(ProviderTableMeta.FILE_IS_DOWNLOADING,
 100                 ProviderTableMeta.FILE_IS_DOWNLOADING);
 101     }
 102
 103     private static final int SINGLE_FILE = 1;
 104     private static final int DIRECTORY = 2;
 105     private static final int ROOT_DIRECTORY = 3;
 106     private static final int SHARES = 4;
 107
 108     private static final String TAG = FileContentProvider.class.getSimpleName();
 109
 110     // Projection for ocshares table
 111     private static HashMap<String, String> mOCSharesProjectionMap;
 112     static {
 113         mOCSharesProjectionMap = new HashMap<String, String>();
 114         mOCSharesProjectionMap.put(ProviderTableMeta._ID, ProviderTableMeta._ID);
 115         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_FILE_SOURCE,
 116                 ProviderTableMeta.OCSHARES_FILE_SOURCE);
 117         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_ITEM_SOURCE,
 118                 ProviderTableMeta.OCSHARES_ITEM_SOURCE);
 119         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_SHARE_TYPE,
 120                 ProviderTableMeta.OCSHARES_SHARE_TYPE);
 121         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_SHARE_WITH,
 122                 ProviderTableMeta.OCSHARES_SHARE_WITH);
 123         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_PATH,
 124                 ProviderTableMeta.OCSHARES_PATH);
 125         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_PERMISSIONS,
 126                 ProviderTableMeta.OCSHARES_PERMISSIONS);
 127         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_SHARED_DATE,
 128                 ProviderTableMeta.OCSHARES_SHARED_DATE);
 129         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_EXPIRATION_DATE,
 130                 ProviderTableMeta.OCSHARES_EXPIRATION_DATE);
 131         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_TOKEN,
 132                 ProviderTableMeta.OCSHARES_TOKEN);
 133         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME,
 134                 ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME);
 135         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_IS_DIRECTORY,
 136                 ProviderTableMeta.OCSHARES_IS_DIRECTORY);
 137         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_USER_ID,
 138                 ProviderTableMeta.OCSHARES_USER_ID);
 139         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED,
 140                 ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED);
 141         mOCSharesProjectionMap.put(ProviderTableMeta.OCSHARES_ACCOUNT_OWNER,
 142                 ProviderTableMeta.OCSHARES_ACCOUNT_OWNER);
 143     }
 144
 145     private UriMatcher mUriMatcher;
 146
 147     @Override
 148     public int delete(Uri uri, String where, String[] whereArgs) {
 149         //Log_OC.d(TAG, "Deleting " + uri + " at provider " + this);
 150         int count = 0;
 151         SQLiteDatabase db = mDbHelper.getWritableDatabase();
 152         db.beginTransaction();
 153         try {
 154             count = delete(db, uri, where, whereArgs);
 155             db.setTransactionSuccessful();
 156         } finally {
 157             db.endTransaction();
 158         }
 159         getContext().getContentResolver().notifyChange(uri, null);
 160         return count;
 161     }
 162
 163     private int delete(SQLiteDatabase db, Uri uri, String where, String[] whereArgs) {
 164         int count = 0;
 165         switch (mUriMatcher.match(uri)) {
 166         case SINGLE_FILE:
 167             Cursor c = query(db, uri, null, where, whereArgs, null);
 168             String remoteId = "";
 169             if (c != null && c.moveToFirst()) {
 170                 remoteId = c.getString(c.getColumnIndex(ProviderTableMeta.FILE_REMOTE_ID));
 171                 //ThumbnailsCacheManager.removeFileFromCache(remoteId);
 172             }
 173             Log_OC.d(TAG, "Removing FILE " + remoteId);
 174
 175             count = db.delete(ProviderTableMeta.FILE_TABLE_NAME,
 176                     ProviderTableMeta._ID
 177                             + "="
 178                             + uri.getPathSegments().get(1)
 179                             + (!TextUtils.isEmpty(where) ? " AND (" + where
 180                                     + ")" : ""), whereArgs);
 181             /* just for log
 182             if (c!=null) {
 183                 c.close();
 184             }
 185             */
 186             break;
 187         case DIRECTORY:
 188             // deletion of folder is recursive
 189             /*
 190             Uri folderUri = ContentUris.withAppendedId(ProviderTableMeta.CONTENT_URI_FILE, Long.parseLong(uri.getPathSegments().get(1)));
 191             Cursor folder = query(db, folderUri, null, null, null, null);
 192             String folderName = "(unknown)";
 193             if (folder != null && folder.moveToFirst()) {
 194                 folderName = folder.getString(folder.getColumnIndex(ProviderTableMeta.FILE_PATH));
 195             }
 196             */
 197             Cursor children = query(uri, null, null, null, null);
 198             if (children != null && children.moveToFirst())  {
 199                 long childId;
 200                 boolean isDir;
 201                 //String remotePath;
 202                 while (!children.isAfterLast()) {
 203                     childId = children.getLong(children.getColumnIndex(ProviderTableMeta._ID));
 204                     isDir = "DIR".equals(children.getString(
 205                             children.getColumnIndex(ProviderTableMeta.FILE_CONTENT_TYPE)
 206                     ));
 207                     //remotePath = children.getString(children.getColumnIndex(ProviderTableMeta.FILE_PATH));
 208                     if (isDir) {
 209                         count += delete(
 210                             db,
 211                             ContentUris.withAppendedId(ProviderTableMeta.CONTENT_URI_DIR, childId),
 212                             null,
 213                             null
 214                         );
 215                     } else {
 216                         count += delete(
 217                             db,
 218                             ContentUris.withAppendedId(ProviderTableMeta.CONTENT_URI_FILE, childId),
 219                             null,
 220                             null
 221                         );
 222                     }
 223                     children.moveToNext();
 224                 }
 225                 children.close();
 226             } /*else {
 227                 Log_OC.d(TAG, "No child to remove in DIRECTORY " + folderName);
 228             }
 229             Log_OC.d(TAG, "Removing DIRECTORY " + folderName + " (or maybe not) ");
 230             */
 231             count += db.delete(ProviderTableMeta.FILE_TABLE_NAME,
 232                     ProviderTableMeta._ID
 233                     + "="
 234                     + uri.getPathSegments().get(1)
 235                     + (!TextUtils.isEmpty(where) ? " AND (" + where
 236                             + ")" : ""), whereArgs);
 237             /* Just for log
 238              if (folder != null) {
 239                 folder.close();
 240             }*/
 241             break;
 242         case ROOT_DIRECTORY:
 243             //Log_OC.d(TAG, "Removing ROOT!");
 244             count = db.delete(ProviderTableMeta.FILE_TABLE_NAME, where, whereArgs);
 245             break;
 246         case SHARES:
 247             count = db.delete(ProviderTableMeta.OCSHARES_TABLE_NAME, where, whereArgs);
 248             break;
 249         default:
 250             //Log_OC.e(TAG, "Unknown uri " + uri);
 251             throw new IllegalArgumentException("Unknown uri: " + uri.toString());
 252         }
 253         return count;
 254     }
 255
 256     @Override
 257     public String getType(Uri uri) {
 258         switch (mUriMatcher.match(uri)) {
 259         case ROOT_DIRECTORY:
 260             return ProviderTableMeta.CONTENT_TYPE;
 261         case SINGLE_FILE:
 262             return ProviderTableMeta.CONTENT_TYPE_ITEM;
 263         default:
 264             throw new IllegalArgumentException("Unknown Uri id."
 265                     + uri.toString());
 266         }
 267     }
 268
 269     @Override
 270     public Uri insert(Uri uri, ContentValues values) {
 271         Uri newUri = null;
 272         SQLiteDatabase db = mDbHelper.getWritableDatabase();
 273         db.beginTransaction();
 274         try {
 275             newUri = insert(db, uri, values);
 276             db.setTransactionSuccessful();
 277         } finally {
 278             db.endTransaction();
 279         }
 280         getContext().getContentResolver().notifyChange(newUri, null);
 281         return newUri;
 282     }
 283
 284     private Uri insert(SQLiteDatabase db, Uri uri, ContentValues values) {
 285         switch (mUriMatcher.match(uri)){
 286         case ROOT_DIRECTORY:
 287         case SINGLE_FILE:
 288             String remotePath = values.getAsString(ProviderTableMeta.FILE_PATH);
 289             String accountName = values.getAsString(ProviderTableMeta.FILE_ACCOUNT_OWNER);
 290             String[] projection = new String[] {
 291                     ProviderTableMeta._ID, ProviderTableMeta.FILE_PATH,
 292                     ProviderTableMeta.FILE_ACCOUNT_OWNER
 293             };
 294             String where = ProviderTableMeta.FILE_PATH + "=? AND " +
 295                     ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?";
 296             String[] whereArgs = new String[] {remotePath, accountName};
 297             Cursor doubleCheck = query(db, uri, projection, where, whereArgs, null);
 298             // ugly patch; serious refactorization is needed to reduce work in
 299             // FileDataStorageManager and bring it to FileContentProvider
 300             if (doubleCheck == null || !doubleCheck.moveToFirst()) {
 301                 long rowId = db.insert(ProviderTableMeta.FILE_TABLE_NAME, null, values);
 302                 if (rowId > 0) {
 303                     Uri insertedFileUri =
 304                             ContentUris.withAppendedId(ProviderTableMeta.CONTENT_URI_FILE, rowId);
 305                     return insertedFileUri;
 306                 } else {
 307                     throw new SQLException("ERROR " + uri);
 308                 }
 309             } else {
 310                 // file is already inserted; race condition, let's avoid a duplicated entry
 311                 Uri insertedFileUri = ContentUris.withAppendedId(
 312                         ProviderTableMeta.CONTENT_URI_FILE,
 313                         doubleCheck.getLong(doubleCheck.getColumnIndex(ProviderTableMeta._ID))
 314                 );
 315                 doubleCheck.close();
 316
 317                 return insertedFileUri;
 318             }
 319
 320         case SHARES:
 321             String path = values.getAsString(ProviderTableMeta.OCSHARES_PATH);
 322             String accountNameShare= values.getAsString(ProviderTableMeta.OCSHARES_ACCOUNT_OWNER);
 323             String[] projectionShare = new String[] {
 324                     ProviderTableMeta._ID, ProviderTableMeta.OCSHARES_PATH,
 325                     ProviderTableMeta.OCSHARES_ACCOUNT_OWNER
 326             };
 327             String whereShare = ProviderTableMeta.OCSHARES_PATH + "=? AND " +
 328                     ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + "=?";
 329             String[] whereArgsShare = new String[] {path, accountNameShare};
 330             Uri insertedShareUri = null;
 331             Cursor doubleCheckShare =
 332                     query(db, uri, projectionShare, whereShare, whereArgsShare, null);
 333             // ugly patch; serious refactorization is needed to reduce work in
 334             // FileDataStorageManager and bring it to FileContentProvider
 335             if (doubleCheckShare == null || !doubleCheckShare.moveToFirst()) {
 336                 long rowId = db.insert(ProviderTableMeta.OCSHARES_TABLE_NAME, null, values);
 337                 if (rowId >0) {
 338                     insertedShareUri =
 339                             ContentUris.withAppendedId(ProviderTableMeta.CONTENT_URI_SHARE, rowId);
 340                 } else {
 341                     throw new SQLException("ERROR " + uri);
 342
 343                 }
 344             } else {
 345                 // file is already inserted; race condition, let's avoid a duplicated entry
 346                 insertedShareUri = ContentUris.withAppendedId(
 347                         ProviderTableMeta.CONTENT_URI_SHARE,
 348                         doubleCheckShare.getLong(
 349                                 doubleCheckShare.getColumnIndex(ProviderTableMeta._ID)
 350                         )
 351                 );
 352                 doubleCheckShare.close();
 353             }
 354             updateFilesTableAccordingToShareInsertion(db, uri, values);
 355             return insertedShareUri;
 356
 357
 358         default:
 359             throw new IllegalArgumentException("Unknown uri id: " + uri);
 360         }
 361
 362     }
 363
 364     private void updateFilesTableAccordingToShareInsertion(
 365             SQLiteDatabase db, Uri uri, ContentValues shareValues
 366             ) {
 367         ContentValues fileValues = new ContentValues();
 368         fileValues.put(
 369                 ProviderTableMeta.FILE_SHARE_BY_LINK,
 370                 ShareType.PUBLIC_LINK.getValue() ==
 371                     shareValues.getAsInteger(ProviderTableMeta.OCSHARES_SHARE_TYPE)? 1 : 0
 372         );
 373         String whereShare = ProviderTableMeta.FILE_PATH + "=? AND " +
 374                 ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?";
 375         String[] whereArgsShare = new String[] {
 376                 shareValues.getAsString(ProviderTableMeta.OCSHARES_PATH),
 377                 shareValues.getAsString(ProviderTableMeta.OCSHARES_ACCOUNT_OWNER)
 378         };
 379         db.update(ProviderTableMeta.FILE_TABLE_NAME, fileValues, whereShare, whereArgsShare);
 380     }
 381
 382
 383     @Override
 384     public boolean onCreate() {
 385         mDbHelper = new DataBaseHelper(getContext());
 386
 387         String authority = getContext().getResources().getString(R.string.authority);
 388         mUriMatcher = new UriMatcher(UriMatcher.NO_MATCH);
 389         mUriMatcher.addURI(authority, null, ROOT_DIRECTORY);
 390         mUriMatcher.addURI(authority, "file/", SINGLE_FILE);
 391         mUriMatcher.addURI(authority, "file/#", SINGLE_FILE);
 392         mUriMatcher.addURI(authority, "dir/", DIRECTORY);
 393         mUriMatcher.addURI(authority, "dir/#", DIRECTORY);
 394         mUriMatcher.addURI(authority, "shares/", SHARES);
 395         mUriMatcher.addURI(authority, "shares/#", SHARES);
 396
 397         return true;
 398     }
 399
 400
 401     @Override
 402     public Cursor query(
 403             Uri uri,
 404             String[] projection,
 405             String selection,
 406             String[] selectionArgs,
 407             String sortOrder
 408         ) {
 409
 410         Cursor result = null;
 411         SQLiteDatabase db = mDbHelper.getReadableDatabase();
 412         db.beginTransaction();
 413         try {
 414             result = query(db, uri, projection, selection, selectionArgs, sortOrder);
 415             db.setTransactionSuccessful();
 416         } finally {
 417             db.endTransaction();
 418         }
 419         return result;
 420     }
 421
 422     private Cursor query(
 423             SQLiteDatabase db,
 424             Uri uri,
 425             String[] projection,
 426             String selection,
 427             String[] selectionArgs,
 428             String sortOrder
 429         ) {
 430
 431         SQLiteQueryBuilder sqlQuery = new SQLiteQueryBuilder();
 432
 433         sqlQuery.setTables(ProviderTableMeta.FILE_TABLE_NAME);
 434         sqlQuery.setProjectionMap(mFileProjectionMap);
 435
 436         switch (mUriMatcher.match(uri)) {
 437         case ROOT_DIRECTORY:
 438             break;
 439         case DIRECTORY:
 440             String folderId = uri.getPathSegments().get(1);
 441             sqlQuery.appendWhere(ProviderTableMeta.FILE_PARENT + "="
 442                     + folderId);
 443             break;
 444         case SINGLE_FILE:
 445             if (uri.getPathSegments().size() > 1) {
 446                 sqlQuery.appendWhere(ProviderTableMeta._ID + "="
 447                         + uri.getPathSegments().get(1));
 448             }
 449             break;
 450         case SHARES:
 451             sqlQuery.setTables(ProviderTableMeta.OCSHARES_TABLE_NAME);
 452             sqlQuery.setProjectionMap(mOCSharesProjectionMap);
 453             if (uri.getPathSegments().size() > 1) {
 454                 sqlQuery.appendWhere(ProviderTableMeta._ID + "="
 455                         + uri.getPathSegments().get(1));
 456             }
 457             break;
 458         default:
 459             throw new IllegalArgumentException("Unknown uri id: " + uri);
 460         }
 461
 462         String order;
 463         if (TextUtils.isEmpty(sortOrder)) {
 464             if (mUriMatcher.match(uri) == SHARES) {
 465                 order = ProviderTableMeta.OCSHARES_DEFAULT_SORT_ORDER;
 466             } else {
 467
 468                 order = ProviderTableMeta.FILE_DEFAULT_SORT_ORDER;
 469             }
 470         } else {
 471             order = sortOrder;
 472         }
 473
 474         // DB case_sensitive
 475         db.execSQL("PRAGMA case_sensitive_like = true");
 476         Cursor c = sqlQuery.query(db, projection, selection, selectionArgs, null, null, order);
 477         c.setNotificationUri(getContext().getContentResolver(), uri);
 478         return c;
 479     }
 480
 481     @Override
 482     public int update(Uri uri, ContentValues values, String selection, String[] selectionArgs) {
 483
 484         int count = 0;
 485         SQLiteDatabase db = mDbHelper.getWritableDatabase();
 486         db.beginTransaction();
 487         try {
 488             count = update(db, uri, values, selection, selectionArgs);
 489             db.setTransactionSuccessful();
 490         } finally {
 491             db.endTransaction();
 492         }
 493         getContext().getContentResolver().notifyChange(uri, null);
 494         return count;
 495     }
 496
 497
 498
 499     private int update(
 500             SQLiteDatabase db,
 501             Uri uri,
 502             ContentValues values,
 503             String selection,
 504             String[] selectionArgs
 505         ) {
 506         switch (mUriMatcher.match(uri)) {
 507             case DIRECTORY:
 508                 return  0; //updateFolderSize(db, selectionArgs[0]);
 509             case SHARES:
 510                 return db.update(
 511                         ProviderTableMeta.OCSHARES_TABLE_NAME, values, selection, selectionArgs
 512                 );
 513             default:
 514                 return db.update(
 515                         ProviderTableMeta.FILE_TABLE_NAME, values, selection, selectionArgs
 516                 );
 517         }
 518     }
 519
 520  /*
 521     private int updateFolderSize(SQLiteDatabase db, String folderId) {
 522         int count = 0;
 523         String [] whereArgs = new String[] { folderId };
 524
 525         // read current size saved for the folder
 526         long folderSize = 0;
 527         long folderParentId = -1;
 528         Uri selectFolderUri = Uri.withAppendedPath(ProviderTableMeta.CONTENT_URI_FILE, folderId);
 529         String[] folderProjection = new String[] { ProviderTableMeta.FILE_CONTENT_LENGTH,  ProviderTableMeta.FILE_PARENT};
 530         String folderWhere = ProviderTableMeta._ID + "=?";
 531         Cursor folderCursor = query(db, selectFolderUri, folderProjection, folderWhere, whereArgs, null);
 532         if (folderCursor != null && folderCursor.moveToFirst()) {
 533             folderSize = folderCursor.getLong(folderCursor.getColumnIndex(ProviderTableMeta.FILE_CONTENT_LENGTH));;
 534             folderParentId = folderCursor.getLong(folderCursor.getColumnIndex(ProviderTableMeta.FILE_PARENT));;
 535         }
 536         folderCursor.close();
 537
 538         // read and sum sizes of children
 539         long childrenSize = 0;
 540         Uri selectChildrenUri = Uri.withAppendedPath(ProviderTableMeta.CONTENT_URI_DIR, folderId);
 541         String[] childrenProjection = new String[] { ProviderTableMeta.FILE_CONTENT_LENGTH,  ProviderTableMeta.FILE_PARENT};
 542         String childrenWhere = ProviderTableMeta.FILE_PARENT + "=?";
 543         Cursor childrenCursor = query(db, selectChildrenUri, childrenProjection, childrenWhere, whereArgs, null);
 544         if (childrenCursor != null && childrenCursor.moveToFirst()) {
 545             while (!childrenCursor.isAfterLast()) {
 546                 childrenSize += childrenCursor.getLong(childrenCursor.getColumnIndex(ProviderTableMeta.FILE_CONTENT_LENGTH));
 547                 childrenCursor.moveToNext();
 548             }
 549         }
 550         childrenCursor.close();
 551
 552         // update if needed
 553         if (folderSize != childrenSize) {
 554             Log_OC.d("FileContentProvider", "Updating " + folderSize + " to " + childrenSize);
 555             ContentValues cv = new ContentValues();
 556             cv.put(ProviderTableMeta.FILE_CONTENT_LENGTH, childrenSize);
 557             count = db.update(ProviderTableMeta.FILE_TABLE_NAME, cv, folderWhere, whereArgs);
 558
 559             // propagate update until root
 560             if (folderParentId > FileDataStorageManager.ROOT_PARENT_ID) {
 561                 Log_OC.d("FileContentProvider", "Propagating update to " + folderParentId);
 562                 updateFolderSize(db, String.valueOf(folderParentId));
 563             } else {
 564                 Log_OC.d("FileContentProvider", "NOT propagating to " + folderParentId);
 565             }
 566         } else {
 567             Log_OC.d("FileContentProvider", "NOT updating, sizes are " + folderSize + " and " + childrenSize);
 568         }
 569         return count;
 570     }
 571 */
 572
 573     @Override
 574     public ContentProviderResult[] applyBatch (ArrayList<ContentProviderOperation> operations)
 575             throws OperationApplicationException {
 576         Log_OC.d("FileContentProvider", "applying batch in provider " + this +
 577                 " (temporary: " + isTemporary() + ")" );
 578         ContentProviderResult[] results = new ContentProviderResult[operations.size()];
 579         int i=0;
 580
 581         SQLiteDatabase db = mDbHelper.getWritableDatabase();
 582         db.beginTransaction();  // it's supposed that transactions can be nested
 583         try {
 584             for (ContentProviderOperation operation : operations) {
 585                 results[i] = operation.apply(this, results, i);
 586                 i++;
 587             }
 588             db.setTransactionSuccessful();
 589         } finally {
 590             db.endTransaction();
 591         }
 592         Log_OC.d("FileContentProvider", "applied batch in provider " + this);
 593         return results;
 594     }
 595
 596
 597     class DataBaseHelper extends SQLiteOpenHelper {
 598
 599         public DataBaseHelper(Context context) {
 600             super(context, ProviderMeta.DB_NAME, null, ProviderMeta.DB_VERSION);
 601
 602         }
 603
 604         @Override
 605         public void onCreate(SQLiteDatabase db) {
 606             // files table
 607             Log_OC.i("SQL", "Entering in onCreate");
 608             db.execSQL("CREATE TABLE " + ProviderTableMeta.FILE_TABLE_NAME + "("
 609                     + ProviderTableMeta._ID + " INTEGER PRIMARY KEY, "
 610                     + ProviderTableMeta.FILE_NAME + " TEXT, "
 611                     + ProviderTableMeta.FILE_PATH + " TEXT, "
 612                     + ProviderTableMeta.FILE_PARENT + " INTEGER, "
 613                     + ProviderTableMeta.FILE_CREATION + " INTEGER, "
 614                     + ProviderTableMeta.FILE_MODIFIED + " INTEGER, "
 615                     + ProviderTableMeta.FILE_CONTENT_TYPE + " TEXT, "
 616                     + ProviderTableMeta.FILE_CONTENT_LENGTH + " INTEGER, "
 617                     + ProviderTableMeta.FILE_STORAGE_PATH + " TEXT, "
 618                     + ProviderTableMeta.FILE_ACCOUNT_OWNER + " TEXT, "
 619                     + ProviderTableMeta.FILE_LAST_SYNC_DATE + " INTEGER, "
 620                     + ProviderTableMeta.FILE_KEEP_IN_SYNC + " INTEGER, "
 621                     + ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA + " INTEGER, "
 622                     + ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA + " INTEGER, "
 623                     + ProviderTableMeta.FILE_ETAG + " TEXT, "
 624                     + ProviderTableMeta.FILE_SHARE_BY_LINK + " INTEGER, "
 625                     + ProviderTableMeta.FILE_PUBLIC_LINK  + " TEXT, "
 626                     + ProviderTableMeta.FILE_PERMISSIONS  + " TEXT null,"
 627                     + ProviderTableMeta.FILE_REMOTE_ID  + " TEXT null,"
 628                     + ProviderTableMeta.FILE_UPDATE_THUMBNAIL  + " INTEGER," //boolean
 629                     + ProviderTableMeta.FILE_IS_DOWNLOADING  + " INTEGER);" //boolean
 630                     );
 631
 632             // Create table ocshares
 633             db.execSQL("CREATE TABLE " + ProviderTableMeta.OCSHARES_TABLE_NAME + "("
 634                     + ProviderTableMeta._ID + " INTEGER PRIMARY KEY, "
 635                     + ProviderTableMeta.OCSHARES_FILE_SOURCE + " INTEGER, "
 636                     + ProviderTableMeta.OCSHARES_ITEM_SOURCE + " INTEGER, "
 637                     + ProviderTableMeta.OCSHARES_SHARE_TYPE + " INTEGER, "
 638                     + ProviderTableMeta.OCSHARES_SHARE_WITH + " TEXT, "
 639                     + ProviderTableMeta.OCSHARES_PATH + " TEXT, "
 640                     + ProviderTableMeta.OCSHARES_PERMISSIONS+ " INTEGER, "
 641                     + ProviderTableMeta.OCSHARES_SHARED_DATE + " INTEGER, "
 642                     + ProviderTableMeta.OCSHARES_EXPIRATION_DATE + " INTEGER, "
 643                     + ProviderTableMeta.OCSHARES_TOKEN + " TEXT, "
 644                     + ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME + " TEXT, "
 645                     + ProviderTableMeta.OCSHARES_IS_DIRECTORY + " INTEGER, "  // boolean
 646                     + ProviderTableMeta.OCSHARES_USER_ID + " INTEGER, "
 647                     + ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED + " INTEGER,"
 648                     + ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + " TEXT );" );
 649         }
 650
 651         @Override
 652         public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
 653             Log_OC.i("SQL", "Entering in onUpgrade");
 654             boolean upgraded = false;
 655             if (oldVersion == 1 && newVersion >= 2) {
 656                 Log_OC.i("SQL", "Entering in the #1 ADD in onUpgrade");
 657                 db.execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 658                            " ADD COLUMN " + ProviderTableMeta.FILE_KEEP_IN_SYNC  + " INTEGER " +
 659                            " DEFAULT 0");
 660                 upgraded = true;
 661             }
 662             if (oldVersion < 3 && newVersion >= 3) {
 663                 Log_OC.i("SQL", "Entering in the #2 ADD in onUpgrade");
 664                 db.beginTransaction();
 665                 try {
 666                     db.execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 667                                " ADD COLUMN " + ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA  +
 668                                " INTEGER " + " DEFAULT 0");
 669
 670                     // assume there are not local changes pending to upload
 671                     db.execSQL("UPDATE " + ProviderTableMeta.FILE_TABLE_NAME +
 672                             " SET " + ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA + " = "
 673                             + System.currentTimeMillis() +
 674                             " WHERE " + ProviderTableMeta.FILE_STORAGE_PATH + " IS NOT NULL");
 675
 676                     upgraded = true;
 677                     db.setTransactionSuccessful();
 678                 } finally {
 679                     db.endTransaction();
 680                 }
 681             }
 682             if (oldVersion < 4 && newVersion >= 4) {
 683                 Log_OC.i("SQL", "Entering in the #3 ADD in onUpgrade");
 684                 db.beginTransaction();
 685                 try {
 686                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 687                            " ADD COLUMN " + ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA +
 688                            " INTEGER " + " DEFAULT 0");
 689
 690                     db.execSQL("UPDATE " + ProviderTableMeta.FILE_TABLE_NAME +
 691                            " SET " + ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA + " = " +
 692                             ProviderTableMeta.FILE_MODIFIED +
 693                            " WHERE " + ProviderTableMeta.FILE_STORAGE_PATH + " IS NOT NULL");
 694
 695                     upgraded = true;
 696                     db.setTransactionSuccessful();
 697                 } finally {
 698                     db.endTransaction();
 699                 }
 700             }
 701             if (!upgraded)
 702                 Log_OC.i("SQL", "OUT of the ADD in onUpgrade; oldVersion == " + oldVersion +
 703                         ", newVersion == " + newVersion);
 704
 705             if (oldVersion < 5 && newVersion >= 5) {
 706                 Log_OC.i("SQL", "Entering in the #4 ADD in onUpgrade");
 707                 db.beginTransaction();
 708                 try {
 709                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 710                             " ADD COLUMN " + ProviderTableMeta.FILE_ETAG + " TEXT " +
 711                             " DEFAULT NULL");
 712
 713                     upgraded = true;
 714                     db.setTransactionSuccessful();
 715                 } finally {
 716                     db.endTransaction();
 717                 }
 718             }
 719             if (!upgraded)
 720                 Log_OC.i("SQL", "OUT of the ADD in onUpgrade; oldVersion == " + oldVersion +
 721                         ", newVersion == " + newVersion);
 722
 723             if (oldVersion < 6 && newVersion >= 6) {
 724                 Log_OC.i("SQL", "Entering in the #5 ADD in onUpgrade");
 725                 db.beginTransaction();
 726                 try {
 727                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 728                             " ADD COLUMN " + ProviderTableMeta.FILE_SHARE_BY_LINK + " INTEGER " +
 729                             " DEFAULT 0");
 730
 731                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 732                             " ADD COLUMN " + ProviderTableMeta.FILE_PUBLIC_LINK + " TEXT " +
 733                             " DEFAULT NULL");
 734
 735                     // Create table ocshares
 736                     db.execSQL("CREATE TABLE " + ProviderTableMeta.OCSHARES_TABLE_NAME + "("
 737                             + ProviderTableMeta._ID + " INTEGER PRIMARY KEY, "
 738                             + ProviderTableMeta.OCSHARES_FILE_SOURCE + " INTEGER, "
 739                             + ProviderTableMeta.OCSHARES_ITEM_SOURCE + " INTEGER, "
 740                             + ProviderTableMeta.OCSHARES_SHARE_TYPE + " INTEGER, "
 741                             + ProviderTableMeta.OCSHARES_SHARE_WITH + " TEXT, "
 742                             + ProviderTableMeta.OCSHARES_PATH + " TEXT, "
 743                             + ProviderTableMeta.OCSHARES_PERMISSIONS+ " INTEGER, "
 744                             + ProviderTableMeta.OCSHARES_SHARED_DATE + " INTEGER, "
 745                             + ProviderTableMeta.OCSHARES_EXPIRATION_DATE + " INTEGER, "
 746                             + ProviderTableMeta.OCSHARES_TOKEN + " TEXT, "
 747                             + ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME + " TEXT, "
 748                             + ProviderTableMeta.OCSHARES_IS_DIRECTORY + " INTEGER, "  // boolean
 749                             + ProviderTableMeta.OCSHARES_USER_ID + " INTEGER, "
 750                             + ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED + " INTEGER,"
 751                             + ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + " TEXT );" );
 752
 753                     upgraded = true;
 754                     db.setTransactionSuccessful();
 755                 } finally {
 756                     db.endTransaction();
 757                 }
 758             }
 759             if (!upgraded)
 760                 Log_OC.i("SQL", "OUT of the ADD in onUpgrade; oldVersion == " + oldVersion +
 761                         ", newVersion == " + newVersion);
 762
 763             if (oldVersion < 7 && newVersion >= 7) {
 764                 Log_OC.i("SQL", "Entering in the #7 ADD in onUpgrade");
 765                 db.beginTransaction();
 766                 try {
 767                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 768                             " ADD COLUMN " + ProviderTableMeta.FILE_PERMISSIONS + " TEXT " +
 769                             " DEFAULT NULL");
 770
 771                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 772                             " ADD COLUMN " + ProviderTableMeta.FILE_REMOTE_ID + " TEXT " +
 773                             " DEFAULT NULL");
 774
 775                     upgraded = true;
 776                     db.setTransactionSuccessful();
 777                 } finally {
 778                     db.endTransaction();
 779                 }
 780             }
 781             if (!upgraded)
 782                 Log_OC.i("SQL", "OUT of the ADD in onUpgrade; oldVersion == " + oldVersion +
 783                         ", newVersion == " + newVersion);
 784
 785             if (oldVersion < 8 && newVersion >= 8) {
 786                 Log_OC.i("SQL", "Entering in the #8 ADD in onUpgrade");
 787                 db.beginTransaction();
 788                 try {
 789                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 790                             " ADD COLUMN " + ProviderTableMeta.FILE_UPDATE_THUMBNAIL + " INTEGER " +
 791                             " DEFAULT 0");
 792
 793                     upgraded = true;
 794                     db.setTransactionSuccessful();
 795                 } finally {
 796                     db.endTransaction();
 797                 }
 798             }
 799             if (!upgraded)
 800                 Log_OC.i("SQL", "OUT of the ADD in onUpgrade; oldVersion == " + oldVersion +
 801                         ", newVersion == " + newVersion);
 802
 803             if (oldVersion < 9 && newVersion >= 9) {
 804                 Log_OC.i("SQL", "Entering in the #9 ADD in onUpgrade");
 805                 db.beginTransaction();
 806                 try {
 807                     db .execSQL("ALTER TABLE " + ProviderTableMeta.FILE_TABLE_NAME +
 808                             " ADD COLUMN " + ProviderTableMeta.FILE_IS_DOWNLOADING + " INTEGER " +
 809                             " DEFAULT 0");
 810
 811                     upgraded = true;
 812                     db.setTransactionSuccessful();
 813                 } finally {
 814                     db.endTransaction();
 815                 }
 816             }
 817             if (!upgraded)
 818                 Log_OC.i("SQL", "OUT of the ADD in onUpgrade; oldVersion == " + oldVersion +
 819                         ", newVersion == " + newVersion);
 820         }
 821     }
 822
 823 }