alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1711 Suggested improvements

Browse Source
This commit is contained in:
Chris Cranford 2020-02-04 11:12:56 -05:00 committed by Chris Cranford
parent 60af8707b0
commit 917799d167
1 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
debezium-quarkus-outbox-integration-tests/src/test/java/io/debezium/outbox/quarkus/it/OutboxTest.java
View File

@ -5,8 +5,12 @@
*/
package io.debezium.outbox.quarkus.it;
import static org.junit.Assert.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import java.time.Instant;
import java.util.UUID;
import javax.inject.Inject;
import javax.persistence.EntityManager;
@ -15,11 +19,16 @@
import org.hibernate.persister.entity.EntityPersister;
import org.junit.jupiter.api.Test;
import com.fasterxml.jackson.databind.JsonNode;
import io.debezium.outbox.quarkus.internal.OutboxConstants;
import io.quarkus.test.common.QuarkusTestResource;
import io.quarkus.test.junit.QuarkusTest;
/**
* Smoke test that verifies the Debezium Outbox extension started successfully and created the Outbox
* database table with the expected properties and return types.
*
* @author Chris Cranford
*/
@QuarkusTest
@ -34,5 +43,13 @@ public void testOutboxEntityMetamodelExists() throws Exception {
final EntityPersister persister = metadata.entityPersister(OutboxConstants.OUTBOX_ENTITY_FULLNAME);
assertNotNull(persister);
// this assumes the default mapping settings, no custom converters or column types
assertEquals(UUID.class, persister.getIdentifierType().getReturnedClass());
assertEquals(String.class, persister.getPropertyType("aggregateType").getReturnedClass());
assertEquals(String.class, persister.getPropertyType("aggregateId").getReturnedClass());
assertEquals(String.class, persister.getPropertyType("type").getReturnedClass());
assertEquals(Instant.class, persister.getPropertyType("timestamp").getReturnedClass());
assertEquals(JsonNode.class, persister.getPropertyType("payload").getReturnedClass());
}
}