R2DBC EventStore

Postgres JSON java application based on Spring Boot and Spring WebFlux with R2DBC, Postgres and nkonev r2dbc migration tool and Jakarta JSON-B Glassfish and yasson implementations

Getting started

./mvnw -P pg-start
./mvnw spring-boot:run

curl -iv localhost:8080/event-stream/00000000-0000-0000-0000-000000000001
curl -iv localhost:8080/event-stream

curl -sSH'Content-Type:application/json' localhost:8080/append-event -d'{"aggregateId":"00000000-0000-0000-0000-000000000001","jsonData":"{\"aggregateId\":\"00000000-0000-0000-0000-000000000001\",\"eventType\":\"VisitorRegisteredEvent\",\"name\":\"Test visitor\"}"}'
curl -sSH'Content-Type:application/json' localhost:8080/append-event -d'{"aggregateId":"00000000-0000-0000-0000-000000000001","jsonData":"{\"aggregateId\":\"00000000-0000-0000-0000-000000000001\",\"eventType\":\"PassCardDeliveredEvent\"}"}'
curl -sSH'Content-Type:application/json' localhost:8080/append-event -d'{"aggregateId":"00000000-0000-0000-0000-000000000001","jsonData":"{\"aggregateId\":\"00000000-0000-0000-0000-000000000001\",\"eventType\":\"EnteredTheDoorEvent\",\"doorId\":\"IN-1\"}"}'
curl -sSH'Content-Type:application/json' localhost:8080/append-event -d'{"aggregateId":"00000000-0000-0000-0000-000000000001","jsonData":"{\"aggregateId\":\"00000000-0000-0000-0000-000000000001\",\"eventType\":\"EnteredTheDoorEvent\",\"doorId\":\"IN-2\"}"}'
curl -sSH'Content-Type:application/json' localhost:8080/append-event -d'{"aggregateId":"00000000-0000-0000-0000-000000000001","jsonData":"{\"aggregateId\":\"00000000-0000-0000-0000-000000000001\",\"eventType\":\"EnteredTheDoorEvent\",\"doorId\":\"OUT-2\"}"}'

./mvnw -P pg-stop

RTFM

• pgjdbc/pgjdbc#265 (comment)
• http://json-b.net/docs/user-guide.html#mapping-an-object
• https://www.postgresqltutorial.com/postgresql-json/
• https://stackoverflow.com/a/58147091/1490636
• https://projectreactor.io/docs/core/release/reference/#processors