init

app/src/main/java/cc/n0th1ng/tripmoney/data/dao/CategoryDao.kt

@@ -0,0 +1,25 @@
+package cc.n0th1ng.tripmoney.data.dao
+
+import androidx.room.Dao
+import androidx.room.Insert
+import androidx.room.Query
+import androidx.room.Transaction
+import androidx.room.Upsert
+import cc.n0th1ng.tripmoney.data.entity.Category
+import kotlinx.coroutines.flow.Flow
+
+@Dao
+interface CategoryDao {
+    @Upsert
+    suspend fun insert(category: Category)
+
+
+    @Transaction
+    @Query(
+        """
+        SELECT * FROM category
+    """
+    )
+    fun categories(): Flow<List<Category>>
+
+}

app/src/main/java/cc/n0th1ng/tripmoney/data/dao/ExpenseDao.kt

@@ -0,0 +1,29 @@
+package cc.n0th1ng.tripmoney.data.dao
+
+import androidx.paging.PagingSource
+import androidx.room.Dao
+import androidx.room.Delete
+import androidx.room.Insert
+import androidx.room.Query
+import androidx.room.Transaction
+import androidx.room.Upsert
+import cc.n0th1ng.tripmoney.data.entity.Expense
+import cc.n0th1ng.tripmoney.data.entity.ExpenseDto
+
+@Dao
+interface ExpenseDao {
+    @Upsert
+    suspend fun insert(expense: Expense)
+
+    @Transaction
+    @Query(
+        """
+        SELECT * FROM expense WHERE trip_id = :tripId
+        ORDER BY DATETIME(expense.datetime) DESC
+    """
+    )
+    fun expenseDto(tripId: Int): PagingSource<Int, ExpenseDto>
+
+    @Delete
+    suspend fun delete(expense: Expense)
+}

app/src/main/java/cc/n0th1ng/tripmoney/data/dao/TripDao.kt

@@ -0,0 +1,22 @@
+package cc.n0th1ng.tripmoney.data.dao
+
+import androidx.paging.PagingSource
+import androidx.room.Dao
+import androidx.room.Insert
+import androidx.room.Query
+import androidx.room.Upsert
+import cc.n0th1ng.tripmoney.data.entity.Trip
+
+@Dao
+interface TripDao {
+    @Upsert
+    suspend fun insert(trip: Trip)
+
+    @Query(
+        """
+        SELECT * FROM trip
+    """
+    )
+    fun tripsPaged(): PagingSource<Int, Trip>
+
+}