nick/amethyst
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Vacuum and Analyze are blocking, so moving to a coroutine.

Browse Source
This commit is contained in:
Vitor Pamplona
2025-12-27 12:40:23 -05:00
parent d435231f55
commit 068ba3b717
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/store/sqlite/SQLiteEventStore.kt
+10 -4
View File
@@ -32,6 +32,8 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.store.IEventStore import com.vitorpamplona.quartz.nip01Core.store.IEventStore
import com.vitorpamplona.quartz.nip01Core.store.sqlite.EventIndexesModule.IndexingStrategy import com.vitorpamplona.quartz.nip01Core.store.sqlite.EventIndexesModule.IndexingStrategy
import com.vitorpamplona.quartz.nip40Expiration.isExpired import com.vitorpamplona.quartz.nip40Expiration.isExpired
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.withContext
class SQLiteEventStore( class SQLiteEventStore(
val context: Context, val context: Context,
@@ -113,16 +115,20 @@ class SQLiteEventStore(
modules.reversed().forEach { it.deleteAll(db) } modules.reversed().forEach { it.deleteAll(db) }
} }
fun vacuum() { suspend fun vacuum() {
// 1. ANALYZE: Collects statistics about tables and indices // 1. ANALYZE: Collects statistics about tables and indices
// to help the query planner optimize queries. // to help the query planner optimize queries.
writableDatabase.execSQL("VACUUM") withContext(Dispatchers.IO) {
writableDatabase.execSQL("VACUUM")
}
} }
fun analyse() { suspend fun analyse() {
// 2. VACUUM: Rebuilds the database file, reclaiming unused space // 2. VACUUM: Rebuilds the database file, reclaiming unused space
// and reducing fragmentation. // and reducing fragmentation.
writableDatabase.execSQL("ANALYZE") withContext(Dispatchers.IO) {
writableDatabase.execSQL("ANALYZE")
}
} }
private fun innerInsertEvent( private fun innerInsertEvent(