rxjava-jdbc example

rxjava-jdbc.groovy

@GrabConfig(systemClassLoader=true)
@Grab('mysql:mysql-connector-java:5.1.25')
@Grab('log4j:log4j:1.2.17')
@Grab('com.github.davidmoten:rxjava-jdbc:0.7')
    
import groovy.sql.Sql
import groovy.sql.GroovyRowResult
import groovy.time.TimeCategory
import com.github.davidmoten.rx.jdbc.Database

def start = new Date()

Database db = Database.from("jdbc:mysql://localhost:3306/lite", "root", "password");
List<String> names = db
        .select("select username from user where username > ? order by username")
        .parameter("admin")
        .getAs(String.class)
        .toList().toBlocking().single();

names.each {
    println it
}

def end = new Date()
def elapsed = TimeCategory.minus(end, start)

println "It took ${elapsed} to process. Bye"