Android数据库表升级(添加列),并保留原表中的数据

版权声明:1.版权归原作者Moment ° 回忆 ✨所有; 2.未经原作者允许不得转载本文内容,否则将视为侵权; 3.转载或者引用本文内容请注明来源及原作者; 4.对于不遵守此声明或者其他违法使用本文内容者,本人依法保留追究权等。 https://blog.csdn.net/qq_35366269/article/details/83348962

  步骤:

        1、首先第一步是更改数据库的 version,当检测到你当前版本比之前的高后会执行onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion)方法,这个方法中第一个参数 db 就是你构造方法中的数据库对象,第二个参数 oldVersion 就是你当前数据库之前的版本,第三个参数 newVersion就是当前数据库现在要升级到的版本。在这个方法里需要对不同版本做不同的操作,假设:

        当前使用app的用户该数据库版本为 1 ,而你现在新数据库版本为 2 ,那么你需要把 1 -> 2版本之间的变化写到一起,比如你在版本更新到 2 时添加了一个列,就要把一个列插入表中。

        当前使用app的用户改数据库版本为 1 或者为 2 ,而你现在新数据库版本为 3 ,那么你需要把 1 -> 3 版本之间所有的变化写到一起,比如你在版本从 1 更新到 2 时添加了一个列,从 2 更新到 3 时添加了二个列,这个时候你就要分情况处理了,如果用户是直接从 1 升到 3 ,那么你要添加三个列,如果用户是从 2 升到 3 ,那么你要添加二个列。

        2、在 onUpgrade 中做添加字段或者删除字段的操作!!!!注意:这里有两种需求!!第一种:不需要保留原表的数据,在我现在公司项目中有一张表要修改一个列名,但是每次使用的都是新数据,所以可以直接删除原表,再重新创建表!第二种:需要保留原数据,只不过后续app的版本添加了功能需要在该表中使用新的列!这里我解决的是第二种情况,也就是需要保留原数据的情况!

        先写思路,最后贴代码,这里以 user 表为例:

        (1)将原来的表更改名字为一张临时表:  "alert table user rename to_temp_user"  ,临时表名可以自己定义,我定义的是  _temp_+原表名 ,比如原表名为 user 表,临时表名就为  _temp_user 。

        (2)创建一张新表,表名为原来的表名,注意:这里的新表中的列要有你需要添加的列,并将新的列添加的原表中的末尾:"create table if not exists user(表中列名和数据类型,多个列以,逗号隔开 )" 。

        (3)将临时表的数据复制到名字为原来表名的新表(这里有一点要注意,因为新的列是在末尾,所以这里我们要预留值给新列,如果没有预留值我也不知道会出什么问题。。。欢迎博友给出意见!!)具体的实现细节在接下来的sql语句中体现:"insert into user select *,' ' from _temp_user" ,这里select * 之后的单引号之间有空格,如果添加多个字段就添加多个' ',以逗号隔开,比如添加两个字段:"insert into user select *,' ',' ' form _temp_user",意思就是给新添加的列赋值为 ' ' !!

        (4)将临时表删除,数据已经复制完毕,有新添加列的表已经生成并保留了数据,临时表已经没用利用价值了,删吧,任性一回!!删除sql语句:"drop  table _temp_user"。

        升级表的操作就结束了!接下来该贴出代码了:
 

  /**
     * 在表中添加字段方法 操作步骤: 1、先更改表名 2、创建新表,表名为原来的表名 3、复制数据 4、删除旧表
     *
     * @param db
     *            数据库名
     * @param newColumnArr
     *            添加的新字段的表名数组
     * @param oldTableName
     *            旧表名,在方法内部将旧表名修改为 _temp_+oldTableName
     */
    private void addColumn(SQLiteDatabase db, String[] newColumnArr,
            String oldTableName) {
       
        if (db == null || newColumnArr == null || newColumnArr.length < 1
                || TextUtils.isEmpty(oldTableName)) {
            // 数据库为空,新字段个数为0,添加字段后的字段数组个数为0,旧表名为空
            return;
        }
 
        // 拿到旧表中所有的数据
        Cursor cursor = db.rawQuery("select * from " + oldTableName, null);
        if (cursor == null) {
            // 如果游标为空,说明旧表中没有数据,如果是这种情况那就可以直接改表的字段,不需要转移数据了,代码后面也有,省略掉复制数据的操作就好
            return;
        }
        // 拿到原来的表中所有的字段名
        String[] oldColumnNames = cursor.getColumnNames();
 
        // 更改原表名为临时表
        String tempTableName = "_temp_" + oldTableName;
        db.execSQL(
                "alter table " + oldTableName + " rename to " + tempTableName);
 
        // 创建新表
        if (oldColumnNames.length < 1) {
            // 如果原来的表中字段个数为0
            return;
        }
 
        // 创建一个线程安全的字符串缓冲对象,防止用conn多线程访问数据库时造成线程安全问题
        StringBuffer createNewTableStr = new StringBuffer();
        createNewTableStr
                .append("create table if not exists " + oldTableName + "(");
        for (int i = 0; i < oldColumnNames.length; i++) {
            if (i == 0) {
                createNewTableStr.append(oldColumnNames[i]
                        + " integer primary key autoincrement,");
            } else {
                createNewTableStr.append(oldColumnNames[i] + ",");
            }
        }
 
        for (int i = 0; i < newColumnArr.length; i++) {
            if (i == newColumnArr.length - 1) {
                // 最后一个
                createNewTableStr.append(newColumnArr[i] + ")");
            } else {
                // 不是最后一个
                createNewTableStr.append(newColumnArr[i] + ",");
            }
        }
      
        db.execSQL(createNewTableStr.toString());
 
        // 复制旧表数据到新表
        StringBuffer copySQLStr = new StringBuffer();
        copySQLStr.append("insert into " + oldTableName + " select *,");
        // 有多少个新的字段,就要预留多少个' '空值给新字段
        for (int i = 0; i < newColumnArr.length; i++) {
            if (i == newColumnArr.length - 1) {
                // 最后一个
                copySQLStr.append("' ' from " + tempTableName);
            } else {
                // 不是最后一个
                copySQLStr.append("' ',");
            }
        }
       
        db.execSQL(copySQLStr.toString());
 
        // 删除旧表
        db.execSQL("drop table " + tempTableName);
 
        // 关闭游标
        cursor.close();
    }

  这个添加新列的方法亲测可用,应该大家可以直接拿到自己的项目中使用!我秉承了写代码的好习惯,注释的还算清晰吧!!

        还是解释一下这个方法的参数吧,里面的逻辑就不再过多解释了:

                第一个参数 SQLiteDatabase db ,很简单,数据库对象,需要对其操作的数据库!

                第二个参数 String[] newColumnArr ,需要添加新列的列名数组!

                第三个参数 String oldTableName ,需要升级的表名!
 

猜你喜欢

转载自blog.csdn.net/qq_35366269/article/details/83348962