Function.java

Function.java

@Singleton
public class Function extends OciFunction {
    @Inject
    DataSource dataSource;

    @ReflectiveAccess
    public String handleRequest() throws SQLException, JsonProcessingException {
        Connection conn = dataSource.getConnection();
        Statement statement = conn.createStatement();
        ResultSet resultSet = statement.executeQuery("select id, first_name, last_name from users");
        return new ObjectMapper().writeValueAsString(convertResultSetToList(resultSet));
    }

    private List<HashMap<String,Object>> convertResultSetToList(ResultSet rs) throws SQLException {
        ResultSetMetaData md = rs.getMetaData();
        int columns = md.getColumnCount();
        List<HashMap<String,Object>> list = new ArrayList<HashMap<String,Object>>();
        while (rs.next()) {
            HashMap<String,Object> row = new HashMap<String, Object>(columns);
            for(int i=1; i<=columns; ++i) {
                row.put(md.getColumnName(i),rs.getObject(i));
            }
            list.add(row);
        }
        return list;
    }

}