How to Use Azure Functions with MongoDB Atlas in Java

1
if (name == null) {
2
    return request.createResponseBuilder(HttpStatus.BAD_REQUEST)
3
        .body("Please pass a name on the query string or in the request body").build();
4
} else {
5
    return request.createResponseBuilder(HttpStatus.OK).body("Hello, " + name).build();
6
}

1
dependencies {
2
    implementation 'com.microsoft.azure.functions:azure-functions-java-library:3.0.0'
3
    // dependency for MongoDB Java driver
4
    implementation 'org.mongodb:mongodb-driver-sync:4.9.0'
5
}

1
public class Movies {
2
    /**
3
     * This function listens at endpoint "/api/Movie". Two ways to invoke it using "curl" command in bash:
4
     * 1. curl -d "HTTP Body" {your host}/api/Movie
5
     * 2. curl {your host}/api/Movie?name=HTTP%20Query
6
     */
7
    @FunctionName("Movies")
8
    public HttpResponseMessage run(
9
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
10
            final ExecutionContext context) {
11
        context.getLogger().info("Java HTTP trigger processed a request.");
12
13
        // Parse query parameter
14
        String query = request.getQueryParameters().get("name");
15
        String name = request.getBody().orElse(query);
16
17
        if (name == null) {
18
            return request.createResponseBuilder(HttpStatus.BAD_REQUEST).body("Please pass a name on the query string or in the request body").build();
19
        } else {
20
            return request.createResponseBuilder(HttpStatus.OK).body("Hello, " + name).build();
21
        }
22
    }
23
}

1
public class Movies {
2
3
    @FunctionName("getMoviesCount")
4
    public HttpResponseMessage getMoviesCount(
5
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
6
            final ExecutionContext context) {
7
        context.getLogger().info("Java HTTP trigger processed a request.");
8
9
        return request.createResponseBuilder(HttpStatus.OK).body("Hello").build();
10
    }
11
}

1
public class Movies {
2
3
    private static final String MONGODB_CONNECTION_URI = "mongodb+srv://xxxxx@cluster0.xxxx.mongodb.net/?retryWrites=true&w=majority";
4
    private static final String DATABASE_NAME = "sample_mflix";
5
    private static final String COLLECTION_NAME = "movies";
6
    private static MongoDatabase database = null;
7
8
    private static MongoDatabase createDatabaseConnection() {
9
        if (database == null) {
10
            try {
11
                MongoClient client = MongoClients.create(MONGODB_CONNECTION_URI);
12
                database = client.getDatabase(DATABASE_NAME);
13
            } catch (Exception e) {
14
                throw new IllegalStateException("Error in creating MongoDB client");
15
            }
16
        }
17
        return database;
18
    }
19
    
20
    /*@FunctionName("getMoviesCount")
21
    public HttpResponseMessage run(
22
            @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
23
            final ExecutionContext context) {
24
        context.getLogger().info("Java HTTP trigger processed a request.");
25
26
        return request.createResponseBuilder(HttpStatus.OK).body("Hello").build();
27
    }*/
28
}

1
long totalRecords=database.getCollection(COLLECTION_NAME).countDocuments();

1
@FunctionName("getMoviesCount")
2
public HttpResponseMessage getMoviesCount(
3
      @HttpTrigger(name = "req",
4
              methods = {HttpMethod.GET},
5
              authLevel = AuthorizationLevel.ANONYMOUS
6
      ) HttpRequestMessage<Optional<String>> request,
7
      final ExecutionContext context) {
8
9
  if (database != null) {
10
      long totalRecords = database.getCollection(COLLECTION_NAME).countDocuments();
11
      return request.createResponseBuilder(HttpStatus.OK).body("Total Records, " + totalRecords + " - At:" + System.currentTimeMillis()).build();
12
  } else {
13
      return request.createResponseBuilder(HttpStatus.INTERNAL_SERVER_ERROR).build();
14
  }
15
}

1
@FunctionName("getMoviesByYear")
2
public HttpResponseMessage getMoviesByYear(
3
      @HttpTrigger(name = "req",
4
              methods = {HttpMethod.GET},
5
              authLevel = AuthorizationLevel.ANONYMOUS
6
      ) HttpRequestMessage<Optional<String>> request,
7
      final ExecutionContext context) {
8
9
}

1
final int yearRequestParam = valueOf(request.getQueryParameters().get("year"));

1
Bson filter = Filters.eq("year", yearRequestParam);
2
Document result = collection.find(filter).first();

1
@FunctionName("getMoviesByYear")
2
public HttpResponseMessage getMoviesByYear(
3
      @HttpTrigger(name = "req",
4
              methods = {HttpMethod.GET},
5
              authLevel = AuthorizationLevel.ANONYMOUS
6
      ) HttpRequestMessage<Optional<String>> request,
7
      final ExecutionContext context) {
8
9
  final int yearRequestParam = valueOf(request.getQueryParameters().get("year"));
10
  MongoCollection<Document> collection = database.getCollection(COLLECTION_NAME);
11
12
  if (database != null) {
13
      Bson filter = Filters.eq("year", yearRequestParam);
14
      Document result = collection.find(filter).first();
15
      return request.createResponseBuilder(HttpStatus.OK).body(result.toJson()).build();
16
  } else {
17
      return request.createResponseBuilder(HttpStatus.BAD_REQUEST).body("Year missing").build();
18
  }
19
}

1
private static final String MONGODB_CONNECTION_URI = "mongodb+srv://xxxxx:xxxx@cluster0.xxxxx.mongodb.net/?retryWrites=true&w=majority";

1
private static final String MONGODB_CONNECTION_URI = System.getenv("MongoDB_Connection_URL");