Java datacatalog migration split 1

datacatalog/snippets/pom.xml

@@ -0,0 +1,65 @@
+<?xml version='1.0' encoding='UTF-8'?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <groupId>com.example.datacatalog</groupId>
+  <artifactId>datacatalog-snippets</artifactId>
+  <packaging>jar</packaging>
+  <name>Google Data Catalog Snippets</name>
+  <url>https://github.com/GoogleCloudPlatform/java-docs-samples/tree/main/datacatalog</url>
+
+  <!--
+    The parent pom defines common style checks and testing strategies for our samples. 
+    Removing or replacing it should not affect the execution of the samples in anyway.
+  -->
+  <parent>
+    <groupId>com.google.cloud.samples</groupId>
+    <artifactId>shared-configuration</artifactId>
+    <version>1.2.0</version>
+  </parent>
+
+  <properties>
+    <maven.compiler.target>1.8</maven.compiler.target>
+    <maven.compiler.source>1.8</maven.compiler.source>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+
+
+  <!-- [START datacatalog_install_with_bom] -->
+  <dependencyManagement>
+    <dependencies>
+      <dependency>
+        <groupId>com.google.cloud</groupId>
+        <artifactId>libraries-bom</artifactId>
+        <version>26.1.2</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
+    </dependencies>
+  </dependencyManagement>
+
+  <dependencies>
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-datacatalog</artifactId>
+    </dependency>
+    <!-- [END datacatalog_install_with_bom] -->
+
+    <dependency>
+      <groupId>com.google.protobuf</groupId>
+      <artifactId>protobuf-java-util</artifactId>
+      <version>3.21.7</version>
+    </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.13.2</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.google.truth</groupId>
+      <artifactId>truth</artifactId>
+      <version>1.1.3</version>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>

datacatalog/snippets/src/main/java/com/example/datacatalog/CreateCustomEntry.java

@@ -0,0 +1,109 @@
+/*
+ * Copyright 2020 Google 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 com.example.datacatalog;
+
+// [START data_catalog_create_custom_entry]
+import com.google.cloud.datacatalog.v1.ColumnSchema;
+import com.google.cloud.datacatalog.v1.CreateEntryGroupRequest;
+import com.google.cloud.datacatalog.v1.CreateEntryRequest;
+import com.google.cloud.datacatalog.v1.DataCatalogClient;
+import com.google.cloud.datacatalog.v1.Entry;
+import com.google.cloud.datacatalog.v1.EntryGroup;
+import com.google.cloud.datacatalog.v1.LocationName;
+import com.google.cloud.datacatalog.v1.Schema;
+import java.io.IOException;
+
+// Sample to create custom entry
+public class CreateCustomEntry {
+
+  public static void main(String[] args) throws IOException {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "my-project";
+    String entryGroupId = "onprem_entry_group";
+    String entryId = "onprem_entry_id";
+    createCustomEntry(projectId, entryGroupId, entryId);
+  }
+
+  public static void createCustomEntry(String projectId, String entryGroupId, String entryId)
+      throws IOException {
+    // Currently, Data Catalog stores metadata in the us-central1 region.
+    String location = "us-central1";
+
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
+      // Construct the EntryGroup for the EntryGroup request.
+      EntryGroup entryGroup =
+          EntryGroup.newBuilder()
+              .setDisplayName("My awesome Entry Group")
+              .setDescription("This Entry Group represents an external system")
+              .build();
+
+      // Construct the EntryGroup request to be sent by the client.
+      CreateEntryGroupRequest entryGroupRequest =
+          CreateEntryGroupRequest.newBuilder()
+              .setParent(LocationName.of(projectId, location).toString())
+              .setEntryGroupId(entryGroupId)
+              .setEntryGroup(entryGroup)
+              .build();
+
+      // Use the client to send the API request.
+      EntryGroup createdEntryGroup = dataCatalogClient.createEntryGroup(entryGroupRequest);
+
+      // Construct the Entry for the Entry request.
+      Entry entry =
+          Entry.newBuilder()
+              .setUserSpecifiedSystem("onprem_data_system")
+              .setUserSpecifiedType("onprem_data_asset")
+              .setDisplayName("My awesome data asset")
+              .setDescription("This data asset is managed by an external system.")
+              .setLinkedResource("//my-onprem-server.com/dataAssets/my-awesome-data-asset")
+              .setSchema(
+                  Schema.newBuilder()
+                      .addColumns(
+                          ColumnSchema.newBuilder()
+                              .setColumn("first_column")
+                              .setDescription("This columns consists of ....")
+                              .setMode("NULLABLE")
+                              .setType("DOUBLE")
+                              .build())
+                      .addColumns(
+                          ColumnSchema.newBuilder()
+                              .setColumn("second_column")
+                              .setDescription("This columns consists of ....")
+                              .setMode("REQUIRED")
+                              .setType("STRING")
+                              .build())
+                      .build())
+              .build();
+
+      // Construct the Entry request to be sent by the client.
+      CreateEntryRequest entryRequest =
+          CreateEntryRequest.newBuilder()
+              .setParent(createdEntryGroup.getName())
+              .setEntryId(entryId)
+              .setEntry(entry)
+              .build();
+
+      // Use the client to send the API request.
+      Entry createdEntry = dataCatalogClient.createEntry(entryRequest);
+      System.out.printf("Custom entry created with name: %s", createdEntry.getName());
+    }
+  }
+}
+// [END data_catalog_create_custom_entry]

datacatalog/snippets/src/main/java/com/example/datacatalog/CreateEntry.java

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2020 Google LLC
+ *
+ * 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 com.example.datacatalog;
+
+// [START data_catalog_create_entry]
+import com.google.cloud.datacatalog.v1.CreateEntryRequest;
+import com.google.cloud.datacatalog.v1.DataCatalogClient;
+import com.google.cloud.datacatalog.v1.Entry;
+import com.google.cloud.datacatalog.v1.EntryGroupName;
+import java.io.IOException;
+
+// Sample to create an entry
+public class CreateEntry {
+
+  public static void main(String[] args) throws IOException {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "MY_PROJECT_ID";
+    String location = "MY_LOCATION";
+    String entryGroupId = "MY_ENTRY_GROUP_ID";
+    String entryId = "MY_ENTRY_ID";
+    EntryGroupName entryGroupName = EntryGroupName.of(projectId, location, entryGroupId);
+    Entry entry = Entry.newBuilder().build();
+    createEntry(entryGroupName, entryId, entry);
+  }
+
+  public static void createEntry(EntryGroupName entryGroupName, String entryId, Entry entry)
+      throws IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (DataCatalogClient client = DataCatalogClient.create()) {
+      CreateEntryRequest request =
+          CreateEntryRequest.newBuilder()
+              .setParent(entryGroupName.toString())
+              .setEntryId(entryId)
+              .setEntry(entry)
+              .build();
+      client.createEntry(request);
+      System.out.println("Entry created successfully");
+    }
+  }
+}
+// [END data_catalog_create_entry]

datacatalog/snippets/src/main/java/com/example/datacatalog/CreateEntryGroup.java

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2020 Google 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 com.example.datacatalog;
+
+// [START data_catalog_create_entry_group]
+import com.google.cloud.datacatalog.v1.CreateEntryGroupRequest;
+import com.google.cloud.datacatalog.v1.DataCatalogClient;
+import com.google.cloud.datacatalog.v1.EntryGroup;
+import com.google.cloud.datacatalog.v1.LocationName;
+import java.io.IOException;
+
+// Sample to create an entry group
+public class CreateEntryGroup {
+
+  public static void main(String[] args) throws IOException {
+    // TODO(developer): Replace these variables before running the sample.
+    String projectId = "MY_PROJECT_ID";
+    String location = "us-central1";
+    String entryGroupId = "MY_ENTRY_GROUP_ID";
+    createEntryGroup(projectId, location, entryGroupId);
+  }
+
+  // Create Entry Group.
+  public static void createEntryGroup(String projectId, String location, String entryGroupId)
+      throws IOException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests. After completing all of your requests, call
+    // the "close" method on the client to safely clean up any remaining background resources.
+    try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
+      EntryGroup entryGroup =
+          EntryGroup.newBuilder()
+              .setDisplayName("MY Entry Group")
+              .setDescription("This Entry Group consists of ....")
+              .build();
+
+      CreateEntryGroupRequest entryGroupRequest =
+          CreateEntryGroupRequest.newBuilder()
+              .setParent(LocationName.of(projectId, location).toString())
+              .setEntryGroupId(entryGroupId)
+              .setEntryGroup(entryGroup)
+              .build();
+
+      dataCatalogClient.createEntryGroup(entryGroupRequest);
+      System.out.println("Entry Group created successfully");
+    }
+  }
+}
+// [END data_catalog_create_entry_group]