atridad/Mealient
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

Insert all recipes in one query

Browse Source
This commit is contained in:
Kirill Kamakin
2022-11-13 13:17:55 +01:00
parent b7e8054d38
commit 946f34cb37
2 changed files with 5 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
app/src/main/java/gq/kirmanak/mealient/data/recipes/db/RecipeStorageImpl.kt
View File

@@ -23,23 +23,17 @@ class RecipeStorageImpl @Inject constructor(
) : RecipeStorage { ) : RecipeStorage {
private val recipeDao: RecipeDao by lazy { db.recipeDao() } private val recipeDao: RecipeDao by lazy { db.recipeDao() }
override suspend fun saveRecipes( override suspend fun saveRecipes(recipes: List<RecipeSummaryInfo>) {
recipes: List<RecipeSummaryInfo>
) = db.withTransaction {
logger.v { "saveRecipes() called with $recipes" } logger.v { "saveRecipes() called with $recipes" }
val entities = recipes.map { it.toRecipeSummaryEntity() }
for (recipe in recipes) { logger.v { "saveRecipes: entities = $entities" }
val recipeSummaryEntity = recipe.toRecipeSummaryEntity() db.withTransaction { recipeDao.insertRecipes(entities) }
recipeDao.insertRecipe(recipeSummaryEntity)
} }
}
override fun queryRecipes(query: String?): PagingSource<Int, RecipeSummaryEntity> { override fun queryRecipes(query: String?): PagingSource<Int, RecipeSummaryEntity> {
logger.v { "queryRecipes() called with: query = $query" } logger.v { "queryRecipes() called with: query = $query" }
return if (query == null) recipeDao.queryRecipesByPages() return if (query == null) recipeDao.queryRecipesByPages()
else recipeDao.queryRecipesByPages(query) else recipeDao.queryRecipesByPages(query)
} }
override suspend fun refreshAll(recipes: List<RecipeSummaryInfo>) { override suspend fun refreshAll(recipes: List<RecipeSummaryInfo>) {

2
database/src/main/kotlin/gq/kirmanak/mealient/database/recipe/RecipeDao.kt
View File

@@ -13,7 +13,7 @@ interface RecipeDao {
fun queryRecipesByPages(query: String): PagingSource<Int, RecipeSummaryEntity> fun queryRecipesByPages(query: String): PagingSource<Int, RecipeSummaryEntity>
@Insert(onConflict = OnConflictStrategy.REPLACE) @Insert(onConflict = OnConflictStrategy.REPLACE)
suspend fun insertRecipe(recipeSummaryEntity: RecipeSummaryEntity) suspend fun insertRecipes(recipeSummaryEntity: Iterable<RecipeSummaryEntity>)
@Query("DELETE FROM recipe_summaries") @Query("DELETE FROM recipe_summaries")
suspend fun removeAllRecipes() suspend fun removeAllRecipes()