R2DBC：如何在不需要所有参数的情况下为 sql 查询绑定数据类？

问题描述

我正在尝试为 sql 查询绑定我的数据类，但是当我没有使用我的数据类中的所有参数时出现错误。有没有办法在 sql 查询中检查哪些参数需要绑定，哪些不需要或允许绑定未使用的参数。错误如下：

Request error
 java.lang.IllegalArgumentException: Identifier 'deleted_at' is not a valid identifier. Should be of the pattern '\$([\d]+)'.
    at io.r2dbc.postgresql.ExtendedQueryPostgresqlStatement.getIndex(ExtendedQueryPostgresqlStatement.java:196)
Caused by: java.lang.IllegalArgumentException: Identifier 'deleted_at' is not a valid identifier. Should be of the pattern '\$([\d]+)'.
    at io.r2dbc.postgresql.ExtendedQueryPostgresqlStatement.getIndex(ExtendedQueryPostgresqlStatement.java:196)

这是我使用的代码： 存储库：

      client
            .sql(
                """
                INSERT INTO app_user_settings (uuid,allows_to_process_transactions,app_user_id) VALUES (:uuid,:allows_to_process_transactions,:app_user_id)
                RETURNING *
                """.trimIndent()
            )
            .bind(AppUserSettingsWriteConverter(),appUserSettings)
            .map(AppUserSettingsReadConverter()::convert)
            .awaitOne()

自定义绑定方法：

fun <T> DatabaseClient.GenericExecuteSpec.bind(
    convertor: Converter<T,OutboundRow>,value: T
): DatabaseClient.GenericExecuteSpec {
    val outboundRow = convertor.convert(value!!)!!
    val t = outboundRow.toMap()
    var execution = this
    t.forEach { (t,u) ->
        execution = execution.bind(t.toString(),u)
    }
    return execution
}

写入转换器：

class AppUserSettingsWriteConverter : Converter<AppUserSettings,OutboundRow> {
    override fun convert(source: AppUserSettings): OutboundRow {
        val outboundRow = OutboundRow()

        if (source.isSaved()) {
            outboundRow[sqlIdentifier.unquoted("id")] = Parameter.from(source.id)
        }
        outboundRow[sqlIdentifier.unquoted("uuid")] = Parameter.from(source.uuid)
        outboundRow[sqlIdentifier.unquoted("allows_to_process_transactions")] = Parameter.from(source.allowsToProcesstransactions)
        outboundRow[sqlIdentifier.unquoted("app_user_id")] = Parameter.from(source.appUserId)
        outboundRow[sqlIdentifier.unquoted("deleted_at")] = Parameter.fromOrEmpty(source.deletedAt,zoneddatetime::class.java)

        return outboundRow
    }
}

我现在正在使用检查是否 delete_at 为空，然后不绑定它，但如果有另一种方法可以做到这一点。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）