Create_Tables

Author: Komal Yadav

cdap-master/pom.xml

@@ -113,11 +113,6 @@
       <artifactId>cdap-messaging-ext-spanner</artifactId>
       <version>${project.version}</version>
     </dependency>
-    <dependency>
-      <groupId>io.cdap.cdap</groupId>
-      <artifactId>cdap-metadata-ext-spanner</artifactId>
-      <version>${project.version}</version>
-    </dependency>
     <dependency>
       <groupId>org.apache.tephra</groupId>
       <artifactId>tephra-api</artifactId>
@@ -739,28 +734,6 @@
                 </configuration>
               </execution>
 
-              <!-- Copy metadata extensions -->
-              <execution>
-                <id>copy-metadata-ext-spanner</id>
-                <phase>process-resources</phase>
-                <goals>
-                  <goal>copy-resources</goal>
-                </goals>
-                <configuration combine.self="override">
-                  <outputDirectory>${stage.metadata.ext.dir}/spanner</outputDirectory>
-                  <resources>
-                    <resource>
-                      <directory>
-                        ${project.parent.basedir}/cdap-metadata-ext-spanner/target/libexec/
-                      </directory>
-                      <includes>
-                        <include>*.jar</include>
-                      </includes>
-                    </resource>
-                  </resources>
-                </configuration>
-              </execution>
-
               <!-- Copy remote authenticator extensions -->
               <execution>
                 <id>copy-authenticator-ext-gcp</id>

cdap-metadata-ext-spanner/src/main/java/io/cdap/cdap/metadata/spanner/SpannerConfig.java

@@ -0,0 +1,65 @@
+/*
+ * Copyright © 2025 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.cdap.metadata.spanner;
+
+import com.google.cloud.spanner.DatabaseAdminClient;
+import com.google.cloud.spanner.DatabaseClient;
+import com.google.cloud.spanner.DatabaseId;
+import com.google.cloud.spanner.Spanner;
+import java.util.Map;
+
+/**
+ * Utility class for spanner metadata storage.
+ */
+class SpannerConfig {
+
+  static final String PROJECT = "project";
+  static final String INSTANCE = "instance";
+  static final String DATABASE = "database";
+
+  static DatabaseClient getSpannerDbClient(String projectID, String instanceID, String databaseID, Spanner spanner) {
+    DatabaseId db = DatabaseId.of(projectID, instanceID, databaseID);
+    return spanner.getDatabaseClient(db);
+  }
+
+  static DatabaseAdminClient getSpannerDbAdminClient(Spanner spanner) {
+    return spanner.getDatabaseAdminClient();
+  }
+
+  static String getInstanceID(Map<String, String> cConf) {
+    String instance = cConf.get(INSTANCE);
+    if (instance == null) {
+      throw new IllegalArgumentException("Missing configuration " + PROJECT);
+    }
+    return instance;
+  }
+
+  static String getDatabaseID(Map<String, String> cConf) {
+    String instance = cConf.get(DATABASE);
+    if (instance == null) {
+      throw new IllegalArgumentException("Missing configuration " + DATABASE);
+    }
+    return cConf.get(DATABASE);
+  }
+
+  static String getProjectID(Map<String, String> cConf) {
+    String instance = cConf.get(PROJECT);
+    if (instance == null) {
+      throw new IllegalArgumentException("Missing configuration " + PROJECT);
+    }
+    return cConf.get(PROJECT);
+  }
+}