Adding insertToRealm: a fast and more memory efficient way to copy da…

…ta into Realm
realm · Aug 7, 2024 · d88f4e6 · d88f4e6
1 parent d81500c
commit d88f4e6
Show file tree

Hide file tree

Showing 6 changed files with 1,817 additions and 2 deletions.
diff --git a/packages/library-base/src/commonMain/kotlin/io/realm/kotlin/MutableRealm.kt b/packages/library-base/src/commonMain/kotlin/io/realm/kotlin/MutableRealm.kt
@@ -87,6 +87,10 @@ public interface MutableRealm : TypedRealm {
      */
     public fun <T : RealmObject> copyToRealm(instance: T, updatePolicy: UpdatePolicy = UpdatePolicy.ERROR): T
 
+    public fun <T : RealmObject> insertToRealm(instance: T, updatePolicy: UpdatePolicy = UpdatePolicy.ERROR)
+
+    public fun <T : RealmObject> insertToRealm(instances: Collection<T>, updatePolicy: UpdatePolicy = UpdatePolicy.ERROR)
+
     /**
      * Returns a [RealmQuery] matching the predicate represented by [query].
      *

diff --git a/packages/library-base/src/commonMain/kotlin/io/realm/kotlin/internal/InternalMutableRealm.kt b/packages/library-base/src/commonMain/kotlin/io/realm/kotlin/internal/InternalMutableRealm.kt
@@ -57,6 +57,24 @@ internal interface InternalMutableRealm : MutableRealm {
         return copyToRealm(configuration.mediator, realmReference, instance, updatePolicy)
     }
 
+    override fun <T : RealmObject> insertToRealm(instance: T, updatePolicy: UpdatePolicy) {
+        val cache: UnmanagedToManagedObjectPointerCache = mutableMapOf()
+
+        insertToRealm(realmReference, instance, updatePolicy, cache)
+
+        cache.forEach { it.value.release() }
+        cache.clear()
+    }
+
+    override fun <T : RealmObject> insertToRealm(instances: Collection<T>, updatePolicy: UpdatePolicy) {
+        val cache: UnmanagedToManagedObjectPointerCache = mutableMapOf()
+
+        insertToRealm(realmReference, instances, updatePolicy, cache)
+
+        cache.forEach { it.value.release() }
+        cache.clear()
+    }
+
     override fun delete(deleteable: Deleteable) {
         deleteable.asInternalDeleteable().delete()
     }