Нет отката транзакции с R2DBC - PullRequest
Новая
       25

Нет отката транзакции с R2DBC

0 голосов
/ 06 мая 2020

Я пытаюсь выполнить транзакцию с помощью spring-data-r2db c, но это не работает. Когда два запроса работают, все в порядке, когда первый запрос не выполняется, второй не выполняется. Но когда второй запрос не выполняется, первый не откатывается.

Я использовал spring-data-r2db c в 1.0.0.RELEASE, r2db c - postgresql в 0.8.1. RELEASE, r2db c -pool в 0.8.1.RELEASE 

@Transactional("reactiveTransactionManager")
fun insertPatchAndData(type: String, patch: JsonPatch, data: MyData, userId: String): Mono<Void> {
    return databaseClient.execute("""
                        insert data_patch(
                            id,
                            serial,
                            member_id,
                            system_id,
                            user_id,
                            type_patch,
                            version,
                            data_patch,
                            created_at,
                            modified_at
                        ) values (
                            :id,
                            nextval('data_patch_serial_seq'),
                            :memberId,
                            :systemId,
                            :userId,
                            :type,
                            :version,
                            :patch,
                            :createdAt,
                            :modifiedAt
                        )
                        """.trimIndent())
            .bind("id", data.id)
            .bind("memberId", data.memberId.toString())
            .bind("systemId", "default")
            .bind("userId", userId)
            .bind("type", type)
            .bind("version", 1)
            .bind("patch", Json.of(objectMapper.writeValueAsString(patch)))
            .bind("createdAt", data.createdAt)
            .bind("modifiedAt", OffsetDateTime.now())
            .fetch()
            .then(databaseClient.execute("""
                        insert into
                            data(id, member_id, json_data)
                        values
                            (:id, :memberId, :data)
                        on conflict (id) do
                        update set
                            json_data = :data
                    """.trimMargin()
                    ).bind("id", data.id)
                    .bind("memberId", data.memberId.toString())
                    .bind("data", Json.of(objectMapper.writeValueAsString(data)))
                    .fetch().rowsUpdated()).then()
}

@Configuration
@EnableTransactionManagement
class R2dbcConfiguration(private val r2dbcProperties: R2dbcProperties) {

    private lateinit var pool: ConnectionPool

    @Bean
    fun connectionFactory(): ConnectionFactory {
        val connectionFactoryOptions = ConnectionFactoryOptions.builder()
            .from(ConnectionFactoryOptions.parse(r2dbcProperties.url))
            .option(ConnectionFactoryOptions.USER, r2dbcProperties.username)
            .option(ConnectionFactoryOptions.PASSWORD, r2dbcProperties.password)
            .build()
        return ConnectionFactories.get(connectionFactoryOptions)
    }

    @Bean
    fun pool(connectionFactory: ConnectionFactory): ConnectionPool {
        val connectionPoolConfiguration = ConnectionPoolConfiguration.builder(connectionFactory)
            .initialSize(r2dbcProperties.pool.initialSize)
            .maxSize(r2dbcProperties.pool.maxSize)
            .build()
        return ConnectionPool(connectionPoolConfiguration)
    }

    @Bean
    fun reactiveTransactionManager(connectionFactory: ConnectionFactory): ReactiveTransactionManager {
        return R2dbcTransactionManager(connectionFactory)
    }

    @Bean
    fun client(pool: ConnectionPool): DatabaseClient {
        return DatabaseClient.create(pool)
    }

    @PreDestroy
    fun destroy() {
        pool.let { if (!it.isDisposed) it.dispose() }
    }
}

При отладке я вижу, что используемый PooledConnection имеет атрибут inTransaction со значением false

...