Android編程操作嵌入式關(guān)系型SQLite數(shù)據(jù)庫實(shí)例詳解

更新時(shí)間：2016年01月04日 16:08:54 作者：傅榮康

這篇文章主要介紹了Android編程操作嵌入式關(guān)系型SQLite數(shù)據(jù)庫的方法,結(jié)合實(shí)例形式較為詳細(xì)的分析了Android操作SQLite數(shù)據(jù)庫的基本技巧與相關(guān)注意事項(xiàng),需要的朋友可以參考下

本文實(shí)例分析了Android編程操作嵌入式關(guān)系型SQLite數(shù)據(jù)庫的方法。分享給大家供大家參考，具體如下：

SQLite特點(diǎn)

1.Android平臺中嵌入了一個(gè)關(guān)系型數(shù)據(jù)庫SQLite，和其他數(shù)據(jù)庫不同的是SQLite存儲數(shù)據(jù)時(shí)不區(qū)分類型

例如一個(gè)字段聲明為Integer類型，我們也可以將一個(gè)字符串存入，一個(gè)字段聲明為布爾型，我們也可以存入浮點(diǎn)數(shù)。

除非是主鍵被定義為Integer，這時(shí)只能存儲64位整數(shù)

2.創(chuàng)建數(shù)據(jù)庫的表時(shí)可以不指定數(shù)據(jù)類型，例如：

復(fù)制代碼代碼如下:

CREATE TABLEperson(id INTEGER PRIMARY KEY, name)

3.SQLite支持大部分標(biāo)準(zhǔn)SQL語句，增刪改查語句都是通用的，分頁查詢語句和MySQL相同

SELECT * FROMperson LIMIT 20 OFFSET 10
SELECT * FROMperson LIMIT 20,10

創(chuàng)建數(shù)據(jù)庫

1.定義類繼承SQLiteOpenHelper
2.聲明構(gòu)造函數(shù)，4個(gè)參數(shù)
3.重寫onCreate()方法
4. 重寫upGrade()方法

示例：

package cn.itcast.sqlite;
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.database.sqlite.SQLiteDatabase.CursorFactory;
public class DBOpenHelper extends SQLiteOpenHelper {
  /**
   * 創(chuàng)建OpenHelper
   * @param context 上下文
   * @param name 數(shù)據(jù)庫名
   * @param factory 游標(biāo)工廠
   * @param version 數(shù)據(jù)庫版本, 不要設(shè)置為0, 如果為0則會(huì)每次都創(chuàng)建數(shù)據(jù)庫
   */
  public DBOpenHelper(Context context, String name, CursorFactory factory, int version) {
    super(context, name, factory, version);
  }
  /**
   * 當(dāng)數(shù)據(jù)庫第一次創(chuàng)建的時(shí)候被調(diào)用
   */
  public void onCreate(SQLiteDatabase db) {
    db.execSQL("CREATE TABLE person(id INTEGER PRIMARY KEY AUTOINCREMENT, name)");
  }
  /**
   * 當(dāng)數(shù)據(jù)庫版本發(fā)生改變的時(shí)候被調(diào)用
   */
  public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
    db.execSQL("ALTER TABLE person ADD balance");
  }
}
public void testCreateDB() {
  DBOpenHelper helper = new DBOpenHelper(getContext(), "itcast.db", null, 2);
  helper.getWritableDatabase(); // 創(chuàng)建數(shù)據(jù)庫
}

CRUD操作

1.和JDBC訪問數(shù)據(jù)庫不同，操作SQLite數(shù)據(jù)庫無需加載驅(qū)動(dòng)，不用獲取連接，直接可以使用

獲取SQLiteDatabase對象之后通過該對象直接可以執(zhí)行SQL語句：

SQLiteDatabase.execSQL()
SQLiteDatabase.rawQuery()

2.getReadableDatabase()和getWritableDatabase()的區(qū)別

查看源代碼后我們發(fā)現(xiàn)getReadableDatabase()在通常情況下返回的就是getWritableDatabase()拿到的數(shù)據(jù)庫只有在拋出異常的時(shí)候才會(huì)以只讀方式打開

3.數(shù)據(jù)庫對象緩存

getWritableDatabase()方法最后會(huì)使用一個(gè)成員變量記住這個(gè)數(shù)據(jù)庫對象，下次打開時(shí)判斷是否重用

4.SQLiteDatabase封裝了insert()、delete()、update()、query()四個(gè)方法也可以對數(shù)據(jù)庫進(jìn)行操作

這些方法封裝了部分SQL語句，通過參數(shù)進(jìn)行拼接

執(zhí)行crud操作有兩種方式，第一種方式自己寫sql語句執(zhí)行操作，第二種方式是使用SQLiteDatabase類調(diào)用響應(yīng)的方法執(zhí)行操作

execSQL()方法可以執(zhí)行insert、delete、update和CREATETABLE之類有更改行為的SQL語句； rawQuery()方法用于執(zhí)行select語句。

第一種方式示例：

package cn.itcast.sqlite.service;
import java.util.ArrayList;
import java.util.List;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import cn.itcast.sqlite.DBOpenHelper;
import cn.itcast.sqlite.domain.Person;
public class SQLPersonService {
  private DBOpenHelper helper;
  public SQLPersonService(Context context) {
    helper = new DBOpenHelper(context, "itcast.db", null, 2);//初始化數(shù)據(jù)庫
  }
  /**
   * 插入一個(gè)Person
   * @param p 要插入的Person
   */
  public void insert(Person p) {
    SQLiteDatabase db = helper.getWritableDatabase(); //獲取到數(shù)據(jù)庫
    db.execSQL("INSERT INTO person(name,phone,balance) VALUES(?,?)", new Object[] { p.getName(), p.getPhone() });
    db.close();
  }
  /**
   * 根據(jù)ID刪除
   * @param id 要?jiǎng)h除的PERSON的ID
   */
  public void delete(Integer id) {
    SQLiteDatabase db = helper.getWritableDatabase();
    db.execSQL("DELETE FROM person WHERE id=?", new Object[] { id });
    db.close();
  }
  /**
   * 更新Person
   * @param p 要更新的Person
   */
  public void update(Person p) {
    SQLiteDatabase db = helper.getWritableDatabase();
    db.execSQL("UPDATE person SET name=?,phone=?,balance=? WHERE id=?", new Object[] { p.getName(), p.getPhone(), p.getBalance(), p.getId() });
    db.close();
  }
  /**
   * 根據(jù)ID查找
   * @param id 要查的ID
   * @return 對應(yīng)的對象, 如果未找到返回null
   */
  public Person find(Integer id) {
    SQLiteDatabase db = helper.getReadableDatabase();
    Cursor cursor = db.rawQuery("SELECT name,phone,balance FROM person WHERE id=?", new String[] { id.toString() });
    Person p = null;
    if (cursor.moveToNext()) {
      String name = cursor.getString(cursor.getColumnIndex("name"));
      String phone = cursor.getString(1);
      Integer balance = cursor.getInt(2);
      p = new Person(id, name, phone, balance);
    }
    cursor.close();
    db.close();
    return p;
  }
  /**
   * 查詢所有Person對象
   * @return Person對象集合, 如未找到, 返回一個(gè)size()為0的List
   */
  public List<Person> findAll() {
    SQLiteDatabase db = helper.getReadableDatabase();
    Cursor cursor = db.rawQuery("SELECT id,name,phone,balance FROM person", null);
    List<Person> persons = new ArrayList<Person>();
    while (cursor.moveToNext()) {
      Integer id = cursor.getInt(0);
      String name = cursor.getString(1);
      String phone = cursor.getString(2);
      Integer balance = cursor.getInt(3);
      persons.add(new Person(id, name, phone, balance));
    }
    cursor.close();
    db.close();
    return persons;
  }
  /**
   * 查詢某一頁數(shù)據(jù)
   * @param page 頁碼
   * @param size 每頁記錄數(shù)
   * @return
   */
  public List<Person> findPage(int page, int size) {
    SQLiteDatabase db = helper.getReadableDatabase();
    Cursor cursor = db.rawQuery("SELECT id,name,phone,balance FROM person LIMIT ?,?" //
        , new String[] { String.valueOf((page - 1) * size), String.valueOf(size) });
    List<Person> persons = new ArrayList<Person>();
    while (cursor.moveToNext()) {
      Integer id = cursor.getInt(0);
      String name = cursor.getString(1);
      String phone = cursor.getString(2);
      Integer balance = cursor.getInt(3);
      persons.add(new Person(id, name, phone, balance));
    }
    cursor.close();
    db.close();
    return persons;
  }
  /**
   * 獲取記錄數(shù)
   * @return 記錄數(shù)
   */
  public int getCount() {
    SQLiteDatabase db = helper.getReadableDatabase();
    Cursor cursor = db.rawQuery("SELECT COUNT(*) FROM person", null);
    cursor.moveToNext();
    return cursor.getInt(0);
  }
}

第二種方式示例：

/**
 * 插入一個(gè)Person
 * @param p 要插入的Person
 */
public void insert(Person p) {
  SQLiteDatabase db = helper.getWritableDatabase();
  ContentValues values = new ContentValues();
  values.put("name", p.getName());
  values.put("phone", p.getPhone());
  values.put("balance", p.getBalance());
  // 第一個(gè)參數(shù)是表名, 第二個(gè)參數(shù)是如果要插入一條空記錄時(shí)指定的某一列的名字, 第三個(gè)參數(shù)是數(shù)據(jù)
  db.insert("person", null, values);
  db.close();
}
/**
 * 根據(jù)ID刪除
 * @param id 要?jiǎng)h除的PERSON的ID
 */
public void delete(Integer id) {
  SQLiteDatabase db = helper.getWritableDatabase();
  db.delete("person", "id=?", new String[] { id.toString() });
  db.close();
}
/**
 * 更新Person
 * @param p 要更新的Person
 */
public void update(Person p) {
  SQLiteDatabase db = helper.getWritableDatabase();
  ContentValues values = new ContentValues();
  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=?", new String[] { p.getId().toString() });
  db.close();
}
/**
 * 根據(jù)ID查找
 * @param id 要查的ID
 * @return 對應(yīng)的對象, 如果未找到返回null
 */
public Person find(Integer id) {
  SQLiteDatabase db = helper.getReadableDatabase();
  Cursor cursor = db.query("person", new String[] { "name", "phone", "balance" }, "id=?", new String[] { id.toString() }, null, null, null);
  Person p = null;
  if (cursor.moveToNext()) {
    String name = cursor.getString(cursor.getColumnIndex("name"));
    String phone = cursor.getString(1);
    Integer balance = cursor.getInt(2);
    p = new Person(id, name, phone, balance);
  }
  cursor.close();
  db.close();
  return p;
}
/**
 * 查詢所有Person對象
 * @return Person對象集合, 如未找到, 返回一個(gè)size()為0的List
 */
public List<Person> findAll() {
  SQLiteDatabase db = helper.getReadableDatabase();
  Cursor cursor = db.query("person", new String[] { "id", "name", "phone", "balance" }, null, null, null, null, "id desc");
  List<Person> persons = new ArrayList<Person>();
  while (cursor.moveToNext()) {
    Integer id = cursor.getInt(0);
    String name = cursor.getString(1);
    String phone = cursor.getString(2);
    Integer balance = cursor.getInt(3);
    persons.add(new Person(id, name, phone, balance));
  }
  cursor.close();
  db.close();
  return persons;
}
/**
 * 查詢某一頁數(shù)據(jù)
 * @param page 頁碼
 * @param size 每頁記錄數(shù)
 * @return
 */
public List<Person> findPage(int page, int size) {
  SQLiteDatabase db = helper.getReadableDatabase();
  Cursor cursor = db.query( //
      "person", new String[] { "id", "name", "phone", "balance" }, null, null, null, null, null, (page - 1) * size + "," + size);
  List<Person> persons = new ArrayList<Person>();
  while (cursor.moveToNext()) {
    Integer id = cursor.getInt(0);
    String name = cursor.getString(1);
    String phone = cursor.getString(2);
    Integer balance = cursor.getInt(3);
    persons.add(new Person(id, name, phone, balance));
  }
  cursor.close();
  db.close();
  return persons;
}
/**
 * 獲取記錄數(shù)
 * @return 記錄數(shù)
 */
public int getCount() {
  SQLiteDatabase db = helper.getReadableDatabase();
  Cursor cursor = db.query( //
      "person", new String[] { "COUNT(*)" }, null, null, null, null, null);
  cursor.moveToNext();
  return cursor.getInt(0);
}

事務(wù)管理

1.使用在SQLite數(shù)據(jù)庫時(shí)可以使用SQLiteDatabase類中定義的相關(guān)方法控制事務(wù)

beginTransaction() 開啟事務(wù)
setTransactionSuccessful() 設(shè)置事務(wù)成功標(biāo)記
endTransaction() 結(jié)束事務(wù)

2.endTransaction()需要放在finally中執(zhí)行，否則事務(wù)只有到超時(shí)的時(shí)候才自動(dòng)結(jié)束，會(huì)降低數(shù)據(jù)庫并發(fā)效率

示例：

public void remit(int from, int to, int amount) {
  SQLiteDatabase db = helper.getWritableDatabase();
  // 開啟事務(wù)
  try {
    db.beginTransaction();
    db.execSQL("UPDATE person SET balance=balance-? WHERE id=?", new Object[] { amount, from });
    System.out.println(1 / 0);
    db.execSQL("UPDATE person SET balance=balance+? WHERE id=?", new Object[] { amount, to });
    // 設(shè)置事務(wù)標(biāo)記
    db.setTransactionSuccessful();
  } finally {
    // 結(jié)束事務(wù)
    db.endTransaction();
  }
  db.close();
}

希望本文所述對大家Android程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: