public ListDatabasesResponse handleRequest()

in hms-lambda-handler/src/main/java/com/amazonaws/athena/hms/handler/ListDatabasesHandler.java [99:132]

34 lines of code
7 McCabe index (conditional complexity)


  public ListDatabasesResponse handleRequest(ListDatabasesRequest request, Context context)
  {
    HiveMetaStoreConf conf = getConf();
    try {
      context.getLogger().log("Connecting to embedded HMS client");
      HiveMetaStoreClient client = getClient();
      ListDatabasesResponse response = new ListDatabasesResponse();
      DatabasePaginator paginator = new DatabasePaginator(context, request, client);
      PaginatedResponse<Database> paginatedResponse = paginator.paginateByNames(request.getNextToken(), request.getMaxSize());
      if (paginatedResponse != null) {
        response.setNextToken(paginatedResponse.getNextToken());
        List<Database> databases = paginatedResponse.getEntries();
        if (databases != null && !databases.isEmpty()) {
          TSerializer serializer = new TSerializer(getTProtocolFactory());
          List<String> jsonDatabaseList = new ArrayList<>();
          for (Database database : databases) {
            jsonDatabaseList.add(serializer.toString(database, StandardCharsets.UTF_8.name()));
          }
          response.setDatabases(jsonDatabaseList);
          context.getLogger().log("Paginated response: entry size: " + jsonDatabaseList.size()
              + ", nextToken: " + response.getNextToken());
        }
      }
      return response;
    }
    catch (RuntimeException e) {
      context.getLogger().log("Exception: " + e.getMessage());
      throw e;
    }
    catch (Exception e) {
      context.getLogger().log("Exception: " + e.getMessage());
      throw new RuntimeException(e);
    }
  }