Testing MongoDB Atlas Search Java Apps Locally with Testcontainers

package com.mycodefu;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.result.InsertOneResult;
import org.bson.BsonType;
import org.bson.codecs.pojo.annotations.BsonId;
import org.bson.codecs.pojo.annotations.BsonRepresentation;
import org.bson.types.ObjectId;
import java.util.Objects;
import static com. mongodb. client. model. Filters. eq;
public class PersonDataAccess implements AutoCloseable {
private final MongoClient mongoClient;
private final MongoCollection < Person > collection;
public record Person (
@BsonId
@BsonRepresentation ( BsonType. OBJECT_ID)
String id,
String name,
int age,
String job,
String bio
) {
public static Person of ( String name, int age, String job, String bio) {
return new Person ( null, name, age, job, bio);
}
}
public PersonDataAccess ( String connectionString) {
this. mongoClient = MongoClients. create ( connectionString);
this. collection = this. mongoClient. getDatabase ( "examples"). getCollection ( "person", Person. class);
}
public String insertPerson ( Person person) {
InsertOneResult insertOneResult = this. collection. insertOne ( person);
return Objects. requireNonNull ( insertOneResult. getInsertedId ()). asObjectId (). getValue (). toHexString ();
}
public Person getPerson ( String id) {
return this. collection. find ( eq ( "_id", new ObjectId ( id))). first ();
}
public void updatePerson ( Person person) {
this. collection. replaceOne ( eq ( "_id", new ObjectId ( person. id ())), person);
}
public void deletePerson ( String id) {
this. collection. deleteOne ( eq ( "_id", new ObjectId ( id)));
}
@Override
public void close () {
this. mongoClient. close ();
}
}

package com.mycodefu;
import com.mycodefu.PersonDataAccess.Person;
import org.junit.jupiter.api.*;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
import org.testcontainers.mongodb.MongoDBAtlasLocalContainer;
import static org. junit. jupiter. api. Assertions.*;
@Testcontainers
class PersonDataAccessTest {
@Container
private static final MongoDBAtlasLocalContainer mongoDBContainer = new MongoDBAtlasLocalContainer ( "mongodb/mongodb-atlas-local:8.0.5");
@AutoClose
private static PersonDataAccess personDataAccess;
@BeforeAll
static void beforeAll () {
personDataAccess = new PersonDataAccess ( mongoDBContainer. getConnectionString ());
}
@Test
void shouldInsertAndRetrievePerson () {
// Given
Person person = Person. of (
"John Doe",
30,
"Software Developer",
"John is a software developer who loves to code."
);
// When
String id = personDataAccess. insertPerson ( person);
Person retrievedPerson = personDataAccess. getPerson ( id);
// Then
assertNotNull ( id);
assertNotNull ( retrievedPerson);
assertEquals ( id, retrievedPerson. id ());
assertEquals ( "John Doe", retrievedPerson. name ());
assertEquals ( 30, retrievedPerson. age ());
assertEquals ( "Software Developer", retrievedPerson. job ());
assertEquals ( "John is a software developer who loves to code.", retrievedPerson. bio ());
}
@Test
void shouldUpdatePerson () {
// Given
Person person = Person. of (
"Jane Smith",
25,
"Data Scientist",
"Jane is a data scientist who loves to analyze data."
);
String id = personDataAccess. insertPerson ( person);
// When
Person updatedPerson = new Person (
id,
"Jane Smith",
26,
"Senior Data Scientist",
"Jane is a senior data scientist who loves to analyze data."
);
personDataAccess. updatePerson ( updatedPerson);
Person retrievedPerson = personDataAccess. getPerson ( id);
// Then
assertEquals ( 26, retrievedPerson. age ());
assertEquals ( "Senior Data Scientist", retrievedPerson. job ());
}
@Test
void shouldDeletePerson () {
// Given
Person person = Person. of (
"Bill Lumbergh",
40,
"Manager",
"Bill is a manager of tech teams. Often asks 'What's happening?'."
);
String id = personDataAccess. insertPerson ( person);
// When
personDataAccess. deletePerson ( id);
Person retrievedPerson = personDataAccess. getPerson ( id);
// Then
assertNull ( retrievedPerson);
}
}

public List < Person > findPersonByBio ( String query) { return List. of ();}