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，希望多多諒解，有問題多多交流。希望這里會是我們擁有共同愛好的程序員們相互交流共同進步的平台，而不是只是為了增加訪問量而將文章放在這里。