DbSqlHandler.java 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. package hello;
  2. import static hello.Helper.randomWorld;
  3. import static hello.Helper.sendJson;
  4. import io.undertow.server.HttpHandler;
  5. import io.undertow.server.HttpServerExchange;
  6. import java.sql.Connection;
  7. import java.sql.PreparedStatement;
  8. import java.sql.ResultSet;
  9. import java.util.Objects;
  10. import javax.sql.DataSource;
  11. /**
  12. * Handles the single-query database test using a SQL database.
  13. */
  14. final class DbSqlHandler implements HttpHandler {
  15. private final DataSource db;
  16. DbSqlHandler(DataSource db) {
  17. this.db = Objects.requireNonNull(db);
  18. }
  19. @Override
  20. public void handleRequest(HttpServerExchange exchange) throws Exception {
  21. World world;
  22. try (Connection connection = db.getConnection();
  23. PreparedStatement statement =
  24. connection.prepareStatement("SELECT * FROM World WHERE id = ?")) {
  25. statement.setInt(1, randomWorld());
  26. try (ResultSet resultSet = statement.executeQuery()) {
  27. resultSet.next();
  28. int id = resultSet.getInt("id");
  29. int randomNumber = resultSet.getInt("randomNumber");
  30. world = new World(id, randomNumber);
  31. }
  32. }
  33. sendJson(exchange, world);
  34. }
  35. }