BulkCursorToCursorAdaptor.java revision d2183654e03d589b120467f4e98da1b178ceeadb
19066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/* 29066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Copyright (C) 2006 The Android Open Source Project 39066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 49066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Licensed under the Apache License, Version 2.0 (the "License"); 59066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * you may not use this file except in compliance with the License. 69066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * You may obtain a copy of the License at 79066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 89066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * http://www.apache.org/licenses/LICENSE-2.0 99066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Unless required by applicable law or agreed to in writing, software 119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * distributed under the License is distributed on an "AS IS" BASIS, 129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * See the License for the specific language governing permissions and 149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * limitations under the License. 159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectpackage android.database; 189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 199066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.os.Bundle; 207cd51efcbd2d083bf577696591ef1769034f7e2fJeff Hamiltonimport android.os.RemoteException; 219066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectimport android.util.Log; 229066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 239066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project/** 24d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown * Adapts an {@link IBulkCursor} to a {@link Cursor} for use in the local process. 259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * 269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * {@hide} 279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Projectpublic final class BulkCursorToCursorAdaptor extends AbstractWindowedCursor { 299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private static final String TAG = "BulkCursor"; 309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 31d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown private SelfContentObserver mObserverBridge = new SelfContentObserver(this); 329066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private IBulkCursor mBulkCursor; 339066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private int mCount; 349066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private String[] mColumns; 359066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project private boolean mWantsAllOnMoveCalls; 369066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 379066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project /** 38d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown * Initializes the adaptor. 39d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown * Must be called before first use. 409ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick */ 41d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown public void initialize(IBulkCursor bulkCursor, int count, int idIndex) { 429ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick mBulkCursor = bulkCursor; 439ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick mColumns = null; // lazily retrieved 449ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick mCount = count; 459ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick mRowIdColumnIndex = idIndex; 469ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick } 479ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick 489ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick /** 499ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick * Returns column index of "_id" column, or -1 if not found. 509ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick */ 519ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick public static int findRowIdColumnIndex(String[] columnNames) { 529ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick int length = columnNames.length; 539ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick for (int i = 0; i < length; i++) { 549ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick if (columnNames[i].equals("_id")) { 559ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick return i; 569ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick } 579ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick } 589ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick return -1; 599ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick } 609ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick 619ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick /** 629066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * Gets a SelfDataChangeOberserver that can be sent to a remote 639066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * process to receive change notifications over IPC. 649ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick * 659066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project * @return A SelfContentObserver hooked up to this Cursor 669066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project */ 67d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown public IContentObserver getObserver() { 689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mObserverBridge.getContentObserver(); 699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 71d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown private void throwIfCursorIsClosed() { 72d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown if (mBulkCursor == null) { 73d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown throw new StaleDataException("Attempted to access a cursor after it has been closed."); 74d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } 75d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } 76d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 779066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 789066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public int getCount() { 79d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown throwIfCursorIsClosed(); 809066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mCount; 819066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 829066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 839066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 849066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public boolean onMove(int oldPosition, int newPosition) { 85d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown throwIfCursorIsClosed(); 86d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Make sure we have the proper window 899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mWindow != null) { 909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (newPosition < mWindow.getStartPosition() || 919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project newPosition >= (mWindow.getStartPosition() + mWindow.getNumRows())) { 92d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown setWindow(mBulkCursor.getWindow(newPosition)); 939066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else if (mWantsAllOnMoveCalls) { 949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project mBulkCursor.onMove(newPosition); 959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } else { 97d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown setWindow(mBulkCursor.getWindow(newPosition)); 989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (RemoteException ex) { 1009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // We tried to get a window and failed 1019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Log.e(TAG, "Unable to get window because the remote process is dead"); 1029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 1039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1059066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // Couldn't obtain a window, something is wrong 1069066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project if (mWindow == null) { 1079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 1089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1109066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return true; 1119066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1129066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1139066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 1149066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void deactivate() { 1159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // This will call onInvalidated(), so make sure to do it before calling release, 1169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // which is what actually makes the data set invalid. 1179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project super.deactivate(); 1189066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 119d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown if (mBulkCursor != null) { 120d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown try { 121d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown mBulkCursor.deactivate(); 122d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } catch (RemoteException ex) { 123d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown Log.w(TAG, "Remote process exception when deactivating"); 124d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } 1259066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1269066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1279066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1289066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 1299066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public void close() { 1309066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project super.close(); 131d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 132d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown if (mBulkCursor != null) { 133d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown try { 134d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown mBulkCursor.close(); 135d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } catch (RemoteException ex) { 136d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown Log.w(TAG, "Remote process exception when closing"); 137d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } finally { 138d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown mBulkCursor = null; 139d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } 1409066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1419066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1429066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1439066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 1449066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public boolean requery() { 145d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown throwIfCursorIsClosed(); 146d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 1479066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 148d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown CursorWindow newWindow = new CursorWindow(false /* create a remote window */); 149d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown try { 150d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown mCount = mBulkCursor.requery(getObserver(), newWindow); 151d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown if (mCount != -1) { 152d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown mPos = -1; 153d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown closeWindow(); 154d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 155d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown // super.requery() will call onChanged. Do it here instead of relying on the 156d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown // observer from the far side so that observers can see a correct value for mCount 157d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown // when responding to onChanged. 158d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown super.requery(); 159d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown return true; 160d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } else { 161d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown deactivate(); 162d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown return false; 163d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } 164d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown } finally { 165d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown // Don't take ownership of the window until the next call to onMove. 166d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown newWindow.close(); 1679066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1689066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (Exception ex) { 1699066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project Log.e(TAG, "Unable to requery because the remote process exception " + ex.getMessage()); 1709066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project deactivate(); 1719066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return false; 1729066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1739066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1749066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1759066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 1769066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public String[] getColumnNames() { 177d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown throwIfCursorIsClosed(); 178d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 1799ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick if (mColumns == null) { 1809ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick try { 1819ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick mColumns = mBulkCursor.getColumnNames(); 1829ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick } catch (RemoteException ex) { 1839ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick Log.e(TAG, "Unable to fetch column names because the remote process is dead"); 1849ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick return null; 1859ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick } 1869ffdfa0c238fce3b85741d7f6828fd484cd8f195Brad Fitzpatrick } 1879066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mColumns; 1889066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 1899066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 1909066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 1919066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public Bundle getExtras() { 192d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown throwIfCursorIsClosed(); 193d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 1949066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 1959066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mBulkCursor.getExtras(); 1969066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (RemoteException e) { 1979066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // This should never happen because the system kills processes that are using remote 1989066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project // cursors when the provider process is killed. 1999066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project throw new RuntimeException(e); 2009066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2019066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2029066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project 2039066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project @Override 2049066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project public Bundle respond(Bundle extras) { 205d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown throwIfCursorIsClosed(); 206d2183654e03d589b120467f4e98da1b178ceeadbJeff Brown 2079066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project try { 2089066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project return mBulkCursor.respond(extras); 2099066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } catch (RemoteException e) { 2106dc0ef005d31f1aaf277164e8bc79be9068e8bf2Karl Rosaen // the system kills processes that are using remote cursors when the provider process 2116dc0ef005d31f1aaf277164e8bc79be9068e8bf2Karl Rosaen // is killed, but this can still happen if this is being called from the system process, 2126dc0ef005d31f1aaf277164e8bc79be9068e8bf2Karl Rosaen // so, better to log and return an empty bundle. 2136dc0ef005d31f1aaf277164e8bc79be9068e8bf2Karl Rosaen Log.w(TAG, "respond() threw RemoteException, returning an empty bundle.", e); 2146dc0ef005d31f1aaf277164e8bc79be9068e8bf2Karl Rosaen return Bundle.EMPTY; 2159066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2169066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project } 2179066cfe9886ac131c34d59ed0e2d287b0e3c0087The Android Open Source Project} 218