关于数据库与LoaderManager的联合使用，节流？？？。。。。。

public class MainActivity extends Activity {// 定义主机名，用以拼接Uri，Uri表明了内容提供的地址，外部应用通过Uri访问内容提供者，来实现对数据的增删改查private static final String AUTHORITY = "com.fishtosky.loaderthrottle";/** 本例中我们将自定义的一个数据库通过内容提供者共享给其它的外部应用，使外部应用可以对数据库中的内容进行 增删改查的操作。* 定义一个类用于定义关于内容提供者和工作表的一些常量，该类实现了BaseColumns接口，表示将继承该接口* _id和_icount两列，我们无需再定义就会在表中创建出这两个列*/public static class MainTable implements BaseColumns {// 构造函数私有化，不允许创建此类的实例private MainTable() {};// 定义表的名字public static final String TABLE_NAME = "main";// 定义这张表的uripublic static final Uri CONTENT_URI = Uri.parse("content://"+ AUTHORITY + "/main");// 定义表中某个条目（某行数据）的Uri的前面公共的部分，使用时我们还需要在后面添加条目的Idpublic static final Uri CONTENT_ID_URI_BASE = Uri.parse("content://"+ AUTHORITY + "/main");// 定义Uri的命名机制，/前面的部分是android系统定义的，不能改变，/后面的部分可以自定义任意字符串public static final String CONTENT_TYPE = "vnd.android.cursor.dir/com.fishtosky.throttle";// 定义某个条目的Uri的命名机制public static final String CONTENT_ITEM_TYPE = "vnd.android.cursor.item/com.fishtosky.throttle";// 定义默认的排序方式public static final String DEFAULT_SORT_ORDER = "data COLLATE LOCALIZED ASC";// 定义列的名字，本例中只有一列public static final String COLUM_NAME_DATA = "data";}/** 定义数据库的帮助库，用于创建数据库和工作表*/public static class DatabaseHelper extends SQLiteOpenHelper {// 定义数据库的名字的版本private static final String DATABASE_NAME = "loader_throttle.db";private static final int DATABASE_VERSION = 1;public DatabaseHelper(Context context) {super(context, DATABASE_NAME, null, DATABASE_VERSION);}@Overridepublic void onCreate(SQLiteDatabase db) {db.execSQL("CREATE TABLE " + MainTable.TABLE_NAME + " ("+ MainTable._ID + " INTEGER PRIMARY KEY,"+ MainTable.COLUM_NAME_DATA + " TEXT);");}@Overridepublic void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {Log.w("TAG", "Upgrading database from version " + oldVersion+ " to " + newVersion + ", which will destroy all old data");// 版本升级时调用，删除旧表，创建新表db.execSQL("DROP TABLE IF EXISTS notes");onCreate(db);}}/** 自定义内容提供者，通过它实现把数据库共享给外部应用*/public static class SimpleProvider extends ContentProvider {// 定义一个集合，把从数据库中选出的列映射到该集合中private Map<String, String> mNotesProjectionMap;// 定义Uri的匹配器，用于解析传入的Uriprivate UriMatcher mUriMatcher;// 定义当Uri匹配时的返回码// 匹配整个表时的返回码private static final int MAIN = 1;// 匹配某一行时的返回码private static final int MAIN_ID = 2;private DatabaseHelper mOpenHelper;public SimpleProvider() {// 为内容提供者注册UrimUriMatcher = new UriMatcher(UriMatcher.NO_MATCH);mUriMatcher.addURI(AUTHORITY, MainTable.TABLE_NAME, MAIN);// #表示通配符mUriMatcher.addURI(AUTHORITY, MainTable.TABLE_NAME + "/#", MAIN_ID);mNotesProjectionMap = new HashMap<String, String>();mNotesProjectionMap.put(MainTable._ID, MainTable._ID);mNotesProjectionMap.put(MainTable.COLUM_NAME_DATA,MainTable.COLUM_NAME_DATA);}@Overridepublic boolean onCreate() {// 创建数据库和数据表mOpenHelper = new DatabaseHelper(getContext());return true;}/** 用于供外部应用从内容提供者中获取数据*/@Overridepublic Cursor query(Uri uri, String[] projection, String selection,String[] selectionArgs, String sortOrder) {// 使用Sql查询语句构建的辅助类SQLiteQueryBuilder qb = new SQLiteQueryBuilder();qb.setTables(MainTable.TABLE_NAME);// 根据匹配Uri的返回码来判定是查询整个数据表，还是查询某条数据switch (mUriMatcher.match(uri)) {case MAIN:// 查询整个表qb.setProjectionMap(mNotesProjectionMap);break;case MAIN_ID:qb.setProjectionMap(mNotesProjectionMap);// 追加筛选条件qb.appendWhere(MainTable._ID + "=?");// 获取查询参数即所要查询条目的IdselectionArgs = DatabaseUtils.appendSelectionArgs(selectionArgs,new String[] { uri.getLastPathSegment() });break;default:throw new IllegalArgumentException("UnKnown Uri" + uri);}// 如果没定义排序规则，则按照默认的规则进行排序if (TextUtils.isEmpty(sortOrder)) {sortOrder = MainTable.DEFAULT_SORT_ORDER;}// 获取到可读的数据库SQLiteDatabase db = mOpenHelper.getReadableDatabase();Cursor c = qb.query(db, projection, selection, selectionArgs, null,null, sortOrder);// 监听uri的变化c.setNotificationUri(getContext().getContentResolver(), uri);return c;}/** 返回对应Uri MIME类型用以验证数据的合法性*/@Overridepublic String getType(Uri uri) {switch (mUriMatcher.match(uri)) {case MAIN:return MainTable.CONTENT_TYPE;case MAIN_ID:return MainTable.CONTENT_ITEM_TYPE;default:throw new IllegalArgumentException("UnKnown Uri" + uri);}}/** 用于外部应用向内容提供者中插入数据*/@Overridepublic Uri insert(Uri uri, ContentValues values) {// 只能插入到数据表中if (mUriMatcher.match(uri) != MAIN) {throw new IllegalArgumentException("UnKnown Uri" + uri);}if (values != null) {SQLiteDatabase db = mOpenHelper.getWritableDatabase();long row_Id = db.insert(MainTable.TABLE_NAME, null, values);// 如果插入成功，则插入行的Id存在if (row_Id > 0) {// ContentUris用于操作Uri路径后面的Id部分Uri noteUri = ContentUris.withAppendedId(MainTable.CONTENT_ID_URI_BASE, row_Id);//必须设置对Uri的监听，不然loader无法获取到数据库的更新，不能实现实时更新getContext().getContentResolver().notifyChange(noteUri, null);// 返回所插入条目的Urireturn noteUri;}}throw new SQLException("Failed to insert row into " + uri);}/** 用于外部应用删除内容提供者中的数据*/@Overridepublic int delete(Uri uri, String where, String[] whereArgs) {SQLiteDatabase db = mOpenHelper.getWritableDatabase();String findWhere;int count = -1;switch (mUriMatcher.match(uri)) {case MAIN:count = db.delete(MainTable.TABLE_NAME, where, whereArgs);break;case MAIN_ID:// 组装查询条件findWhere = DatabaseUtils.concatenateWhere(MainTable._ID + "="+ ContentUris.parseId(uri), where);count = db.delete(MainTable.TABLE_NAME, findWhere, whereArgs);break;default:throw new IllegalArgumentException("Unknown URI " + uri);}getContext().getContentResolver().notifyChange(uri, null);return count;}@Overridepublic int update(Uri uri, ContentValues values, String where,String[] whereArgs) {SQLiteDatabase db = mOpenHelper.getWritableDatabase();String findWhere;int count = -1;switch (mUriMatcher.match(uri)) {case MAIN:count = db.update(MainTable.TABLE_NAME, values, where,whereArgs);break;case MAIN_ID:// 组装查询条件findWhere = DatabaseUtils.concatenateWhere(MainTable._ID + "="+ ContentUris.parseId(uri), where);count = db.update(MainTable.TABLE_NAME, values, findWhere,whereArgs);break;default:throw new IllegalArgumentException("Unknown URI " + uri);}getContext().getContentResolver().notifyChange(uri, null);return count;}}@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);FragmentManager fm = getFragmentManager();if (fm.findFragmentById(android.R.id.content) == null) {LoaderThrottleFragment frg = new LoaderThrottleFragment();fm.beginTransaction().add(android.R.id.content, frg).commit();}}public static class LoaderThrottleFragment extends ListFragment {private static final int POPULATE_ID = Menu.FIRST;private static final int CLEAR_ID = Menu.FIRST + 1;private SimpleCursorAdapter mAdapter;private AsyncTask<Void, Void, Void> mPopulatingTask;final String[] projection = new String[] { MainTable._ID,MainTable.COLUM_NAME_DATA };private LoaderCallbacks<Cursor> myLoader = new LoaderCallbacks<Cursor>() {@Overridepublic Loader<Cursor> onCreateLoader(int id, Bundle args) {CursorLoader c = new CursorLoader(getActivity(),MainTable.CONTENT_URI, projection, null,null, null);System.out.println("数据变化了吗？");//最多每2秒更新一次c.setUpdateThrottle(2000);return c;}@Overridepublic void onLoadFinished(Loader<Cursor> loader, Cursor data) {System.out.println("数据准备完毕了吗？"+data.getCount());mAdapter.swapCursor(data);if(isResumed()){setListShown(true);}else{setListShownNoAnimation(true);}}@Overridepublic void onLoaderReset(Loader<Cursor> loader) {mAdapter.swapCursor(null);}};@Overridepublic void onActivityCreated(Bundle savedInstanceState) {super.onActivityCreated(savedInstanceState);setEmptyText("No data.  Select 'Populate' to fill with data from Z to A at a rate of 4 per second.");setHasOptionsMenu(true);mAdapter = new SimpleCursorAdapter(getActivity(),android.R.layout.simple_list_item_1, null,new String[] { MainTable.COLUM_NAME_DATA },new int[] { android.R.id.text1 }, 0);setListAdapter(mAdapter);setListShown(false);getLoaderManager().initLoader(111, null, myLoader);}@Overridepublic void onCreateOptionsMenu(Menu menu, MenuInflater inflater) {super.onCreateOptionsMenu(menu, inflater);menu.add(Menu.NONE, POPULATE_ID, 0, "populate").setShowAsAction(MenuItem.SHOW_AS_ACTION_IF_ROOM);menu.add(Menu.NONE, CLEAR_ID, 0, "clear").setShowAsAction(MenuItem.SHOW_AS_ACTION_IF_ROOM);}@Overridepublic boolean onOptionsItemSelected(MenuItem item) {switch (item.getItemId()) {case POPULATE_ID:addToDatabase();//testadd();return true;case CLEAR_ID:deleteData();return true;}return super.onOptionsItemSelected(item);}/*private void testadd() {ContentValues values = new ContentValues();values.put(MainTable.COLUM_NAME_DATA, "I am test string");Uri rowUri=getActivity().getContentResolver().insert(MainTable.CONTENT_URI, values);if(rowUri!=null){getLoaderManager().restartLoader(111, null, myLoader);}System.out.println("rowUri:"+rowUri.toString());}*/private void deleteData() {if (mPopulatingTask != null) {mPopulatingTask.cancel(false);mPopulatingTask = null;}AsyncTask<Void, Void, Void> task = new AsyncTask<Void, Void, Void>() {@Overrideprotected Void doInBackground(Void... params) {getActivity().getContentResolver().delete(MainTable.CONTENT_URI, null, null);return null;}};task.execute((Void[]) null);}private void addToDatabase() {// 如果异步任务不为空，则取消任务if (mPopulatingTask != null) {mPopulatingTask.cancel(false);mPopulatingTask = null;}// 开启线程向数据库中添加内容mPopulatingTask = new AsyncTask<Void, Void, Void>() {@Overrideprotected Void doInBackground(Void... params) {// 向数据库中添加内容for (char c = 'z'; c >= 'a'; c--) {if (isCancelled()) {break;}StringBuilder sb = new StringBuilder("Data ");sb.append(c);ContentValues values = new ContentValues();values.put(MainTable.COLUM_NAME_DATA, sb.toString());Uri rowUri=getActivity().getContentResolver().insert(MainTable.CONTENT_URI, values);//System.out.println("rowUri:"+rowUri.toString());try {Thread.sleep(250);} catch (InterruptedException e) {e.printStackTrace();}}return null;}};// 使用系统默认的线程池来管理线程//mPopulatingTask.execute((Void[]) null);mPopulatingTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR,(Void[]) null);//getLoaderManager().restartLoader(111, null, myLoader);}@Overridepublic void onListItemClick(ListView l, View v, int position, long id) {super.onListItemClick(l, v, position, id);Toast.makeText(getActivity(), "Item click:" + id, 0).show();}}
}

在配置文件中注册内容提供者

<provider android:name="com.fishtosky.loaderthrottle.MainActivity$SimpleProvider"android:authorities="com.fishtosky.loaderthrottle"></provider>

关于数据库与LoaderManager的联合使用，节流？？？。。。。。相关推荐

阿里云PolarDB开源数据库社区与 Tapdata 联合共建开放数据技术生态
简介:近日,阿里云PolarDB开源数据库社区宣布将与 Tapdata 联合共建开放数据技术生态. 近日,阿里云PolarDB开源数据库社区宣布将与 Tapdata 联合共建开放数据技术生态.在此之际 ...
android sqllite数据库的多表联合查询
Android数据库有时候需要多表联合查询,经过学习,可以用以下代码 Currsor = db.rawQuery("select * from tablea as a left outer ...
数据库之多表联合查询
一.知识点名称多表联合查询(一对多数据显示.多对多数据展示) 二.知识点业务场景一对多关联: 学生和成绩的关系用户与订单的关系企业与员工的关系用户与银行卡的关系多对多关联: 学生和选课的关 ...
Oracle数据库(二)多表联合查询
1.执行使用两个表的select语句: 1)例句: select products.name,product_types.name from products,product_types where ...
CSDN联合腾讯云重磅发布“腾讯云数据库TDSQL工程师路线图”
腾讯云数据库TDSQL是腾讯自研的企业级分布式数据库,在金融.政务.运营商.电商.游戏等数十个行业中落地应用,具备金融级高可用.强一致.高性能.高可靠等特性.目前,腾讯云数据库TDSQL 已助力 20 ...
在db2中两个数据库之间的两个表的联合查询
大家好,今天遇到了在db2中两个数据库之间的两个表的联合查询我知道oracle中有dblink,可是不知到db2的两个数据库联合查询怎么处理我找了类似于比如两个数据库: db1,db2 用户名 ...
CSDN联合腾讯云发布“腾讯云数据库TDSQL工程师路线图”
腾讯云数据库TDSQL是腾讯自研的企业级分布式数据库,在金融.政务.运营商.电商.游戏等数十个行业中落地应用,具备金融级高可用.强一致.高性能.高可靠等特性.目前,腾讯云数据库TDSQL 已助力 20 ...
连接数据孤岛，巨杉数据库与 Tapdata 联合共建开放数据生态
近日,专注实时数据服务平台的Tapdata ,宣布开源其数据源开发框架--PDK(Plugin Development Kit),并同步启动PDK插件生态共建计划,旨在充分激发实时数据流动的价值,助力 ...
mysql联合查询sql优化
我们在使用mysql数据库时,经常会使用到mysql的联合查询,联合查询分为内连接和外连接,内连接查询结果是联合的表都存在匹配才会有结果,外连接则根据驱动表是否存在匹配来生成结果集. 这里使用mysq ...

关于数据库与LoaderManager的联合使用，节流？？？。。。。。

关于数据库与LoaderManager的联合使用，节流？？？。。。。。相关推荐

最新文章

热门文章