android - 将新数据保存到另一个领域数据库并替换当前

Question

现在的情况

在我的应用程序中，我使用realm database从下载的.insertJsonReaderjson file

现在：一切正常，但保存这么多数据需要几分钟（2 到 5 分钟），仅用于解析保存操作。（我OKHTTP用来下载一个json文件--.txt和InputStream-> JsonReader-> Gson->realm.insert用于解析-插入操作）

可能的改进想法

由于在我的应用程序逻辑中，此操作也可能在后台线程上完成，因此我在徘徊是否可以执行如下操作：

1. 从互联网异步下载数据
2. 将数据保存到new realm database
3. 完成后，提示用户更新数据
4. 从新数据库中取出一些表并通过批量删除插入将它们放入旧表中（我不在乎丢失这些表的旧数据，新数据始终是正确的，用户无法编辑它们） .

该实施可能存在的问题

我对这个解决方案的开发很好，但是在执行这样的重构操作之前，我有几个问题：

1. 我可以database2在 a 中执行保存操作background thread并让用户使用UIand或者两个 dbsdatabase1在操作main thread期间都将被锁定database2 insert？
2. 如果我当前的数据库使用，我可以只传递不同的数据库名称default configurations来创建另一个领域数据库吗？custom configurations

这就是我想为最终的替换操作做的事情（obv 这只是一个示例，只是从中提取概念）：

Realm oldRealm = Realm.getDefaultInstance();
Realm newRealm = Realm.getInstance(secondConfig);

//assume it's inside a transaction
oldRealm.delete(mytable.class);
oldRealm.insert(newRealm.where(myTable.class).findAll());

对这个：

• 这是一个合理的解决方案吗？
• 这个解决方案会比使用 JsonReader 下载和插入更快吗？
• 有没有更好的方法呢？

谢谢大家，很抱歉发了这么长的帖子/英语不好

编辑

我的下载保存代码（简化。我同步下载了 +- 30 个文件并将它们保存到我的数据库中。最大的一个大约是 70Mb，写入事务确实需要很多时间）：

我删除了无用的代码，只留下了相关部分。一直占用的行是插入数据库。我也尝试过不使用 Gson，但我需要它，因为

//i'm inside an AsyncTask here
@Override
protected Void doInBackground(String... params) {
    Realm realm = null;
    try {
        realm = Realm.getDefaultInstance();

        String url = myDownloadFileURL;

        //here I download my files with OkHttp
        OkHttpClient client = new OkHttpClient.Builder()
                .connectTimeout(10, TimeUnit.SECONDS)
                .writeTimeout(600, TimeUnit.SECONDS)
                .readTimeout(600, TimeUnit.SECONDS)
                .retryOnConnectionFailure(true)
                .build();

        Request request = new Request.Builder().url(url)
                .addHeader("Content-Type", "application/json")
                .addHeader("Connection", "close")
                .build();
        Response response = client.newCall(request).execute();

        ResponseBody responseBody = response.body();

        if (responseBody == null) {
            return null;
        }

        // I save all my files into the internal storage because otherwise they will make the connection timeout
        File extStorageDirectory = Environment.getExternalStorageDirectory();
        File myFolder = new File(extStorageDirectory, BuildConfig.FLAVOR);
        myFolder.mkdirs();
        final File file = new File(myFolder, fileName + ".txt");
        FileOutputStream outputStream = new FileOutputStream(file);
        InputStream is = responseBody.byteStream();
        byte[] buffer = new byte[4096]; //Buffer size, Usually 1024-4096
        int len;
        while ((len = is.read(buffer, 0, buffer.length)) > 0) {
            outputStream.write(buffer, 0, len);
        }
        outputStream.flush();
        outputStream.close();

        responseBody.close();
        client.connectionPool().evictAll();

        //here I analyze my downloaded data and I save them to realm.
        //I put only one case, they are all the same :)
        switch (fileName) {
            case "Cities": {
                realm.executeTransaction(new Realm.Transaction() {
                    @Override
                    public void execute(Realm realm) {
                        try {
                           // {0} --> REFER BELOW
                        } catch (Exception error) {
                            //removed not useful code
                        }
                    }
                });
                break;
            }
            default:
                break;
        }
        response.close();

    } catch (IOException error) {
        //removed not useful code
    } finally {
        if (realm != null) {
            realm.close();
        }
    }
    return null;
}

@Override
protected void onPostExecute(Void v) {
    //removed not useful code
}

{0} --> 参考下面

对于那部分代码（较慢的部分），我尝试了很多方法.. 这两种方法对于性能和非错误抛出是最好的：

1）使用解析列表

Log.wtf("SYNC", "City - start delete");
realm.delete(City.class);
Log.wtf("SYNC", "City - end delete, start create");
BufferedReader reader = new BufferedReader(new FileReader(file));
realm.insert((List<City>) gson.fromJson(reader, new TypeToken<List<City>>(){}.getType()));
Log.wtf("SYNC", "City - end create");

2) 使用 JsonReader

Log.wtf("SYNC", "City - start delete");
realm.delete(Meter.class);
Log.wtf("SYNC", "City - end delete, start create");
InputStream is = new FileInputStream(file);
JsonReader jReader = new JsonReader(new InputStreamReader(is));
jReader.beginArray();
while (jReader.hasNext()) {
    realm.insert((City) gson.fromJson(jReader, City.class));
}
jReader.endArray();
jReader.close();
Log.wtf("SYNC", "City - end create");

在这两种情况下，插入操作都很长。

问题可能是 Gson，但我需要解析我的模型，因为我有一些必须使用自定义 typeAdapter 解析的日期字段。

标签： androidrealm