Instantly share code, notes, and snippets.

What would you like to do?
package jmodern;
import com.codahale.metrics.*;
import com.codahale.metrics.annotation.*;
import com.fasterxml.jackson.annotation.*;
import feign.Feign;
import feign.jackson.*;
import feign.jaxrs.*;
import io.dropwizard.Application;
import io.dropwizard.*;
import io.dropwizard.db.*;
import io.dropwizard.jdbi.*;
import io.dropwizard.setup.*;
import java.sql.*;
import java.util.*;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.atomic.AtomicLong;
import javax.validation.Valid;
import javax.validation.constraints.NotNull;
import org.hibernate.validator.constraints.*;
import org.skife.jdbi.v2.*;
import org.skife.jdbi.v2.sqlobject.*;
import org.skife.jdbi.v2.sqlobject.customizers.RegisterMapper;
import org.skife.jdbi.v2.tweak.*;
public class Main extends Application<Main.JModernConfiguration> {
public static void main(String[] args) throws Exception {
new Main().run(new String[]{"server", System.getProperty("dropwizard.config")});
public void initialize(Bootstrap<JModernConfiguration> bootstrap) {
public void run(JModernConfiguration cfg, Environment env) throws ClassNotFoundException {
JmxReporter.forRegistry(env.metrics()).build().start(); // Manually add JMX reporting (Dropwizard regression)
env.jersey().register(new HelloWorldResource(cfg));
Feign.Builder feignBuilder = Feign.builder()
.contract(new JAXRSModule.JAXRSContract())
.encoder(new JacksonEncoder())
.decoder(new JacksonDecoder());
env.jersey().register(new ConsumerResource(feignBuilder));
final DBI dbi = new DBIFactory().build(env, cfg.getDataSourceFactory(), "db");
env.jersey().register(new DBResource(dbi));
// YAML Configuration
public static class JModernConfiguration extends Configuration {
@JsonProperty private @NotEmpty String template;
@JsonProperty private @NotEmpty String defaultName;
@Valid @NotNull @JsonProperty private DataSourceFactory database = new DataSourceFactory();
public DataSourceFactory getDataSourceFactory() { return database; }
public String getTemplate() { return template; }
public String getDefaultName() { return defaultName; }
// The actual service
public static class HelloWorldResource {
private final AtomicLong counter = new AtomicLong();
private final String template;
private final String defaultName;
public HelloWorldResource(JModernConfiguration configuration) {
this.template = configuration.getTemplate();
this.defaultName = configuration.getDefaultName();
@Timed // monitor timing of this service with Metrics
public Saying sayHello(@QueryParam("name") Optional<String> name) throws InterruptedException {
final String value = String.format(template, name.or(defaultName));
Thread.sleep(ThreadLocalRandom.current().nextInt(10, 500));
return new Saying(counter.incrementAndGet(), value);
public static class ConsumerResource {
private final HelloWorldAPI hellowWorld;
public ConsumerResource(Feign.Builder feignBuilder) {
this.hellowWorld =, "http://localhost:8080");
public String consume() {
Saying saying = hellowWorld.hi("consumer");
return String.format("The service is saying: %s (id: %d)", saying.getContent(), saying.getId());
public static class DBResource {
private final ModernDAO dao;
public DBResource(DBI dbi) {
this.dao = dbi.onDemand(ModernDAO.class);
try (Handle h = {
h.execute("create table something (id int primary key auto_increment, name varchar(100))");
String[] names = { "Gigantic", "Bone Machine", "Hey", "Cactus" }; -> h.insert("insert into something (name) values (?)", name));
@POST @Path("/add")
public Something add(String name) {
return find(dao.insert(name));
@GET @Path("/item/{id}")
public Something find(@PathParam("id") Integer id) {
return dao.findById(id);
@GET @Path("/all")
public List<Something> all(@PathParam("id") Integer id) {
return dao.all();
interface ModernDAO {
@SqlUpdate("insert into something (name) values (:name)")
int insert(@Bind("name") String name);
@SqlQuery("select * from something where id = :id")
Something findById(@Bind("id") int id);
@SqlQuery("select * from something")
List<Something> all();
public static class Something {
@JsonProperty public final int id;
@JsonProperty public final String name;
public Something(int id, String name) { = id; = name;
public static class SomethingMapper implements ResultSetMapper<Something> {
public Something map(int index, ResultSet r, StatementContext ctx) throws SQLException {
return new Something(r.getInt("id"), r.getString("name"));
interface HelloWorldAPI {
@GET @Path("/hello-world")
Saying hi(@QueryParam("name") String name);
@GET @Path("/hello-world")
Saying hi();
// JSON (immutable!) payload
public static class Saying {
private long id;
private @Length(max = 10) String content;
public Saying(long id, String content) { = id;
this.content = content;
public Saying() {} // required for deserialization
@JsonProperty public long getId() { return id; }
@JsonProperty public String getContent() { return content; }
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment