Предварительно заполнить базу данных номеров залпом - PullRequest
0 голосов
/ 25 февраля 2019

Предисловие

Итак, я довольно новичок в разработке для Android, и в данный момент я занимаюсь разработкой приложения, которое извлекает данные с сервера REST в качестве ответа JSON.Приложение должно быть работоспособным в автономном режиме, поэтому, чтобы сделать это, основываясь на рекомендациях Android, я решил использовать Room Database и следовал этому уроку: Учебник Room with View .

Само учебное пособие было хорошо сделано, и я смог следовать базовым настройкам и немного адаптировать его под свои нужды.

Задача

Однако у меня возникли некоторые проблемы с предварительным заполнением базы данных RoomDatabase данными с моего сервера.В учебнике проиллюстрирован аспект предварительного заполнения с использованием статических данных, и это прекрасно работает.Однако, когда я пытаюсь изменить это, чтобы использовать данные, извлеченные с сервера через запрос Volley, я сталкиваюсь с проблемами.

Код

Когда я пытаюсь запустить следующее

public abstract class AppDatabase extends RoomDatabase {

    public abstract MachineMovementDao machineMovementDao();

    private static volatile AppDatabase INSTANCE;
    private static Context ctx;

    public static AppDatabase getDatabase(final Context context) {
        ctx = context;
        if (INSTANCE == null) {
            synchronized (AppDatabase.class) {
                if (INSTANCE == null) {
                    INSTANCE = Room.databaseBuilder(context.getApplicationContext(),
                        AppDatabase.class, "local_database")
                        .addCallback(sRoomDatabaseCallback)
                        //.fallbackToDestructiveMigration()
                        .build();
                }
            }
        }
        return INSTANCE;
    }

    public static RoomDatabase.Callback sRoomDatabaseCallback =
        new RoomDatabase.Callback() {

        @Override
        public void onOpen(@NonNull SupportSQLiteDatabase db) {
            super.onOpen(db);
            new PopulateDbAsync(INSTANCE).execute();
        }
    };

    private static class PopulateDbAsync extends AsyncTask<Void, Void, Void> {

        private final MachineMovementDao machineMovementDao;

        PopulateDbAsync(AppDatabase db) {
            machineMovementDao = db.machineMovementDao();
        }

        @Override
        protected Void doInBackground(final Void... params) {
            machineMovementDao.deleteAll();

            String url = "http://192.168.10.124:8888/movement/machine/all";

            JsonArrayRequest jsonArrayRequest = new JsonArrayRequest
                (Request.Method.GET, url, null, new Response.Listener<JSONArray>() {
                    @Override
                    public void onResponse(JSONArray response) {
                        try {
                            for (int i = 0; i < response.length(); i++) {
                                JSONObject jsonObject = response.getJSONObject(i);
                                MachineMovement movement = new MachineMovement(jsonObject);
                                machineMovementDao.insert(movement);
                            }
                        } catch (JSONException e) {
                            System.out.println(e.toString());
                        }

                    }
                }, new Response.ErrorListener() {
                    @Override
                    public void onErrorResponse(VolleyError volleyError) {
                        System.out.println(">>>>>>>>>>>>>>>>>>> > Error:" + volleyError.toString());
                    }
            });

            DataVolleyRequest.getInstance(ctx.getApplicationContext())
                .addToRequestQueue(jsonArrayRequest);

            /*
            MachineMovement movement = new MachineMovement("AMUSEMENT_MACHINE", "00003",
                "SN969NI7VCSXN", 1);
            movement.setLocationFromID(1);
            movement.setLocationToID(2);
            machineMovementDao.insert(movement);
            movement = new MachineMovement("AMUSEMENT_MACHINE", "00003",
                "SN969NI7VCSXN", 1);
            movement.setLocationFromID(2);
            movement.setLocationToID(1);
            machineMovementDao.insert(movement);
            */
            return null;
        }
    }
}

Ошибка

Я получаюследующая ошибка

E/AndroidRuntime: FATAL EXCEPTION: main
Process: com.sunnygroup.backoffice.tdcapp, PID: 18175
java.lang.IllegalStateException: Cannot access database on the main thread since it may potentially lock the UI for a long period of time.
    at android.arch.persistence.room.RoomDatabase.assertNotMainThread(RoomDatabase.java:204)
    at android.arch.persistence.room.RoomDatabase.beginTransaction(RoomDatabase.java:251)
    at com.sunnygroup.backoffice.tdcapp.daos.MachineMovementDao_Impl.insert(MachineMovementDao_Impl.java:115)
    at com.sunnygroup.backoffice.tdcapp.database.AppDatabase$PopulateDbAsync$1.onResponse(AppDatabase.java:78)
    at com.sunnygroup.backoffice.tdcapp.database.AppDatabase$PopulateDbAsync$1.onResponse(AppDatabase.java:71)
    at com.android.volley.toolbox.JsonRequest.deliverResponse(JsonRequest.java:90)
    at com.android.volley.ExecutorDelivery$ResponseDeliveryRunnable.run(ExecutorDelivery.java:102)
    at android.os.Handler.handleCallback(Handler.java:739)
    at android.os.Handler.dispatchMessage(Handler.java:95)
    at android.os.Looper.loop(Looper.java:135)
    at android.app.ActivityThread.main(ActivityThread.java:5593)
    at java.lang.reflect.Method.invoke(Native Method)
    at java.lang.reflect.Method.invoke(Method.java:372)
    at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:960)
    at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:755)

строка 78 - это строка в моем коде, где вы видите

machineMovementDao.insert(movement);

Любая помощь будет принята с благодарностью

1 Ответ

0 голосов
/ 25 февраля 2019

Вы можете разрешить запуск комнаты в главном потоке (https://developer.android.com/reference/androidx/room/RoomDatabase.Builder.html#allowMainThreadQueries())

В вашем случае:

AppDatabase.class, "local_database")
                        .addCallback(sRoomDatabaseCallback)
                        .allowMainThreadQueries()
                        .build();

Обратите внимание , что это не рекомендуется дляпроизводственные приложения.

Или вы можете запустить это в фоновом потоке. Вы можете либо выполнить эту инструкцию в asyncTask, либо посмотреть на интеграцию RxJava в вашу реализацию Room. Здесь является примером.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...