app/src/main/java/net/ktnx/mobileledger/dao/ProfileDAO.java

   1 /*
   2  * Copyright © 2021 Damyan Ivanov.
   3  * This file is part of MoLe.
   4  * MoLe is free software: you can distribute it and/or modify it
   5  * under the term of the GNU General Public License as published by
   6  * the Free Software Foundation, either version 3 of the License, or
   7  * (at your opinion), any later version.
   8  *
   9  * MoLe is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12  * GNU General Public License terms for details.
  13  *
  14  * You should have received a copy of the GNU General Public License
  15  * along with MoLe. If not, see <https://www.gnu.org/licenses/>.
  16  */
  17
  18 package net.ktnx.mobileledger.dao;
  19
  20 import androidx.lifecycle.LiveData;
  21 import androidx.room.Dao;
  22 import androidx.room.Delete;
  23 import androidx.room.Insert;
  24 import androidx.room.OnConflictStrategy;
  25 import androidx.room.Query;
  26 import androidx.room.Transaction;
  27 import androidx.room.Update;
  28
  29 import net.ktnx.mobileledger.db.Profile;
  30
  31 import java.util.List;
  32
  33 @Dao
  34 public abstract class ProfileDAO extends BaseDAO<Profile> {
  35     @Insert(onConflict = OnConflictStrategy.REPLACE)
  36     abstract long insertSync(Profile item);
  37
  38     @Transaction
  39     public long insertLastSync(Profile item) {
  40         int count = getProfileCountSync();
  41         item.setOrderNo(count + 1);
  42         return insertSync(item);
  43     }
  44     public void insertLast(Profile item, OnInsertedReceiver onInsertedReceiver) {
  45         BaseDAO.runAsync(() -> {
  46             long id = insertLastSync(item);
  47             if (onInsertedReceiver != null)
  48                 onInsertedReceiver.onInsert(id);
  49         });
  50     }
  51
  52     @Update
  53     abstract void updateSync(Profile item);
  54
  55     @Delete
  56     public abstract void deleteSync(Profile item);
  57
  58     @Query("select * from profiles where id = :profileId")
  59     public abstract Profile getByIdSync(long profileId);
  60
  61     @Query("SELECT * FROM profiles WHERE id=:profileId")
  62     public abstract LiveData<Profile> getById(long profileId);
  63
  64     @Query("SELECT * FROM profiles ORDER BY order_no")
  65     public abstract List<Profile> getAllOrderedSync();
  66
  67     @Query("SELECT * FROM profiles ORDER BY order_no")
  68     public abstract LiveData<List<Profile>> getAllOrdered();
  69
  70     @Query("SELECT * FROM profiles LIMIT 1")
  71     public abstract Profile getAnySync();
  72
  73     @Query("SELECT * FROM profiles WHERE uuid=:uuid")
  74     public abstract LiveData<Profile> getByUuid(String uuid);
  75
  76     @Query("SELECT * FROM profiles WHERE uuid=:uuid")
  77     public abstract Profile getByUuidSync(String uuid);
  78
  79     @Query("SELECT MAX(order_no) FROM profiles")
  80     public abstract int getProfileCountSync();
  81     public void updateOrderSync(List<Profile> list) {
  82         if (list == null)
  83             list = getAllOrderedSync();
  84         int order = 1;
  85         for (Profile p : list) {
  86             p.setOrderNo(order++);
  87             updateSync(p);
  88         }
  89     }
  90     public void updateOrder(List<Profile> list, Runnable onDone) {
  91         BaseDAO.runAsync(() -> {
  92             updateOrderSync(list);
  93             if (onDone != null)
  94                 onDone.run();
  95
  96         });
  97     }
  98 }