Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,8 @@ repositories {
}

dependencies {
implementation("io.flamingock:flamingock-core-commons:$flamingockVersion")
implementation("io.flamingock:flamingock-core-api:${flamingockVersion}")//we need nullable
implementation("io.flamingock:flamingock-template-api:$flamingockVersion")
implementation("org.slf4j:slf4j-api:1.7.36")
compileOnly("org.mongodb:mongodb-driver-sync:4.0.0")

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,10 @@

import com.mongodb.client.ClientSession;
import com.mongodb.client.MongoDatabase;
import io.flamingock.api.annotations.Apply;
import io.flamingock.api.annotations.ApplyTemplate;
import io.flamingock.api.annotations.ChangeTemplate;
import io.flamingock.api.annotations.Nullable;
import io.flamingock.api.annotations.Rollback;
import io.flamingock.api.annotations.RollbackTemplate;
import io.flamingock.api.template.AbstractChangeTemplate;
import io.flamingock.api.template.wrappers.TemplateVoid;
import io.flamingock.api.template.TemplateValidationContext;
Expand Down Expand Up @@ -90,7 +90,7 @@ public MongoChangeTemplate() {
* via {@link MongoOperation#validate(TemplateValidationContext)}, which delegates to the appropriate
* {@code ParametersValidator} for each operation type. No validation is performed here.
*/
@Apply
@ApplyTemplate
public void apply(MongoDatabase db, @Nullable ClientSession clientSession) {
validateSession(clientSession);
applyPayload.getOperator(db).apply(clientSession);
Expand All @@ -103,7 +103,7 @@ public void apply(MongoDatabase db, @Nullable ClientSession clientSession) {
* via {@link MongoOperation#validate(TemplateValidationContext)}, which delegates to the appropriate
* {@code ParametersValidator} for each operation type. No validation is performed here.
*/
@Rollback
@RollbackTemplate
public void rollback(MongoDatabase db, @Nullable ClientSession clientSession) {
validateSession(clientSession);
rollbackPayload.getOperator(db).apply(clientSession);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,11 @@
import com.mongodb.client.MongoDatabase;
import io.flamingock.template.mongodb.MongoTemplateExecutionException;
import io.flamingock.template.mongodb.model.MongoOperation;
import io.flamingock.internal.util.log.FlamingockLoggerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public abstract class MongoOperator {
protected static final Logger logger = FlamingockLoggerFactory.getLogger("MongoTemplate");
protected static final Logger logger = LoggerFactory.getLogger("MongoTemplate");

protected final MongoDatabase mongoDatabase;
protected final MongoOperation op;
Expand Down
Loading