import io.r2dbc.mssql.MssqlConnectionConfiguration;
import io.r2dbc.mssql.MssqlConnectionFactory;
import io.r2dbc.spi.ConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.r2dbc.config.AbstractR2dbcConfiguration;

import javax.annotation.ParametersAreNonnullByDefault;

@Configuration
@ParametersAreNonnullByDefault
public class R2dbcConfig extends AbstractR2dbcConfiguration {

    private final R2dbcProperties r2dbcProperties;

    public R2dbcConfig(R2dbcProperties r2dbcProperties) {
        this.r2dbcProperties = r2dbcProperties;
    }

    @Bean
    @Override
    public ConnectionFactory connectionFactory() {
        MssqlConnectionConfiguration configuration = MssqlConnectionConfiguration.builder()
                .host(r2dbcProperties.getHost())
                .username(r2dbcProperties.getUsername())
                .password(r2dbcProperties.getPassword())
                .database(r2dbcProperties.getDatabase())
                .build();
        return new MssqlConnectionFactory(configuration);
    }

//    @Bean
//    ReactiveTransactionManager transactionManager(ConnectionFactory connectionFactory) {
//        return new R2dbcTransactionManager(connectionFactory);
//    }

//    @Bean
//    ReactiveTransactionSynchronization reactiveTransactionSynchronization() {
//        return new ReactiveTransactionSynchronization();
//    }
}