mirror of
https://github.com/TeamAmaze/AmazeFileManager.git
synced 2026-10-24 09:28:22 +08:00
Merge pull request #2784 from TeamAmaze/bugfix/2751
This commit is contained in:
Emmanuel
@@ -34,6 +34,14 @@ android {
|
||||
|
||||
vectorDrawables.useSupportLibrary = true
|
||||
testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
|
||||
|
||||
javaCompileOptions {
|
||||
annotationProcessorOptions {
|
||||
arguments += ["room.schemaLocation" : "$projectDir/schemas".toString(),
|
||||
"room.incremental" : "true",
|
||||
"room.expandProjection": "true"]
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
signingConfigs {
|
||||
@@ -145,6 +153,7 @@ dependencies {
|
||||
testImplementation "org.awaitility:awaitility:$awaitilityVersion"
|
||||
testImplementation 'org.jsoup:jsoup:1.11.2'
|
||||
testImplementation 'commons-net:commons-net:3.6'
|
||||
testImplementation "androidx.room:room-migration:$roomVersion"
|
||||
kaptTest "com.google.auto.service:auto-service:1.0-rc4"
|
||||
|
||||
androidTestImplementation "junit:junit:$junitVersion"//tests the app logic
|
||||
|
||||
@@ -0,0 +1,46 @@
|
||||
{
|
||||
"formatVersion": 1,
|
||||
"database": {
|
||||
"version": 1,
|
||||
"identityHash": "00000000000000000000000000000001",
|
||||
"entities": [
|
||||
{
|
||||
"tableName": "tab",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`tab_no` INTEGER NOT NULL, `path` TEXT, `home` TEXT, PRIMARY KEY(`tab_no`))",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "tabNumber",
|
||||
"columnName": "tab_no",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "home",
|
||||
"columnName": "home",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"tab_no"
|
||||
],
|
||||
"autoGenerate": false
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
}
|
||||
],
|
||||
"views": [],
|
||||
"setupQueries": [
|
||||
"CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",
|
||||
"INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(1, '00000000000000000000000000000001')"
|
||||
]
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,110 @@
|
||||
{
|
||||
"formatVersion": 1,
|
||||
"database": {
|
||||
"version": 5,
|
||||
"identityHash": "00000000000000000000000000000005",
|
||||
"entities": [
|
||||
{
|
||||
"tableName": "tab",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`tab_no` INTEGER NOT NULL, `path` TEXT, `home` TEXT, PRIMARY KEY(`tab_no`))",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "tabNumber",
|
||||
"columnName": "tab_no",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "home",
|
||||
"columnName": "home",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"tab_no"
|
||||
],
|
||||
"autoGenerate": false
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "encrypted",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`_id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, `path` TEXT, `password` TEXT)",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "_id",
|
||||
"columnName": "_id",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "password",
|
||||
"columnName": "password",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"_id"
|
||||
],
|
||||
"autoGenerate": true
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "cloud",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`_id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, `service` INTEGER, `persist` TEXT)",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "_id",
|
||||
"columnName": "_id",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "serviceType",
|
||||
"columnName": "service",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "persistData",
|
||||
"columnName": "persist",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"_id"
|
||||
],
|
||||
"autoGenerate": true
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
}
|
||||
],
|
||||
"views": [],
|
||||
"setupQueries": [
|
||||
"CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",
|
||||
"INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(5, '00000000000000000000000000000005')"
|
||||
]
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,136 @@
|
||||
{
|
||||
"formatVersion": 1,
|
||||
"database": {
|
||||
"version": 6,
|
||||
"identityHash": "00000000000000000000000000000006",
|
||||
"entities": [
|
||||
{
|
||||
"tableName": "tab",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`tab_no` INTEGER NOT NULL, `path` TEXT, `home` TEXT, PRIMARY KEY(`tab_no`))",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "tabNumber",
|
||||
"columnName": "tab_no",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "home",
|
||||
"columnName": "home",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"tab_no"
|
||||
],
|
||||
"autoGenerate": false
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "encrypted",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`_id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, `path` TEXT, `password` TEXT)",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "_id",
|
||||
"columnName": "_id",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "password",
|
||||
"columnName": "password",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"_id"
|
||||
],
|
||||
"autoGenerate": true
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "cloud",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`_id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, `service` INTEGER, `persist` TEXT)",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "_id",
|
||||
"columnName": "_id",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "serviceType",
|
||||
"columnName": "service",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "persistData",
|
||||
"columnName": "persist",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"_id"
|
||||
],
|
||||
"autoGenerate": true
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "sort",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`path` TEXT NOT NULL, `type` INTEGER NOT NULL, PRIMARY KEY(`path`))",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "type",
|
||||
"columnName": "type",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"path"
|
||||
],
|
||||
"autoGenerate": false
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
}
|
||||
],
|
||||
"views": [],
|
||||
"setupQueries": [
|
||||
"CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",
|
||||
"INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(6, '00000000000000000000000000000006')"
|
||||
]
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,136 @@
|
||||
{
|
||||
"formatVersion": 1,
|
||||
"database": {
|
||||
"version": 7,
|
||||
"identityHash": "06766b689063c1bcaa4d0df3fd06f5e6",
|
||||
"entities": [
|
||||
{
|
||||
"tableName": "tab",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`tab_no` INTEGER NOT NULL, `path` TEXT, `home` TEXT, PRIMARY KEY(`tab_no`))",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "tabNumber",
|
||||
"columnName": "tab_no",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "home",
|
||||
"columnName": "home",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"tab_no"
|
||||
],
|
||||
"autoGenerate": false
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "sort",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`path` TEXT NOT NULL, `type` INTEGER NOT NULL, PRIMARY KEY(`path`))",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "type",
|
||||
"columnName": "type",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"path"
|
||||
],
|
||||
"autoGenerate": false
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "encrypted",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`_id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, `path` TEXT, `password` TEXT)",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "_id",
|
||||
"columnName": "_id",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "path",
|
||||
"columnName": "path",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "password",
|
||||
"columnName": "password",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"_id"
|
||||
],
|
||||
"autoGenerate": true
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
},
|
||||
{
|
||||
"tableName": "cloud",
|
||||
"createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`_id` INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, `service` INTEGER, `persist` TEXT)",
|
||||
"fields": [
|
||||
{
|
||||
"fieldPath": "_id",
|
||||
"columnName": "_id",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": true
|
||||
},
|
||||
{
|
||||
"fieldPath": "serviceType",
|
||||
"columnName": "service",
|
||||
"affinity": "INTEGER",
|
||||
"notNull": false
|
||||
},
|
||||
{
|
||||
"fieldPath": "persistData",
|
||||
"columnName": "persist",
|
||||
"affinity": "TEXT",
|
||||
"notNull": false
|
||||
}
|
||||
],
|
||||
"primaryKey": {
|
||||
"columnNames": [
|
||||
"_id"
|
||||
],
|
||||
"autoGenerate": true
|
||||
},
|
||||
"indices": [],
|
||||
"foreignKeys": []
|
||||
}
|
||||
],
|
||||
"views": [],
|
||||
"setupQueries": [
|
||||
"CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",
|
||||
"INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(42, '06766b689063c1bcaa4d0df3fd06f5e6')"
|
||||
]
|
||||
}
|
||||
}
|
||||
@@ -46,8 +46,7 @@ import androidx.sqlite.db.SupportSQLiteDatabase;
|
||||
*/
|
||||
@Database(
|
||||
entities = {Tab.class, Sort.class, EncryptedEntry.class, CloudEntry.class},
|
||||
version = 7,
|
||||
exportSchema = false)
|
||||
version = 7)
|
||||
public abstract class ExplorerDatabase extends RoomDatabase {
|
||||
|
||||
private static final String DATABASE_NAME = "explorer.db";
|
||||
@@ -76,7 +75,7 @@ public abstract class ExplorerDatabase extends RoomDatabase {
|
||||
private static final String TEMP_TABLE_PREFIX = "temp_";
|
||||
|
||||
// 1->2: add encrypted table (66f08f34)
|
||||
private static final Migration MIGRATION_1_2 =
|
||||
static final Migration MIGRATION_1_2 =
|
||||
new Migration(1, 2) {
|
||||
@Override
|
||||
public void migrate(@NonNull SupportSQLiteDatabase database) {
|
||||
@@ -96,7 +95,7 @@ public abstract class ExplorerDatabase extends RoomDatabase {
|
||||
};
|
||||
|
||||
// 2->3: add cloud table (8a5ced1b)
|
||||
private static final Migration MIGRATION_2_3 =
|
||||
static final Migration MIGRATION_2_3 =
|
||||
new Migration(2, 3) {
|
||||
@Override
|
||||
public void migrate(@NonNull SupportSQLiteDatabase database) {
|
||||
@@ -116,21 +115,21 @@ public abstract class ExplorerDatabase extends RoomDatabase {
|
||||
};
|
||||
|
||||
// 3->4: same as 2->3 (765140f6)
|
||||
private static final Migration MIGRATION_3_4 =
|
||||
static final Migration MIGRATION_3_4 =
|
||||
new Migration(3, 4) {
|
||||
@Override
|
||||
public void migrate(@NonNull SupportSQLiteDatabase database) {}
|
||||
};
|
||||
|
||||
// 4->5: same as 3->4, same as 2->3 (37357436)
|
||||
private static final Migration MIGRATION_4_5 =
|
||||
static final Migration MIGRATION_4_5 =
|
||||
new Migration(4, 5) {
|
||||
@Override
|
||||
public void migrate(@NonNull SupportSQLiteDatabase database) {}
|
||||
};
|
||||
|
||||
// 5->6: add sort table (fe7c0aba)
|
||||
private static final Migration MIGRATION_5_6 =
|
||||
static final Migration MIGRATION_5_6 =
|
||||
new Migration(5, 6) {
|
||||
@Override
|
||||
public void migrate(@NonNull SupportSQLiteDatabase database) {
|
||||
@@ -146,7 +145,7 @@ public abstract class ExplorerDatabase extends RoomDatabase {
|
||||
}
|
||||
};
|
||||
|
||||
private static final Migration MIGRATION_6_7 =
|
||||
static final Migration MIGRATION_6_7 =
|
||||
new Migration(6, DATABASE_VERSION) {
|
||||
@Override
|
||||
public void migrate(@NonNull SupportSQLiteDatabase database) {
|
||||
@@ -162,7 +161,24 @@ public abstract class ExplorerDatabase extends RoomDatabase {
|
||||
+ COLUMN_HOME
|
||||
+ " TEXT)");
|
||||
database.execSQL(
|
||||
"INSERT INTO " + TEMP_TABLE_PREFIX + TABLE_TAB + " SELECT * FROM " + TABLE_TAB);
|
||||
"INSERT INTO "
|
||||
+ TEMP_TABLE_PREFIX
|
||||
+ TABLE_TAB
|
||||
+ "("
|
||||
+ COLUMN_TAB_NO
|
||||
+ ","
|
||||
+ COLUMN_PATH
|
||||
+ ","
|
||||
+ COLUMN_HOME
|
||||
+ ")"
|
||||
+ " SELECT "
|
||||
+ COLUMN_TAB_NO
|
||||
+ ","
|
||||
+ COLUMN_PATH
|
||||
+ ","
|
||||
+ COLUMN_HOME
|
||||
+ " FROM "
|
||||
+ TABLE_TAB);
|
||||
database.execSQL("DROP TABLE " + TABLE_TAB);
|
||||
database.execSQL(
|
||||
"ALTER TABLE " + TEMP_TABLE_PREFIX + TABLE_TAB + " RENAME TO " + TABLE_TAB);
|
||||
|
||||
@@ -0,0 +1,116 @@
|
||||
/*
|
||||
* Copyright (C) 2014-2021 Arpit Khurana <arpitkh96@gmail.com>, Vishal Nehra <vishalmeham2@gmail.com>,
|
||||
* Emmanuel Messulam<emmanuelbendavid@gmail.com>, Raymond Lai <airwave209gt at gmail.com> and Contributors.
|
||||
*
|
||||
* This file is part of Amaze File Manager.
|
||||
*
|
||||
* Amaze File Manager is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
package com.amaze.filemanager.database;
|
||||
|
||||
import static android.os.Build.VERSION_CODES.JELLY_BEAN;
|
||||
import static android.os.Build.VERSION_CODES.KITKAT;
|
||||
import static android.os.Build.VERSION_CODES.P;
|
||||
import static com.amaze.filemanager.database.ExplorerDatabase.MIGRATION_1_2;
|
||||
import static com.amaze.filemanager.database.ExplorerDatabase.MIGRATION_2_3;
|
||||
import static com.amaze.filemanager.database.ExplorerDatabase.MIGRATION_3_4;
|
||||
import static com.amaze.filemanager.database.ExplorerDatabase.MIGRATION_4_5;
|
||||
import static com.amaze.filemanager.database.ExplorerDatabase.MIGRATION_5_6;
|
||||
import static com.amaze.filemanager.database.ExplorerDatabase.MIGRATION_6_7;
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
import org.junit.Rule;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.robolectric.annotation.Config;
|
||||
|
||||
import com.amaze.filemanager.shadows.ShadowMultiDex;
|
||||
|
||||
import androidx.room.Room;
|
||||
import androidx.sqlite.db.SupportSQLiteDatabase;
|
||||
import androidx.sqlite.db.framework.FrameworkSQLiteOpenHelperFactory;
|
||||
import androidx.test.ext.junit.runners.AndroidJUnit4;
|
||||
import androidx.test.platform.app.InstrumentationRegistry;
|
||||
|
||||
@RunWith(AndroidJUnit4.class)
|
||||
@Config(
|
||||
shadows = {ShadowMultiDex.class},
|
||||
sdk = {JELLY_BEAN, KITKAT, P})
|
||||
public class ExplorerDatabaseMigrationTest {
|
||||
|
||||
private static final String TEST_DB = "explorer-test";
|
||||
|
||||
@Rule
|
||||
public final MigrationTestHelper helper =
|
||||
new MigrationTestHelper(
|
||||
InstrumentationRegistry.getInstrumentation(),
|
||||
ExplorerDatabase.class.getCanonicalName(),
|
||||
new FrameworkSQLiteOpenHelperFactory());
|
||||
|
||||
@Test
|
||||
public void migrateAll() throws IOException {
|
||||
SupportSQLiteDatabase db = helper.createDatabase(TEST_DB, 1);
|
||||
db.close();
|
||||
|
||||
ExplorerDatabase explorerDatabase =
|
||||
Room.databaseBuilder(
|
||||
InstrumentationRegistry.getInstrumentation().getTargetContext(),
|
||||
ExplorerDatabase.class,
|
||||
TEST_DB)
|
||||
.addMigrations(
|
||||
MIGRATION_1_2,
|
||||
MIGRATION_2_3,
|
||||
MIGRATION_3_4,
|
||||
MIGRATION_4_5,
|
||||
MIGRATION_5_6,
|
||||
MIGRATION_6_7)
|
||||
.build();
|
||||
explorerDatabase.getOpenHelper().getWritableDatabase();
|
||||
explorerDatabase.close();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void migrateFromV5() throws IOException {
|
||||
SupportSQLiteDatabase db = helper.createDatabase(TEST_DB, 5);
|
||||
db.close();
|
||||
|
||||
ExplorerDatabase explorerDatabase =
|
||||
Room.databaseBuilder(
|
||||
InstrumentationRegistry.getInstrumentation().getTargetContext(),
|
||||
ExplorerDatabase.class,
|
||||
TEST_DB)
|
||||
.addMigrations(MIGRATION_5_6, MIGRATION_6_7)
|
||||
.build();
|
||||
explorerDatabase.getOpenHelper().getWritableDatabase();
|
||||
explorerDatabase.close();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void migrateFromV6() throws IOException {
|
||||
SupportSQLiteDatabase db = helper.createDatabase(TEST_DB, 6);
|
||||
db.close();
|
||||
|
||||
ExplorerDatabase explorerDatabase =
|
||||
Room.databaseBuilder(
|
||||
InstrumentationRegistry.getInstrumentation().getTargetContext(),
|
||||
ExplorerDatabase.class,
|
||||
TEST_DB)
|
||||
.addMigrations(MIGRATION_6_7)
|
||||
.build();
|
||||
explorerDatabase.getOpenHelper().getWritableDatabase();
|
||||
explorerDatabase.close();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,584 @@
|
||||
/*
|
||||
* Copyright (C) 2014-2021 Arpit Khurana <arpitkh96@gmail.com>, Vishal Nehra <vishalmeham2@gmail.com>,
|
||||
* Emmanuel Messulam<emmanuelbendavid@gmail.com>, Raymond Lai <airwave209gt at gmail.com> and Contributors.
|
||||
*
|
||||
* This file is part of Amaze File Manager.
|
||||
*
|
||||
* Amaze File Manager is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
package com.amaze.filemanager.database;
|
||||
|
||||
/*
|
||||
* Copyright (C) 2017 The Android Open Source Project
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
import java.io.File;
|
||||
import java.io.FileInputStream;
|
||||
import java.io.FileNotFoundException;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.lang.ref.WeakReference;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
|
||||
import org.junit.rules.TestWatcher;
|
||||
import org.junit.runner.Description;
|
||||
|
||||
import android.annotation.SuppressLint;
|
||||
import android.app.Instrumentation;
|
||||
import android.content.Context;
|
||||
import android.database.Cursor;
|
||||
import android.util.Log;
|
||||
|
||||
import androidx.annotation.NonNull;
|
||||
import androidx.arch.core.executor.ArchTaskExecutor;
|
||||
import androidx.room.DatabaseConfiguration;
|
||||
import androidx.room.Room;
|
||||
import androidx.room.RoomDatabase;
|
||||
import androidx.room.RoomOpenHelper;
|
||||
import androidx.room.RoomOpenHelper.ValidationResult;
|
||||
import androidx.room.migration.Migration;
|
||||
import androidx.room.migration.bundle.DatabaseBundle;
|
||||
import androidx.room.migration.bundle.DatabaseViewBundle;
|
||||
import androidx.room.migration.bundle.EntityBundle;
|
||||
import androidx.room.migration.bundle.FieldBundle;
|
||||
import androidx.room.migration.bundle.ForeignKeyBundle;
|
||||
import androidx.room.migration.bundle.FtsEntityBundle;
|
||||
import androidx.room.migration.bundle.IndexBundle;
|
||||
import androidx.room.migration.bundle.SchemaBundle;
|
||||
import androidx.room.util.FtsTableInfo;
|
||||
import androidx.room.util.TableInfo;
|
||||
import androidx.room.util.ViewInfo;
|
||||
import androidx.sqlite.db.SupportSQLiteDatabase;
|
||||
import androidx.sqlite.db.SupportSQLiteOpenHelper;
|
||||
import androidx.sqlite.db.framework.FrameworkSQLiteOpenHelperFactory;
|
||||
|
||||
/**
|
||||
* A class that can be used in your Instrumentation tests that can create the database in an older
|
||||
* schema.
|
||||
*
|
||||
* <p>You must copy the schema json files (created by passing {@code room.schemaLocation} argument
|
||||
* into the annotation processor) into your test assets and pass in the path for that folder into
|
||||
* the constructor. This class will read the folder and extract the schemas from there.
|
||||
*
|
||||
* <pre>
|
||||
* android {
|
||||
* defaultConfig {
|
||||
* javaCompileOptions {
|
||||
* annotationProcessorOptions {
|
||||
* arguments = ["room.schemaLocation": "$projectDir/schemas".toString()]
|
||||
* }
|
||||
* }
|
||||
* }
|
||||
* sourceSets {
|
||||
* androidTest.assets.srcDirs += files("$projectDir/schemas".toString())
|
||||
* }
|
||||
* }
|
||||
* </pre>
|
||||
*/
|
||||
@SuppressWarnings("all")
|
||||
/*
|
||||
I don't want to deal with anything codacy reported here. If just someone can find a way to use
|
||||
original MigrationTestHelper without this forking hack, this class will never exist.
|
||||
|
||||
- @TranceLove
|
||||
*/
|
||||
public class MigrationTestHelper extends TestWatcher {
|
||||
private static final String TAG = "MigrationTestHelper";
|
||||
private final String mAssetsFolder;
|
||||
private final SupportSQLiteOpenHelper.Factory mOpenFactory;
|
||||
private List<WeakReference<SupportSQLiteDatabase>> mManagedDatabases = new ArrayList<>();
|
||||
private List<WeakReference<RoomDatabase>> mManagedRoomDatabases = new ArrayList<>();
|
||||
private boolean mTestStarted;
|
||||
private Instrumentation mInstrumentation;
|
||||
|
||||
/**
|
||||
* Creates a new migration helper. It uses the Instrumentation context to load the schema (falls
|
||||
* back to the app resources) and the target context to create the database.
|
||||
*
|
||||
* @param instrumentation The instrumentation instance.
|
||||
* @param assetsFolder The asset folder in the assets directory.
|
||||
*/
|
||||
public MigrationTestHelper(Instrumentation instrumentation, String assetsFolder) {
|
||||
this(instrumentation, assetsFolder, new FrameworkSQLiteOpenHelperFactory());
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates a new migration helper. It uses the Instrumentation context to load the schema (falls
|
||||
* back to the app resources) and the target context to create the database.
|
||||
*
|
||||
* @param instrumentation The instrumentation instance.
|
||||
* @param assetsFolder The asset folder in the assets directory.
|
||||
* @param openFactory Factory class that allows creation of {@link SupportSQLiteOpenHelper}
|
||||
*/
|
||||
public MigrationTestHelper(
|
||||
Instrumentation instrumentation,
|
||||
String assetsFolder,
|
||||
SupportSQLiteOpenHelper.Factory openFactory) {
|
||||
mInstrumentation = instrumentation;
|
||||
if (assetsFolder.endsWith("/")) {
|
||||
assetsFolder = assetsFolder.substring(0, assetsFolder.length() - 1);
|
||||
}
|
||||
mAssetsFolder = assetsFolder;
|
||||
mOpenFactory = openFactory;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void starting(Description description) {
|
||||
super.starting(description);
|
||||
mTestStarted = true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates the database in the given version. If the database file already exists, it tries to
|
||||
* delete it first. If delete fails, throws an exception.
|
||||
*
|
||||
* @param name The name of the database.
|
||||
* @param version The version in which the database should be created.
|
||||
* @return A database connection which has the schema in the requested version.
|
||||
* @throws IOException If it cannot find the schema description in the assets folder.
|
||||
*/
|
||||
@SuppressLint("RestrictedApi")
|
||||
@SuppressWarnings("SameParameterValue")
|
||||
public SupportSQLiteDatabase createDatabase(String name, int version) throws IOException {
|
||||
File dbPath = mInstrumentation.getTargetContext().getDatabasePath(name);
|
||||
if (dbPath.exists()) {
|
||||
Log.d(TAG, "deleting database file " + name);
|
||||
if (!dbPath.delete()) {
|
||||
throw new IllegalStateException(
|
||||
"there is a database file and i could not delete"
|
||||
+ " it. Make sure you don't have any open connections to that database"
|
||||
+ " before calling this method.");
|
||||
}
|
||||
}
|
||||
SchemaBundle schemaBundle = loadSchema(version);
|
||||
RoomDatabase.MigrationContainer container = new RoomDatabase.MigrationContainer();
|
||||
DatabaseConfiguration configuration =
|
||||
new DatabaseConfiguration(
|
||||
mInstrumentation.getTargetContext(),
|
||||
name,
|
||||
mOpenFactory,
|
||||
container,
|
||||
null,
|
||||
true,
|
||||
RoomDatabase.JournalMode.TRUNCATE,
|
||||
ArchTaskExecutor.getIOThreadExecutor(),
|
||||
ArchTaskExecutor.getIOThreadExecutor(),
|
||||
false,
|
||||
true,
|
||||
false,
|
||||
Collections.<Integer>emptySet(),
|
||||
null,
|
||||
null);
|
||||
RoomOpenHelper roomOpenHelper =
|
||||
new RoomOpenHelper(
|
||||
configuration,
|
||||
new MigrationTestHelper.CreatingDelegate(schemaBundle.getDatabase()),
|
||||
schemaBundle.getDatabase().getIdentityHash(),
|
||||
// we pass the same hash twice since an old schema does not necessarily have
|
||||
// a legacy hash and we would not even persist it.
|
||||
schemaBundle.getDatabase().getIdentityHash());
|
||||
return openDatabase(name, roomOpenHelper);
|
||||
}
|
||||
|
||||
/**
|
||||
* Runs the given set of migrations on the provided database.
|
||||
*
|
||||
* <p>It uses the same algorithm that Room uses to choose migrations so the migrations instances
|
||||
* that are provided to this method must be sufficient to bring the database from current version
|
||||
* to the desired version.
|
||||
*
|
||||
* <p>After the migration, the method validates the database schema to ensure that migration
|
||||
* result matches the expected schema. Handling of dropped tables depends on the {@code
|
||||
* validateDroppedTables} argument. If set to true, the verification will fail if it finds a table
|
||||
* that is not registered in the Database. If set to false, extra tables in the database will be
|
||||
* ignored (this is the runtime library behavior).
|
||||
*
|
||||
* @param name The database name. You must first create this database via {@link
|
||||
* #createDatabase(String, int)}.
|
||||
* @param version The final version after applying the migrations.
|
||||
* @param validateDroppedTables If set to true, validation will fail if the database has unknown
|
||||
* tables.
|
||||
* @param migrations The list of available migrations.
|
||||
* @throws IOException If it cannot find the schema for {@code toVersion}.
|
||||
* @throws IllegalStateException If the schema validation fails.
|
||||
*/
|
||||
@SuppressLint("RestrictedApi")
|
||||
public SupportSQLiteDatabase runMigrationsAndValidate(
|
||||
String name, int version, boolean validateDroppedTables, Migration... migrations)
|
||||
throws IOException {
|
||||
File dbPath = mInstrumentation.getTargetContext().getDatabasePath(name);
|
||||
if (!dbPath.exists()) {
|
||||
throw new IllegalStateException(
|
||||
"Cannot find the database file for "
|
||||
+ name
|
||||
+ ". "
|
||||
+ "Before calling runMigrations, you must first create the database via "
|
||||
+ "createDatabase.");
|
||||
}
|
||||
SchemaBundle schemaBundle = loadSchema(version);
|
||||
RoomDatabase.MigrationContainer container = new RoomDatabase.MigrationContainer();
|
||||
container.addMigrations(migrations);
|
||||
DatabaseConfiguration configuration =
|
||||
new DatabaseConfiguration(
|
||||
mInstrumentation.getTargetContext(),
|
||||
name,
|
||||
mOpenFactory,
|
||||
container,
|
||||
null,
|
||||
true,
|
||||
RoomDatabase.JournalMode.TRUNCATE,
|
||||
ArchTaskExecutor.getIOThreadExecutor(),
|
||||
ArchTaskExecutor.getIOThreadExecutor(),
|
||||
false,
|
||||
true,
|
||||
false,
|
||||
Collections.<Integer>emptySet(),
|
||||
null,
|
||||
null);
|
||||
RoomOpenHelper roomOpenHelper =
|
||||
new RoomOpenHelper(
|
||||
configuration,
|
||||
new MigrationTestHelper.MigratingDelegate(
|
||||
schemaBundle.getDatabase(), validateDroppedTables),
|
||||
// we pass the same hash twice since an old schema does not necessarily have
|
||||
// a legacy hash and we would not even persist it.
|
||||
schemaBundle.getDatabase().getIdentityHash(),
|
||||
schemaBundle.getDatabase().getIdentityHash());
|
||||
return openDatabase(name, roomOpenHelper);
|
||||
}
|
||||
|
||||
private SupportSQLiteDatabase openDatabase(String name, RoomOpenHelper roomOpenHelper) {
|
||||
SupportSQLiteOpenHelper.Configuration config =
|
||||
SupportSQLiteOpenHelper.Configuration.builder(mInstrumentation.getTargetContext())
|
||||
.callback(roomOpenHelper)
|
||||
.name(name)
|
||||
.build();
|
||||
SupportSQLiteDatabase db = mOpenFactory.create(config).getWritableDatabase();
|
||||
mManagedDatabases.add(new WeakReference<>(db));
|
||||
return db;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void finished(Description description) {
|
||||
super.finished(description);
|
||||
for (WeakReference<SupportSQLiteDatabase> dbRef : mManagedDatabases) {
|
||||
SupportSQLiteDatabase db = dbRef.get();
|
||||
if (db != null && db.isOpen()) {
|
||||
try {
|
||||
db.close();
|
||||
} catch (Throwable ignored) {
|
||||
}
|
||||
}
|
||||
}
|
||||
for (WeakReference<RoomDatabase> dbRef : mManagedRoomDatabases) {
|
||||
final RoomDatabase roomDatabase = dbRef.get();
|
||||
if (roomDatabase != null) {
|
||||
roomDatabase.close();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Registers a database connection to be automatically closed when the test finishes.
|
||||
*
|
||||
* <p>This only works if {@code MigrationTestHelper} is registered as a Junit test rule via {@link
|
||||
* org.junit.Rule Rule} annotation.
|
||||
*
|
||||
* @param db The database connection that should be closed after the test finishes.
|
||||
*/
|
||||
public void closeWhenFinished(SupportSQLiteDatabase db) {
|
||||
if (!mTestStarted) {
|
||||
throw new IllegalStateException(
|
||||
"You cannot register a database to be closed before"
|
||||
+ " the test starts. Maybe you forgot to annotate MigrationTestHelper as a"
|
||||
+ " test rule? (@Rule)");
|
||||
}
|
||||
mManagedDatabases.add(new WeakReference<>(db));
|
||||
}
|
||||
|
||||
/**
|
||||
* Registers a database connection to be automatically closed when the test finishes.
|
||||
*
|
||||
* <p>This only works if {@code MigrationTestHelper} is registered as a Junit test rule via {@link
|
||||
* org.junit.Rule Rule} annotation.
|
||||
*
|
||||
* @param db The RoomDatabase instance which holds the database.
|
||||
*/
|
||||
public void closeWhenFinished(RoomDatabase db) {
|
||||
if (!mTestStarted) {
|
||||
throw new IllegalStateException(
|
||||
"You cannot register a database to be closed before"
|
||||
+ " the test starts. Maybe you forgot to annotate MigrationTestHelper as a"
|
||||
+ " test rule? (@Rule)");
|
||||
}
|
||||
mManagedRoomDatabases.add(new WeakReference<>(db));
|
||||
}
|
||||
|
||||
private SchemaBundle loadSchema(int version) throws IOException {
|
||||
try {
|
||||
return loadSchema(mInstrumentation.getContext(), version);
|
||||
} catch (FileNotFoundException testAssetsIOExceptions) {
|
||||
Log.w(
|
||||
TAG,
|
||||
"Could not find the schema file in the test assets. Checking the"
|
||||
+ " application assets");
|
||||
try {
|
||||
return loadSchema(mInstrumentation.getTargetContext(), version);
|
||||
} catch (FileNotFoundException appAssetsException) {
|
||||
appAssetsException.printStackTrace();
|
||||
// throw the test assets exception instead
|
||||
throw new FileNotFoundException(
|
||||
"Cannot find the schema file in the assets folder. "
|
||||
+ "Make sure to include the exported json schemas in your test assert "
|
||||
+ "inputs. See "
|
||||
+ "https://developer.android.com/training/data-storage/room/"
|
||||
+ "migrating-db-versions#export-schema for details. Missing file: "
|
||||
+ testAssetsIOExceptions.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* This is where loading behaviour differs from original code. Monkeypatched to force loading
|
||||
* of JSON schemas, without including the schema output directory
|
||||
*
|
||||
* - @TranceLove
|
||||
*/
|
||||
private SchemaBundle loadSchema(Context context, int version) throws IOException {
|
||||
InputStream input = new FileInputStream("./schemas/" + mAssetsFolder + "/" + version + ".json");
|
||||
return SchemaBundle.deserialize(input);
|
||||
}
|
||||
|
||||
@SuppressWarnings("WeakerAccess") /* synthetic access */
|
||||
static TableInfo toTableInfo(EntityBundle entityBundle) {
|
||||
return new TableInfo(
|
||||
entityBundle.getTableName(),
|
||||
toColumnMap(entityBundle),
|
||||
toForeignKeys(entityBundle.getForeignKeys()),
|
||||
toIndices(entityBundle.getIndices()));
|
||||
}
|
||||
|
||||
@SuppressWarnings("WeakerAccess") /* synthetic access */
|
||||
static FtsTableInfo toFtsTableInfo(FtsEntityBundle ftsEntityBundle) {
|
||||
return new FtsTableInfo(
|
||||
ftsEntityBundle.getTableName(),
|
||||
toColumnNamesSet(ftsEntityBundle),
|
||||
ftsEntityBundle.getCreateSql());
|
||||
}
|
||||
|
||||
@SuppressWarnings("WeakerAccess") /* synthetic access */
|
||||
static ViewInfo toViewInfo(DatabaseViewBundle viewBundle) {
|
||||
return new ViewInfo(viewBundle.getViewName(), viewBundle.createView());
|
||||
}
|
||||
|
||||
private static Set<TableInfo.Index> toIndices(List<IndexBundle> indices) {
|
||||
if (indices == null) {
|
||||
return Collections.emptySet();
|
||||
}
|
||||
Set<TableInfo.Index> result = new HashSet<>();
|
||||
for (IndexBundle bundle : indices) {
|
||||
result.add(new TableInfo.Index(bundle.getName(), bundle.isUnique(), bundle.getColumnNames()));
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
private static Set<TableInfo.ForeignKey> toForeignKeys(List<ForeignKeyBundle> bundles) {
|
||||
if (bundles == null) {
|
||||
return Collections.emptySet();
|
||||
}
|
||||
Set<TableInfo.ForeignKey> result = new HashSet<>(bundles.size());
|
||||
for (ForeignKeyBundle bundle : bundles) {
|
||||
result.add(
|
||||
new TableInfo.ForeignKey(
|
||||
bundle.getTable(),
|
||||
bundle.getOnDelete(),
|
||||
bundle.getOnUpdate(),
|
||||
bundle.getColumns(),
|
||||
bundle.getReferencedColumns()));
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
private static Set<String> toColumnNamesSet(EntityBundle entity) {
|
||||
Set<String> result = new HashSet<>();
|
||||
for (FieldBundle field : entity.getFields()) {
|
||||
result.add(field.getColumnName());
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
private static Map<String, TableInfo.Column> toColumnMap(EntityBundle entity) {
|
||||
Map<String, TableInfo.Column> result = new HashMap<>();
|
||||
for (FieldBundle bundle : entity.getFields()) {
|
||||
TableInfo.Column column = toColumn(entity, bundle);
|
||||
result.put(column.name, column);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
private static TableInfo.Column toColumn(EntityBundle entity, FieldBundle field) {
|
||||
return new TableInfo.Column(
|
||||
field.getColumnName(),
|
||||
field.getAffinity(),
|
||||
field.isNonNull(),
|
||||
findPrimaryKeyPosition(entity, field),
|
||||
field.getDefaultValue(),
|
||||
TableInfo.CREATED_FROM_ENTITY);
|
||||
}
|
||||
|
||||
private static int findPrimaryKeyPosition(EntityBundle entity, FieldBundle field) {
|
||||
List<String> columnNames = entity.getPrimaryKey().getColumnNames();
|
||||
int i = 0;
|
||||
for (String columnName : columnNames) {
|
||||
i++;
|
||||
if (field.getColumnName().equalsIgnoreCase(columnName)) {
|
||||
return i;
|
||||
}
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
static class MigratingDelegate extends MigrationTestHelper.RoomOpenHelperDelegate {
|
||||
private final boolean mVerifyDroppedTables;
|
||||
|
||||
MigratingDelegate(DatabaseBundle databaseBundle, boolean verifyDroppedTables) {
|
||||
super(databaseBundle);
|
||||
mVerifyDroppedTables = verifyDroppedTables;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void createAllTables(SupportSQLiteDatabase database) {
|
||||
throw new UnsupportedOperationException(
|
||||
"Was expecting to migrate but received create."
|
||||
+ "Make sure you have created the database first.");
|
||||
}
|
||||
|
||||
@NonNull
|
||||
@Override
|
||||
protected RoomOpenHelper.ValidationResult onValidateSchema(@NonNull SupportSQLiteDatabase db) {
|
||||
final Map<String, EntityBundle> tables = mDatabaseBundle.getEntitiesByTableName();
|
||||
for (EntityBundle entity : tables.values()) {
|
||||
if (entity instanceof FtsEntityBundle) {
|
||||
final FtsTableInfo expected = toFtsTableInfo((FtsEntityBundle) entity);
|
||||
final FtsTableInfo found = FtsTableInfo.read(db, entity.getTableName());
|
||||
if (!expected.equals(found)) {
|
||||
return new ValidationResult(
|
||||
false, expected.name + "\nExpected: " + expected + "\nFound: " + found);
|
||||
}
|
||||
} else {
|
||||
final TableInfo expected = toTableInfo(entity);
|
||||
final TableInfo found = TableInfo.read(db, entity.getTableName());
|
||||
if (!expected.equals(found)) {
|
||||
return new ValidationResult(
|
||||
false, expected.name + "\nExpected: " + expected + " \nfound: " + found);
|
||||
}
|
||||
}
|
||||
}
|
||||
for (DatabaseViewBundle view : mDatabaseBundle.getViews()) {
|
||||
final ViewInfo expected = toViewInfo(view);
|
||||
final ViewInfo found = ViewInfo.read(db, view.getViewName());
|
||||
if (!expected.equals(found)) {
|
||||
return new ValidationResult(
|
||||
false, expected + "\nExpected: " + expected + " \nfound: " + found);
|
||||
}
|
||||
}
|
||||
if (mVerifyDroppedTables) {
|
||||
// now ensure tables that should be removed are removed.
|
||||
Set<String> expectedTables = new HashSet<>();
|
||||
for (EntityBundle entity : tables.values()) {
|
||||
expectedTables.add(entity.getTableName());
|
||||
if (entity instanceof FtsEntityBundle) {
|
||||
expectedTables.addAll(((FtsEntityBundle) entity).getShadowTableNames());
|
||||
}
|
||||
}
|
||||
Cursor cursor =
|
||||
db.query(
|
||||
"SELECT name FROM sqlite_master WHERE type='table'" + " AND name NOT IN(?, ?, ?)",
|
||||
new String[] {Room.MASTER_TABLE_NAME, "android_metadata", "sqlite_sequence"});
|
||||
//noinspection TryFinallyCanBeTryWithResources
|
||||
try {
|
||||
while (cursor.moveToNext()) {
|
||||
final String tableName = cursor.getString(0);
|
||||
if (!expectedTables.contains(tableName)) {
|
||||
return new ValidationResult(false, "Unexpected table " + tableName);
|
||||
}
|
||||
}
|
||||
} finally {
|
||||
cursor.close();
|
||||
}
|
||||
}
|
||||
return new ValidationResult(true, null);
|
||||
}
|
||||
}
|
||||
|
||||
static class CreatingDelegate extends MigrationTestHelper.RoomOpenHelperDelegate {
|
||||
|
||||
CreatingDelegate(DatabaseBundle databaseBundle) {
|
||||
super(databaseBundle);
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void createAllTables(SupportSQLiteDatabase database) {
|
||||
for (String query : mDatabaseBundle.buildCreateQueries()) {
|
||||
database.execSQL(query);
|
||||
}
|
||||
}
|
||||
|
||||
@NonNull
|
||||
@Override
|
||||
protected RoomOpenHelper.ValidationResult onValidateSchema(@NonNull SupportSQLiteDatabase db) {
|
||||
throw new UnsupportedOperationException(
|
||||
"This open helper just creates the database but" + " it received a migration request.");
|
||||
}
|
||||
}
|
||||
|
||||
abstract static class RoomOpenHelperDelegate extends RoomOpenHelper.Delegate {
|
||||
final DatabaseBundle mDatabaseBundle;
|
||||
|
||||
RoomOpenHelperDelegate(DatabaseBundle databaseBundle) {
|
||||
super(databaseBundle.getVersion());
|
||||
mDatabaseBundle = databaseBundle;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void dropAllTables(SupportSQLiteDatabase database) {
|
||||
throw new UnsupportedOperationException("cannot drop all tables in the test");
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void onCreate(SupportSQLiteDatabase database) {}
|
||||
|
||||
@Override
|
||||
protected void onOpen(SupportSQLiteDatabase database) {}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user