Class PetServlet

kilo-test/src/main/java/org/httprpc/kilo/test/PetServlet.java:39–105

import static org.httprpc.kilo.util.Iterables.*;

@WebServlet("/pets/example")
public class PetServlet extends PageServlet {
    private interface Parameters {
        @Required
        String getOwner();
    }

    private DataSource dataSource = null;

    @Override
    public void init() throws ServletException {
        super.init();

        try {
            var initialContext = new InitialContext();
            var environmentContext = (Context)initialContext.lookup("java:comp/env");

            dataSource = (DataSource)environmentContext.lookup(AbstractDatabaseService.DEMO_DB);
        } catch (NamingException exception) {
            throw new ServletException(exception);
        }
    }

    @Override
    protected Connection openConnection() throws SQLException {
        return dataSource.getConnection();
    }

    @Override
    protected Object execute() throws IOException, SQLException {
        var parameters = getParameters(Parameters.class);

        var owner = parameters.getOwner();

        var queryBuilder = QueryBuilder.select(Pet.class)
            .filterByForeignKey(Owner.class, "owner")
            .ordered(true);

        List<Pet> pets;
        try (var statement = queryBuilder.prepare(getConnection());
            var results = queryBuilder.executeQuery(statement, mapOf(
                entry("owner", owner)
            ))) {
            pets = listOf(mapAll(results, BeanAdapter.toType(Pet.class)));
        }

        var request = getRequest();

        var accept = request.getHeader("Accept");

        if (accept != null && accept.equalsIgnoreCase(WebService.TEXT_CSV)) {
            var response = getResponse();

            response.setContentType(WebService.TEXT_CSV);

            var csvEncoder = new CSVEncoder(listOf("name", "species", "sex", "birth", "death"));

            csvEncoder.setResourceBundle(ResourceBundle.getBundle(getClass().getName(), request.getLocale()));