Android操做SQLite數據庫

SQLite特色
1.Android平臺中嵌入了一個關係型數據庫SQLite，和其餘數據庫不一樣的是SQLite存儲數據時不區分類型

例如一個字段聲明爲Integer類型，咱們也能夠將一個字符串存入，一個字段聲明爲布爾型，咱們也能夠存入浮點數。

除非是主鍵被定義爲Integer，這時只能存儲64位整數

 

2.建立數據庫的表時能夠不指定數據類型，例如：

CREATE TABLEperson(id INTEGER PRIMARY KEY, name)

 

3.SQLite支持大部分標準SQL語句，增刪改查語句都是通用的，分頁查詢語句和MySQL相同

SELECT * FROMperson LIMIT 20 OFFSET 10

SELECT * FROMperson LIMIT 20,10
建立數據庫
1.定義類繼承SQLiteOpenHelper

2.聲明構造函數，4個參數

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 {

/**
* 建立OpenHelper
* @param context 上下文
* @param name 數據庫名
* @param factory 遊標工廠
* @param version 數據庫版本, 不要設置爲0, 若是爲0則會每次都建立數據庫
*/
public DBOpenHelper(Context context, String name, CursorFactory factory, int version) {
super(context, name, factory, version);
}

/**
* 當數據庫第一次建立的時候被調用
*/
public void onCreate(SQLiteDatabase db) {
db.execSQL(「CREATE TABLE person(id INTEGER PRIMARY KEY AUTOINCREMENT, name)」);
}

/**
* 當數據庫版本發生改變的時候被調用
*/
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(); // 建立數據庫
}
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語句。

第一種方式示例：

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);//初始化數據庫
}

/**
* 插入一個Person
* @param p 要插入的Person
*/
public void insert(Person p) {
SQLiteDatabase db = helper.getWritableDatabase(); //獲取到數據庫
db.execSQL(「INSERT INTO person(name,phone,balance) VALUES(?,?)」, new Object[] { p.getName(), p.getPhone() });
db.close();
}

/**
* 根據ID刪除
* @param id 要刪除的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();
}

/**
* 根據ID查找
* @param id 要查的ID
* @return 對應的對象, 若是未找到返回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對象集合, 如未找到, 返回一個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;
}

/**
* 查詢某一頁數據
* @param page 頁碼
* @param size 每頁記錄數
* @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;
}

/**
* 獲取記錄數
* @return 記錄數
*/
public int getCount() {
SQLiteDatabase db = helper.getReadableDatabase();
Cursor cursor = db.rawQuery(「SELECT COUNT(*) FROM person」, null);
cursor.moveToNext();
return cursor.getInt(0);
}
}

第二種方式示例：
/**
* 插入一個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());

// 第一個參數是表名, 第二個參數是若是要插入一條空記錄時指定的某一列的名字, 第三個參數是數據
db.insert(「person」, null, values);

db.close();
}

/**
* 根據ID刪除
* @param id 要刪除的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();
}

/**
* 根據ID查找
* @param id 要查的ID
* @return 對應的對象, 若是未找到返回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對象集合, 如未找到, 返回一個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;
}

/**
* 查詢某一頁數據
* @param page 頁碼
* @param size 每頁記錄數
* @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;
}

/**
* 獲取記錄數
* @return 記錄數
*/
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);
}

事務管理
1.使用在SQLite數據庫時可使用SQLiteDatabase類中定義的相關方法控制事務

beginTransaction() 開啓事務

setTransactionSuccessful() 設置事務成功標記

endTransaction() 結束事務

2.endTransaction()須要放在finally中執行，不然事務只有到超時的時候才自動結束，會下降數據庫併發效率

示例：

public void remit(int from, int to, int amount) {
SQLiteDatabase db = helper.getWritableDatabase();

// 開啓事務
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 });
// 設置事務標記
db.setTransactionSuccessful();
} finally {
// 結束事務
db.endTransaction();
}

db.close(); }