Android中SQLiteDatabase操作【附源码】

　　像我们做的很多应用程序及网站一样，基本都是对数据库进行增删改查来实现相应的功能。那么Android开发也一样，不过由于在移动客户端应用，所以不会像sql server、mysql那么复杂，Android应用程序支持本地数据库，SQLiteDatabase，通俗的说就是在手机上我们开发的应用程序中创建一个数据库，然后我们可以在手机上对我们的数据进行增删改查，不过这并不是绝对的，像前段时间我们开发一个小组OA，需要多人使用，功能简单，但需要大家连接到一个数据库中进行数据读取操作，所以这种情况下就要考虑到用mysql这样的数据库，最后选择了用php操作后台，然后然会Android进行数据处理，不过对于我们使用的2G网络很多程度上对速度还是有影响的。缓存这一块接触的比较少，计划等到Android这一块学的差不多了再研究其稍底层的一些开发。

　　这篇文章主要向大家分享如何操作SQLiteDatabase。　

　　当然首先我们要了解SQLiteDatabase，它具有很多优点：

SQLite特性：

    1. 轻量级

    2. 独立性

    3. 隔离性

        SQLite数据库中所有的信息(比如表、视图、触发器等)都包含在一个文件内，方便管理和维护。

    4. 跨平台

    5. 多语言接口

    6. 安全性

        SQLite数据库通过数据库级上的独占性和共享锁来实现独立事务处理。这意味着多个进程可以在同一时间从同一数据库读取数据，但只有一个可以写入数据。在某个进程或现成向数据库执行操作之前，必须获得独占锁定。在发出独占锁定以后，其他的读或写操作将不会再发生。

创建和打开数据库：

    openOrCreateDatabase(),自动检测是否存在这个数据库，如果存在则打开，否则创建，创建成功会返回一个SQLiteDatabase对象，否则抛出异常FileNotFoundException：

        mSQLiteDatabase = this.openOrCreateDatabase("abc.db",MODE_PRIVATE,null);

创建表：

    execSQL()：

        String Create_Table = "Create table table1...";

        mSQLiteDatabase.execSQL(Create_Table);

向表中添加数据：

    insert方法需要把数据打包到ContentValues中，ContentValues其实就是一个Map，Key值是字段名称，Value值是字段的值。通过ContentValues的put方法就可以把数据放到ContentValues对象中，然后插入到表中：

        ContentValue cv = new ContentValues();

        cv.put(table_num,1);

        mSQLiteDatabase.insert(TABLE_NAME,null,cv);

从表中删除数据：

    delete():

        mSQLiteDatabase.delete("abc.db","where...",null);

修改表数据：

    update():

        ContentValues cv = new ContentValues();

        cv.put(TABLE_NUM,3);

        mSQLiteDatabase.update("table1",cv,"num"+"="+Integer.toString(0),null);

  当然，插入、删除和修改操作也可以通过execSQL(sql)方法来实现。

关闭数据库:

        mSQLiteDatabase.close();

删除指定表：

        mSQLiteDatabase.execSQL("DROP TABLE table1");

删除数据库：

        this.deleteDatabase("abc.db");

查询表中的某条记录：

        通过Cursor类实现，当使用SQLiteDatabase.query()方法时，会得到一个Cursor对象，Cursor指向的就是每一条数据。它提供了很多有关查询的方法：

            

方法	说明
move	以当前位置为参考，将Cursor移动到指定的位置，成功返回true
moveToPosition	将Cursor移动的指定的位置，返回boolean
moveToNext	将Cursor向前移动一个位置，返回boolean
moveToLast	将Cursor向后移动一个位置，返回boolean
moveToFirst	将Cursor移动的第一行，返回boolean
isBeforeFirst	返回Cursor是否指向第一项数据之前
isAfterLast	返回Cursor是否指向最后一项数据之后
isClosed	返回Cursor是否关闭
isFirst	返回Cursor是否指向第一项数据
isLast	返回Cursor是否指向最后一项数据
isNull	返回指定位置的值是否为null
getCount	返回总的数据项数
getInt	返回当前行指定索引的数据

 例如：

        Cursor cur = mSQLiteDatabase.rawQuery("select * from table",null);

        if(cur != null)

        {

            if(cur.moveToFirst())

            {

                do{

                    int numColumn = cur.getColumnIndex("num");

                    int num = cur.getInt(numColumn);

                  }while(cur.moveToNext());

            }

        }

     使用SQLiteDatabase数据库后要及时关闭，否则可能会抛出SQLiteException异常。    

 

上面的方法像大部分基础语法书上一样直接执行sql语句的形式，那么在Android中为了简化用户操作以及提高性能，Android系统提供了SQLiteOpenHelper，封装了常用的数据库操作方法。利用它我们可以很轻松的完成对数据库的增删改查。　　

 首先我们创建一个DBHelper类继承SQLiteOpenHelper，用它来完成数据库的初始化工作：创建数据库，创建表等操作。

他包含一些借口方法，在下面的注释里已经注释的很详细，就不再罗嗦。

package com.example.core;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabase.CursorFactory;
import android.database.sqlite.SQLiteOpenHelper;

public class DBHelper extends SQLiteOpenHelper{

    public DBHelper(Context context) {
        //创建数据库名为march_test.db的数据库
        super(context,"march_test.db",null,1);
    }

    /* (non-Javadoc)
     * 数据库每次被创建时调用
     * @see android.database.sqlite.SQLiteOpenHelper#onCreate(android.database.sqlite.SQLiteDatabase)
     */
    @Override
    public void onCreate(SQLiteDatabase db) {
        //创建数据库表
        String create_sql = "CREATE TABLE student(id integer primary key autoincrement," +
                "name varchar(20),age integer not null)";
        db.execSQL(create_sql);
    }

    /* (non-Javadoc)
     * 版本号发生变化时执行
     * @see android.database.sqlite.SQLiteOpenHelper#onUpgrade(android.database.sqlite.SQLiteDatabase, int, int)
     */
    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        // TODO Auto-generated method stub
        String alter_sql = "ALTER TABLE student ADD money integer";
        db.execSQL(alter_sql);
    }
    
}

　　通过实例化这个类，可以创建一个名为march_test.db的数据库。包含数据表student。可以文件系统中看到：

　　路径为data/data/包名/databases/数据库名：

　　　　

　　这种db格式的数据库在这里给大家推荐一个非常好用的工具SQLite Expert Professional，非常好用，在网上也很好找到。他mysql workbench等数据库可视化工具一样给我们提供了可视化数据库操作，软件界面如下：

　　　　

　　我们可以把我们创建的表在文件系统中导出来然后放到这里查看。

　　首先要声明我们要操作的数据类型类：

package com.example.sqllite;

public class Student{
    
    private Integer id;
    private String name;
    private Integer age;
    
    public Student(Integer id, String name, Integer age) {
        super();
        this.id = id;
        this.name = name;
        this.age = age;
    }
    
    public Student(String name , Integer age){
        super();
        this.name = name;
        this.age = age;
    }

    public Integer getId() {
        return id;
    }
    
    public void setId(Integer id) {
        this.id = id;
    }
    
    public String getName() {
        return name;
    }
    
    public void setName(String name) {
        this.name = name;
    }
    
    public Integer getAge() {
        return age;
    }
    
    public void setAge(Integer age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "Student [id=" + id + ", name=" + name + ", age=" + age + "]";
    }
    
}

下面要编写对数据库的增删改查类，它继承我们上面创建的SQLiteOpenHelper为基类的DBHelper类：

package com.example.core;

import java.util.ArrayList;
import java.util.List;

import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;

import com.example.sqllite.Student;

/**
 * @author fanchangfa
 *数据库操作类
 *增删改查
 *获取分页查询数据
 *获取表中记录总数
 */
public class DbServer{
    
    private DBHelper dbhelper;
    
    public DbServer(Context context){
        this.dbhelper = new DBHelper(context);        
    }
    
    /**
     *  增加信息
     * @param student    增加的学生信息
     */
    public void add(Student student){
        SQLiteDatabase db = dbhelper.getWritableDatabase();
        db.execSQL("insert into student(name , age) values(?,?)",
                new Object[]{student.getName(),student.getAge()});
    }
    
    /**
     * 删除信息
     * @param id    要删除的学生id
     */
    public void delete(Integer id){
        SQLiteDatabase db = dbhelper.getWritableDatabase();
        db.execSQL("delete from student where id = ?",new Object[]{id});
    }
    
    /**
     * 修改指定id的学生信息
     * @param stu    包括修改学生的id，以及修改的信息
     */
    public void alter(Student stu){
        SQLiteDatabase db = dbhelper.getWritableDatabase();
        db.execSQL("update student set name=?,age=? where id=?",
                new Object[]{stu.getName(),stu.getAge(),stu.getId()});
    }
    
    /**
     * 查找信息
     * @param id    要查找的学生id
     */
    public Student find(Integer id){
        SQLiteDatabase db = dbhelper.getReadableDatabase();
        Cursor cursor = db.rawQuery("select * from student where id = ?",new String[]{id.toString()});
        
        if(cursor.moveToFirst())    //如果查询结果集中有数据,将游标指向第一条记录
        {
            int sid = cursor.getInt(cursor.getColumnIndex("id"));
            String name = cursor.getString(cursor.getColumnIndex("name"));
            int age = cursor.getInt(cursor.getColumnIndex("age"));
            
            return new Student(sid , name , age);
        }
        
        cursor.close();
        
        return null;
    }
    
    /**
     * 分页查询数据
     * @param start    分页开始记录数
     * @param end    分页结束记录数
     * @return        查询结果集
     */
    public List<Student> page(int start , int end){
        SQLiteDatabase db = dbhelper.getReadableDatabase();
        List<Student> page = new ArrayList<Student>();
        Cursor cur = db.rawQuery("select id,name,age from student order by id limit ?,?",
                new String[]{String.valueOf(start),String.valueOf(end)});
        
        while(cur.moveToNext()){
            int id = cur.getInt(cur.getColumnIndex("id"));
            String name = cur.getString(cur.getColumnIndex("name"));
            int age= cur.getInt(cur.getColumnIndex("age"));
            page.add(new Student(id,name,age));
        }
        
        cur.close();
        
        return page;
    }
    
    /**
     * 返回指定分页数据
     * @param start
     * @param end
     * @return Cursor型数据
     */
    public Cursor curpage(int start , int end){
        SQLiteDatabase db = dbhelper.getReadableDatabase();
        Cursor cur = db.rawQuery("select id as _id,name,age from student order by id limit ?,?",
                new String[]{String.valueOf(start),String.valueOf(end)});
        
        cur.moveToFirst();
        
        return cur;
    }
    
    /**
     * 获取表记录总数
     * @return
     */
    public long getCount(){
        SQLiteDatabase db = dbhelper.getReadableDatabase();
        
        Cursor cur = db.rawQuery("select count(*) from student",null);
        cur.moveToFirst();
        
        long count = cur.getLong(0);
        
        cur.close();
        
        return count;
    }
    
    /**
     * 执行事务
     */
    public void transaction(){
        SQLiteDatabase db = dbhelper.getWritableDatabase();
        db.beginTransaction();
        
        try{
            db.execSQL("update student set age = 21 where id =5");
            db.execSQL("update student set age= 22 where id=6");
            db.setTransactionSuccessful();
            //事务默认有commit、rollback，默认为False，即非提交状态，需要设置为commit
        }
        finally{
            db.endTransaction();
        }
        
    }
}

具体操作代码中已经注释完善，可以进行试验。

下面要对其进行测试：

编写测试单元如下：

package com.example.test;

import java.util.List;

import com.example.core.DbServer;
import com.example.sqllite.Student;

import android.test.AndroidTestCase;
import android.util.Log;

/**
 * @author fanchangfa
 * 数据库操作单元测试
 * 测试DbServer中数据的增删改查
 *
 */
public class DbServerTest extends AndroidTestCase{
    
    //控制台打印信息标志
    private static final String TAG = "SQLtest";
    
    /**
     * 添加数据测试
     */
    public void addTest(){
        DbServer dbserver = new DbServer(this.getContext());
        for(int i = 0 ; i<20 ; i++)
        {
            Student stu = new Student("fanchangfa"+i,20);
            dbserver.add(stu);
        }
    }
    
    public void deleteTest(){
        DbServer dbserver = new DbServer(this.getContext());
        dbserver.delete(2);
    }
    
    public void alterTest(){
        DbServer dbserver = new DbServer(this.getContext());
        Student stu = dbserver.find(3);
        stu.setName("liuzihang");
        stu.setAge(25);
        dbserver.alter(stu);
    }
    
    /**
     * 测试数据库查找
     * 根据提供id返回记录结果 
     */
    public void findTest(){
        DbServer dbserver = new DbServer(this.getContext());
        Student stu = dbserver.find(5);
        Log.i(TAG, stu.toString());
    }
    
    /**
     * 数据库查找分页测试 
     */
    public void findpage(){
        DbServer dbserver = new DbServer(this.getContext());
        List<Student> students = dbserver.page(0, 8);
        
        for(Student stu : students){
            Log.i(TAG,stu.toString());
        }
        
    }
    
    /**
     * 执行事务测试
     */
    public void transactionTest(){
        DbServer dbserver = new DbServer(this.getContext());
        dbserver.transaction();
    }
    
}

经验证，没有问题，由于此文件系统和操作比较麻烦，我将自己写的实例放到这里共大家下载，此实例中包括数据库的操作以及SQLite中事物的使用，以及将在下一篇写的关于ListView显示数据的几种方法，界面虽然很难看，不过这只是demo，希望多多谅解，有问题多多交流。希望这里会是我们拥有共同爱好的程序员们相互交流共同进步的平台，而不是只是为了增加访问量而将文章放在这里。