起航学习网

数据库版本如何单独升级，并且将原有数据迁移过去！数据库升级对现有升级影响大吗？

在我们开发的应用中，一般都会涉及到数据库，使用数据的时候会涉及到数据库的升级、数据的迁移、增加行的字段等。比如，用户定制数据的保存，文件的端点续传信息的保存等都会涉及到数据库。

​我们应用第一个版本是V1.0，在迭代版本V1.1 时，我们在数据库中增加了一个字段。因此V1.0的数据库在V1.1版本需要升级，V1.0版本升级到V1.1时原来数据库中的数据不能丢失，

​那么在V1.1中就要有地方能够检测出来版本的差异，并且把V1.0软件的数据库升级到V1.1软件能够使用的数据库。也就是说，要在V1.0软件的数据库的那个表中增加那个字段，并赋予这个字段默认值。 应用中怎么检测数据库需要升级呢? SQLiteOpenHelper 类中有一个方法

1. public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {} 

​当我们创建对象的时候如果传入的版本号大于之前的版本号，该方法就会被调用，通过判断oldVersion 和 newVersion 就可以决定如何升级数据库。在这个函数中把老版本数据库的相应表中增加字段，并给每条记录增加默认值即可。新版本号和老版本号都会作为onUpgrade函数的参数传进来，便于开发者知道数据库应该从哪个版本升级到哪个版本。升级完成后，数据库会自动存储最新的版本号为当前数据库版本号。

数据库升级

SQLite提供了ALTER TABLE命令，允许用户重命名或添加新的字段到已有表中，但是不能从表中删除字段。并且只能在表的末尾添加字段，比如,为Orders 表中添加一个字段：”ALTER TABLE Order ADDCOLUMN Country”

代码如下：

1. public class OrderDBHelper extends SQLiteOpenHelper { 
2. private static final int DB_VERSION = 1; 
3. private static final String DB_NAME = "Test.db"; 
4. public static final String TABLE_NAME = "Orders"; 
5. public OrderDBHelper(Context context, int version) { 
6.  super(context, DB_NAME, null, version); 
7. } 
8. @Override 
9. public void onCreate(SQLiteDatabase db) { 
10.  String sql = "create table if not exists " + TABLE_NAME + " (Id integer primary key, " + 
11.  "CustomName text, OrderPrice integer)"; 
12.  db.execSQL(sql); 
13. } 
14. @Override 
15. public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { 
16.  Log.e("owen", "DB onUpgrade"); 
17.  if (newVersion == 2) { 
18.  db.execSQL("ALTER TABLE " + TABLE_NAME + " ADD COLUMN Country"); 
19.  Cursor cr = db.rawQuery("select * from " + TABLE_NAME, null); 
20.  while (cr.moveToNext()) { 
21.  String name = cr.getString(cr.getColumnIndex("CustomName")); 
22.  ContentValues values = new ContentValues(); 
23.  values.put("CustomName", name); 
24.  values.put("Country", "China"); 
25.  db.update(TABLE_NAME, values, "CustomName=?", new String[] {name}); 
26.  } 
27.  cr.close(); 
28.  } 
29. } 
30. OrderDBHelper orderDBHelper = new OrderDBHelper(this, 2); 
31. SQLiteDatabase db = orderDBHelper.getWritableDatabase(); 
32. ContentValues contentValues = new ContentValues(); 
33. contentValues.put("OrderPrice", 100); 
34. contentValues.put("CustomName", "OwenChan"); 
35. db.insert(OrderDBHelper.TABLE_NAME, null, contentValues); 
36. Log.e("owen", "create finish"); 
37. Cursor cr = db.rawQuery("select * from " + OrderDBHelper.TABLE_NAME , null); 
38. while (cr.moveToNext()) { 
39.  String name = cr.getString(cr.getColumnIndex("CustomName")); 
40.  Log.e("owen", "name:" + name); 
41.  String country = cr.getString(cr.getColumnIndex("Country")); 
42.  Log.e("owen", "country:" + country); 
43. } 
44. cr.close(); 
45. db.close(); 

数据库的迁移

可以分一下几个步骤迁移数据库

1、 将表名改成临时表

ALTER TABLE Order RENAME TO _Order;

2、创建新表

1. CREATETABLE Test(Id VARCHAR(32) PRIMARY KEY ,CustomName VARCHAR(32) NOTNULL , Country VARCHAR(16) NOTNULL); 

3、导入数据

1. INSERTINTO Order SELECT id, “”, Age FROM _Order; 

4、删除临时表

DROPTABLE _Order;

通过以上四个步骤，就可以完成旧数据库结构向新数据库结构的迁移，并且其中还可以保证数据不会因为升级而流失。 当然，如果遇到减少字段的情况，也可以通过创建临时表的方式来实现。

实现代码如下

1. @Override 
2. public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { 
3.  if (newVersion == 2) { 
4.  char str = '"'; 
5.  db.beginTransaction(); 
6.  db.execSQL("ALTER TABLE Order RENAME TO _Order"); 
7.  db.execSQL("CREATE TABLE Order(Id integer primary key autoincrement , CustomName VARCHAR(20) NOT NULL," 
8.  + " Country VARCHAR(32) NOT NULL , OrderPrice VARCHAR(16) NOT NULL)"); 
9.  db.execSQL("INSERT INTO Order SELECT Id, " + str + str 
10.  + ", CustomName, OrderPrice FROM _Order"); 
11.  db.setTransactionSuccessful(); 
12.  db.endTransaction(); 
13.  } 
14. } 

多个数据库版本的升级

假如我们开发的程序已经发布了两个版本：V1.0，V2.0，我们正在开发V3.0。版本号分别是1，2，3。对于这种情况，我们应该如何实现升级? 用户的选择有：

• V1.0 -> V3.0 DB 1 -> 2
• V2.0 -> V3.0 DB 2 -> 3

数据库的每一个版本所代表的数据库必须是定义好的，比如说V1.0的数据库，它可能只有两张表TableA和TableB，如果V2.0要添加一张表TableC，如果V3.0要修改TableC，数据库结构如下：

1. V1.0 —> TableA, TableB V1.2 —> TableA, TableB, TableC V1.3 —> TableA, TableB, TableC (Modify) 

代码如下：

1. @Override 
2. public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { 
3.  if (1 == oldVersion) { 
4.  String sql = "Create table C...."; 
5.  db.execSQL(sql); 
6.  oldVersion = 2; 
7.  } 
8.  if (2 == oldVersion) { 
9.  //modify C 
10.  oldVersion = 3; 
11.  } 
12. } 

导入已有数据库

1. /** 
2.  * Created by Owen Chan 
3.  * On 2017-09-26. 
4.  */ 
5. public class DbManager { 
6.  public static final String PACKAGE_NAME = "com.example.sql"; 
7.  public static final String DB_NAME = "table.db"; 
8.  public static final String DB_PATH = "/data/data/" + PACKAGE_NAME; 
9.  private Context mContext; 
10.  public DbManager(Context mContext) { 
11.  this.mContext = mContext; 
12.  } 
13.  public SQLiteDatabase openDataBase() { 
14.  return SQLiteDatabase.openOrCreateDatabase(DB_PATH + "/" + DB_NAME, null); 
15.  } 
16.  public void importDB() { 
17.  File file = new File(DB_PATH + "/" + DB_NAME); 
18.  if (!file.exists()) { 
19.  try { 
20.  FileOutputStream out = new FileOutputStream(file); 
21.  int buffer = 1024; 
22.  InputStream in = mContext.getResources().openRawResource(R.raw.xxxx); 
23.  byte[] bts = new byte[buffer]; 
24.  int lenght; 
25.  while ((lenght = in.read(bts)) > 0) { 
26.  out.write(bts, 0, bts.length); 
27.  } 
28.  out.close(); 
29.  in.close(); 
30.  } catch (Exception e) { 
31.  e.printStackTrace(); 
32.  } 
33.  } 
34.  } 
35. } 

调用方式

1. @Override 
2. protected void onResume() { 
3.  super.onResume(); 
4.  DbManager dbManager = new DbManager(this); 
5.  dbManager.importDB(); 
6.  SQLiteDatabase db = dbManager.openDataBase(); 
7.  db.execSQL("do what you want"); 
8. } 

文章出自：http://qh.itpxw.cn/peixun/software/201949150.html

文章标题：【数据库培训】数据库升级对数据有影响吗

免责声明：本站文章均由入驻起航学习网的会员所发或者网络转载，所述观点仅代表作者本人，不代表起航学习网立场。如有侵权或者其他问题，请联系举报，必删。侵权投诉