val connection = connectionFactory.create()
val mono: Mono[Connection] = Flux.from(connection).next()
mono.flatMapMany(connection => {
println("Connection established")
connection.createStatement("INSERT INTO person (id, first_name, last_name) VALUES ($1, $2, $3)")
.bind("$1", 1)
.bind("$2", "Walter")
.bind("$3", "White")
.execute()
}).flatMap(result => {
println("Statement executed")
result.getRowsUpdated
}).subscribe(rowsUpdated => {
println("Inserted " + rowsUpdated + " row(s)")
})