android 数据库怎么监听数据变化_工具

在android中经常会用到改变数据库内容后再去使用数据库更新的内容，很多人会重新去query一遍，但是这样的问题就是程序会特别占内存，而且有可能会搂关cursor而导致程序内存未释放等等。其实android内部提供了一种ContentObserver的东西来监听数据库内容的变化。

ContentObserver的构造函数需要一个参数Hanlder，因为ContentObserver内部使用了一个实现Runnable接口的内部类NotificationRunnable，来实现数据库内容的变化。需要使用hanlder去post消息。注册ContentObserver的方法是：getContentResolver()registerContentObserver(uri, notifyForDescendents, observer)

上面3个参数为：uri----Uri类型，是需要监听的数据库的uri

notifyForDescendents---boolean true的话就会监听所有与此uri相关的uri。false的话则是直接特殊的uri才会监听。一般都设置为true

observer-----ContentObserver 就是需要的contentobserver

初始化一个ContentObserver对象，重载onChange(boolean ),在这个方法里去 *** 作数据库的使用，针对变化后的使用。

写了一个小demo，可以参考下。提示这种监听方式必须是contentprovider才能使用，因为contentprovider有uri简单的那种sqlite数据库没有uri是使用不了的。

下面demo *** 作的是在一个activityA里点击button跳转至另外一个activityB,在B中点击button往数据库中加数据，加完后关闭B回到A。A的button的文字自动变化设置到数据库中的字符串。[code]

package tycomlto;

03 import androidappActivity;

04 import androidcontentIntent;

05 import androiddatabaseContentObserver;

06 import androidosBundle;

07 import androidosHandler;

08 import androidviewView;

09 import androidwidgetButton;

11 public class ListenDataTest extends Activity{

12 private Button testBtn;

14 @Override

15 protected void onCreate(Bundle savedInstanceState) {

16 superonCreate(savedInstanceState);

17 setContentView(Rlayoutlisten_data_test);

18 getContentResolver()registerContentObserver(DataChangeProviderCONTENT_URI,

19 true, cob);

21 testBtn = (Button)findViewById(Ridtest_btn);

22 testBtnsetOnClickListener(new ViewOnClickListener() {

24 public void onClick(View v) {

25 Intent in = newIntent(ListenDataTestthis,DataChangeTestclass);

26 startActivity(in);

28 }

29 });

31 }

33 private ContentObserver cob = new ContentObserver(new Handler()) {

35 @Override

36 public boolean deliverSelfNotifications() {

37 return superdeliverSelfNotifications();

38 }

40 @Override

41 public void onChange(boolean selfChange) {

42 superonChange(selfChange);

43 testBtnsetText(DataUtilsgetChangeName(getApplicationContext()));

44 }

46 };

48 @Override

49 protected void onDestroy() {

50 superonDestroy();

51 getContentResolver()unregisterContentObserver(cob);

52 }

55 }

[code]01 package tycomlto;

03 import androidappActivity;

04 import androidcontentContentValues;

05 import androidcontentIntent;

06 import androiddatabaseContentObservable;

07 import androiddatabaseContentObserver;

08 import androidosBundle;

09 import androidosHandler;

10 import androidviewView;

11 import androidwidgetButton;

13 public class DataChangeTest extends Activity{

14 private Button dataBtn;

15 DataSqlite mDataSqlite;

16 @Override

17 protected void onCreate(Bundle savedInstanceState) {

18 superonCreate(savedInstanceState);

19 setContentView(Rlayoutdata_change_test);

20 dataBtn = (Button)findViewById(Riddata_test_btn);

21 mDataSqlite = new DataSqlite(this);

22 dataBtnsetOnClickListener(new ViewOnClickListener() {

24 public void onClick(View v) {

25 ContentValues con = new ContentValues();

26 conput("name", "数据变化了");

27 getContentResolver()insert(DataChangeProviderCONTENT_URI, con);

28 finish();

29 }

30 });

31 }

32 }

[code]view sourceprint

001 package tycomlto;

002

003

004 import androidcontentContentProvider;

005 import androidcontentContentUris;

006 import androidcontentContentValues;

007 import androidcontentContext;

008 import androidcontentUriMatcher;

009 import androiddatabaseCursor;

010 import androiddatabaseSQLException;

011 import androiddatabasesqliteSQLiteDatabase;

012 import androiddatabasesqliteSQLiteOpenHelper;

013 import androiddatabasesqliteSQLiteQueryBuilder;

014 import androiddatabasesqliteSQLiteDatabaseCursorFactory;

015 import androidnetUri;

016 import androidtextTextUtils;

017

018 public class DataChangeProvider extends ContentProvider{

019 private SQLiteOpenHelper mOpenHelper;

020 private static final int ALARMS = 1;

021 private static final int ALARMS_ID = 2;

022 private static final UriMatcher sURLMatcher = new UriMatcher(UriMatcherNO_MATCH);

023 public static final Uri CONTENT_URI = Uriparse("content://tycomlto/test");

024

025 static {

026 sURLMatcheraddURI("tycomlto", "test", ALARMS);

027 sURLMatcheraddURI("tycomlto", "test/#", ALARMS_ID);

028 }

029

030 private static class DatabaseHelper extends SQLiteOpenHelper{

031 private static final String TEST_DATABASE = "testdb";

032 private static final int VERSION = 1;

033

034 public DatabaseHelper(Context context) {

035 super(context, TEST_DATABASE, null, VERSION);

036 // TODO Auto-generated constructor stub

037 }

038

039

040 @Override

041 public void onCreate(SQLiteDatabase db) {

042 String sql = "CREATE TABLE "+"test"+" (" +

043 "_id INTEGER PRIMARY KEY," +

044 "name TEXT "+

045 ");";

046 dbexecSQL(sql);

047 }

048

049 @Override

050 public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {

051 String sql = "DROP TABLE IF EXIST "+TEST_DATABASE;

052 dbexecSQL(sql);

053 onCreate(db);

054 }

055

056 }

057

058 public DataChangeProvider() {

059 }

060

061 @Override

062 public int delete(Uri url, String where, String[] whereArgs) {

063 SQLiteDatabase db = mOpenHelpergetWritableDatabase();

064 int count;

065 long rowId = 0;

066 switch (sURLMatchermatch(url)) {

067 case ALARMS:

068 count = dbdelete("test", where, whereArgs);

069 break;

070 case ALARMS_ID:

071 String segment = urlgetPathSegments()get(1);

072

android读取数据库可以使用sqlite一些api进行读取，实例如下：

查找一条数据

@param uid

public User find(Integer uid){

SQLiteDatabase db=dbOpenHelpergetReadableDatabase(); //创建数据库辅助类

Cursor cursor =dbrawQuery("select from user where uid=", new String[]{uidtoString()}); //创建一个游标

if(cursormoveToFirst()){ //循环遍历查找数组

int uid2=cursorgetInt(cursorgetColumnIndex("uid"));

String uname=cursorgetString(cursorgetColumnIndex("uname"));

String uaddress=cursorgetString(cursorgetColumnIndex("uaddress"));

User user=new User();

usersetUid(uid2);

usersetUname(uname);

usersetUaddress(uaddress);

return user;

}

cursorclose();

return null;

}

SQLite 一个非常流行的嵌入式数据库，它支持 SQL 语言，并且只利用很少的内存就有很好的性能。此外它还是开源的，任何人都可以使用它。许多开源项目（(Mozilla, PHP, Python）都使用了 SQLite

Android 开发中使用 SQLite 数据库

Activites 可以通过 Content Provider 或者 Service 访问一个数据库。下面会详细讲解如果创建数据库，添加数据和查询数据库。

创建数据库

Android 不自动提供数据库。在 Android 应用程序中使用 SQLite，必须自己创建数据库，然后创建表、索引，填充数据。Android 提供了 SQLiteOpenHelper 帮助你创建一个数据库，你只要继承 SQLiteOpenHelper 类，就可以轻松的创建数据库。SQLiteOpenHelper 类根据开发应用程序的需要，封装了创建和更新数据库使用的逻辑。SQLiteOpenHelper 的子类，至少需要实现三个方法：

构造函数，调用父类 SQLiteOpenHelper 的构造函数。这个方法需要四个参数：上下文环境（例如，一个 Activity），数据库名字，一个可选的游标工厂（通常是 Null），一个代表你正在使用的数据库模型版本的整数。

onCreate（）方法，它需要一个 SQLiteDatabase 对象作为参数，根据需要对这个对象填充表和初始化数据。

onUpgrage() 方法，它需要三个参数，一个 SQLiteDatabase 对象，一个旧的版本号和一个新的版本号，这样你就可以清楚如何把一个数据库从旧的模型转变到新的模型。

这种方式通常连接一个外部的数据库，第一个参数就是数据库文件,这个数据库不是当前项目中生成的，通常放在项目的Assets目录下，当然也可以在手机内，如上面参数那个目录，前提是那个文件存在且你的程序有访问权限。

另一种使用数据库的方式是，自己创建数据库并创建相应的数据库表,参考下面的代码：

public class DatabaseHelper extends SQLiteOpenHelper {

//构造，调用父类构造，数据库名字，版本号（传入更大的版本号可以让数据库升级，onUpgrade被调用）

public DatabaseHelper(Context context) {

super(context, DatabaseConstantDATABASE_NAME, null, DatabaseConstantDATABASE_VERSION);

}

//数据库创建时调用，里面执行表创建语句

@Override

public void onCreate(SQLiteDatabase db) {

dbexecSQL(createVoucherTable());

}

//数据库升级时调用，先删除旧表，在调用onCreate创建表

@Override

public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {

dbexecSQL("DROP TABLE IF EXISTS " + DatabaseConstantTABLE_NAME);

onCreate(db);

}

//生成创建表的SQL语句

private String createVoucherTable() {

StringBuffer sb = new StringBuffer();

sbappend(" CREATE TABLE ")append(DatabaseConstantTABLE_NAME)append("( ")append(“ID”)

append(" TEXT PRIMARY KEY, ")

append(“USER_ID”)append(" INTEGER, ")append(“SMS_CONTENT”)append(" TEXT ) ");

return sbtoString();

}

} 继承SQLiteOpenHelper并实现里面的方法

之后：

//得到数据库助手类

helper

new

DatabaseHelper(context);

//通过助手类，打开一个可读写的数据库连接

SQLiteDatabase

database

helpergetReadableDatabase();

//查询表中所有记录

databasequery(DatabaseConstantTABLE_NAME,

null,

null);

final ContentResolver cr = getContentResolver();

Uri uri = Uriparse("content://comandroidlauncher2settings/favoritesnotify=true");

Cursor c = crquery(uri,

new String[] { "title", "intent" }, "title= and intent=",

new String[] { title, intenttoUri(0) }, order);

一般都用ContentResolver

Android 连接数据库

Android采用关系型数据库SQLite3，它是一个支持SQL轻量级的嵌入式数据库，在嵌入式 *** 作上有很广泛的，WM采用的也是SQLite3

关于过于、原理方面的东西在这篇文章里不会提到，但是如果你想能够快速的学会 *** 作SQLite3，那这就是你要找的文章！

首先，我们看一下api，所有数据库相关的接口、类都在。database和androiddatabasesqlite两个包下，虽然只有两个包，但是如果你英文不好或是太懒的话也要迷茫一段时间，其实，我们真正用的到的没有几个！

1、SQLiteOpenHelper （androiddatabasesqliteSQLiteOpenHelper）

这是一个抽象类，关于抽象类我们都知道，如果要使用它，一定是继承它！

这个类的方法很少，有一个构造方法

SQLiteOpenHelper（androidcontentContext context, javalangString name,androiddatabasesqliteSQLiteDatabaseCursorFactory factory, int version）；

参数不做过多的解释，CursorFactory一般直接传null就可以

public void onCreate（SQLiteDatabase db）

此方法在创建数据库是被调用，所以，应该把创建表的 *** 作放到这个方法里面，一会儿在后面我们会再详细的说如何创建表

public void onUpgrade（SQLiteDatabase db, int oldVersion, int newVersion）

从方法名上我们就能知道这个方法是执行更新的，没错，当version改变是系统会调用这个方法，所以在这个方法里应该执行删除现有表，然后手动调用onCreate的 *** 作

SQLiteDatabase getReadableDatabase（）

可读的SQLiteDatabase对象

SQLiteDatabase getWritableDatabase（）

获取可写的SQLiteDatabase对象

2、SQLiteDatabase（androiddatabasesqliteSQLiteDatabase）

关于 *** 作数据库的工作（增、删、查、改）都在这个类里

execSQL（sql）

执行SQL语句，用这个方法+SQL语句可以非常方便的执行增、删、查、改

除此之外，Android还提供了功过方法实现增、删、查、改

long insert（TABLE_NAME, null, contentValues）添加记录

int delete（TABLE_NAME, where, whereValue）删除记录

int update（TABLE_NAME, contentValues, where, whereValue）更新记录

Cursor query（TABLE_NAME, null, null, null, null, null, null）查询记录

除此之外，还有很多方法，如：beginTransaction（）开始事务、endTransaction（）结束事务…有兴趣的可以自己看api，这里就不多赘述了

3、Cursor（androiddatabaseCursor）

游标（接口），这个很熟悉了吧，Cursor里的方法非常多，常用的有：

boolean moveToPosition（position）将指针移动到某记录

getColumnIndex（ContactsPeopleNAME）按列名获取id

int getCount（）获取记录总数

boolean requery（）重新查询

boolean isAfterLast（）指针是否在末尾

boolean isBeforeFirst（）时候是开始位置

boolean isFirst（）是否是第一条记录

boolean isLast（）是否是最后一条记录

boolean moveToFirst（）、 boolean moveToLast（）、 boolean moveToNext（）同moveToPosition（position）

4、SimpleCursorAdapter（androidwidgetSimpleCursorAdapter）

也许你会奇怪了，之前我还说过关于数据库的 *** 作都在database和databasesqlite包下，为什么把一个Adapter放到这里，如果你用过Android的SQLite3，你一定会知道

，这是因为我们对数据库的 *** 作会经常跟列表联系起来

经常有朋友会在这出错，但其实也很简单

SimpleCursorAdapter adapter = new SimpleCursorAdapter（

this,

Rlayoutlist,

myCursor,

new String[] {DBTEXT1,DB TEXT2},

new int[]{ Ridlist1,RidlistText2 }）；

mysetAdapter（adapter）；

一共5个参数，具体如下：

参数1:Content

参数2:布局

参数3:Cursor游标对象

参数4:显示的字段，传入String[]

参数5:显示字段使用的组件，传入int[]，该数组中是TextView组件的id

到这里，关于数据库的 *** 作就结束了，但是到目前为止我只做了翻译的工作，有些同学可能还是没有掌握，放心，下面我们一起顺着正常开发的思路理清一下头绪！

前面的只是帮没做过的朋友做下普及，下面才是你真正需要的！

一、写一个类继承SQLiteOpenHelpe

public class DatabaseHelper extends SQLiteOpenHelper

构造方法：

DatabaseHelper（Context context） {

super（context, DATABASE_NAME, null, DATABASE_VERSION）；

}

在onCreate方法里写建表的 *** 作

public void onCreate（SQLiteDatabase db） {

String sql = “CREATE TABLE tb_test （_id INTEGER DEFAULT '1' NOT NULL PRIMARY KEY AUTOINCREMENT,class_jb TEXT NOT NULL,class_ysbj TEXT NOT NULL,title TEXT NOT NULL,content_ysbj TEXT NOT NULL）”;

dbexecSQL（sql）；//需要异常捕获

}

在onUpgrade方法里删除现有表，然后手动调用onCtreate创建表

public void onUpgrade（SQLiteDatabase db, int oldVersion, int newVersion） {

String sql = “drop table ”+tbname;

dbexecSQL（sql）；

onCreate（db）；

}

对表增、删、查、改的方法，这里用的是SQLiteOpenHelper提供的方法，也可以用sql语句实现，都是一样的

关于获取可读/可写SQLiteDatabase，我不说大家也应该会想到，只有查找才会用到可读的SQLiteDatabase

添加数据

public long insert（String tname, int tage, String ttel）{

SQLiteDatabase db= getWritableDatabase（）；//获取可写SQLiteDatabase对象

//ContentValues类似map，存入的是键值对

ContentValues contentValues = new ContentValues（）；

contentValuesput（“tname”, tname）；

contentValuesput（“tage”, tage）；

contentValuesput（“ttel”, ttel）；

return dbinsert（tbname, null, contentValues）；

}

删除记录

@param _id

public void delete（String _id）{

SQLiteDatabase db= getWritableDatabase（）；

dbdelete（tbname,

“_id=”,

new String[]{_id}）；

}

更新记录的，跟插入的很像

public void update（String _id,String tname, int tage, String ttel）{

SQLiteDatabase db= getWritableDatabase（）；

ContentValues contentValues = new ContentValues（）；

contentValuesput（“tname”, tname）；

contentValuesput（“tage”, tage）；

contentValuesput（“ttel”, ttel）；

dbupdate（tbname, contentValues,

“_id=”,

new String[]{_id}）；

}

查询所有数据

@return Cursor

public Cursor select（）{

SQLiteDatabase db = getReadableDatabase（）；

return dbquery（

tbname,

new String[]{“_id”,“tname”,“tage”,“ttel”,“taddr”},

null,

null, null, null, “_id desc”）；

}

关于dbquery方法的参数，有很多，为了防止大家弄乱，我简单说一下

参数1：表名

参数2：返回数据包含的列信息，String数组里放的都是列名

参数3：相当于sql里的where，sql里where后写的内容放到这就行了，例如：tage>

参数4：如果你在参数3里写了？（知道我为什么写tage>了吧），那个这里就是代替？的值接上例：new String[]{“30”}

参数5：分组，不解释了，不想分组就传null

参数6：having，想不起来的看看SQL

参数7：orderBy排序

到这里，你已经完成了最多的第一步！我们来看看都用到了那些类：

SQLiteOpenHelper我们继承使用的

SQLiteDatabase增删查改都离不开它，即使你直接用sql语句，也要用到execSQL（sql）

二、这里无非是对DatabaseHelper类定义方法的调用，没什么可说的，不过我还是对查询再唠叨几句吧

Android查询出来的结果一Cursor形式返回

cursor = sqLiteHelperselect（）；//是不是很简单？

查询出来的cursor一般会显示在listView中，这就要用到刚才提到的SimpleCursorAdapter

SimpleCursorAdapter adapter = new SimpleCursorAdapter（

this,

Rlayoutlist_row,

cursor,

new String[]{“tname”,“ttel”},

new int[]{RidTextView01,RidTextView02}

）；

里面带有实例。自己好好学习吧！

以上就是关于android 数据库怎么监听数据变化全部的内容，包括:android 数据库怎么监听数据变化、android 怎么读取数据库中的数据、android怎么连接sqlite数据库等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/sjk/9674199.html

android 数据库怎么监听数据变化

发表评论

评论列表（0条）