error.type and db.response.status_code for jdbc

Author: zeitlinger

instrumentation/cassandra/cassandra-3.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/cassandra/v3_0/CassandraSqlAttributesGetter.java

@@ -7,13 +7,14 @@
 
 import static java.util.Collections.singleton;
 
+import com.datastax.driver.core.ExecutionInfo;
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.SqlClientAttributesGetter;
 import io.opentelemetry.semconv.incubating.DbIncubatingAttributes;
 import java.util.Collection;
 import javax.annotation.Nullable;
 
 final class CassandraSqlAttributesGetter
-    implements SqlClientAttributesGetter<CassandraRequest, Void> {
+    implements SqlClientAttributesGetter<CassandraRequest, ExecutionInfo> {
 
   @SuppressWarnings("deprecation") // using deprecated DbSystemIncubatingValues
   @Override

instrumentation/cassandra/cassandra-4.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/cassandra/v4_0/CassandraSqlAttributesGetter.java

@@ -8,13 +8,14 @@
 import static java.util.Collections.singleton;
 
 import com.datastax.oss.driver.api.core.CqlIdentifier;
+import com.datastax.oss.driver.api.core.cql.ExecutionInfo;
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.SqlClientAttributesGetter;
 import io.opentelemetry.semconv.incubating.DbIncubatingAttributes;
 import java.util.Collection;
 import javax.annotation.Nullable;
 
 final class CassandraSqlAttributesGetter
-    implements SqlClientAttributesGetter<CassandraRequest, Void> {
+    implements SqlClientAttributesGetter<CassandraRequest, ExecutionInfo> {
 
   @SuppressWarnings("deprecation") // using deprecated DbSystemIncubatingValues
   @Override

instrumentation/cassandra/cassandra-4.4/library/src/main/java/io/opentelemetry/instrumentation/cassandra/v4_4/CassandraSqlAttributesGetter.java

@@ -8,12 +8,13 @@
 import static java.util.Collections.singleton;
 
 import com.datastax.oss.driver.api.core.CqlIdentifier;
+import com.datastax.oss.driver.api.core.cql.ExecutionInfo;
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.SqlClientAttributesGetter;
 import java.util.Collection;
 import javax.annotation.Nullable;
 
 final class CassandraSqlAttributesGetter
-    implements SqlClientAttributesGetter<CassandraRequest, Void> {
+    implements SqlClientAttributesGetter<CassandraRequest, ExecutionInfo> {
   // copied from DbIncubatingAttributes.DbSystemIncubatingValues
   private static final String CASSANDRA = "cassandra";
 

instrumentation/clickhouse-client-0.5/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/clickhouse/ClickHouseAttributesGetter.java

@@ -5,6 +5,7 @@
 
 package io.opentelemetry.javaagent.instrumentation.clickhouse;
 
+import com.clickhouse.client.ClickHouseException;
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.DbClientAttributesGetter;
 import io.opentelemetry.semconv.incubating.DbIncubatingAttributes;
 import javax.annotation.Nullable;
@@ -59,4 +60,13 @@ public String getDbNamespace(ClickHouseDbRequest request) {
   public String getConnectionString(ClickHouseDbRequest request) {
     return null;
   }
+
+  @Nullable
+  @Override
+  public String getResponseStatusFromException(Throwable throwable) {
+    if (throwable instanceof ClickHouseException) {
+      return Integer.toString(((ClickHouseException) throwable).getErrorCode());
+    }
+    return null;
+  }
 }

instrumentation/couchbase/couchbase-2.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/couchbase/v2_0/CouchbaseAttributesGetter.java

@@ -5,6 +5,7 @@
 
 package io.opentelemetry.javaagent.instrumentation.couchbase.v2_0;
 
+import com.couchbase.client.core.CouchbaseException;
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.DbClientAttributesGetter;
 import io.opentelemetry.semconv.incubating.DbIncubatingAttributes;
 import javax.annotation.Nullable;
@@ -49,4 +50,22 @@ public String getDbQueryText(CouchbaseRequestInfo couchbaseRequest) {
   public String getDbOperationName(CouchbaseRequestInfo couchbaseRequest) {
     return couchbaseRequest.operation();
   }
+
+  @Nullable
+  @Override
+  public String getResponseStatusFromException(Throwable throwable) {
+    if (throwable instanceof CouchbaseException) {
+      //      ResponseStatusDetails details = ((CouchbaseException) throwable).details();
+      // in newer versions of the SDK, this is available as a method on the exception
+      // check if it's available and contains the status
+      //      @InterfaceAudience.Public
+      //       @InterfaceStability.Experimental
+      //       public ResponseStatusDetails details() {
+      //           return this.responseStatusDetails;
+      //       }
+      //      throwable.
+      //      return throwable.getClass().getSimpleName();
+    }
+    return null;
+  }
 }

instrumentation/elasticsearch/elasticsearch-transport-common/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/elasticsearch/transport/ElasticsearchTransportAttributesGetter.java

@@ -8,10 +8,10 @@
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.DbClientAttributesGetter;
 import io.opentelemetry.semconv.incubating.DbIncubatingAttributes;
 import javax.annotation.Nullable;
-import org.elasticsearch.client.Response;
+import org.elasticsearch.action.ActionResponse;
 
 final class ElasticsearchTransportAttributesGetter
-    implements DbClientAttributesGetter<ElasticTransportRequest, Response> {
+    implements DbClientAttributesGetter<ElasticTransportRequest, ActionResponse> {
 
   @SuppressWarnings("deprecation") // using deprecated DbSystemIncubatingValues
   @Override

instrumentation/jdbc/library/src/main/java/io/opentelemetry/instrumentation/jdbc/internal/JdbcAttributesGetter.java

@@ -57,7 +57,7 @@ public Long getBatchSize(DbRequest request) {
   @Override
   public String getResponseStatusFromException(Throwable throwable) {
     if (throwable instanceof SQLException) {
-      return String.valueOf(((SQLException) throwable).getErrorCode());
+      return Integer.toString(((SQLException) throwable).getErrorCode());
     }
     return null;
   }

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

@@ -8,9 +8,10 @@
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.DbClientAttributesGetter;
 import io.opentelemetry.semconv.incubating.DbIncubatingAttributes;
 import javax.annotation.Nullable;
+import org.opensearch.client.Response;
 
 final class OpenSearchRestAttributesGetter
-    implements DbClientAttributesGetter<OpenSearchRestRequest, Void> {
+    implements DbClientAttributesGetter<OpenSearchRestRequest, Response> {
 
   @SuppressWarnings("deprecation") // using deprecated DbSystemIncubatingValues
   @Override
@@ -49,4 +50,9 @@ public String getDbQueryText(OpenSearchRestRequest request) {
   public String getDbOperationName(OpenSearchRestRequest request) {
     return request.getMethod();
   }
+
+  @Override
+  public String getResponseStatus(Response response) {
+    return String.valueOf(response.getStatusLine().getStatusCode());
+  }
 }

instrumentation/spymemcached-2.12/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/spymemcached/SpymemcachedAttributesGetter.java

@@ -9,7 +9,7 @@
 import javax.annotation.Nullable;
 
 public class SpymemcachedAttributesGetter
-    implements DbClientAttributesGetter<SpymemcachedRequest, Void> {
+    implements DbClientAttributesGetter<SpymemcachedRequest, Object> {
 
   @Override
   public String getDbSystem(SpymemcachedRequest spymemcachedRequest) {