High Level DAO Library for VertX
The goal of this library is to offer a simple way to create and manage DAOs using VertX.
HLVX-Dao is still in alpha, so please report any issues discovered.
HLVX-Dao is available on maven central, simply add this dependency to your maven project:
<dependency>
<groupId>com.github.hlvx</groupId>
<artifactId>hlvx-dao</artifactId>
<version>VERSION</version>
</dependency>Cloning this repository
git clone https://github.com/hlvx/HLVX-DaoThen install the library locally
cd HLVX-Dao
mvn installThe complete example can be found here.
All examples assumes that you have a minimal environment similar to the one
defined here:
public class Example {
public void test() throws NoSuchMethodException {
Vertx vertx = Vertx.vertx();
JsonObject config = new JsonObject()
.put("url", "jdbc:hsqldb:mem:test?shutdown=true")
.put("driver_class", "org.hsqldb.jdbcDriver")
.put("max_pool_size", 30);
JDBCClient client = JDBCClient.createShared(vertx, config);
DaoManager manager = new DaoManager(client);
manager.registerDao(MyDaoClass.class);
manager.registerDao(MyDaoClass2.class);
// Next examples executes here
}
private static class MyDaoClass extends DAO<MyDaoClass> {
public void exampleQuery(Handler<AsyncResult<ResultSet>> handler) {
executeQuery(handler, "SELECT * FROM users");
}
public void exampleInsert(Handler<AsyncResult<UpdateResult>> handler, String username, String email) {
executeInsert(handler, "INSERT INTO users (username, email) VALUES (?, ?)", username, email);
}
}
private static class MyDaoClass2 extends DAO<MyDaoClass2> {
public void exampleUpdate(Handler<AsyncResult<UpdateResult>> handler, String username, String newUsername) {
executeUpdate(handler, "UPDATE users SET username = ? WHERE username = ?", newUsername, username);
}
}
}manager.createDao(MyDaoClass.class, daoResult -> {
if (daoResult.succeeded()) {
daoResult.result().exampleQuery(resultSet -> {
if (resultSet.succeeded()) {
ResultSet rs = resultSet.result();
// Do what you want to do with your result set here
} else {
// Handle error
}
});
} else {
// Handle error
}
});manager.createDao(MyDaoClass.class, daoResult -> {
if (daoResult.succeeded()) {
MyDaoClass dao = daoResult.result();
dao.startTransaction(sessionResult -> {
if (sessionResult.succeeded()) {
dao.exampleInsert(resultSetResult -> {
if (resultSetResult.succeeded()) {
dao.deleteUser(deletionResult -> {
if (deletionResult.succeeded()) {
dao.commit(result -> {
if (result.failed()) {
dao.rollback(result2 -> {
if (result2.failed()) {
// Handle error
}
});
// Handle error
}
});
} else {
dao.rollback(result -> {
if (result.failed()) {
// Handle error
}
});
// Handle error
}
}, "username");
} else {
dao.rollback(result -> {
if (result.failed()) {
// Handle error
}
});
// Handle error
}
}, "username", "email");
} else {
// Handle error
}
});
} else {
// Handle error
}
});SQLSession.createSession(client, sessionResult -> {
if (sessionResult.succeeded()) {
SQLSession session = sessionResult.result();
manager.createDao(session, MyDaoClass.class, dao1Result -> {
if (dao1Result.succeeded()) {
MyDaoClass dao1 = dao1Result.result();
manager.createDao(session, MyDaoClass2.class, dao2Result -> {
MyDaoClass2 dao2 = dao2Result.result();
if (dao2Result.succeeded()) {
session.startTransaction(result -> {
if (result.succeeded()) {
dao1.exampleInsert(resultSet1Result -> {
if (resultSet1Result.succeeded()) {
dao2.exampleUpdate(resultSet2Result -> {
if (resultSet2Result.succeeded()) {
session.commit(commitResult -> {
if (commitResult.failed()) {
// Handle error
}
});
} else {
session.rollback(rollbackResult -> {
if (rollbackResult.failed()) {
// Handle error
}
});
// Handle error
}
}, "username", "newUsername");
} else {
session.rollback(rollbackResult -> {
if (rollbackResult.failed()) {
// Handle error
}
});
// Handle error
}
}, "username", "email");
} else {
// Handle error
}
});
} else {
// Handle error
}
});
} else {
// Handle error
}
});
} else {
// Handle error
}
});HLVX-Dao uses Slf4j logging API. In order to see all messages produces by HLVX-Dao use a Slf4j compatible logging implementation.
<logger name="com.github.hlvx" level="DEBUG" />