Android SQLite数据库版本升级的管理实现

android sqlite数据库版本升级的管理实现

我们知道在sqliteopenhelper的构造方法:

super(context context, string name, sqlitedatabase.cursorfactory factory, int version) 

中最后一个参数表示数据库的版本号.当新的版本号大于当前的version时会调用方法:

onupgrade(sqlitedatabase db, int oldversion, int newversion) 

所以我们的重点是在该方法中实现sqlite数据库版本升级的管理

当我们项目刚开始的时候第一版sqliteopenhelper是这样写的:

package cc.database; 
 
import android.content.context; 
import android.database.sqlite.sqlitedatabase; 
import android.database.sqlite.sqlitedatabase.cursorfactory; 
import android.database.sqlite.sqliteopenhelper; 
/** 
 * demo描述: 
 * sqlite数据库版本升级的管理实现 
 * 
 * 参考资料: 
 * http://blog.csdn.net/guolin_blog 
 * thank you very much 
 */ 
public class databaseopenhelper extends sqliteopenhelper { 
  private final static string database_name="test.db"; 
  private static databaseopenhelper mdatabaseopenhelper; 
   
  public static final string create_person= 
  "create table person(personid integer primary key autoincrement,name varchar(20),phone varchar(12))"; 
   
  public databaseopenhelper(context context,string name,cursorfactory factory,int version) { 
    super(context, name, factory, version); 
  } 
 
   
  //注意: 
  //将databaseopenhelper写成单例的. 
  //否则当在一个for循环中频繁调用openhelper.getwritabledatabase()时 
  //会报错,提示数据库没有执行关闭操作 
  static synchronized databaseopenhelper getdbinstance(context context) { 
    if (mdatabaseopenhelper == null) { 
      mdatabaseopenhelper = new databaseopenhelper(context,database_name,null,1); 
    } 
    return mdatabaseopenhelper; 
  }  
   
  @override 
  public void oncreate(sqlitedatabase db) { 
    db.execsql(create_person); 
  } 
 
  @override 
  public void onupgrade(sqlitedatabase db, int oldversion, int newversion) { 
     
  } 
 
} 

在几天之后根据项目需求，需要添加一张student表，于是databaseopenhelper就出现了第二版:

package cc.database; 
 
import android.content.context; 
import android.database.sqlite.sqlitedatabase; 
import android.database.sqlite.sqlitedatabase.cursorfactory; 
import android.database.sqlite.sqliteopenhelper; 
 
public class databaseopenhelper extends sqliteopenhelper { 
  private final static string database_name="test.db"; 
  private static databaseopenhelper mdatabaseopenhelper; 
   
  public static final string create_person= 
  "create table person(personid integer primary key autoincrement,name varchar(20),phone varchar(12))"; 
   
  public static final string create_student= 
  "create table student(studentid integer primary key autoincrement,name varchar(20),phone varchar(12))"; 
   
  public databaseopenhelper(context context,string name,cursorfactory factory,int version) { 
    super(context, name, factory, version); 
  } 
 
   
  //注意: 
  //将databaseopenhelper写成单例的. 
  //否则当在一个for循环中频繁调用openhelper.getwritabledatabase()时 
  //会报错,提示数据库没有执行关闭操作 
  static synchronized databaseopenhelper getdbinstance(context context) { 
    if (mdatabaseopenhelper == null) { 
      //改动1 
      mdatabaseopenhelper = new databaseopenhelper(context,database_name,null,2); 
    } 
    return mdatabaseopenhelper; 
  }  
   
  @override 
  public void oncreate(sqlitedatabase db) { 
    db.execsql(create_person); 
    //改动2 
    db.execsql(create_student); 
  } 
 
  @override 
  public void onupgrade(sqlitedatabase db, int oldversion, int newversion) { 
    //改动3 
    switch (oldversion) { 
     
    case 1: 
    db.execsql(create_student); 
 
    default: 
    } 
  } 
 
} 

较版本一在版本二中有三处修改的地方：

1 版本号变成了2

2 在oncreate()方法中添加了代码db.execsql(create_student);创建student表

   因为有的用户根本就没有第一版本的app，直接从市场下载了第二版本的app。所以当然会执行oncreate()而不会执行onupgrade()

3 在onupgrade()做了处理：当oldversion为1时调用db.execsql(create_student);创建student表
   因为有的用户手机上本来就有第一版本的app，所以在app升级到第二版本时会执行onupgrade()，不会执行oncreate()

通过这样的处理使得不同的情况下使用第二版app时都会生成student表

又过了一个月，根据项目变更，需要给person表添加一个字段genderid，于是databaseopenhelper就出现了第三版:

package cc.database; 
 
import android.content.context; 
import android.database.sqlite.sqlitedatabase; 
import android.database.sqlite.sqlitedatabase.cursorfactory; 
import android.database.sqlite.sqliteopenhelper; 
 
public class databaseopenhelper extends sqliteopenhelper { 
  private final static string database_name="test.db"; 
  private static databaseopenhelper mdatabaseopenhelper; 
   
  //改动1 
  public static final string create_person= 
  "create table person(personid integer primary key autoincrement,name varchar(20),phone varchar(12)),genderid integer)"; 
   
  public static final string alter_person="alter table person add column genderid integer"; 
   
  public static final string create_student= 
  "create table student(studentid integer primary key autoincrement,name varchar(20),phone varchar(12))"; 
   
  public databaseopenhelper(context context,string name,cursorfactory factory,int version) { 
    super(context, name, factory, version); 
  } 
 
   
  //注意: 
  //将databaseopenhelper写成单例的. 
  //否则当在一个for循环中频繁调用openhelper.getwritabledatabase()时 
  //会报错,提示数据库没有执行关闭操作 
  static synchronized databaseopenhelper getdbinstance(context context) { 
    if (mdatabaseopenhelper == null) { 
      //改动2 
      mdatabaseopenhelper = new databaseopenhelper(context,database_name,null,3); 
    } 
    return mdatabaseopenhelper; 
  }  
   
  @override 
  public void oncreate(sqlitedatabase db) { 
    db.execsql(create_person); 
    db.execsql(create_student); 
  } 
 
  @override 
  public void onupgrade(sqlitedatabase db, int oldversion, int newversion) { 
    switch (oldversion) { 
     
    case 1: 
    db.execsql(create_student); 
     
    //改动3 
    case 2: 
    db.execsql(alter_person); 
 
    default: 
    } 
  } 
 
} 

较版本二在版本三中有三处修改的地方：

1 改变了create_person语句，在改语句中增加了一个字段genderid 

  和前面的描述类似，有的用户第一次安装该app时就直接下载了第三版

2 修改版本号为3

   应对了用户从第一版本或者第二版本升级到第三版本的情况(见下分析)

3 在onupgrade()方法中)做了处理：当oldversion为2时调用 db.execsql(alter_person);修改person表，增加genderid字段

   应对了用户从第二版本升级到第三版本的情况(见下分析)

注意一个问题：为什么这里的switch语句在每个case中没有break？？？

这是为了保证跨版本升级的时候每次数据库的升级都会执行到。

比如从第二版升级到第三版本，那么case 2会被执行。

比如从第一版直接升级到第三版本，那么case 1肯定会被调用，由于没有break所以会穿透switch语句又执行case 2语句继续升级，从而保证了数据的所有版本中的升级都会被执行到。

如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！