ensure provided tags are reported for fetchExists

Signed-off-by: heechann <[email protected]>

Author: HeeChanN

micrometer-core/src/main/java/io/micrometer/core/instrument/binder/db/MetricsDSLContext.java

@@ -21,6 +21,7 @@
 import io.micrometer.core.instrument.Tags;
 import org.jooq.*;
 import org.jooq.Record;
+import org.jooq.impl.DSL;
 import org.jooq.impl.DefaultDSLContext;
 
 import java.util.Arrays;
@@ -792,4 +793,9 @@ public <R extends Record> UpdateSetFirstStep<R> update(Table<R> table) {
         return timeCoercable(super.update(table));
     }
 
+    @Override
+    public boolean fetchExists(Table<?> table, Condition condition) {
+        return super.fetchExists(DSL.selectOne().from(table).where(condition));
+    }
+
 }

micrometer-core/src/test/java/io/micrometer/core/instrument/binder/db/MetricsDSLContextTest.java

@@ -173,6 +173,22 @@ void timeTwoStatementsCreatedBeforeEitherIsExecuted() throws SQLException {
         }
     }
 
+    @Test
+    void fetchExistsIsTimedWithProvidedTags() throws SQLException {
+        try (Connection conn = DriverManager.getConnection("jdbc:h2:mem:fetchExists")) {
+            MetricsDSLContext jooq = createDatabase(conn);
+
+            boolean exists = jooq.tag("name", "checkAuthorExists").fetchExists(table("author"), field("id").eq(1));
+            assertThat(exists).isTrue();
+
+            assertThat(meterRegistry.get("jooq.query")
+                .tag("name", "checkAuthorExists")
+                .tag("type", "read")
+                .timer()
+                .count()).isEqualTo(1);
+        }
+    }
+
     @Test
     void userExecuteListenerShouldBePreserved() {
         ExecuteListener userExecuteListener = mock(ExecuteListener.class);