7.数据库、Contentobserver

群组页是程序内部维护的一个数据库，其中一张表groups，用于存放创建的群组，还有一张表thread_group，用于关联群组和系统短信数据库中的会话。

数据库应该这样设计

MySqliteHelper 
  1. public class MySqliteHelper extends SQLiteOpenHelper{
  3. 	public MySqliteHelper(Context context, String name, int version) {
  4. 		super(context, name, null, version);
  5. 	}
  7. 	public static final String TABLE_GROUPS = "groups";
  8. 	public static final String TABLE_THREAD_GROUPS = "thread_groups";
  9. 	
  10. 	@Override
  11. 	public void onCreate(SQLiteDatabase db) {
  12. 		
  13. 		db.execSQL("create table groups(_id integer primary key autoincrement, group_name varchar(20));");
  14. 		
  15. 		db.execSQL("create table thread_groups(_id integer primary key autoincrement, group_id integer, thread_id integer);");
  16. 		
  17. 	}
  19. 	@Override
  20. 	public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
  21. 		// TODO Auto-generated method stub
  22. 		
  23. 	}
  25. }
DBUtils 
  1. public class DBUtils {
  3. 	/**
  4. 	 * 用于更新cursor 的URI
  5. 	 */
  6. 	private static final Uri uri = Uri.parse("content://www.itheima.com");
  8. 	private Context ctx;
  9. 	
  10. 	private MySqliteHelper sqlHelper;
  11. 	
  12. 	private DBUtils(Context ctx){
  13. 		this.ctx = ctx;
  14. 		sqlHelper = new MySqliteHelper(ctx, "heima39", 1);
  15. 		
  16. 	}
  17. 	
  18. 	private  static DBUtils instance;
  19. 	
  20. 	public static synchronized DBUtils getInstance(Context ctx){
  21. 		
  22. 		if(instance == null){
  23. 			instance = new DBUtils(ctx);
  24. 		}
  25. 		return instance;
  26. 	}
  28. 	/**
  29. 	 * 创建新群组
  30. 	 * @param name 群组的名称
  31. 	 */
  32. 	public void createNewGroup(String name) {
  33. 		SQLiteDatabase db = sqlHelper.getWritableDatabase();
  34. 		
  35. 		ContentValues values = new ContentValues();
  36. 		
  37. 		values.put("group_name", name);
  38. 		
  39. 		db.insert(MySqliteHelper.TABLE_GROUPS, "_id", values);
  40. 		
  41. 		notifyCursor();
  42. 		
  43. 	}
  45. 	/**
  46. 	 * 查询所有的群组信息
  47. 	 * @return
  48. 	 */
  49. 	public Cursor getAllGroup() {
  50. 		SQLiteDatabase db = sqlHelper.getReadableDatabase();
  51. 		
  52. 		Cursor cursor = db.query(MySqliteHelper.TABLE_GROUPS, null, null, null, null, null, null);
  54. 		// android.database.sqlite.SQLiteCursor
  55. 		System.out.println(cursor);
  56. 		
  57. 		//为cursor 设置 通知提醒的URI 
  58. 		cursor.setNotificationUri(ctx.getContentResolver(), uri);
  59. 		
  60. 		return cursor;
  61. 	}
  63. 	/**
  64. 	 * 通知cursor 群组表中的内容已经发生变化
  65. 	 * @param cursor
  66. 	 */
  67. 	private void notifyCursor() {
  68. 		// 让内容处理者，根据URI 发出更新通知
  69. 		ctx.getContentResolver().notifyChange(uri, null);
  70. 	}
  72. 	/**
  73. 	 * 通过群组ID删除群组
  74. 	 * @param groupId
  75. 	 */
  76. 	public void deleteGroupById(int groupId) {
  77. 		SQLiteDatabase db = sqlHelper.getWritableDatabase();
  78. 		
  79. 		db.delete(MySqliteHelper.TABLE_GROUPS, " _id = "+groupId, null);
  80. 		
  81. 		notifyCursor();
  82. 	}
  84. 	/**
  85. 	 * 更新群组名称
  86. 	 * @param groupId 群组的ID
  87. 	 * @param name 群组的新名
  88. 	 */
  89. 	public void updateGroupById(int groupId, String name) {
  90. 		SQLiteDatabase db = sqlHelper.getWritableDatabase();
  91. 		
  92. 		ContentValues values = new ContentValues();
  93. 		
  94. 		values.put("group_name", name);
  95. 		
  96. 		db.update(MySqliteHelper.TABLE_GROUPS, values, " _id = "+groupId , null);
  97. 		
  98. 		notifyCursor();
  99. 	}
  101. 	/**
  102. 	 * 将会话ID和群组ID 插入到会话群组关系 表中
  103. 	 * @param threadId
  104. 	 * @param groupId
  105. 	 */
  106. 	public void insertThradIdAndGroupId(int threadId, int groupId) {
  107. 		SQLiteDatabase db = sqlHelper.getWritableDatabase();
  108. 		
  109. 		ContentValues values = new ContentValues();
  110. 		
  111. 		values.put("thread_id", threadId);
  112. 		values.put("group_id", groupId);
  113. 		
  114. 		db.insert(MySqliteHelper.TABLE_THREAD_GROUPS,null, values);
  115. 		
  116. 	}
  118. 	/**
  119. 	 * 返回所有的指定群组ID的会话信息
  120. 	 * @param groupId
  121. 	 * @return
  122. 	 */
  123. 	public Cursor getAllThreadIdByGroupId(int groupId) {
  124. 		SQLiteDatabase db = sqlHelper.getReadableDatabase();
  125. 		Cursor cursor = db.query(MySqliteHelper.TABLE_THREAD_GROUPS, null, " group_id = "+groupId, null, null, null, null);
  126. 		return cursor;
  127. 	}
  128. }
在activity中不需要做任何操作，当数据库发生变化list条目也变化了，前提必须是CursorAdapter
源码：
curosr 注册监听：
* cursor.setNotificationUri(ctx.getContentResolver(), uri);
* SQLiteCursor --> AbstractWindowedCursor  --> AbstractCursor 
*  在AbstractCursor类中：
public void setNotificationUri(ContentResolver cr, Uri notifyUri) {
mNotifyUri = notifyUri;
mContentResolver = cr;
 
mSelfObserver = new SelfContentObserver(this);
// 将uri 和 mSelfObserver 在  mContentResolver 中注册 
mContentResolver.registerContentObserver(mNotifyUri, true, mSelfObserver);

}
}

发出通知：
ctx.getContentResolver().notifyChange(uri, null);
* 在 ContentResolver中发出通知：
notifyChange(uri, observer, true /* sync to network */);
*结论： 根据uri 找到 监听此URI 的Contentobserver ，即  AbstractCursor 类中的 mSelfObserver 然后，执行，mSelfObserver 中 onChange方法
* 那么 cursor 中的内容观察者执行onChange方法 时，如何刷新页面：

* CursorAdapter  init方法中为cursor注册了二个监听：
c.registerContentObserver(mChangeObserver); // 内容观察者
c.registerDataSetObserver(mDataSetObserver); // 数据观察者
* 当Contentobserver 根据URI 发送更新通知时，执行cursor的 内容观察者即：
* mChangeObserver.onChange()方法 ：
   private class ChangeObserver extends ContentObserver {
public void onChange(boolean selfChange) {
onContentChanged();
}
}
* 在 onContentChanged方法 中 执行curosr.requery：
 protected void onContentChanged() {
...
mDataValid = mCursor.requery();
}
* 此时，cursor ,实际对象是 SQLiteCursor ，就执行 SQLiteCursor 中的requery方法 ，
* 在SQLiteCursor 中的requery方法中：
* 重新查询数据：
* 执行数据观察者的notify方法 ：mDataSetObservable.notifyChanged();
* 即执行观察者的onChanged方法： observer.onChanged();
* CursorAdapter中已经为cursor 注册了一个数据观察者： mDataSetObserver 
* 当 mDataSetObserver 执行onChanged 方法时：
  private class MyDataSetObserver extends DataSetObserver {
public void onChanged() {
mDataValid = true;
notifyDataSetChanged(); // 刷新了listView的数据 
}
｝
GroupUI 
群组创建后，在会话页，长按某一个会话添加到群组中

  1. public class GroupUI extends ListActivity implements OnItemLongClickListener, OnItemClickListener{
  2. 	
  3. 	private ListView listView;
  4. 	private Context ctx;
  5. 	@Override
  6. 	protected void onCreate(Bundle savedInstanceState) {
  7. 		super.onCreate(savedInstanceState);
  8. 		ctx = this;
  9. 		listView = getListView();
  10. 		adapter = new GropListAdapter(this, null);
  11. 		listView.setAdapter(adapter);
  12. 		
  13. 		listView.setOnItemLongClickListener(this);
  14. 		
  15. 		listView.setOnItemClickListener(this);
  16. 		
  17. 		prepareData();
  18. 	}
  20. 	private void prepareData() {
  21. 		
  22. 		DBUtils dbu = DBUtils.getInstance(ctx);
  23. 		Cursor cursor = dbu.getAllGroup();
  24. 		adapter.changeCursor(cursor);
  25. 		
  26. 	}
  28. 	private GropListAdapter adapter;
  29. 	
  30. 	class GropListAdapter extends CursorAdapter{
  32. 		public GropListAdapter(Context context, Cursor c) {
  33. 			super(context, c);
  34. 		}
  36. 		@Override
  37. 		public View newView(Context context, Cursor cursor, ViewGroup parent) {
  38. 			View view = View.inflate(context, R.layout.list_item_group, null);
  39. 			
  40. 			TextView name = (TextView) view.findViewById(R.id.tv_name_group);
  41. 			
  42. 			view.setTag(name);
  43. 			
  44. 			return view;
  45. 		}
  47. 		@Override
  48. 		public void bindView(View view, Context context, Cursor cursor) {
  49. 			
  50. 			TextView name = (TextView) view.getTag();
  51. 			
  52. 			name.setText(cursor.getString(cursor.getColumnIndex("group_name")));
  53. 			
  54. 		}
  55. 	}
  56. 	
  57. 	
  58. 	@Override
  59. 	/**
  60. 	 * 创建菜单
  61. 	 */
  62. 	public boolean onCreateOptionsMenu(Menu menu) {
  63. 		// 将 资料ID对应的文件转换为 菜单条目 ，并添加至  menu 中
  64. 		getMenuInflater().inflate(R.menu.activity_group, menu);
  65. 		return true;
  66. 	}
  67. 	
  68. 	@Override
  69. 	/**
  70. 	 * 响应菜单的点击事件
  71. 	 */
  72. 	public boolean onOptionsItemSelected(MenuItem item) {
  73. 		switch (item.getItemId()) {
  74. 		case R.id.menu_new_group:
  75. 			
  76. 			showCreateGroupDialog();
  77. 			
  78. 			break;
  79. 		}
  80. 		return true;
  81. 	}
  83. 	private AlertDialog dialog;
  84. 	
  85. 	/**
  86. 	 * 显示新建群组对话框
  87. 	 */
  88. 	private void showCreateGroupDialog() {
  89. 		AlertDialog.Builder adb =new AlertDialog.Builder(ctx);
  90. 		dialog = adb.create();
  91. 		View view = View.inflate(ctx, R.layout.dialog_new_group, null);
  92. 		final EditText etInputName = (EditText) view.findViewById(R.id.et_input_new_group);
  93. 		Button btnOk = (Button) view.findViewById(R.id.btn_ok);
  94. 		btnOk.setOnClickListener(new OnClickListener() {
  95. 			@Override
  96. 			public void onClick(View v) {
  97. 				String name = etInputName.getText().toString();
  98. 				if(TextUtils.isEmpty(name)){
  99. 					Toast.makeText(ctx, "请输入群组名称", 0).show();
  100. 					return ;
  101. 				}
  102. 				// 将群组名称保存至数据库
  103. 				DBUtils dbu = DBUtils.getInstance(ctx);
  104. 				dbu.createNewGroup(name);
  105. 				dialog.dismiss();
  106. 			}
  107. 		});
  108. 		dialog.setView(view,0,0,0,0);
  109. 		dialog.show();
  110. 		
  111. 	}
  113. 	@Override
  114. 	/**
  115. 	 * 响应listview条目的长按事件
  116. 	 */
  117. 	public boolean onItemLongClick(AdapterView<?> parent, View view,
  118. 			int position, long id) {
  119. 		
  120. 		showEditGroupDialog(position);
  121. 		
  122. 		return true;
  123. 	}
  125. 	/**
  126. 	 * 显示编辑群组对话框 
  127. 	 * @param position
  128. 	 */
  129. 	private void showEditGroupDialog(final int position) {
  130. 		
  131. 		AlertDialog.Builder adb = new AlertDialog.Builder(ctx);
  132. 		
  133. 		String items[]=new String[]{"编辑","删除"};
  134. 		
  135. 		adb.setItems(items, new DialogInterface.OnClickListener() {
  136. 			@Override
  137. 			/**
  138. 			 * which 是点击的条目的位置
  139. 			 */
  140. 			public void onClick(DialogInterface dialog, int which) {
  141. 				if(which == 0){ // “编辑”
  142. 					showUpdateGroupDialog(position);
  143. 				}else{ // 删除
  144. 					showConfirmDeleteDialog(position);
  145. 				}
  146. 				
  147. 			}
  148. 		});
  149. 		
  150. 		adb.show();
  151. 		
  152. 	}
  154. 	/**
  155. 	 * 显示确认删除的对话框
  156. 	 * @param position
  157. 	 */
  158. 	protected void showConfirmDeleteDialog(final int position) {
  159. 		AlertDialog.Builder adb = new AlertDialog.Builder(ctx);
  160. 		adb.setTitle("删除群组");
  161. 		adb.setMessage("确定要删除这个群吗？");
  162. 		adb.setNegativeButton("确定", new DialogInterface.OnClickListener() {
  163. 			
  164. 			@Override
  165. 			public void onClick(DialogInterface dialog, int which) {
  166. 				// 删除对应的群组
  167. 				DBUtils dbu = DBUtils.getInstance(ctx);
  168. 				Cursor cursor = adapter.getCursor();
  169. 				cursor.moveToPosition(position);
  170. 				int groupId = cursor.getInt(0); // 获得第0列的值，即，_id 这一列的值
  171. 				dbu.deleteGroupById(groupId);
  172. 				
  173. 				dialog.dismiss();
  174. 			}
  175. 		});
  176. 		adb.setPositiveButton("取消", null);
  177. 		adb.show();
  178. 		
  179. 	}
  181. 	/**
  182. 	 * 显示更新群组的对话框 
  183. 	 * @param position
  184. 	 */
  185. 	protected void showUpdateGroupDialog(final int position) {
  186. 		
  187. 		AlertDialog.Builder adb =new AlertDialog.Builder(ctx);
  188. 		dialog = adb.create();
  189. 		
  190. 		View view = View.inflate(ctx, R.layout.dialog_new_group, null);
  191. 		
  192. 		TextView title = (TextView) view.findViewById(R.id.tv_title_dialog);
  193. 		title.setText("更新群组名称");
  194. 		
  195. 		final EditText etInputName = (EditText) view.findViewById(R.id.et_input_new_group);
  196. 		Button btnOk = (Button) view.findViewById(R.id.btn_ok);
  197. 		
  198. 		btnOk.setOnClickListener(new OnClickListener() {
  199. 			@Override
  200. 			public void onClick(View v) {
  201. 				String name = etInputName.getText().toString();
  202. 				if(TextUtils.isEmpty(name)){
  203. 					Toast.makeText(ctx, "请输入群组名称", 0).show();
  204. 					return ;
  205. 				}
  206. 				// 将群组名称保存至数据库
  207. 				DBUtils dbu = DBUtils.getInstance(ctx);
  208. 				
  209. 				Cursor cursor = adapter.getCursor();
  210. 				cursor.moveToPosition(position);
  211. 				
  212. 				int groupId = cursor.getInt(0); // 获得群组ID
  213. 				
  214. 				dbu.updateGroupById(groupId,name);
  215. 				
  216. 				dialog.dismiss();
  217. 			}
  218. 		});
  219. 		dialog.setView(view,0,0,0,0);
  220. 		dialog.show();
  221. 	}
  223. 	@Override
  224. 	/**
  225. 	 * 响应listview条目点击事件
  226. 	 */
  227. 	public void onItemClick(AdapterView<?> parent, View view, int position,
  228. 			long id) {
  229. 		
  230. 		Cursor cursor = adapter.getCursor();
  231. 		cursor.moveToPosition(position);
  232. 		int groupId = cursor.getInt(0); // 返回群组ID
  233. 		
  234. 		DBUtils dbu =DBUtils.getInstance(ctx);
  235. 		Cursor cursor2 =  dbu.getAllThreadIdByGroupId(groupId);
  236. 		if(cursor2.getCount() == 0){ // 该群组没有人
  237. 			Toast.makeText(ctx, "该群还没有人，快回点人气吧", 0).show();
  238. 		}else{
  239. 			// 如果有人的话，希望能过cursor2 拼凑出如： thread_id in (1,2);
  240. 			
  241. 			String subSql = convertCursor2Str(cursor2);
  242. 			
  243. 			System.out.println("subSql"+subSql);
  244. 			
  245. 			Intent intent = new Intent(this,ConversationUI.class);
  246. 			intent.putExtra("subSql", subSql);
  247. 			
  248. 			startActivity(intent);
  249. 			
  250. 		}
  251. 	}
  253. 	/**
  254. 	 * 根据cursor中的内容，拼凑出 如   thread_id in (1,2); 的字符串
  255. 	 * @param cursor2
  256. 	 * @return
  257. 	 */
  258. 	private String convertCursor2Str(Cursor cursor) {
  259. 		cursor.moveToPosition(-1);
  260. 		StringBuilder sb=new StringBuilder("  thread_id in ( ");
  261. 		while(cursor.moveToNext()){
  262. 			String threadId = cursor.getString(cursor.getColumnIndex("thread_id"));
  263. 			sb.append(threadId+",");  //  thread_id in (1,
  264. 		}
  265. 	//  thread_id in (1,2,3,4,
  266. 		sb.replace(sb.lastIndexOf(","), sb.length(), ")");
  267. 		
  268. 		return sb.toString();
  269. 	}
  270. }





【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/sixrain/p/4994973.html