Using RethinkDB Java driver with Kotlin

RethinkDB.kt

/**
 * Database.kt
 */
import com.rethinkdb.RethinkDB
import com.rethinkdb.gen.ast.ReqlExpr
import com.rethinkdb.net.Connection
import com.rethinkdb.net.ConnectionInstance

object Database {
    private lateinit var db: String
    lateinit var connection: Connection<ConnectionInstance>

    fun connect(db: String) {
        this.db = db
        connection = RethinkDB.r.connection().connect()
    }

    fun query(table: String) = RethinkDB.r.db(db).table(table)
}

fun ReqlExpr.run() = this.run<Any>(Database.connection)
inline fun <reified T : Any> ReqlExpr.one(): T? = this.run(Database.connection, T::class.java)

/**
 * Client code
 */
Database.query("tags").insert(pojo).run()
val selected = Database.query("tags").get(id).one<PojoClass>()