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