diff --git a/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/DbClientCommonAttributesGetter.java b/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/DbClientCommonAttributesGetter.java index b135625bd970..bda95d5c69a7 100644 --- a/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/DbClientCommonAttributesGetter.java +++ b/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/DbClientCommonAttributesGetter.java @@ -10,17 +10,7 @@ /** An interface for getting attributes common to database clients. */ public interface DbClientCommonAttributesGetter { - @Deprecated - @Nullable - default String getSystem(REQUEST request) { - return null; - } - - // TODO: make this required to implement - @Nullable - default String getDbSystem(REQUEST request) { - return getSystem(request); - } + String getDbSystem(REQUEST request); @Deprecated @Nullable @@ -28,20 +18,8 @@ default String getUser(REQUEST request) { return null; } - /** - * @deprecated Use {@link #getDbNamespace(Object)} instead. - */ - @Deprecated - @Nullable - default String getName(REQUEST request) { - return null; - } - - // TODO: make this required to implement @Nullable - default String getDbNamespace(REQUEST request) { - return getName(request); - } + String getDbNamespace(REQUEST request); @Deprecated @Nullable diff --git a/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesExtractor.java b/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesExtractor.java index 4cb1ae7fc8cc..b30a61505176 100644 --- a/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesExtractor.java +++ b/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesExtractor.java @@ -27,8 +27,8 @@ * *

It sets the same set of attributes as {@link DbClientAttributesExtractor} plus an additional * db.sql.table attribute. The raw SQL statements returned by the {@link - * SqlClientAttributesGetter#getRawQueryText(Object)} method are sanitized before use, all statement - * parameters are removed. + * SqlClientAttributesGetter#getRawQueryTexts(Object)} method are sanitized before use, all + * statement parameters are removed. */ public final class SqlClientAttributesExtractor extends DbClientCommonAttributesExtractor< diff --git a/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesGetter.java b/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesGetter.java index bdf64e638a1c..3c9af7d35449 100644 --- a/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesGetter.java +++ b/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesGetter.java @@ -5,13 +5,9 @@ package io.opentelemetry.instrumentation.api.incubator.semconv.db; -import static java.util.Collections.emptySet; -import static java.util.Collections.singleton; - import java.util.Collection; import java.util.Collections; import java.util.Map; -import javax.annotation.Nullable; /** * An interface for getting SQL database client attributes. @@ -27,30 +23,6 @@ public interface SqlClientAttributesGetter extends DbClientCommonAttributesGetter { - /** - * Get the raw SQL statement. The value returned by this method is later sanitized by the {@link - * SqlClientAttributesExtractor} before being set as span attribute. - * - * @deprecated Use {@link #getRawQueryText(Object)} instead. - */ - @Deprecated - @Nullable - default String getRawStatement(REQUEST request) { - return null; - } - - /** - * Get the raw SQL query text. The value returned by this method is later sanitized by the {@link - * SqlClientAttributesExtractor} before being set as span attribute. - * - * @deprecated Use {@link #getRawQueryTexts(Object)} instead. - */ - @Deprecated - @Nullable - default String getRawQueryText(REQUEST request) { - return getRawStatement(request); - } - /** * Get the raw SQL query texts. The values returned by this method is later sanitized by the * {@link SqlClientAttributesExtractor} before being set as span attribute. @@ -58,11 +30,7 @@ default String getRawQueryText(REQUEST request) { *

If {@code request} is not a batch query, then this method should return a collection with a * single element. */ - // TODO: make this required to implement - default Collection getRawQueryTexts(REQUEST request) { - String rawQueryText = getRawQueryText(request); - return rawQueryText == null ? emptySet() : singleton(rawQueryText); - } + Collection getRawQueryTexts(REQUEST request); // TODO: make this required to implement default Long getBatchSize(REQUEST request) { diff --git a/instrumentation-api/src/test/java/io/opentelemetry/instrumentation/api/internal/InstrumenterContextTest.java b/instrumentation-api/src/test/java/io/opentelemetry/instrumentation/api/internal/InstrumenterContextTest.java index 044935031cc2..7aa8897b7911 100644 --- a/instrumentation-api/src/test/java/io/opentelemetry/instrumentation/api/internal/InstrumenterContextTest.java +++ b/instrumentation-api/src/test/java/io/opentelemetry/instrumentation/api/internal/InstrumenterContextTest.java @@ -34,6 +34,15 @@ void testSqlSanitizer() { String testQuery = "SELECT name FROM test WHERE id = 1"; SqlClientAttributesGetter getter = new SqlClientAttributesGetter() { + @Override + public String getDbSystem(Object o) { + return "testdb"; + } + + @Override + public String getDbNamespace(Object o) { + return null; + } @Override public Collection getRawQueryTexts(Object request) {