当前位置: 代码迷 >> SQL >> 怎么使用SQLiteOpenHelper
  详细解决方案

怎么使用SQLiteOpenHelper

热度:101   发布时间:2016-05-05 12:11:51.0
如何使用SQLiteOpenHelper

都知道在Android中SQLiteOpenHelper是用来创建和升级数据库,参考
$ANDROID_SDK_HOME/docs/reference/android/database/sqlite/SQLiteOpenHelper.html

软件发布出去了,用户已经安装使用了,但是随着软件的升级,数据库结构做了些改动,我们不希望用户把应用卸载了再装(这样会丢失应用所有的数据),我们希望在数据库总体结构和已有数据不变的情况下做些小的改动,比如新增一个字段或索引,新增加一个表等等,那么这个时候我们就要用到这个类了

常用的也就是onCreate和onUpgrade这两个方法,在使用的时候这两个方法都需要重写,里面实现自己的逻辑

我们先列出一个场景:
假设第一版程序发布出去,First Public Version,代码如下

1@Override
2public void onCreate(SQLiteDatabase db) {
3????bootstrapDB(db);
4}
5?
6@Override
7public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
8}

onUpgrade里面没有代码,第一版出去没有需要更新的,bootstrapDB方法就是些DDL和数据初始化操作等等

之后过了一段时间,新的程序发布(其中数据库结构做了些变化),这个时候已经开始使用第一版程序的用户就需要升级,我们不希望他已经存在的数据被破坏,那么我们发布出去的新的版本中代码该怎么写呢?
直接看代码,这些代码都是从Android自带的应用中抽取出来的,做了些具体业务上的简化,主要是阐述清楚用法

1@Override
2public void onCreate(SQLiteDatabase db) {
3????bootstrapDB(db); // 这个方法里面都是最新版的初始化方法
4}
5?
6@Override
7public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
8????Log.i(TAG, "Upgrading DB from version " + oldVersion + " to "
9????????????+ newVersion);
10????if (oldVersion == 1) {
11????????upgradeToVersion2(db);
12????????oldVersion += 1;
13????}
14????Log.v("do upgrade", "我更新了。。。");
15}

这样如果后来又有新的程序发布,那么这两个方法会变成类似这个样子

1@Override
2public void onCreate(SQLiteDatabase db) {
3????bootstrapDB(db); // 这个方法里面始终都是最新版的初始化方法
4}
5?
6@Override
7public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
8????Log.i(TAG, "Upgrading DB from version " + oldVersion + " to "
9????????????+ newVersion);
10????if (oldVersion == 1) {
11????????upgradeToVersion2(db);
12????????oldVersion += 1;
13????}
14????if (oldVersion == 2) {
15????????upgradeToVersion3(db);
16????????oldVersion += 1;
17????}
18????// 这是一种逐级更新的方式
19????????????// 对于目前使用的还是第一版的用户而言,会先执行完upgradeToVersion2再执行upgradeToVersion3
20????????????// 对于目前使用的还是第二版的用户而言,会执行upgradeToVersion3
21????Log.v("do upgrade", "我更新了。。。");
22}

这样也许就能看的很清楚这个类的意图和用法了,后面版本一直增加的话,我们就一直这样写就好,保证全新的用户和升级的用户都能正常使用,那么我们如何来调用呢
一般我们会有个构造方法,有个参数就是数据库的版本,比如下面这两个构造方法

1public MyDatabaseHelper(Context context, String name, CursorFactory factory,
2????????int version) {
3????super(context, name, factory, version);
4}
5?
6public MyDatabaseHelper(Context context, int version) {
7????super(context, NAME, null, version);
8}

采用如下方式调用

1helper = new MyDatabaseHelper(context, 10); // 这个数据库版本号会随着程序的每次发布而变化,是表示每次需要更新到的版本号,也就是最新的版本号
2sqlite = helper.getWritableDatabase();

其实更好理解这个用法就是读SQLiteOpenHelper.getWritableDatabase这个方法,里面有段代码

1int version = db.getVersion();
2if (version != mNewVersion) {
3????db.beginTransaction();
4????try {
5????????if (version == 0) {
6????????????onCreate(db);
7????????} else {
8????????????onUpgrade(db, version, mNewVersion);
9????????}
10????????db.setVersion(mNewVersion);
11????????db.setTransactionSuccessful();
12????} finally {
13????????db.endTransaction();
14????}
15}

另外,看看set/get Version就知道数据库版本标记是通过PRAGMA user_version;这个命令来完成的,你也可以用sqlite3之类的工具把数据库文件打开,然后执行PRAGMA user_version查看或者设置版本值

如下是完整的两个代码,是目前在使用的

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
package org.xkit.android.demo;
?
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
?
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
?
public class DBAdapter {
private Context context;
private SQLiteDatabase sqlite;
?
private MyDatabaseHelper helper;
?
public DBAdapter(Context c) {
this.context = c;
}
?
public void open() {
helper = new MyDatabaseHelper(context, 10);
sqlite = helper.getWritableDatabase();
}
?
public void execSQL(String sql) {
Log.i("sql execute", sql);
sqlite.execSQL(sql);
}
?
public Cursor getResultSet(String tableName, String condition,
Object[] fields) {
StringBuffer sb = new StringBuffer();
String allFields = new String();
if (fields == null) {
allFields = "*";
} else {
for (int i = 0; i < fields.length; i++) {
allFields += fields[i].toString() + ",";
}
allFields = allFields.substring(0, allFields.length() - 1);
}
sb.append("select ").append(allFields).append(" from ").append(
tableName).append(" where ").append(condition);
Log.i("sqlquery", sb.toString());
return sqlite.rawQuery(sb.toString(), null);
}
?
public Cursor getResultSet(String sql) {
Log.i("sql query", sql);
return sqlite.rawQuery(sql, null);
}
?
public List<Map<String, String>> getResultSet(String sql, int pageSize) {
Log.i("sql query", sql);
Cursor cursor = sqlite.rawQuery(sql, null);
int count = cursor.getCount();
int columnCount = cursor.getColumnCount();
Log.d("Column Count", "" + columnCount);
List<Map<String, String>> list = new ArrayList<Map<String, String>>(
count);
Map<String, String> entity = new HashMap<String, String>(columnCount);
for (cursor.moveToFirst(); !cursor.isAfterLast(); cursor.moveToNext()) {
// 找出一共有多少列
for (int i = 0; i < columnCount; i++) {
Log.d("Column Found", cursor.getColumnName(i) + " : "
+ cursor.getString(i));
entity.put(cursor.getColumnName(i), cursor.getString(i));
}
list.add(entity);
}
cursor.close();
entity = null;
return list;
}
?
public void close() {
// 关闭我们打开的数据库
throw new RuntimeException("Only for Stub!");
}
}
view rawDBAdapter.javaThis Gist?brought to you by?GitHub.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
package org.xkit.android.demo;
?
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.database.sqlite.SQLiteDatabase.CursorFactory;
import android.util.Log;
?
public class MyDatabaseHelper extends SQLiteOpenHelper {
?
private static final String TAG = "MyDatabaseHelper";
?
public static final String NAME = "lucane.db";
?
public MyDatabaseHelper(Context context, String name, CursorFactory factory,
int version) {
super(context, name, factory, version);
}
?
public MyDatabaseHelper(Context context, int version) {
super(context, NAME, null, version);
}
?
@Override
public void onCreate(SQLiteDatabase db) {
bootstrapDB(db);
}
?
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
Log.i(TAG, "Upgrading DB from version " + oldVersion + " to "
+ newVersion);
if (oldVersion < 8) {
// 如果版本太小,就直接删除,然后创建
// 所以bootstrapDB应该是最新的SQL初始化语句
dropTables(db);
onCreate(db);
return;
}
?
if (oldVersion == 8) {
upgradeToVersion9(db);
oldVersion += 1;
}
?
if (oldVersion == 9) {
upgradeToVersion10(db);
oldVersion += 1;
}
?
// 这是一种逐级更新的方式
Log.v("do upgrade", "我更新了。。。");
}
?
private void bootstrapDB(SQLiteDatabase db) {
Log.i(TAG, "Bootstrapping database");
db
.execSQL("CREATE TABLE person (personid integer primary key autoincrement,name varchar(20),age integer )");
}
?
private void dropTables(SQLiteDatabase db) {
db.execSQL("DROP TABLE IF EXISTS person;");
}
?
// PATCH方法开始
?
static void upgradeToVersion10(SQLiteDatabase db) {
db.execSQL("CREATE INDEX idx_person_name_gender ON person (" + "name"
+ ", " + "gender" + ");");
}
?
static void upgradeToVersion9(SQLiteDatabase db) {
db.execSQL("ALTER TABLE "
+ "person ADD COLUMN gender INTEGER NOT NULL DEFAULT 1;");
}
?
// PATCH方法结束
}