Android编程操作嵌入式关系型SQLite数据库实例详解
本文实例分析了Android编程操作嵌入式关系型SQLite数据库的方法。分享给大家供大家参考，具体如下：
SQLite特点
1.Android平台中嵌入了一个关系型数据库SQLite，和其他数据库不同的是SQLite存储数据时不区分类型
例如一个字段声明为Integer类型，我们也可以将一个字符串存入，一个字段声明为布尔型，我们也可以存入浮点数。
除非是主键被定义为Integer，这时只能存储64位整数
2.创建数据库的表时可以不指定数据类型，例如：
CREATETABLEperson(idINTEGERPRIMARYKEY,name)
3.SQLite支持大部分标准SQL语句，增删改查语句都是通用的，分页查询语句和MySQL相同
SELECT*FROMpersonLIMIT20OFFSET10 SELECT*FROMpersonLIMIT20,10
创建数据库
1.定义类继承SQLiteOpenHelper
2.声明构造函数，4个参数
3.重写onCreate()方法
4.重写upGrade()方法
示例：
packagecn.itcast.sqlite;
importandroid.content.Context;
importandroid.database.sqlite.SQLiteDatabase;
importandroid.database.sqlite.SQLiteOpenHelper;
importandroid.database.sqlite.SQLiteDatabase.CursorFactory;
publicclassDBOpenHelperextendsSQLiteOpenHelper{
/**
*创建OpenHelper
*@paramcontext上下文
*@paramname数据库名
*@paramfactory游标工厂
*@paramversion数据库版本,不要设置为0,如果为0则会每次都创建数据库
*/
publicDBOpenHelper(Contextcontext,Stringname,CursorFactoryfactory,intversion){
super(context,name,factory,version);
}
/**
*当数据库第一次创建的时候被调用
*/
publicvoidonCreate(SQLiteDatabasedb){
db.execSQL("CREATETABLEperson(idINTEGERPRIMARYKEYAUTOINCREMENT,name)");
}
/**
*当数据库版本发生改变的时候被调用
*/
publicvoidonUpgrade(SQLiteDatabasedb,intoldVersion,intnewVersion){
db.execSQL("ALTERTABLEpersonADDbalance");
}
}
publicvoidtestCreateDB(){
DBOpenHelperhelper=newDBOpenHelper(getContext(),"itcast.db",null,2);
helper.getWritableDatabase();//创建数据库
}
CRUD操作
1.和JDBC访问数据库不同，操作SQLite数据库无需加载驱动，不用获取连接，直接可以使用
获取SQLiteDatabase对象之后通过该对象直接可以执行SQL语句：
SQLiteDatabase.execSQL() SQLiteDatabase.rawQuery()
2.getReadableDatabase()和getWritableDatabase()的区别
查看源代码后我们发现getReadableDatabase()在通常情况下返回的就是getWritableDatabase()拿到的数据库只有在抛出异常的时候才会以只读方式打开
3.数据库对象缓存
getWritableDatabase()方法最后会使用一个成员变量记住这个数据库对象，下次打开时判断是否重用
4.SQLiteDatabase封装了insert()、delete()、update()、query()四个方法也可以对数据库进行操作
这些方法封装了部分SQL语句，通过参数进行拼接
执行crud操作有两种方式，第一种方式自己写sql语句执行操作，第二种方式是使用SQLiteDatabase类调用响应的方法执行操作
execSQL()方法可以执行insert、delete、update和CREATETABLE之类有更改行为的SQL语句；rawQuery()方法用于执行select语句。
第一种方式示例：
packagecn.itcast.sqlite.service;
importjava.util.ArrayList;
importjava.util.List;
importandroid.content.Context;
importandroid.database.Cursor;
importandroid.database.sqlite.SQLiteDatabase;
importcn.itcast.sqlite.DBOpenHelper;
importcn.itcast.sqlite.domain.Person;
publicclassSQLPersonService{
privateDBOpenHelperhelper;
publicSQLPersonService(Contextcontext){
helper=newDBOpenHelper(context,"itcast.db",null,2);//初始化数据库
}
/**
*插入一个Person
*@paramp要插入的Person
*/
publicvoidinsert(Personp){
SQLiteDatabasedb=helper.getWritableDatabase();//获取到数据库
db.execSQL("INSERTINTOperson(name,phone,balance)VALUES(?,?)",newObject[]{p.getName(),p.getPhone()});
db.close();
}
/**
*根据ID删除
*@paramid要删除的PERSON的ID
*/
publicvoiddelete(Integerid){
SQLiteDatabasedb=helper.getWritableDatabase();
db.execSQL("DELETEFROMpersonWHEREid=?",newObject[]{id});
db.close();
}
/**
*更新Person
*@paramp要更新的Person
*/
publicvoidupdate(Personp){
SQLiteDatabasedb=helper.getWritableDatabase();
db.execSQL("UPDATEpersonSETname=?,phone=?,balance=?WHEREid=?",newObject[]{p.getName(),p.getPhone(),p.getBalance(),p.getId()});
db.close();
}
/**
*根据ID查找
*@paramid要查的ID
*@return对应的对象,如果未找到返回null
*/
publicPersonfind(Integerid){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.rawQuery("SELECTname,phone,balanceFROMpersonWHEREid=?",newString[]{id.toString()});
Personp=null;
if(cursor.moveToNext()){
Stringname=cursor.getString(cursor.getColumnIndex("name"));
Stringphone=cursor.getString(1);
Integerbalance=cursor.getInt(2);
p=newPerson(id,name,phone,balance);
}
cursor.close();
db.close();
returnp;
}
/**
*查询所有Person对象
*@returnPerson对象集合,如未找到,返回一个size()为0的List
*/
publicList<Person>findAll(){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.rawQuery("SELECTid,name,phone,balanceFROMperson",null);
List<Person>persons=newArrayList<Person>();
while(cursor.moveToNext()){
Integerid=cursor.getInt(0);
Stringname=cursor.getString(1);
Stringphone=cursor.getString(2);
Integerbalance=cursor.getInt(3);
persons.add(newPerson(id,name,phone,balance));
}
cursor.close();
db.close();
returnpersons;
}
/**
*查询某一页数据
*@parampage页码
*@paramsize每页记录数
*@return
*/
publicList<Person>findPage(intpage,intsize){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.rawQuery("SELECTid,name,phone,balanceFROMpersonLIMIT?,?"//
,newString[]{String.valueOf((page-1)*size),String.valueOf(size)});
List<Person>persons=newArrayList<Person>();
while(cursor.moveToNext()){
Integerid=cursor.getInt(0);
Stringname=cursor.getString(1);
Stringphone=cursor.getString(2);
Integerbalance=cursor.getInt(3);
persons.add(newPerson(id,name,phone,balance));
}
cursor.close();
db.close();
returnpersons;
}
/**
*获取记录数
*@return记录数
*/
publicintgetCount(){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.rawQuery("SELECTCOUNT(*)FROMperson",null);
cursor.moveToNext();
returncursor.getInt(0);
}
}
第二种方式示例：
/**
*插入一个Person
*@paramp要插入的Person
*/
publicvoidinsert(Personp){
SQLiteDatabasedb=helper.getWritableDatabase();
ContentValuesvalues=newContentValues();
values.put("name",p.getName());
values.put("phone",p.getPhone());
values.put("balance",p.getBalance());
//第一个参数是表名,第二个参数是如果要插入一条空记录时指定的某一列的名字,第三个参数是数据
db.insert("person",null,values);
db.close();
}
/**
*根据ID删除
*@paramid要删除的PERSON的ID
*/
publicvoiddelete(Integerid){
SQLiteDatabasedb=helper.getWritableDatabase();
db.delete("person","id=?",newString[]{id.toString()});
db.close();
}
/**
*更新Person
*@paramp要更新的Person
*/
publicvoidupdate(Personp){
SQLiteDatabasedb=helper.getWritableDatabase();
ContentValuesvalues=newContentValues();
values.put("id",p.getId());
values.put("name",p.getName());
values.put("phone",p.getPhone());
values.put("balance",p.getBalance());
db.update("person",values,"id=?",newString[]{p.getId().toString()});
db.close();
}
/**
*根据ID查找
*@paramid要查的ID
*@return对应的对象,如果未找到返回null
*/
publicPersonfind(Integerid){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.query("person",newString[]{"name","phone","balance"},"id=?",newString[]{id.toString()},null,null,null);
Personp=null;
if(cursor.moveToNext()){
Stringname=cursor.getString(cursor.getColumnIndex("name"));
Stringphone=cursor.getString(1);
Integerbalance=cursor.getInt(2);
p=newPerson(id,name,phone,balance);
}
cursor.close();
db.close();
returnp;
}
/**
*查询所有Person对象
*@returnPerson对象集合,如未找到,返回一个size()为0的List
*/
publicList<Person>findAll(){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.query("person",newString[]{"id","name","phone","balance"},null,null,null,null,"iddesc");
List<Person>persons=newArrayList<Person>();
while(cursor.moveToNext()){
Integerid=cursor.getInt(0);
Stringname=cursor.getString(1);
Stringphone=cursor.getString(2);
Integerbalance=cursor.getInt(3);
persons.add(newPerson(id,name,phone,balance));
}
cursor.close();
db.close();
returnpersons;
}
/**
*查询某一页数据
*@parampage页码
*@paramsize每页记录数
*@return
*/
publicList<Person>findPage(intpage,intsize){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.query(//
"person",newString[]{"id","name","phone","balance"},null,null,null,null,null,(page-1)*size+","+size);
List<Person>persons=newArrayList<Person>();
while(cursor.moveToNext()){
Integerid=cursor.getInt(0);
Stringname=cursor.getString(1);
Stringphone=cursor.getString(2);
Integerbalance=cursor.getInt(3);
persons.add(newPerson(id,name,phone,balance));
}
cursor.close();
db.close();
returnpersons;
}
/**
*获取记录数
*@return记录数
*/
publicintgetCount(){
SQLiteDatabasedb=helper.getReadableDatabase();
Cursorcursor=db.query(//
"person",newString[]{"COUNT(*)"},null,null,null,null,null);
cursor.moveToNext();
returncursor.getInt(0);
}
事务管理
1.使用在SQLite数据库时可以使用SQLiteDatabase类中定义的相关方法控制事务
beginTransaction()开启事务
setTransactionSuccessful()设置事务成功标记
endTransaction()结束事务
2.endTransaction()需要放在finally中执行，否则事务只有到超时的时候才自动结束，会降低数据库并发效率
示例：
publicvoidremit(intfrom,intto,intamount){
SQLiteDatabasedb=helper.getWritableDatabase();
//开启事务
try{
db.beginTransaction();
db.execSQL("UPDATEpersonSETbalance=balance-?WHEREid=?",newObject[]{amount,from});
System.out.println(1/0);
db.execSQL("UPDATEpersonSETbalance=balance+?WHEREid=?",newObject[]{amount,to});
//设置事务标记
db.setTransactionSuccessful();
}finally{
//结束事务
db.endTransaction();
}
db.close();
}
希望本文所述对大家Android程序设计有所帮助。