<lambda>null1 import androidx.room.RoomDatabase
2 import androidx.room.RxRoom.Companion.createCompletable
3 import androidx.room.RxRoom.Companion.createMaybe
4 import androidx.room.RxRoom.Companion.createSingle
5 import androidx.room.util.getLastInsertedRowId
6 import androidx.sqlite.SQLiteStatement
7 import io.reactivex.Completable
8 import io.reactivex.Maybe
9 import io.reactivex.Single
10 import javax.`annotation`.processing.Generated
11 import kotlin.Int
12 import kotlin.Long
13 import kotlin.String
14 import kotlin.Suppress
15 import kotlin.collections.List
16 import kotlin.reflect.KClass
17
18 @Generated(value = ["androidx.room.RoomProcessor"])
19 @Suppress(names = ["UNCHECKED_CAST", "DEPRECATION", "REDUNDANT_PROJECTION", "REMOVAL"])
20 public class MyDao_Impl(
21 __db: RoomDatabase,
22 ) : MyDao {
23 private val __db: RoomDatabase
24 init {
25 this.__db = __db
26 }
27
28 public override fun insertPublisherSingle(id: String, name: String): Single<Long> {
29 val _sql: String = "INSERT INTO MyEntity (pk, other) VALUES (?, ?)"
30 return createSingle(__db, false, true) { _connection ->
31 val _stmt: SQLiteStatement = _connection.prepare(_sql)
32 try {
33 var _argIndex: Int = 1
34 _stmt.bindText(_argIndex, id)
35 _argIndex = 2
36 _stmt.bindText(_argIndex, name)
37 _stmt.step()
38 getLastInsertedRowId(_connection)
39 } finally {
40 _stmt.close()
41 }
42 }
43 }
44
45 public override fun insertPublisherMaybe(id: String, name: String): Maybe<Long> {
46 val _sql: String = "INSERT INTO MyEntity (pk, other) VALUES (?, ?)"
47 return createMaybe(__db, false, true) { _connection ->
48 val _stmt: SQLiteStatement = _connection.prepare(_sql)
49 try {
50 var _argIndex: Int = 1
51 _stmt.bindText(_argIndex, id)
52 _argIndex = 2
53 _stmt.bindText(_argIndex, name)
54 _stmt.step()
55 getLastInsertedRowId(_connection)
56 } finally {
57 _stmt.close()
58 }
59 }
60 }
61
62 public override fun insertPublisherCompletable(id: String, name: String): Completable {
63 val _sql: String = "INSERT INTO MyEntity (pk, other) VALUES (?, ?)"
64 return createCompletable(__db, false, true) { _connection ->
65 val _stmt: SQLiteStatement = _connection.prepare(_sql)
66 try {
67 var _argIndex: Int = 1
68 _stmt.bindText(_argIndex, id)
69 _argIndex = 2
70 _stmt.bindText(_argIndex, name)
71 _stmt.step()
72 } finally {
73 _stmt.close()
74 }
75 }
76 }
77
78 public companion object {
79 public fun getRequiredConverters(): List<KClass<*>> = emptyList()
80 }
81 }
82