Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
juliuskrah committed Mar 18, 2024
1 parent 9519aee commit b742f21
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ import org.bson.conversions.Bson
import org.springframework.aot.hint.annotation.Reflective
import org.springframework.core.io.ClassPathResource
import java.io.IOException
import java.lang.System.Logger.Level.INFO
import java.time.Instant
import java.util.ResourceBundle

Expand All @@ -30,12 +29,12 @@ import java.util.ResourceBundle
*/
@Reflective
@ChangeUnit(id = "create-product-collection-202401151530", order = "202401151530", author = "Julius Krah")
class CreateProductCollectionChangeUnit202401151530(
class `202401151530CreateProductCollectionChangeUnit`(
private val database: MongoDatabase,
private val session: ClientSession,
private val jackson: ObjectMapper
) {
private val log: System.Logger = System.getLogger(CreateProductCollectionChangeUnit202401151530::class.simpleName, ResourceBundle.getBundle("messages.messages"))
private val log: System.Logger = System.getLogger(`202401151530CreateProductCollectionChangeUnit`::class.simpleName, ResourceBundle.getBundle("messages.messages"))

companion object {
@JvmStatic
Expand Down Expand Up @@ -116,7 +115,7 @@ class CreateProductCollectionChangeUnit202401151530(
@Execution
fun addDataProductCollection() {
val jsonProducts = readFile("data/products.json")
log.log(INFO, "log.migration.json.data", jsonProducts)
log.log(System.Logger.Level.INFO, "log.migration.json.data", jsonProducts)
val products = jsonProducts.map{
it["createdAt"] = Instant.ofEpochSecond((it["createdAt"] as Int).toLong())
it["updatedAt"] = Instant.ofEpochSecond((it["updatedAt"] as Int).toLong())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ package com.example.graph.repository
import com.example.graph.spring.EnableMongockChangeUnit
import com.mongodb.reactivestreams.client.MongoClient
import io.mongock.api.annotations.ChangeUnit
import io.mongock.api.config.MongockConfiguration
import io.mongock.driver.mongodb.reactive.driver.MongoReactiveDriver
import io.mongock.runner.core.executor.MongockRunner
import io.mongock.runner.springboot.base.MongockApplicationRunner
Expand All @@ -17,7 +18,6 @@ import org.springframework.data.domain.ReactiveAuditorAware
import org.springframework.data.mongodb.config.EnableReactiveMongoAuditing
import org.springframework.data.mongodb.core.mapping.Document
import reactor.core.publisher.Mono
import io.mongock.api.config.MongockConfiguration as MongockConfig

/**
* @author Julius Krah
Expand All @@ -33,7 +33,7 @@ class MongoDBConfiguration {
@Bean
fun connectionDriver(
@Value("\${spring.data.mongodb.database}") database: String,
config: MongockConfig, client: MongoClient,
config: MongockConfiguration, client: MongoClient,
): MongoReactiveDriver {
val driver = MongoReactiveDriver.withLockStrategy(client, database,
config.lockAcquiredForMillis,
Expand Down

0 comments on commit b742f21

Please sign in to comment.