如何将领域与异步获取请求一起使用？

Question

我遇到过这种情况满足我的要求：

步骤 1. 将数据保存到移动设备 phone（领域）

中的本地数据库

step 2.上传本地数据到服务器，成功后服务器会return数据id 步骤 3. 通过步骤 2

获得的 returned ids 删除本地数据库中的记录

Realm.open({schema:[MySchame],encryptionKey:getRealmKey()})
        .then(realm =>{
            realm.write(() => {
                // 1. get all step data from db
                let objetcs = realm.objects('MySchema');
                // 2. upload obtained data to server
                if(objetcs.length > 0){
                    let recordArr = [];
                    for (let o of steps){
                        recordArr.push(o.get());
                    }
                   uploadDataToServer(recordArr,(res)=>{
                        //3. filter the uploaded steps and delete them
                        let uploadedSteps = realm.objects('MySchema').filtered('id=[=10=]',res.id);
                        if(uploadedSteps.length > 0){
                            realm.delete(uploadedSteps);
                        }
                    });
                }
            });
            realm.close();
        })
        .catch(error =>{
            console.log(error);
        });

但这并不像预期的那样有效，似乎数据库比网络成功回调早关闭。感谢您的任何想法。

Answer 1

首先像下面这样创建一个服务

import repository from "./realmConfig";

let CatalogsService = {
    findAll: function () {
        return repository.objects("CatalogsModel");
    },

    save: function (catalogs) {
        repository.write(() => {
            repository.create("CatalogsModel", catalogs);
        });
    },
    delete: function () {
        repository.write(() => {
            let all = repository.objects("CatalogsModel");
            repository.delete(all);
        });
    },

    update: function (catalogs, callback) {
        if (!callback) return;
        repository.write(() => {
            callback();
            catalogs.updatedAt = new Date();
        });
    }
};

module.exports = CatalogsService;

我的 realmConfig 文件是

import Realm from "realm";

class CatalogsModel extends Realm.Object { }
CatalogsModel.schema = {
    name: "CatalogsModel",
    primaryKey: "id",
    properties: {
        id: "string",
        name: "string",
        url: "string",
        status: "int"
    }
};
class OffersModel extends Realm.Object { }
OffersModel.schema = {
    name: "OffersModel",
    primaryKey: "id",
    properties: {
        id: "string",
        name: "string",
        url: "string",
        status: "int",
        machineId: "string",
        machineName: "string"
    }
};

export default new Realm({
    schema: [CatalogsModel, OffersModel],
    schemaVersion: 1,
    deleteRealmIfMigrationNeeded: true

});

现在在调用 async 服务器调用的地方导入 Service.js 并完成你的工作。参考下面的代码

import CatalogService from './path/to/CatalogService .js'

//get objects
var catalogs = CatalogsService.findAll();

// fire async function , I prefer axios for network calls

Axios.post("SERVER_URL", {
        data: catalogs
    })
    .then(function (response) {
        if (response.success)
            CatalogsService.delete()
    }

我假设您可以根据需要轻松修改 findAll() 和 delete() 方法

Answer 2

最后，我使用这样的领域：

let realm = new Realm({schema:[JOB_SCHEMA.jobTrack],encryptionKey:getRealmKey()});
        let objects = realm.objects('JobTrack');
        realm.beginTransaction();
        realm.delete(objects);
        realm.commitTransaction();
        realm.close();

如何将领域与异步获取请求一起使用？

How to use realm with async fetch request?

react-native

mobile

async-await

realm-js