DbInfo simplification

Author: trask

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

@@ -54,7 +54,6 @@ public void onEnd(
   }
 
   private static String getName(DbInfo dbInfo) {
-    String name = dbInfo.getName();
-    return name == null ? dbInfo.getDb() : name;
+    return dbInfo.getName();
   }
 }

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

@@ -6,7 +6,6 @@
 package io.opentelemetry.instrumentation.jdbc.internal;
 
 import io.opentelemetry.instrumentation.api.incubator.semconv.db.SqlClientAttributesGetter;
-import io.opentelemetry.instrumentation.jdbc.internal.dbinfo.DbInfo;
 import java.sql.SQLException;
 import java.util.Collection;
 import java.util.Map;
@@ -36,8 +35,7 @@ public String getUser(DbRequest request) {
   @Nullable
   @Override
   public String getDbNamespace(DbRequest request) {
-    DbInfo dbInfo = request.getDbInfo();
-    return dbInfo.getName() == null ? dbInfo.getDb() : dbInfo.getName();
+    return request.getDbInfo().getName();
   }
 
   @Deprecated // to be removed in 3.0

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

@@ -63,7 +63,7 @@ DbInfo.Builder doParse(String jdbcUrl, DbInfo.Builder builder) {
           path = path.substring(1);
         }
         if (!path.isEmpty()) {
-          builder.db(path);
+          builder.name(path);
         }
         if (uri.getHost() != null) {
           builder.host(uri.getHost());
@@ -91,13 +91,6 @@ DbInfo.Builder doParse(String jdbcUrl, DbInfo.Builder builder) {
       }
 
       String[] split = jdbcUrl.split(";", 2);
-      if (split.length > 1) {
-        Map<String, String> props = splitQuery(split[1], ";");
-        populateStandardProperties(builder, props);
-        if (props.containsKey("instance")) {
-          builder.name(props.get("instance"));
-        }
-      }
 
       String urlServerName = split[0].substring(hostIndex + 17);
       if (!urlServerName.isEmpty()) {
@@ -106,10 +99,18 @@ DbInfo.Builder doParse(String jdbcUrl, DbInfo.Builder builder) {
 
       int databaseLoc = serverName.indexOf("/");
       if (databaseLoc > 1) {
-        builder.db(serverName.substring(databaseLoc + 1));
+        builder.name(serverName.substring(databaseLoc + 1));
         serverName = serverName.substring(0, databaseLoc);
       }
 
+      if (split.length > 1) {
+        Map<String, String> props = splitQuery(split[1], ";");
+        populateStandardProperties(builder, props);
+        if (props.containsKey("instance")) {
+          builder.name(props.get("instance"));
+        }
+      }
+
       int portLoc = serverName.indexOf(":");
       if (portLoc > 1) {
         builder.port(Integer.parseInt(serverName.substring(portLoc + 1)));
@@ -294,9 +295,9 @@ DbInfo.Builder doParse(String jdbcUrl, DbInfo.Builder builder) {
 
       if (paramLoc > 0) {
         populateStandardProperties(builder, splitQuery(jdbcUrl.substring(paramLoc + 1), "&"));
-        builder.db(jdbcUrl.substring(dbLoc + 1, paramLoc));
+        builder.name(jdbcUrl.substring(dbLoc + 1, paramLoc));
       } else {
-        builder.db(jdbcUrl.substring(dbLoc + 1));
+        builder.name(jdbcUrl.substring(dbLoc + 1));
       }
 
       if (portLoc > 0) {
@@ -330,9 +331,9 @@ DbInfo.Builder doParse(String jdbcUrl, DbInfo.Builder builder) {
 
       if (paramLoc > 0) {
         populateStandardProperties(builder, splitQuery(jdbcUrl.substring(paramLoc + 1), "&"));
-        builder.db(jdbcUrl.substring(dbLoc + 1, paramLoc));
+        builder.name(jdbcUrl.substring(dbLoc + 1, paramLoc));
       } else if (dbLoc != -1) {
-        builder.db(jdbcUrl.substring(dbLoc + 1));
+        builder.name(jdbcUrl.substring(dbLoc + 1));
       }
 
       if (jdbcUrl.startsWith("address=")) {
@@ -808,7 +809,10 @@ DbInfo.Builder doParse(String jdbcUrl, DbInfo.Builder builder) {
       if (host != null) {
         builder.host(host);
       }
-      return builder.name(instance);
+      if (instance != null) {
+        builder.name(instance);
+      }
+      return builder;
     }
   },
 
@@ -1116,10 +1120,10 @@ private static void populateStandardProperties(DbInfo.Builder builder, Map<?, ?>
       }
 
       if (props.containsKey("databasename")) {
-        builder.db((String) props.get("databasename"));
+        builder.name((String) props.get("databasename"));
       }
       if (props.containsKey("databaseName")) {
-        builder.db((String) props.get("databaseName"));
+        builder.name((String) props.get("databaseName"));
       }
 
       if (props.containsKey("servername")) {

instrumentation/jdbc/library/src/main/java/io/opentelemetry/instrumentation/jdbc/internal/dbinfo/DbInfo.java

@@ -37,9 +37,6 @@ public static DbInfo.Builder builder() {
   @Nullable
   public abstract String getName();
 
-  @Nullable
-  public abstract String getDb();
-
   @Nullable
   public abstract String getHost();
 
@@ -53,7 +50,6 @@ public Builder toBuilder() {
         .shortUrl(getShortUrl())
         .user(getUser())
         .name(getName())
-        .db(getDb())
         .host(getHost())
         .port(getPort());
   }
@@ -75,8 +71,6 @@ public abstract static class Builder {
 
     public abstract Builder name(String name);
 
-    public abstract Builder db(String db);
-
     public abstract Builder host(String host);
 
     public abstract Builder port(Integer port);

instrumentation/jdbc/library/src/test/java/io/opentelemetry/instrumentation/jdbc/datasource/OpenTelemetryDataSourceTest.java

@@ -105,8 +105,7 @@ private static void assertDbInfo(DbInfo dbInfo) {
     assertThat(dbInfo.getSubtype()).isNull();
     assertThat(dbInfo.getShortUrl()).isEqualTo("postgresql://127.0.0.1:5432");
     assertThat(dbInfo.getUser()).isNull();
-    assertThat(dbInfo.getName()).isNull();
-    assertThat(dbInfo.getDb()).isEqualTo("dbname");
+    assertThat(dbInfo.getName()).isEqualTo("dbname");
     assertThat(dbInfo.getHost()).isEqualTo("127.0.0.1");
     assertThat(dbInfo.getPort()).isEqualTo(5432);
   }