From 7e7c7be8c3936f6fce26b435a2386752ec75cded Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Wed, 24 Jan 2024 15:11:47 -0500 Subject: [PATCH] DBZ-7388 Fix test failures --- .../it/OutboxWithoutOpenTelemetryTest.java | 19 ++++++------------- 1 file changed, 6 insertions(+), 13 deletions(-) diff --git a/debezium-quarkus-outbox/integration-tests/src/test/java/io/debezium/outbox/quarkus/it/OutboxWithoutOpenTelemetryTest.java b/debezium-quarkus-outbox/integration-tests/src/test/java/io/debezium/outbox/quarkus/it/OutboxWithoutOpenTelemetryTest.java index ab5eaec30..30f3facdf 100644 --- a/debezium-quarkus-outbox/integration-tests/src/test/java/io/debezium/outbox/quarkus/it/OutboxWithoutOpenTelemetryTest.java +++ b/debezium-quarkus-outbox/integration-tests/src/test/java/io/debezium/outbox/quarkus/it/OutboxWithoutOpenTelemetryTest.java @@ -7,11 +7,10 @@ import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; -import static org.junit.jupiter.api.Assertions.fail; +import static org.junit.jupiter.api.Assertions.assertNull; -import org.hibernate.QueryException; import org.hibernate.engine.spi.SessionImplementor; -import org.hibernate.metamodel.spi.MetamodelImplementor; +import org.hibernate.metamodel.spi.MappingMetamodelImplementor; import org.hibernate.persister.entity.EntityPersister; import org.junit.jupiter.api.Test; @@ -32,18 +31,12 @@ public class OutboxWithoutOpenTelemetryTest extends AbstractOutboxTest { @Test public void testOutboxEntityMetamodelDoesntHaveTracingSpanColumn() throws Exception { - final MetamodelImplementor metadata = entityManager.unwrap(SessionImplementor.class).getFactory().getMetamodel(); + final MappingMetamodelImplementor metadata = entityManager.unwrap(SessionImplementor.class).getFactory().getMappingMetamodel(); - final EntityPersister persister = metadata.entityPersister(OutboxConstants.OUTBOX_ENTITY_FULLNAME); + final EntityPersister persister = metadata.getEntityDescriptor(OutboxConstants.OUTBOX_ENTITY_FULLNAME); assertNotNull(persister); - try { - assertEquals(String.class, persister.getPropertyType("aggregateType").getReturnedClass()); - persister.getPropertyType("tracingspancontext"); - fail("Expected exception not thrown"); - } - catch (QueryException e) { - assertEquals("could not resolve property: tracingspancontext of: io.debezium.outbox.quarkus.internal.OutboxEvent", e.getMessage()); - } + assertEquals(String.class.getName(), persister.findAttributeMapping("aggregateType").getJavaType().getTypeName()); + assertNull(persister.findAttributeMapping("tracingspancontext")); } }