//contentObserver只是通知数据库中内容变化了

cursor.registerContentObserver(mChangeObserver);

//datasetObserver是调用requery之后通知上层cursor数据内容已经更新
cursor.registerDataSetObserver(mDataSetObserver);

我们的调用流程如下:

当我们使用getContentResolver().query()的时候，我们的resolver会通过uri找到对应的provider，调用相应的query()方法，

该方法中的部分内容：

        SQLiteDatabase db = mOpenHelper.getReadableDatabase();
        Cursor ret = qb.query(db, projection, selection,selectionArgs, null, null, finalSortOrder);
        // TODO: Does this need to be a URI for this provider.
        ret.setNotificationUri(getContext().getContentResolver(), uri); 
        return ret;

Cursor本身只是接口，实际调用的应该是AbstractCursor

public void setNotificationUri(ContentResolver cr, Uri notifyUri) {
        synchronized (mSelfObserverLock) {
            mNotifyUri = notifyUri;
            mContentResolver = cr;
            if (mSelfObserver != null) {
                mContentResolver.unregisterContentObserver(mSelfObserver);
            }
            mSelfObserver = new SelfContentObserver(this); 
            mContentResolver.registerContentObserver(mNotifyUri, true, mSelfObserver); 
            mSelfObserverRegistered = true;
        }
    }

//AbstractCursor的内部类

 protected static class SelfContentObserver extends ContentObserver {
        WeakReference<AbstractCursor> mCursor;

        public SelfContentObserver(AbstractCursor cursor) {
            super(null);
            mCursor = new WeakReference<AbstractCursor>(cursor);
        }

        @Override
        public boolean deliverSelfNotifications() {
            return false;
        }

        @Override
        public void onChange(boolean selfChange) {
            AbstractCursor cursor = mCursor.get();
            if (cursor != null) {
                cursor.onChange(false); 
            }
        }
    }

ContentObservable mContentObservable = new ContentObservable(); //AbstractCursor持有的contentObservable

//AbstractCursor的onchange()

protected void onChange(boolean selfChange) {
        synchronized (mSelfObserverLock) {
            mContentObservable.dispatchChange(selfChange); 
            if (mNotifyUri != null && selfChange) {
                mContentResolver.notifyChange(mNotifyUri, mSelfObserver); //selfChange = false 
            }
        }
    }

AbstractCursor中

public void registerContentObserver(ContentObserver observer) {
        mContentObservable.registerObserver(observer);
    }

在ContentObservable中

public void dispatchChange(boolean selfChange) {
        synchronized(mObservers) {
            for (ContentObserver observer : mObservers) {
                if (!selfChange || observer.deliverSelfNotifications()) {
                    observer.dispatchChange(selfChange); 
                }
            }
        }
    }

在CursorAdapter中我们注册了ContentObserver

private class ChangeObserver extends ContentObserver {
        public ChangeObserver() {
            super(new Handler());
        }

        @Override
        public boolean deliverSelfNotifications() {
            return true;
        }

        @Override
        public void onChange(boolean selfChange) {
            onContentChanged(); 
        }
    }

//父类的方法

public final void dispatchChange(boolean selfChange) {   
        if (mHandler == null) {
            onChange(selfChange);
        } else {
            mHandler.post(new NotificationRunnable(selfChange)); 
        }
    }

//父类的内部类 

private final class NotificationRunnable implements Runnable {

        private boolean mSelf;

        public NotificationRunnable(boolean self) {
            mSelf = self;
        }

        public void run() {
            ContentObserver.this.onChange(mSelf); 
        }
    }

在CursorAdapter中

protected void onContentChanged() {
        if (mAutoRequery && mCursor != null && !mCursor.isClosed()) {
            if (Config.LOGV) Log.v("Cursor", "Auto requerying " + mCursor + " due to update");
            mDataValid = mCursor.requery(); 
        }
    }

在AbstractCursor中

public boolean requery() {
        if (mSelfObserver != null && mSelfObserverRegistered == false) {
            mContentResolver.registerContentObserver(mNotifyUri, true, mSelfObserver);
            mSelfObserverRegistered = true;
        }
        mDataSetObservable.notifyChanged(); //任何继承AbstractCursor的Cursor都将通过调用super.requery()执行此句
        return true;
    }

如果我们注册了dataset的observer，就会得到相应的通知。

总结：

contentObserver是一个提前通知，这时候只是通知cursor说，我的内容变化了。

datasetObserver是一个后置通知，只有通过requery() deactivate() close()方法的调用才能获得这个通知。

因此，最为重要的还是ContentObserver，它可以告诉你数据库变化了，当然如果你要在更新完Cursor的dataset之后做一些

事情，datasetObserver也是必需的。

本文转自wanqi博客园博客，原文链接：http://www.cnblogs.com/wanqieddy/archive/2011/06/23/2088290.html如需转载请自行联系原作者