后端ORM【免费下载链接】sqldelightSQLDelight - Generates typesafe Kotlin APIs from SQL项目地址https://gitcode.com/gh_mirrors/sq/sqldelight点击查看免费下载SQLDelight 生成的查询对象是“可监听的类型化查询”listenable, typed query而 RxJava 扩展模块rxjava3-extensions / rxjava2-extensions将这些查询无缝桥接为 RxJava 的Observable流每当底层结果集发生变化时流自动发出新数据从而以响应式方式驱动 Android 界面刷新。读完本文你将掌握如何引入 RxJava 扩展依赖、用asObservable()与mapToList()等操作符订阅 SQLDelight 查询并理解其底层基于Query.Listener的实时通知机制与调度器行为。RxJava 扩展能做什么SQLDelight 本身生成的查询接口是可观察的每个查询都支持注册Query.Listener在底层表数据变更查询被“dirty”标记时收到同步回调。RxJava 扩展模块在此基础上提供了一组 Kotlin 扩展函数把QueryT包装成ObservableQueryT并进一步映射为具体的数据类型T、ListT、OptionalT等让开发者可以直接用 RxJava 的订阅、组合、线程调度能力消费数据库查询结果。该扩展模块的核心实现在 RxJavaExtensions.ktRxJava 3与 RxJavaExtensions.ktRxJava 2两个模块的 API 完全对齐仅包名app.cash.sqldelight.rx3/app.cash.sqldelight.rx2与 RxJava 版本不同。添加依赖要观察查询需要引入 RxJava 扩展工件artifact并使用它提供的扩展方法。官方文档给出的依赖声明如下 Kotlin (build.gradle.kts)kotlin dependencies { implementation(app.cash.sqldelight:rxjava3-extensions:{{ versions.sqldelight }}) } Groovy (build.gradle)groovy dependencies { implementation app.cash.sqldelight:rxjava3-extensions:{{ versions.sqldelight }} }其中{{ versions.sqldelight }}为当前 SQLDelight 版本号占位符。根据仓库 gradle/libs.versions.toml 中的版本目录配置项目使用 Kotlin 2.3.10、AGP 9.4.1 等较新工具链发布版本请以你使用的 SQLDelight 版本为准可在项目的gradle/libs.versions.toml中查看当前版本号。注意RxJava 2 用户如果项目使用的是 RxJava 2则将工件名替换为rxjava2-extensions对应模块位于 rxjava2-extensions包名相应变为app.cash.sqldelight.rx2。两个模块的gradle.properties也印证了它们的定位POM_ARTIFACT_IDrxjava3-extensions、POM_NAMESQLDelight RxJava3 Extensions、POM_DESCRIPTIONKotlin extension functions to expose SQLDelight Querys as ObservableSources参见 rxjava3-extensions/gradle.properties。基本用法把查询变成 Observable添加依赖后即可对生成的Query调用asObservable()再配合映射操作符消费数据。文档中的核心示例val players: ObservableListHockeyPlayer playerQueries.selectAll() .asObservable() .mapToList()这里playerQueries是由 SQLDelight Gradle 插件根据.sq文件生成的查询接口selectAll()返回QueryHockeyPlayer。整条链路的语义是asObservable()将QueryHockeyPlayer转换为ObservableQueryHockeyPlayer订阅时立即发射一次当前结果集对应的Query对象此后每当该查询被变更标记时再次发射mapToList()把每个Query映射为ListHockeyPlayer内部调用executeAsList()因此players就是会随数据库变化自动更新的ObservableListHockeyPlayer。在 Android 中典型做法是订阅后通过RxJavaPlugins或subscribeOn/observeOn将发射调度到 UI 线程直接驱动RecyclerView等界面组件刷新。六个核心扩展方法详解从 RxJavaExtensions.kt 的源码可以看到扩展模块共提供 6 个顶层函数函数输入输出底层实现语义说明asObservable(scheduler)QueryTObservableQueryTObservable.create(QueryOnSubscribe(query)).observeOn(scheduler)将查询包装为可监听的 Observable默认在Schedulers.io()发射mapToOne()ObservableQueryTObservableTmap { it.executeAsOne() }发射唯一一行无结果抛NullPointerException多行抛IllegalStateExceptionmapToOneOrDefault(defaultValue)ObservableQueryTObservableTmap { it.executeAsOneOrNull() ?: defaultValue }无结果时发射给定默认值mapToOptional()ObservableQueryTObservableOptionalTmap { Optional.ofNullable(it.executeAsOneOrNull()) }无结果时发射Optional.empty()适配 Java 8mapToList()ObservableQueryTObservableListTmap { it.executeAsList() }发射完整结果集列表无行时发射空列表mapToOneNonNull()ObservableQueryTObservableTflatMap { ... }无结果时不发射Observable.empty()有结果时发射该行其中asObservable带JvmOverloads注解因此 Java 调用方也可省略 scheduler 参数JvmName(toObservable)则确保 Java 侧以RxQuery.toObservable(query)的静态方法形式调用。这一点可从 rxjava3-extensions.api 的 ABI 声明中得到印证RxQuery类暴露了toObservable、mapToList、mapToOne、mapToOneNonNull、mapToOneOrDefault、mapToOptional全部静态方法。各操作符的语义边界测试验证扩展模块附带的 QueryTest.kt 用一整套用例明确了每个操作符的边界行为mapToOne单行时发射该行两行时抛错错误信息包含ResultSet returned more than 1 rowmapToOneOrDefault无结果时发射默认值测试中为Employee(fred, Fred Frederson)多行时同样抛错mapToList返回全部行测试数据为 alice/bob/eve 三名员工WHERE 12无匹配时发射emptyList()mapToOptional单行时发射Optional.of(...)无结果时发射Optional.empty()多行抛错mapToOneNonNull无结果时不发射任何值配合take(1)验证流直接完成。这些行为均直接继承自 runtime 模块中 Query.kt 对executeAsList/executeAsOne/executeAsOneOrNull的定义executeAsOne在无行时抛出NullPointerException在多于一行时抛出IllegalStateException。因此选择哪个映射操作符取决于你对“查询结果可能为空”的处理策略。底层原理Listener 驱动的实时通知理解扩展模块的关键在于其监听机制。asObservable的源码核心如下RxJava 3 与 RxJava 2 实现完全一致private class QueryOnSubscribeT : Any( private val query: QueryT, ) : ObservableOnSubscribeQueryT { override fun subscribe(emitter: ObservableEmitterQueryT) { val listenerAndDisposable QueryListenerAndDisposable(emitter, query) query.addListener(listenerAndDisposable) // 注册监听 emitter.setDisposable(listenerAndDisposable) // 退订时自动移除 emitter.onNext(query) // 订阅即发射当前结果 } } private class QueryListenerAndDisposableT : Any( private val emitter: ObservableEmitterQueryT, private val query: QueryT, ) : AtomicBoolean(), Query.Listener, Disposable { override fun queryResultsChanged() { emitter.onNext(query) // 数据变更时重新发射 } override fun dispose() { if (compareAndSet(false, true)) { query.removeListener(this) // 退订后不再收到通知 } } }由此可以归纳出该桥接层的三个关键设计订阅即发射subscribe时立即onNext(query)保证订阅者第一时间拿到当前数据而不是等待下一次数据库变更变更即重放queryResultsChanged()回调由 SQLDelight 的Query.Listener触发再次发射同一个Query流式订阅者据此重新执行映射拿到最新数据。runtime 中Query.Listener的文档明确说明回调在数据变更发生的线程上同步执行见 Query.kt退订即清理Disposable.dispose()通过AtomicBoolean保证幂等并调用query.removeListener(this)移除监听避免内存泄漏与孤儿监听器。调度器方面asObservable默认使用Schedulers.io()并可以通过参数覆盖如asObservable(Schedulers.trampoline())在测试中常用。测试用例对行为的验证rxjava3-extensions/src/test 目录下的测试从多个角度验证了上述行为ObservingTest.kt 验证了核心订阅语义query observes notification订阅后插入一条新员工记录Observer 立即收到包含新记录的最新结果集queryInitialValueAndTriggerUsesScheduler使用TestScheduler时初始值与变更通知都延迟到scheduler.triggerActions()才发射证明observeOn(scheduler)确实生效queryNotNotifiedAfterDispose/queryNotNotifiedWhenQueryTransformerUnsubscribesdispose 或takeUntil取消订阅后数据库再插入数据不会触发任何事件验证退订清理逻辑queryOnlyNotifiedAfterSubscribe订阅前发生的变更不会“补发”订阅时只会拿到当前最新数据queryCanBeSubscribedToTwice同一个 Observable 可被重复订阅zipWith 自组合也能工作说明每次订阅都会独立注册监听器。QueryObservableTest.kt 验证错误传播查询执行抛出的异常会作为onError传递以及“订阅与退订竞态下不残留孤儿监听器”的边界场景。这些测试同时是很好的使用参考在 JVM 单元测试中通过asObservable(Schedulers.trampoline()) RxJava 的TestObserver即可稳定断言查询流的发射内容。Android 集成要点结合 android_sqlite 入门文档 中的流程在 Android 工程中使用 RxJava 扩展的完整链路为引入 Android 驱动与 SQLDelight 插件生成数据库与查询接口implementation(app.cash.sqldelight:android-driver:{{ versions.sqldelight }})引入本文所述的 RxJava 扩展工件见上文依赖小节构造驱动与查询后用asObservable().mapToList()等 API 建立响应式数据流。需要注意的是asObservable默认在Schedulers.io()上发射而Query.Listener的回调本身在数据变更线程同步执行。若要在 Android 主线程更新 UI应结合observeOn(AndroidSchedulers.mainThread())来自io.reactivex.rxjava3.android.schedulers做线程切换这是 RxJava 使用中的通用实践。小结SQLDelight 的 RxJava 扩展把“可监听的类型化查询”完整地接入了 RxJava 生态asObservable()负责建立订阅与退订的监听桥接mapToList()/mapToOne()/mapToOptional()/mapToOneNonNull()等映射操作符负责把Query转换为业务数据类型而 runtime 的Query.Listener机制保证了结果集变更的实时推送。无论是 RxJava 2 还是 RxJava 3只需更换工件名与 import 包名即可复用同一套 API是 Android 响应式 UI 与 SQLDelight 结合的最直接方案。赞分享后端ORM【免费下载链接】sqldelightSQLDelight - Generates typesafe Kotlin APIs from SQL项目地址https://gitcode.com/gh_mirrors/sq/sqldelight点击查看免费下载相关推荐SQLDelight 与 RxJava 集成指南用 Observable 响应式观察数据库查询变化SQLDelight 与 RxJava 集成指南用 Observable 响应式观察数据库查询变化 SQLDelight 提供了一套基于 Query.List后端ORMSQLDelight 协程扩展实战使用 asFlow 将 SQL 查询转换为响应式 FlowSQLDelight 协程扩展实战使用 asFlow 将 SQL 查询转换为响应式 Flow 本篇指南聚焦 SQLDelight 提供的 coroutines后端ORMSQLDelight RxJava 扩展用响应式流观察查询结果SQLDelight RxJava 扩展用响应式流观察查询结果 导读 SQLDelight 会根据 SQL 生成类型安全的 Kotlin 查询 API但查询后端ORM上一篇DistroAV终极指南7个简单步骤实现OBS Studio多设备NDI网络视频传输下一篇Markdown Viewer终极浏览器Markdown阅读器让技术文档阅读体验焕然一新创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
