Merge "Commonize clearAllTables()" into androidx-main

Treehugger Robot · Gerrit Code Review · commit 5de3c474cbe5 · 2026-03-18T06:06:05.000-07:00
diff --git a/room3/integration-tests/multiplatformtestapp/src/commonTest/kotlin/androidx/room3/integration/multiplatformtestapp/test/BaseQueryTest.kt b/room3/integration-tests/multiplatformtestapp/src/commonTest/kotlin/androidx/room3/integration/multiplatformtestapp/test/BaseQueryTest.kt
@@ -454,4 +454,13 @@ abstract class BaseQueryTest {
         val result = db.libraryDao().getAll()
         assertThat(result).containsExactlyElementsIn(items)
     }
+
+    @Test
+    fun clearTables() = runTest {
+        val dao = db.dao()
+        repeat(10) { dao.insertItem(it.toLong()) }
+        assertThat(dao.getItemList().size).isEqualTo(10)
+        db.clearAllTables()
+        assertThat(dao.getItemList()).isEmpty()
+    }
 }
diff --git a/room3/room3-compiler/src/main/kotlin/androidx/room3/ext/xpoet_ext.kt b/room3/room3-compiler/src/main/kotlin/androidx/room3/ext/xpoet_ext.kt
@@ -223,6 +223,7 @@ object RoomMemberNames {
         RoomTypeNames.DB_UTIL.packageMember("performInTransactionSuspending")
     val DB_UTIL_PERFORM_IN_TRANSACTION_BLOCKING =
         RoomTypeNames.DB_UTIL.packageMember("performInTransactionBlocking")
+    val DB_UTIL_PERFORM_CLEAR = RoomTypeNames.DB_UTIL.packageMember("performClear")
     val STATEMENT_UTIL_WRAP_MAPPED_COLUMNS =
         RoomTypeNames.STATEMENT_UTIL.packageMember("wrapMappedColumns")
     val ROOM_SQL_QUERY_ACQUIRE =
diff --git a/room3/room3-compiler/src/main/kotlin/androidx/room3/processor/DatabaseProcessor.kt b/room3/room3-compiler/src/main/kotlin/androidx/room3/processor/DatabaseProcessor.kt
@@ -125,9 +125,6 @@ class DatabaseProcessor(baseContext: Context, val element: XTypeElement) {
 
         val hasForeignKeys = entities.any { it.foreignKeys.isNotEmpty() }
 
-        val hasClearAllTables =
-            roomDatabaseTypeElement.getDeclaredMethods().any { it.name == "clearAllTables" }
-
         val version = dbAnnotation.getAsInt("version")
         context.checker.check(
             predicate = version > 0,
@@ -147,7 +144,6 @@ class DatabaseProcessor(baseContext: Context, val element: XTypeElement) {
                 daoFunctions = daoFunctions,
                 exportSchema = exportSchema,
                 enableForeignKeys = hasForeignKeys,
-                overrideClearAllTables = hasClearAllTables,
                 constructorObject = constructorObject,
             )
         database.autoMigrations = processAutoMigrations(element, dbAnnotation, database.bundle)
diff --git a/room3/room3-compiler/src/main/kotlin/androidx/room3/vo/Database.kt b/room3/room3-compiler/src/main/kotlin/androidx/room3/vo/Database.kt
@@ -39,7 +39,6 @@ data class Database(
     val version: Int,
     val exportSchema: Boolean,
     val enableForeignKeys: Boolean,
-    val overrideClearAllTables: Boolean,
     val constructorObject: DatabaseConstructor?,
 ) {
     // This variable will be set once auto-migrations are processed given the DatabaseBundle from
diff --git a/room3/room3-compiler/src/main/kotlin/androidx/room3/writer/DatabaseWriter.kt b/room3/room3-compiler/src/main/kotlin/androidx/room3/writer/DatabaseWriter.kt
@@ -36,6 +36,7 @@ import androidx.room3.compiler.processing.PropertySpecHelper
 import androidx.room3.ext.CommonTypeNames
 import androidx.room3.ext.KotlinCollectionMemberNames
 import androidx.room3.ext.KotlinTypeNames
+import androidx.room3.ext.RoomMemberNames
 import androidx.room3.ext.RoomTypeNames
 import androidx.room3.ext.decapitalize
 import androidx.room3.ext.stripNonJava
@@ -58,9 +59,7 @@ class DatabaseWriter(val database: Database, writerContext: WriterContext) :
             setVisibility(VisibilityModifier.INTERNAL)
             addFunction(createOpenDelegate())
             addFunction(createCreateInvalidationTracker())
-            if (database.overrideClearAllTables) {
-                addFunction(createClearAllTables())
-            }
+            addFunction(createClearAllTables())
             addFunction(createCreateTypeConvertersMap())
             addFunction(createCreateAutoMigrationSpecsSet())
             addFunction(createGetAutoMigrations())
@@ -169,13 +168,19 @@ class DatabaseWriter(val database: Database, writerContext: WriterContext) :
                 name = "clearAllTables",
                 visibility = VisibilityModifier.PUBLIC,
                 isOverride = true,
+                isSuspend = true,
             )
             .apply {
                 val tableNames =
                     database.entities.sortedWith(EntityDeleteComparator()).joinToString(", ") {
                         "\"${it.tableName}\""
                     }
-                addStatement("super.performClear(%L, %L)", database.enableForeignKeys, tableNames)
+                addStatement(
+                    "%M(this, %L, %L)",
+                    RoomMemberNames.DB_UTIL_PERFORM_CLEAR,
+                    database.enableForeignKeys,
+                    tableNames,
+                )
             }
             .build()
     }
diff --git a/room3/room3-compiler/src/test/kotlin/androidx/room3/verifier/DatabaseVerifierTest.kt b/room3/room3-compiler/src/test/kotlin/androidx/room3/verifier/DatabaseVerifierTest.kt
@@ -403,7 +403,6 @@ class DatabaseVerifierTest(private val useLocalizedCollation: Boolean) {
             version = -1,
             exportSchema = false,
             enableForeignKeys = false,
-            overrideClearAllTables = true,
             constructorObject = null,
         )
     }
diff --git a/room3/room3-compiler/src/test/kotlin/androidx/room3/vo/DatabaseTest.kt b/room3/room3-compiler/src/test/kotlin/androidx/room3/vo/DatabaseTest.kt
@@ -72,7 +72,6 @@ class DatabaseTest {
                 version = 1,
                 exportSchema = false,
                 enableForeignKeys = false,
-                overrideClearAllTables = true,
                 constructorObject = null,
             )
 
diff --git a/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_daoProperty.kt b/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_daoProperty.kt
@@ -5,6 +5,7 @@ import androidx.room3.migration.Migration
 import androidx.room3.util.TableInfo
 import androidx.room3.util.TableInfo.Companion.read
 import androidx.room3.util.dropFtsSyncTriggers
+import androidx.room3.util.performClear
 import androidx.sqlite.SQLiteConnection
 import androidx.sqlite.executeSQL
 import javax.`annotation`.processing.Generated
@@ -86,8 +87,8 @@ internal class MyDatabase_Impl : MyDatabase() {
     return InvalidationTracker(this, _shadowTablesMap, _viewTables, "MyEntity")
   }
 
-  public override fun clearAllTables() {
-    super.performClear(false, "MyEntity")
+  public override suspend fun clearAllTables() {
+    performClear(this, false, "MyEntity")
   }
 
   protected override fun getRequiredTypeConverterClasses(): Map<KClass<*>, List<KClass<*>>> {
diff --git a/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_internalVisibility.kt b/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_internalVisibility.kt
@@ -5,6 +5,7 @@ import androidx.room3.migration.Migration
 import androidx.room3.util.TableInfo
 import androidx.room3.util.TableInfo.Companion.read
 import androidx.room3.util.dropFtsSyncTriggers
+import androidx.room3.util.performClear
 import androidx.sqlite.SQLiteConnection
 import androidx.sqlite.executeSQL
 import javax.`annotation`.processing.Generated
@@ -83,8 +84,8 @@ internal class MyDatabase_Impl : MyDatabase() {
     return InvalidationTracker(this, _shadowTablesMap, _viewTables, "MyEntity")
   }
 
-  public override fun clearAllTables() {
-    super.performClear(false, "MyEntity")
+  public override suspend fun clearAllTables() {
+    performClear(this, false, "MyEntity")
   }
 
   protected override fun getRequiredTypeConverterClasses(): Map<KClass<*>, List<KClass<*>>> {
diff --git a/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_java.kt b/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_java.kt
@@ -5,6 +5,7 @@ import androidx.room3.migration.Migration
 import androidx.room3.util.TableInfo
 import androidx.room3.util.TableInfo.Companion.read
 import androidx.room3.util.dropFtsSyncTriggers
+import androidx.room3.util.performClear
 import androidx.sqlite.SQLiteConnection
 import androidx.sqlite.executeSQL
 import javax.`annotation`.processing.Generated
@@ -83,8 +84,8 @@ internal class MyDatabase_Impl : MyDatabase() {
     return InvalidationTracker(this, _shadowTablesMap, _viewTables, "MyEntity")
   }
 
-  public override fun clearAllTables() {
-    super.performClear(false, "MyEntity")
+  public override suspend fun clearAllTables() {
+    performClear(this, false, "MyEntity")
   }
 
   protected override fun getRequiredTypeConverterClasses(): Map<KClass<*>, List<KClass<*>>> {
diff --git a/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_simple.kt b/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_simple.kt
@@ -5,6 +5,7 @@ import androidx.room3.migration.Migration
 import androidx.room3.util.TableInfo
 import androidx.room3.util.TableInfo.Companion.read
 import androidx.room3.util.dropFtsSyncTriggers
+import androidx.room3.util.performClear
 import androidx.sqlite.SQLiteConnection
 import androidx.sqlite.executeSQL
 import javax.`annotation`.processing.Generated
@@ -83,8 +84,8 @@ internal class MyDatabase_Impl : MyDatabase() {
     return InvalidationTracker(this, _shadowTablesMap, _viewTables, "MyEntity")
   }
 
-  public override fun clearAllTables() {
-    super.performClear(false, "MyEntity")
+  public override suspend fun clearAllTables() {
+    performClear(this, false, "MyEntity")
   }
 
   protected override fun getRequiredTypeConverterClasses(): Map<KClass<*>, List<KClass<*>>> {
diff --git a/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_withFtsAndView.kt b/room3/room3-compiler/src/test/test-data/kotlinCodeGen/database_withFtsAndView.kt
@@ -6,6 +6,7 @@ import androidx.room3.util.FtsTableInfo
 import androidx.room3.util.TableInfo
 import androidx.room3.util.ViewInfo
 import androidx.room3.util.dropFtsSyncTriggers
+import androidx.room3.util.performClear
 import androidx.sqlite.SQLiteConnection
 import androidx.sqlite.executeSQL
 import javax.`annotation`.processing.Generated
@@ -141,8 +142,8 @@ internal class MyDatabase_Impl : MyDatabase() {
     return InvalidationTracker(this, _shadowTablesMap, _viewTables, "MyParentEntity", "MyEntity", "MyFtsEntity")
   }
 
-  public override fun clearAllTables() {
-    super.performClear(true, "MyParentEntity", "MyEntity", "MyFtsEntity")
+  public override suspend fun clearAllTables() {
+    performClear(this, true, "MyParentEntity", "MyEntity", "MyFtsEntity")
   }
 
   protected override fun getRequiredTypeConverterClasses(): Map<KClass<*>, List<KClass<*>>> {
diff --git a/room3/room3-runtime/api/current.txt b/room3/room3-runtime/api/current.txt
@@ -59,7 +59,7 @@ package androidx.room3 {
   }
 
   public abstract class RoomDatabase {
-    method @WorkerThread public abstract void clearAllTables();
+    method public abstract suspend Object? clearAllTables(kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method public void close();
     method protected abstract androidx.room3.InvalidationTracker createInvalidationTracker();
     method @InaccessibleFromKotlin public androidx.room3.InvalidationTracker getInvalidationTracker();
diff --git a/room3/room3-runtime/api/restricted_current.txt b/room3/room3-runtime/api/restricted_current.txt
@@ -109,7 +109,7 @@ package androidx.room3 {
   public abstract class RoomDatabase {
     ctor @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public RoomDatabase();
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public void assertNotMainThread();
-    method @WorkerThread public abstract void clearAllTables();
+    method public abstract suspend Object? clearAllTables(kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method public void close();
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public abstract java.util.List<androidx.room3.migration.Migration> createAutoMigrations(java.util.Map<kotlin.reflect.KClass<? extends androidx.room3.migration.AutoMigrationSpec>,? extends androidx.room3.migration.AutoMigrationSpec> autoMigrationSpecs);
     method protected abstract androidx.room3.InvalidationTracker createInvalidationTracker();
@@ -312,6 +312,7 @@ package androidx.room3.util {
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public static suspend Object? dropFtsSyncTriggers(androidx.sqlite.SQLiteConnection connection, kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public static suspend Object? foreignKeyCheck(androidx.sqlite.SQLiteConnection db, String tableName, kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public static <R> R performBlocking(androidx.room3.RoomDatabase db, boolean isReadOnly, boolean inTransaction, kotlin.jvm.functions.Function2<? super androidx.sqlite.SQLiteConnection,? super kotlin.coroutines.Continuation<? super R>,? extends java.lang.Object?> block);
+    method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public static suspend Object? performClear(androidx.room3.RoomDatabase db, boolean hasForeignKeys, String[] tableNames, kotlin.coroutines.Continuation<? super kotlin.Unit>);
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public static <R> R performInTransactionBlocking(androidx.room3.RoomDatabase db, kotlin.jvm.functions.Function0<? extends R> block);
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public static suspend <R> Object? performInTransactionSuspending(androidx.room3.RoomDatabase db, kotlin.jvm.functions.Function1<? super kotlin.coroutines.Continuation<? super R>,? extends java.lang.Object?> block, kotlin.coroutines.Continuation<? super R>);
     method @RestrictTo(androidx.annotation.RestrictTo.Scope.LIBRARY_GROUP_PREFIX) public static suspend <R> Object? performSuspending(androidx.room3.RoomDatabase db, boolean isReadOnly, boolean inTransaction, kotlin.jvm.functions.Function2<? super androidx.sqlite.SQLiteConnection,? super kotlin.coroutines.Continuation<? super R>,? extends java.lang.Object?> block, kotlin.coroutines.Continuation<? super R>);
diff --git a/room3/room3-runtime/bcv/native/current.txt b/room3/room3-runtime/bcv/native/current.txt
@@ -119,6 +119,7 @@ abstract class androidx.room3/RoomDatabase { // androidx.room3/RoomDatabase|null
     abstract fun createOpenDelegate(): androidx.room3/RoomOpenDelegateMarker // androidx.room3/RoomDatabase.createOpenDelegate|createOpenDelegate(){}[0]
     abstract fun getRequiredAutoMigrationSpecClasses(): kotlin.collections/Set<kotlin.reflect/KClass<out androidx.room3.migration/AutoMigrationSpec>> // androidx.room3/RoomDatabase.getRequiredAutoMigrationSpecClasses|getRequiredAutoMigrationSpecClasses(){}[0]
     abstract fun getRequiredTypeConverterClasses(): kotlin.collections/Map<kotlin.reflect/KClass<*>, kotlin.collections/List<kotlin.reflect/KClass<*>>> // androidx.room3/RoomDatabase.getRequiredTypeConverterClasses|getRequiredTypeConverterClasses(){}[0]
+    abstract suspend fun clearAllTables() // androidx.room3/RoomDatabase.clearAllTables|clearAllTables(){}[0]
     final fun <#A1: kotlin/Any> getTypeConverter(kotlin.reflect/KClass<#A1>): #A1 // androidx.room3/RoomDatabase.getTypeConverter|getTypeConverter(kotlin.reflect.KClass<0:0>){0§<kotlin.Any>}[0]
     final fun close() // androidx.room3/RoomDatabase.close|close(){}[0]
     final fun getCoroutineScope(): kotlinx.coroutines/CoroutineScope // androidx.room3/RoomDatabase.getCoroutineScope|getCoroutineScope(){}[0]
@@ -458,3 +459,4 @@ final suspend fun androidx.room3.util/dropFtsSyncTriggers(androidx.sqlite/SQLite
 final suspend fun androidx.room3.util/foreignKeyCheck(androidx.sqlite/SQLiteConnection, kotlin/String) // androidx.room3.util/foreignKeyCheck|foreignKeyCheck(androidx.sqlite.SQLiteConnection;kotlin.String){}[0]
 final suspend fun androidx.room3.util/getLastInsertedRowId(androidx.sqlite/SQLiteConnection): kotlin/Long // androidx.room3.util/getLastInsertedRowId|getLastInsertedRowId(androidx.sqlite.SQLiteConnection){}[0]
 final suspend fun androidx.room3.util/getTotalChangedRows(androidx.sqlite/SQLiteConnection): kotlin/Int // androidx.room3.util/getTotalChangedRows|getTotalChangedRows(androidx.sqlite.SQLiteConnection){}[0]
+final suspend fun androidx.room3.util/performClear(androidx.room3/RoomDatabase, kotlin/Boolean, kotlin/Array<out kotlin/String>...) // androidx.room3.util/performClear|performClear(androidx.room3.RoomDatabase;kotlin.Boolean;kotlin.Array<out|kotlin.String>...){}[0]
diff --git a/room3/room3-runtime/src/androidHostTest/kotlin/androidx/room3/BuilderTest_TestDatabase_Impl.kt b/room3/room3-runtime/src/androidHostTest/kotlin/androidx/room3/BuilderTest_TestDatabase_Impl.kt
@@ -32,7 +32,7 @@ internal class BuilderTest_TestDatabase_Impl : BuilderTest.TestDatabase() {
         return mock()
     }
 
-    override fun clearAllTables() {}
+    override suspend fun clearAllTables() {}
 
     override fun createAutoMigrations(
         autoMigrationSpecs: Map<KClass<out AutoMigrationSpec>, AutoMigrationSpec>
diff --git a/room3/room3-runtime/src/androidHostTest/kotlin/androidx/room3/InvalidationTrackerTest.kt b/room3/room3-runtime/src/androidHostTest/kotlin/androidx/room3/InvalidationTrackerTest.kt
@@ -526,7 +526,7 @@ class InvalidationTrackerTest {
             }
         }
 
-        override fun clearAllTables() {}
+        override suspend fun clearAllTables() {}
 
         override fun createAutoMigrations(
             autoMigrationSpecs: Map<KClass<out AutoMigrationSpec>, AutoMigrationSpec>
@@ -575,7 +575,7 @@ class InvalidationTrackerTest {
             override fun close() {}
         }
 
-        private inner class FakeSQLiteStatement(private val invalidateTables: IntArray?) :
+        private class FakeSQLiteStatement(private val invalidateTables: IntArray?) :
             SQLiteStatement {
 
             private var position = -1
diff --git a/room3/room3-runtime/src/androidMain/kotlin/androidx/room3/RoomDatabase.android.kt b/room3/room3-runtime/src/androidMain/kotlin/androidx/room3/RoomDatabase.android.kt
@@ -26,14 +26,12 @@ import android.os.Looper
 import android.util.Log
 import androidx.annotation.IntRange
 import androidx.annotation.RestrictTo
-import androidx.annotation.WorkerThread
 import androidx.room3.Room.LOG_TAG
 import androidx.room3.autoclose.AutoCloser
 import androidx.room3.autoclose.AutoCloserConfig
 import androidx.room3.autoclose.AutoClosingSQLiteDriver
 import androidx.room3.concurrent.CloseBarrier
 import androidx.room3.coroutines.TransactionElement
-import androidx.room3.coroutines.runBlockingUninterruptible
 import androidx.room3.coroutines.withTransactionContext
 import androidx.room3.migration.AutoMigrationSpec
 import androidx.room3.migration.Migration
@@ -344,37 +342,7 @@ actual constructor() {
      *
      * See SQLite documentation for details. [FileFormat](https://www.sqlite.org/fileformat.html)
      */
-    @WorkerThread public abstract fun clearAllTables()
-
-    /**
-     * Performs a 'clear all tables' operation.
-     *
-     * This should only be invoked from generated code.
-     *
-     * @see [RoomDatabase.clearAllTables]
-     */
-    @RestrictTo(RestrictTo.Scope.LIBRARY_GROUP)
-    protected fun performClear(hasForeignKeys: Boolean, vararg tableNames: String) {
-        assertNotMainThread()
-        runBlockingUninterruptible {
-            connectionManager.useConnection(isReadOnly = false) { connection ->
-                if (!connection.inTransaction()) {
-                    invalidationTracker.sync()
-                }
-                connection.withTransaction(Transactor.SQLiteTransactionType.IMMEDIATE) {
-                    if (hasForeignKeys) {
-                        executeSQL("PRAGMA defer_foreign_keys = TRUE")
-                    }
-                    tableNames.forEach { tableName -> executeSQL("DELETE FROM `$tableName`") }
-                }
-                if (!connection.inTransaction()) {
-                    connection.executeSQL("PRAGMA wal_checkpoint(FULL)")
-                    connection.executeSQL("VACUUM")
-                    invalidationTracker.refreshAsync()
-                }
-            }
-        }
-    }
+    public actual abstract suspend fun clearAllTables()
 
     /** True if the actual database connection is open, regardless of auto-close. */
     internal val isOpenInternal: Boolean
diff --git a/room3/room3-runtime/src/commonMain/kotlin/androidx/room3/RoomDatabase.kt b/room3/room3-runtime/src/commonMain/kotlin/androidx/room3/RoomDatabase.kt
@@ -199,6 +199,20 @@ constructor() {
     @RestrictTo(RestrictTo.Scope.LIBRARY_GROUP)
     public suspend fun <R> useConnection(isReadOnly: Boolean, block: suspend (Transactor) -> R): R
 
+    /**
+     * Deletes all rows from all the tables that are registered to this database as
+     * [Database.entities].
+     *
+     * This does NOT reset the auto-increment value generated by [PrimaryKey.autoGenerate].
+     *
+     * After deleting the rows, Room will set a WAL checkpoint and run `VACUUM`. This means that the
+     * data is completely erased. The space will be reclaimed by the system if the amount surpasses
+     * the threshold of database file size.
+     *
+     * See SQLite documentation for details. [FileFormat](https://www.sqlite.org/fileformat.html)
+     */
+    public abstract suspend fun clearAllTables()
+
     /**
      * Journal modes for SQLite database.
      *
diff --git a/room3/room3-runtime/src/commonMain/kotlin/androidx/room3/util/DBUtil.kt b/room3/room3-runtime/src/commonMain/kotlin/androidx/room3/util/DBUtil.kt
@@ -24,6 +24,7 @@ import androidx.room3.PooledConnection
 import androidx.room3.RoomDatabase
 import androidx.room3.Transactor
 import androidx.room3.coroutines.RawConnectionAccessor
+import androidx.room3.executeSQL
 import androidx.sqlite.SQLiteConnection
 import androidx.sqlite.SQLiteException
 import androidx.sqlite.SQLiteStatement
@@ -179,3 +180,27 @@ private suspend fun processForeignKeyCheckFailure(stmt: SQLiteStatement): String
         }
     }
 }
+
+@RestrictTo(RestrictTo.Scope.LIBRARY_GROUP_PREFIX) // used in generated code
+public suspend fun performClear(
+    db: RoomDatabase,
+    hasForeignKeys: Boolean,
+    vararg tableNames: String,
+) {
+    db.useConnection(isReadOnly = false) { connection ->
+        if (!connection.inTransaction()) {
+            db.invalidationTracker.sync()
+        }
+        connection.withTransaction(Transactor.SQLiteTransactionType.IMMEDIATE) {
+            if (hasForeignKeys) {
+                executeSQL("PRAGMA defer_foreign_keys = TRUE")
+            }
+            tableNames.forEach { tableName -> executeSQL("DELETE FROM `$tableName`") }
+        }
+        if (!connection.inTransaction()) {
+            connection.executeSQL("PRAGMA wal_checkpoint(FULL)")
+            connection.executeSQL("VACUUM")
+            db.invalidationTracker.refreshAsync()
+        }
+    }
+}
diff --git a/room3/room3-runtime/src/jvmNativeWebMain/kotlin/androidx/room3/RoomDatabase.jvmNativeWeb.kt b/room3/room3-runtime/src/jvmNativeWebMain/kotlin/androidx/room3/RoomDatabase.jvmNativeWeb.kt
diff --git a/room3/room3-runtime/src/nativeTest/kotlin/androidx/room3/BuilderTest_TestDatabase_Impl.kt b/room3/room3-runtime/src/nativeTest/kotlin/androidx/room3/BuilderTest_TestDatabase_Impl.kt

Original file line number	Diff line number	Diff line change
`@@ -454,4 +454,13 @@ abstract class BaseQueryTest {`
`454`	`454`	`val result = db.libraryDao().getAll()`
`455`	`455`	`assertThat(result).containsExactlyElementsIn(items)`
`456`	`456`	`}`
	`457`	`+`
	`458`	`+ @Test`
	`459`	`+ fun clearTables() = runTest {`
	`460`	`+ val dao = db.dao()`
	`461`	`+ repeat(10) { dao.insertItem(it.toLong()) }`
	`462`	`+ assertThat(dao.getItemList().size).isEqualTo(10)`
	`463`	`+ db.clearAllTables()`
	`464`	`+ assertThat(dao.getItemList()).isEmpty()`
	`465`	`+ }`
`457`	`466`	`}`
Original file line number	Diff line number	Diff line change
`@@ -403,7 +403,6 @@ class DatabaseVerifierTest(private val useLocalizedCollation: Boolean) {`
`403`	`403`	`version = -1,`
`404`	`404`	`exportSchema = false,`
`405`	`405`	`enableForeignKeys = false,`
`406`		`- overrideClearAllTables = true,`
`407`	`406`	`constructorObject = null,`
`408`	`407`	`)`
`409`	`408`	`}`
Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,6 @@ class DatabaseTest {`
`72`	`72`	`version = 1,`
`73`	`73`	`exportSchema = false,`
`74`	`74`	`enableForeignKeys = false,`
`75`		`- overrideClearAllTables = true,`
`76`	`75`	`constructorObject = null,`
`77`	`76`	`)`
`78`	`77`