error.type and db.response.status_code for jdbc

Author: zeitlinger

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/DbClientCommonAttributesGetter.java

@@ -54,4 +54,10 @@ default String getResponseStatusFromException(Throwable throwable) {
   default String getResponseStatus(RESPONSE response) {
     return null;
   }
+
+  @Nullable
+  default String httpStatusToResponseStatus(int httpStatus) {
+    int hundreds = httpStatus / 100;
+    return hundreds == 4 || hundreds == 5 ? Integer.toString(httpStatus) : null;
+  }
 }

instrumentation/elasticsearch/elasticsearch-rest-common/library/src/main/java/io/opentelemetry/instrumentation/elasticsearch/rest/internal/ElasticsearchDbAttributesGetter.java

@@ -95,6 +95,6 @@ public String getDbOperationName(ElasticsearchRestRequest request) {
 
   @Override
   public String getResponseStatus(Response response) {
-    return String.valueOf(response.getStatusLine().getStatusCode());
+    return httpStatusToResponseStatus(response.getStatusLine().getStatusCode());
   }
 }

instrumentation/lettuce/lettuce-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/lettuce/v4_0/LettuceAsyncClientTest.java

@@ -8,6 +8,7 @@
 import static io.opentelemetry.api.common.AttributeKey.booleanKey;
 import static io.opentelemetry.instrumentation.testing.junit.db.SemconvStabilityUtil.maybeStable;
 import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
+import static io.opentelemetry.semconv.ErrorAttributes.ERROR_TYPE;
 import static io.opentelemetry.semconv.ServerAttributes.SERVER_ADDRESS;
 import static io.opentelemetry.semconv.ServerAttributes.SERVER_PORT;
 import static io.opentelemetry.semconv.incubating.DbIncubatingAttributes.DB_OPERATION;
@@ -422,7 +423,9 @@ void testCommandCompletesExceptionally() {
                         .hasException(new IllegalStateException("TestException"))
                         .hasAttributesSatisfyingExactly(
                             equalTo(maybeStable(DB_SYSTEM), "redis"),
-                            equalTo(maybeStable(DB_OPERATION), "DEL"))));
+                            equalTo(maybeStable(DB_OPERATION), "DEL"),
+                            equalTo(maybeStable(ERROR_TYPE), "java.lang.IllegalStateException")
+                        )));
   }
 
   @Test

instrumentation/opensearch/opensearch-rest-common/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/opensearch/rest/OpenSearchRestAttributesGetter.java

@@ -53,6 +53,6 @@ public String getDbOperationName(OpenSearchRestRequest request) {
 
   @Override
   public String getResponseStatus(Response response) {
-    return String.valueOf(response.getStatusLine().getStatusCode());
+    return httpStatusToResponseStatus(response.getStatusLine().getStatusCode());
   }
 }