
SQLiteOpenHelper
// 如果数据库文件不存在,只有onCreate()被调用(该方法在创建数据库时被调用一次)
public abstract void onCreate(SQLiteDatabase db);
// 如果数据库文件存在,会调用onUpgrade()方法升级数据库,并更新版本号。
public abstract void onUpgrade(SQLiteDatabase db,int oldVersion,int newVersion);
OnCreate : 如果数据库文件不存在,SQLiteOpenHelper在创建数据库文件,打开数据库这个数据库后,调用onCreate()方法,在该方法中一般需要创建表、视图等组件。在创建前数据库一般是空的,因此不需要先删除数据库中相关的组件。
OnUpgrade : 当系统在构造SQLiteOpenHelper类的对象时,如果发现版本号不一样,就会自动调用onUpgrade函数,让你在这里对数据库进行升级。
新版本号和老版本号都会作为onUpgrade函数的参数传进来,便于开发者知道数据库应该从哪个版本升级到哪个版本。
升级完成后,数据库会自动存储最新的版本号为当前数据库版本号。
需要对SQLite数据库的结构进行升级:
SQLite提供了ALTER TABLE命令,允许用户重命名或添加新的字段到已有表中,但是不能从表中删除字段。
并且只能在表的末尾添加字段,比如,为 Student添加两个字段:
ALTER TABLE Student ADD COLUMN UserPhone VARCHAR;
ALTER TABLE Student ADD COLUMN UserNickName VARCHAR;
如果遇到复杂的修改操作,比如在修改的同时,需要进行数据的转移,那么可以采取在一个事务中执行如下语句来实现修改表的需求。
1. 将表名改为临时表
ALTER TABLE Student RENAME TO __temp__Student;
2. 创建新表
CREATE TABLE Student (UserId VARCHAR() PRIMARY KEY ,UserName VARCHAR() NOT NULL ,UserAddress VARCHAR() NOT NULL);
3. 导入数据
INSERT INTO Student SELECT UserId, “”, UserAddress FROM __temp__Student;
或者
INSERT INTO Student() SELECT UserId, “”, UserAddress FROM __temp__Student;
* 注意 双引号”” 是用来补充原来不存在的数据的
4. 删除临时表
DROP TABLE __temp__Student;
通过以上四个步骤,就可以完成旧数据库结构向新数据库结构的迁移,并且其中还可以保证数据不会应为升级而流失。
当然,如果遇到减少字段的情况,也可以通过创建临时表的方式来实现。
获取表中字段:
// 获取升级前表中的字段
protected String getColumnNames(SQLiteDatabase db, String tableName)
{
StringBuffer columnNameBuffer = null;
Cursor c = null;
try
{
c = db.rawQuery( "PRAGMA table_info(" + tableName + ")", null);
if (null != c) {
int columnIndex = c.getColumnIndex("name");
if (-1 == columnIndex) {
return null;
} int index = 0;
columnNameBuffer = new StringBuffer(c.getCount());
for ( c.moveToFirst(); !c.isAfterLast(); c.moveToNext()) {
columnNameBuffer.append(c.getString( columnIndex ));
columnNameBuffer.append(",");
index++;
}
}
}
catch (Exception e) {
e.printStackTrace();
}
finally {
if (c != null) {
c.close();
}
}
return columnNameBuffer.toString(); }
加上事物控制:
// update table
private void updateTable(SQLiteDatabase db, String tableName, String columns)
{
try
{
db.beginTransaction();
String oldColumns = columns.substring(0, columns.length() - 1);
// rename the table
String tempTable = tableName + "texp_temptable";
String renameTableSql = "alter table " + tableName + " rename to " + tempTable;
db.execSQL(renameTableSql); // drop the oldtable
String dropTableSql = "drop table if exists " + tableName;
db.execSQL(dropTableSql);
// creat table
String createTableSql = "create table if not exists " + tableName + "(name text, pwd text, tel text)";
db.execSQL(createTableSql);
// load data
String newColume = "tel";
String newColumns = oldColumns + "," + newColumn;
String insertSql = "insert into " + tableName + " (" + newColumns + ") " + "select " + oldColumns + "" + " " + " from " + tempTable;
db.execSql(insertSql);
db.setTransactionSuccessful();
}
catch (Exception e)
{
// TODO: handle exception
Log.i( "tag", e.getMessage() );
}
finally
{
db.endTransaction();
}
}
//DBHelper:
public class DBHelper extends SQLiteOpenHelper { private static final String DATABASE_NAME = "student.db";
private static final int DATABASE_VERSION = 1002; private static DBHelper instance = null; public DBHelper(Context context) {
super(context, DATABASE_NAME, null, DATABASE_VERSION);
} public synchronized static DBHelper getInstance(Context context) {
if (instance == null) {
instance = new DBHelper(context);
}
return instance;
} @Override
public void onCreate(SQLiteDatabase db) {
db.execSQL(SQL.CREATE_TABLE_FAVORITE); // 若不是第一个版本安装,直接执行数据库升级
// 请不要修改FIRST_DATABASE_VERSION的值,其为第一个数据库版本大小
final int FIRST_DATABASE_VERSION = 1000;
onUpgrade(db, FIRST_DATABASE_VERSION, DATABASE_VERSION);
} @Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
// 使用for实现跨版本升级数据库
for (int i = oldVersion; i < newVersion; i++) {
switch (i) {
case 1000:
upgradeToVersion1001(db);
break;
case 1001:
upgradeToVersion1002(db);
break; default:
break;
}
}
} private void upgradeToVersion1001(SQLiteDatabase db){
// student 表新增1个字段
String sql1 = "ALTER TABLE Student ADD COLUMN age VARCHAR";
db.execSQL(sql1);
}
private void upgradeToVersion1002(SQLiteDatabase db){
// student 表新增2个字段, 添加新字段只能一个字段一个字段加,sqlite有限制不予许一条语句加多个字段
String sql1 = "ALTER TABLE Student ADD COLUMN tel VARCHAR";
String sql2 = "ALTER TABLE Student ADD COLUMN address VARCHAR";
db.execSQL(sql1);
db.execSQL(sql2);
}
}