Извлечение логики SQLBrite во внешний класс в Android

Question

В моем приложении чата я использую оболочку SQLBrite для обновления чата из локальной базы данных. В настоящее время моя деятельность включает в себя как пользовательский интерфейс, так и SQLBrite. Теперь я хочу извлечь логику SQLBrite во внешний класс. Поэтому, пока моя деятельность жива, мне нужно, чтобы мой извлеченный SQLBrite также был живым. В настоящее время у меня проблема с подписчиком. Я также извлек его во внешний класс, и его исходящий запрос все время происходил, хотя все было так же, как и во время работы, и это работало.

это старый код, где все было в одной деятельности: как я могу это сделать?

SqlBrite sqlBrite;
sqlBrite = SqlBrite.create(DatabaseManager.DatabaseHelper);
private final CompositeSubscription subscriptions = new CompositeSubscription();

private void saveMessage(Message message) {

        ContentValues values = new ContentValues();
        values.put(DatabaseContract.MessageEntry.COLUMN_NAME_MESSAGE_ID, message.getId());
        values.put(DatabaseContract.MessageEntry.COLUMN_NAME_SERIAL_NUMBER, message.getSerialNumber());
        values.put(DatabaseContract.MessageEntry.COLUMN_NAME_TEXT, message.getText());

        sqlBrite.insert(DatabaseContract.MessageEntry.TABLE_NAME, values, SQLiteDatabase.CONFLICT_IGNORE);
    }

    private void subscribeToDbChanges() {
        String NEW_MSG_QUERY = "SELECT * FROM "
                + DatabaseContract.MessageEntry.TABLE_NAME
                + " WHERE "
                + DatabaseContract.MessageEntry.COLUMN_NAME_CREATED_AT_MILLS
                + " >= ? ORDER BY "
                + DatabaseContract.MessageEntry.COLUMN_NAME_CREATED_AT_MILLS
                + " DESC";

        String grpId = String.valueOf(groupId);
        String msgDate = String.valueOf(dividerMsgDate);

        Observable<Query> freshMessages = sqlBrite.createQuery(DatabaseContract.MessageEntry.TABLE_NAME, NEW_MSG_QUERY, grpId, msgDate);
        subscriptions.add(
                freshMessages.subscribe(query -> parseQueryData(query)));
    }

    private void parseQueryData(Query query) {
        Log.d(TAG, "subscriber called");
        List<Message> messages = new ArrayList<>();
        Cursor c = query.run();
        try {
            while (c.moveToNext()) {
                Message message = new Message();
                message.setLocalId(c.getInt(c.getColumnIndexOrThrow(DatabaseContract.MessageEntry._ID)));
                message.setId(c.getInt(c.getColumnIndexOrThrow(DatabaseContract.MessageEntry.COLUMN_NAME_MESSAGE_ID)));

                messages.add(message);
            }
        } finally {
            c.close();
        }

        updateChatList(messages, "new");
    }

Answer 1

Я не уверен на 100%, что понял ваш вопрос, но я хотел бы создать класс помощника SQLBrite с кодом, который вы предоставили выше, и создать его экземпляр в onCreate() действия.

Кроме того, вы должны передать события onResume() и onPause() вашему вспомогательному классу (потому что это нужно только в том случае, когда активность активна) и вернуть результаты через Callback.

 MyActivity.java


 public class MyActivity extends Activity implements SQLHelper.ResultListener {

   SQLHelper mSQLHelper;

   public void onCreate() {
     mSQLHelper = new SQLHelper(this);
   }


   public void onResume() {
     mSQLHelper.onResume();
   }


   public void onPause() {
     mSQLHelper.onPause();
   }

   @
   Override
   public void onUpdateChatList(String _message) {
     //show it
   }
 }


 SQLHelper.java

 public class SQLHelper {

   ResultListener mListener;

   public interface ResultListener {
     public void onUpdateChatList(String _message);
   }

   public void SQLHelper(ResultListener _resultListener) {
     mListener = _resultListener;
   }


   public void onResume() {
     //Here subscribe to your query
   }


   public void onPause() {
     //here unsubscribe
   }

   private void parseQueryData(Query query) {
     //... your code
     mListener.onUpdateChatList(String _message);
   }
 }

Надеюсь, это поможет.