SQLite数据库版本升级

目录.png

一.简介

我们在开发应用的时候，存储数据可能会用到数据库。第一个版本时所设计的数据库结构，如果在以后的app版本中需要增加业务逻辑，数据库的表可能要做相应的修改，那么原来的数据库结构就不能用了，这时就需要对数据库进行升级。

二.升级方案

1.让用户将应用卸载然后再安装最新版本的app
2.对数据库进行升级
对于第一种方案，用户卸载老版本就会造成数据丢失，这样对于用户的体验性极差，不到万不得已的时候不要做。
我们倾向于选择第二项方案。

三.不同版本升级分析

3.1.Version1.0

当我们开发第一个版本数据库的时候，SQLiteOpenHelper的继承类里会走onCreate()方法，即 —->v1.0 走onCreate()，这时候并不涉及更新的方法。

3.2.Version2.0

当我们开发到第二个数据库版本的时候，分两种情况：
(1) 用户从1.0版本升级到2.0版本 SQLiteOpenHelper的继承类里会走onUpgrade()方法,不走onCreate()方法。即v1.0—->v2.0 走onUpgrade()；
(2) 如果是用户直接安装v2.0 ， SQLiteOpenHelper的继承类里会走onCreate()方法,不走onUpgrade()方法。即 —->v2.0 走onCreate()

3.3.Version3.0

(1) 用户从1.0版本升级到3.0版本，SQLiteOpenHelper的继承类里会走onUpgrade()方法,不走onCreate()方法。即v1.0—->v3.0 走onUpgrade()
(2) 用户从2.0版本升级到3.0版本，SQLiteOpenHelper的继承类里会走onUpgrade()方法,不走onCreate()方法。即v2.0—->v3.0 走onUpgrade()
(3) 如果是用户直接安装3.0 ，SQLiteOpenHelper的继承类里会走onCreate()方法,不走onUpgrade()方法。即 —->v3.0 走onCreate()
如下图

版本升级方法分析.png

只要是第一次安装或者第一个数据库版本的都走onCreate()方法，而不走onUpgrade()方法，从低版本升级到高版本的都走onUpgrade()方法而不走onCreate()方法。

四.代码分析

4.1第一个数据库版本

只走onCreate()，所以我们可以把创建表的方法写在这个方法里，

@Override
    public void onCreate(SQLiteDatabase db) {
        try {
            db.execSQL(DataBaseConfig.FIRST_VERSION_INFO);
        } catch (Exception e) {
            Log.e(tag,"e=="+e);
        }
    }

另外需要注意的是，我们要把创建SQLiteOpenHelper子类的地方写成单例模式，这样可以避免重复创建，出现问题。

private static volatile MySqliteOpenHelper instance = null;
     /**
     * 第一个参数 context 上下文
     * 第二个参数 name  数据库名称
     * 第三个参数 factory 为了创建cursor对象, 默认为空
     * 第四个参数 version 数据库版本
     * @param context
     */
    private MySqliteOpenHelper(Context context) {
        super(context, DataBaseConfig.DATABASE_NAME, null, DataBaseConfig.DATABASE_NEW_VERSION);
        db = this.getWritableDatabase();//调用此方法时数据库才算真正创建
    }
    /**
     * 创建实例
     *
     * @param context
     * @return
     */
    public static MySqliteOpenHelper getDBHelper(Context context) {
        if (instance == null) {
            synchronized (MySqliteOpenHelper.class) {
                if (instance == null)
                    instance = new MySqliteOpenHelper(context);
            }
        }
        return instance;
    }
       @Override
    public void onCreate(SQLiteDatabase db) {
        try {
            db.execSQL(DataBaseConfig.FIRST_VERSION_INFO);
        } catch (Exception e) {
            Log.e(tag,"e=="+e);
        }
    }

//第一个版本的sql
    String FIRST_VERSION_INFO ="create table if not exists "+TABLE_TEST1+"( " +
            " id      varchar     DEFAULT ''," +
            " name    varchar     DEFAULT ''," +
            " age     varchar     DEFAULT '')";

此时的DataBaseConfig.DATABASE_NEW_VERSION 为1
点击获取低版本信息按钮

数据库版本1.png

如果以后的需求改变，需要往数据库里加字段或者改字段，需要升级数据库。

4.2第二个数据库版本

如果是从v1.0升级到v2.0，则走onUpgrade,如果是直接安装v2.0，则走onCreate()

4.2.1. 比如从v1.0升级到v2.0 需要增加字段

/**
     * 新版本比旧版本高就会走这个方法
     */
    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        for (int i = oldVersion; i < newVersion; i++) {
            switch (i) {
                case DataBaseConfig.DATABASE_FIRST_VERSION:
                    addUpgradeToVersion2(db);//添加两个字段
                    break;
                default:
                    break;
            }
        }
    }
 /**
     * 新版本升级的改动
     *
     * @param db
     */
    private void addUpgradeToVersion2(SQLiteDatabase db) {//注意添加两个字段时要分开写
        String sql1 = "ALTER TABLE " + DataBaseConfig.TABLE_TEST1 + " ADD COLUMN sex  varchar";
        String sql2 = "ALTER TABLE " + DataBaseConfig.TABLE_TEST1 + " ADD COLUMN address varchar";
        db.execSQL(sql1);
        db.execSQL(sql2);
    }

此时 DataBaseConfig.DATABASE_NEW_VERSION 为2 ，DataBaseConfig.DATABASE_FIRST_VERSION为1

数据库版本2.png

版本2比版本1中新增了sex,和address字段，比版本1多了两项，由于代码中默认的性别是女，所以前三个的性别是女。

还要再处理onCreate(),因为用户可能是直接安装V2.0
有两种方法：
（1）执行旧版数据库sql,则后面还要调用onUpgrade

@Override
    public void onCreate(SQLiteDatabase db) {
        try {
            db.execSQL(DataBaseConfig.FIRST_VERSION_INFO);
            onUpgrade(db,DataBaseConfig.DATABASE_FIRST_VERSION,DataBaseConfig.DATABASE_NEW_VERSION);
        } catch (Exception e) {
            Log.e(tag,"e=="+e);
        }
    }

（2）执行新版数据库sql，不需要调用onUpgrade

@Override
    public void onCreate(SQLiteDatabase db) {
        try {
            db.execSQL(DataBaseConfig.NEW_VERSION_INFO);
        } catch (Exception e) {
            Log.e(tag,"e=="+e);
        }
    }
 //增加两个字段
    String NEW_VERSION_INFO ="create table if not exists "+TABLE_TEST1+"( " +
            " id      varchar     DEFAULT ''," +
            " name    varchar     DEFAULT ''," +
            " age     varchar     DEFAULT '',"+
            " sex     varchar     DEFAULT '',"+
            " address  varchar     DEFAULT '')";

4.2.2. 第二个版本数据库需要新增并修改字段

1. 比如从v1.0升级到v2.0 需要增加字段
  新增sex,address字段，修改age–>sign

/**
     * 新版本比旧版本高就会走这个方法
     */
    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        for (int i = oldVersion; i < newVersion; i++) {
            switch (i) {
                case DataBaseConfig.DATABASE_FIRST_VERSION:
                    updateUpgradeToVersion2(db);//修改表原有字段并新增字段
                    break;
                default:
                    break;
            }
        }
    }
private void updateUpgradeToVersion2(SQLiteDatabase db) {
        try{
            db.beginTransaction();
            // 1, 将表TABLE_TEST1重命名为TABLE_TEST1+"_temp"
            String tempTableName = DataBaseConfig.TABLE_TEST1 + "_temp";
            String sql = "ALTER TABLE " + DataBaseConfig.TABLE_TEST1 + " RENAME TO " + tempTableName;
            db.execSQL(sql);
            // 2, 创建用户表(字段id、name改变、并新增了以个字段phone)
            db.execSQL(DataBaseConfig.NEW_VERSION_INFO);
            // 3, 将旧表数据导入到新表中,旧表中的id,name,age分别查到新表中的id,name,sign
            sql = "INSERT INTO " + DataBaseConfig.TABLE_TEST1 + " (" + "id,name,sign" + ") " + " SELECT " + "id,name,age" + " FROM " + tempTableName;
            db.execSQL(sql);
            // 4, 删除旧的表
            db.execSQL("DROP TABLE IF EXISTS " + tempTableName);
            db.setTransactionSuccessful();
            db.setVersion(2);

        }catch (SQLException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            db.endTransaction();
        }

    }