Object-oriented wrapper for JDBC

Simple object-oriented wrapper around JDBC. This is a fork of jcabi-jdbc.

SQL queries

Single value queries

String name = new JdbcSession<>(
    new Select<>(
        new Sql("SELECT name FROM users"),
        new SingleOutcome<>(String.class)
    )
).using(datasource);

Collection queries

List<String> names = new JdbcSession<>(
    new Select<>(
        new Sql(
            "SELECT name FROM users",
            "WHERE age > ?"
        ),
        new Args(20),
        new ColumnOutcome<>(String.class)
    )
).using(datasource);

Custom collection queries

List<User> kids = new JdbcSession<>(
    new Select<>(
        new Sql(
            "SELECT name, age FROM users",
            "WHERE age < ?"
        ),
        new Args(10),
        new ListOutcome<>(
            rset -> new User(
                rset.getString("name"),
                rset.getInt("age")
            );
        )
    )
).using(datasource);

@RequiredArgsConstructor
class User {
    private final String name;
    private final int age;
}

Insert/Update statements

Single table inserts

long id = new JdbcSession<>(
    new Insert<>(
        new Sql(
            "INSERT INTO users (name, age)",
            "VALUES (?, ?)"
        ),
        new Args("Mark", 32),
        Outcome.LAST_INSERT_ID
    )
).using(datasource);

Multiple (transactional) table updates

new JdbcSessionTx<>(
    conn -> {
        long id = new Insert<>(
            new Sql(
                "INSERT INTO users (name, age)",
                "VALUES (?, ?)"
            ),
            new Args("Mark", 32),
            Outcome.LAST_INSERT_ID
        ).using(conn);
        return new Insert<>(
            new Sql(
                "INSERT INTO family (user)",
                "VALUES (?)"
            ),
            new Args(id),
            Outcome.VOID
        ).using(conn);
    }
).using(datasource);

Other statements

Table creation

new JdbcSession<>(
    new Exec(
        new Sql(
            "CREATE TABLE IF NOT EXISTS foo (name VARCHAR(50))"
        )
    )
).using(datasource);

Procedure creation and call

final Object[] result = new JdbcSession<>(
    conn -> {
        new Exec(
            new Sql(
                "CREATE PROCEDURE proc(OUT username text, OUT day date) ",
                "BEGIN SELECT name, CURDATE() INTO username, day ",
                "FROM users; ",
                "SELECT username, day; ",
                "END"
            )
        ).using(conn);
        return new ProcCall<>(
            new Sql("CALL proc(?, ?)"),
            stmt -> {
                ((CallableStatement) stmt).registerOutParameter(1, Types.VARCHAR);
                ((CallableStatement) stmt).registerOutParameter(2, Types.DATE);
            },
            new StoredProcedureOutcome<Object[]>(1, 2)
        ).using(conn);
    }
).using(datasource);

Please, note the library is still in early development and it's API can frequently change.

To get started, add dependency to your project:

<dependency>
    <groupId>com.github.piotrkot</groupId>
    <artifactId>oojdbc</artifactId>
    <version>1.4.0</version>
</dependency>

Feel free to fork me on GitHub, report bugs or post comments.

For Pull Requests, please run mvn clean package, first.

Tests depend on testcontainers. To successfully run them, you must have Docker installed. Since the Docker daemon always runs as the root user it may be tempting to create and give access to the 'docker' group. This however, may give permanent and non-password protected root access. Instead, it's better to run sudo mvn clean package -Dmaven.repo.local=/home/user/.m2/repository.