public void upgrade(Context context) {
//надо найти файл с описанием прошлой базы
//в ней есть версия
/*если новая версия больше - посмотреть какие поля есть в моделях, которых нет в файле описания
если такие есть - добавить
создать новый файл описания*/
String path = context.getFilesDir().getAbsolutePath() + "/db_version.txt";
File file = new File(path);
int lastDBVersion = -1;
boolean needCreateFile = false;
boolean needApplyUpdates = false;
List<String> savedFields = null;
//файл существует
if (file.exists()) {
BufferedReader br = null;
try {
br = new BufferedReader(new FileReader(file));
String line = br.readLine();
lastDBVersion = Integer.parseInt(line);
} catch (Exception ex) {
ex.printStackTrace();
} finally {
try {
if (br != null) {
br.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
} else {
//
needApplyUpdates = true;
}
//костыль при переходе на версию
//boolean needChangeEventTypeValue = false;
//dbVersion += 1;
if (lastDBVersion != -1 && lastDBVersion < dbVersion) {
needApplyUpdates = true;
}
if (needApplyUpdates) {
//читаем старый список
savedFields = new ArrayList<>();
//создаем список из полей в бд
for (Class classModel : models) {
String tableName = getTableName(classModel);
Cursor cursor = ActiveAndroid.getDatabase().rawQuery("PRAGMA table_info(" + tableName + ")", null);
try {
int nameIdx = cursor.getColumnIndexOrThrow("name");
int typeIdx = cursor.getColumnIndexOrThrow("type");
while (cursor.moveToNext()) {
String type = cursor.getString(typeIdx);
String name = cursor.getString(nameIdx);
savedFields.add(tableName + "." + name + "." + type);
}
} finally {
cursor.close();
}
}
//создаем новый список
List<FieldClassStruct> newFields = new ArrayList<>();
for (Class model : models) {
Set<Field> modelFields = getClassFields(model);
for (Field field : modelFields) {
newFields.add(new FieldClassStruct(field, model));
}
}
try {
//ActiveAndroid.beginTransaction();
//сравниваем новый список со старым
for (FieldClassStruct newField : newFields) {
if (!savedFields.contains(newField.getDesc())) {
makeAlterForField(newField);
}
}
} catch (Exception ex) {
ex.printStackTrace();
} finally {
/*ActiveAndroid.setTransactionSuccessful();
ActiveAndroid.endTransaction();*/
}
}
/*ActiveAndroid.dispose();
ActiveAndroid.initialize(configurationBuilder.create());*/
//сохраняем новый список
file.delete();
BufferedWriter wr = null;
try {
wr = new BufferedWriter(new FileWriter(file));
wr.write(dbVersion + "\n");
} catch (IOException e) {
e.printStackTrace();
} finally {
if (wr != null) {
try {
wr.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}@Override
public Response load(Uri uri, int networkPolicy) throws IOException {
final AtomicReference<Object> notifier = new AtomicReference<>();
serverId = "https://" + Utils.API_SERVER_HTTP + "/download/" + serverId;
fileDownloader = new FileDownloader(serverId, outPath, true, new FileDownloader.IFileDownloaderListener() {
@Override
public void onProgress(int progress) {
}
@Override
public void onSuccess() {
synchronized (notifier) {
try {
notifier.set(new Response(decodeBitmap(outPath), false));
} catch (Exception ex) {
ex.printStackTrace();
notifier.set(new Exception());
} finally {
notifier.notify();
}
}
}
@Override
public void onError() {
synchronized (notifier) {
notifier.set(new Exception());
notifier.notify();
}
}
}, staticHandler);
fileDownloader.execute();
synchronized (notifier) {
try {
while (notifier.get() == null)
notifier.wait();
} catch (Exception ex) {
ex.printStackTrace();
}
}
if (notifier.get() instanceof Exception)
{
throw new ResponseException("File cannot be downloaded", 0, 404);
}
return (Response) notifier.get();
}