Хочу сделать обновление БД у пользователей приложения т.к. в БД были добавлены новые записи (т.е. из новой версии БД скопировать в БД пользователей только те записи, которых у них нет.). БД содержит одну таблицу table1 с полями: _id (autoincrement), col1 (текстовое), col2 (текстовое) type (integer), favorites (integer).
Но не понимаю как это можно реализовать. Кто направит на путь истинный?
ВОТ выкладываю код из двух классов
public class Contract {
private Contract() {
};
public static final class Entry implements BaseColumns {
public final static String TABLE_NAME = "table1";
public final static String _ID = BaseColumns._ID;
public final static String COLUMN_WORD = "col1";
public final static String COLUMN_TRANSLATION = "col2";
public final static String COLUMN_TYPE = "type";
public final static String COLUMN_FAVORITES = "favorites";
}
}
Второй класс
public class DBHeler extends SQLiteOpenHelper {
//Пусть к БД
private static String DB_PATH = "/data/data/ru.test.dbtest/databases/";
//Имя файла базы данных
private static final String DATABASE_NAME = "dbase.db";
//Версия базы данных. При изменении схемы увеличить на единицу
private static final int DATABASE_VERSION = 2;
//Объектная переменная типа SQLiteDatabase
public SQLiteDatabase database;
private Context myContext;
//Конструктор
//Третий параметр null в суперклассе используется для работы с курсорами. Сейчас их не используем, поэтому оставим в покое.
public DBHeler(Context context) {
super(context, DATABASE_NAME, null, DATABASE_VERSION);
this.myContext = context;
}
public void createDataBase() throws IOException {
boolean dbExist = checkDataBase();
if(dbExist){
//ничего не делать - база уже есть
}else{
//вызывая этот метод создаем пустую базу, позже она будет перезаписана
this.getReadableDatabase();
try {
copyDataBase();
} catch (IOException e) {
throw new Error("Error copying database");
}
}
}
/**
* Проверяет, существует ли уже эта база, чтобы не копировать каждый раз при запуске приложения
* @return true если существует, false если не существует
*/
private boolean checkDataBase(){
SQLiteDatabase checkDB = null;
try {
String myPath = DB_PATH + DATABASE_NAME;
checkDB = SQLiteDatabase.openDatabase(myPath, null, SQLiteDatabase.OPEN_READONLY);
} catch(SQLiteException e){
//база еще не существует
}
if(checkDB != null){
checkDB.close();
}
return checkDB != null ? true : false;
}
/**
* Копирует базу из папки assets заместо созданной локальной БД
* Выполняется путем копирования потока байтов.
* */
private void copyDataBase() throws IOException{
//Открываем локальную БД как входящий поток
InputStream myInput = myContext.getAssets().open(DATABASE_NAME);
//Путь ко вновь созданной БД
String outFileName = DB_PATH + DATABASE_NAME;
//Открываем пустую базу данных как исходящий поток
OutputStream myOutput = new FileOutputStream(outFileName);
//перемещаем байты из входящего файла в исходящий
byte[] buffer = new byte[1024];
int length;
while ((length = myInput.read(buffer))>0){
myOutput.write(buffer, 0, length);
}
//закрываем потоки
myOutput.flush();
myOutput.close();
myInput.close();
}
public void openDataBase() throws SQLException {
//открываем БД
String myPath = DB_PATH + DATABASE_NAME;
database = SQLiteDatabase.openDatabase(myPath, null, SQLiteDatabase.OPEN_READWRITE);
}
@Override
public synchronized void close() {
if(database != null)
database.close();
super.close();
}
@Override
public void onCreate(SQLiteDatabase db) {
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
String query = "SELECT * from " + Contract.Entry.TABLE_NAME;
Cursor cr = db.rawQuery(query, null);
if (newVersion == 2) {
db.beginTransaction();
try {
db.execSQL("CREATE TABLE table2 (_id INTEGER, col1 TEXT NOT NULL, col2 TEXT NOT NULL, type INTEGER NOT NULL, " +
"favorites INTEGER NOT NULL, PRIMARY KEY (_id, col1, col2, type, favorites))");
while (cr.moveToNext()) {
int idxCol1 = cr.getColumnIndex("col1");
int idxCol2 = cr.getColumnIndex("col2");
int idxID = cr.getColumnIndex("_id");
int idxType = cr.getColumnIndex("type");
int idxFavorites = cr.getColumnIndex("favorites");
String strCol1 = cr.getString(idxCol1);
String strCol2 = cr.getString(idxCol2);
String strID = cr.getString(idxID);
String strType = cr.getString(idxType);
String strFavorites = cr.getString(idxFavorites);
ContentValues cv = new ContentValues();
cv.put("col1", strCol1);
cv.put("col2", strCol2);
cv.put("_id", strID);
cv.put("type", strType);
cv.put("favorites", strFavorites);
long newRowId = db.insert("table2", null, cv);
}
db.execSQL("drop table table1");
db.execSQL("alter table table2 rename to table1");
} finally {
db.endTransaction();
}
}
}
}
БД закидывается в папку assets, т.е. заменяется файл db и приложение заново собирается в apk