diff --git a/‎.github/.OwlBot-hermetic.yaml‎
Lines changed: 4 additions & 0 deletions b/‎.github/.OwlBot-hermetic.yaml‎
Lines changed: 4 additions & 0 deletions
diff --git a/‎.github/dependabot.yml‎
Lines changed: 1 addition & 2 deletions b/‎.github/dependabot.yml‎
Lines changed: 1 addition & 2 deletions
diff --git a/‎.github/sync-repo-settings.yaml‎
Lines changed: 0 additions & 16 deletions b/‎.github/sync-repo-settings.yaml‎
Lines changed: 0 additions & 16 deletions
diff --git a/‎.gitignore‎
Lines changed: 1 addition & 1 deletion b/‎.gitignore‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎google-cloud-datastore-utils/pom.xml‎
Lines changed: 111 additions & 0 deletions b/‎google-cloud-datastore-utils/pom.xml‎
Lines changed: 111 additions & 0 deletions
diff --git a/‎google-cloud-datastore-utils/src/main/java/com/google/datastore/utils/Datastore.java‎
Lines changed: 136 additions & 0 deletions b/‎google-cloud-datastore-utils/src/main/java/com/google/datastore/utils/Datastore.java‎
Lines changed: 136 additions & 0 deletions
diff --git a/‎google-cloud-datastore-utils/src/main/java/com/google/datastore/utils/DatastoreException.java‎
Lines changed: 49 additions & 0 deletions b/‎google-cloud-datastore-utils/src/main/java/com/google/datastore/utils/DatastoreException.java‎
Lines changed: 49 additions & 0 deletions
@@ -22,8 +22,12 @@ deep-copy-regex:
   dest: "/owl-bot-staging/$1/proto-google-cloud-datastore-$1/src"
 - source: "/google/datastore/admin/(v.*)/.*-java/proto-google-.*/src"
   dest: "/owl-bot-staging/$1/proto-google-cloud-datastore-admin-$1/src"
+- source: "/google/datastore/(v.*)/.*-java/grpc-google-.*/src"
+  dest: "/owl-bot-staging/$1/grpc-google-cloud-datastore-$1/src"
 - source: "/google/datastore/admin/(v.*)/.*-java/grpc-google-.*/src"
   dest: "/owl-bot-staging/$1/grpc-google-cloud-datastore-admin-$1/src"
 # Admin & Data APIs share the same wrapper library.
+- source: "/google/datastore/(v.*)/.*-java/gapic-google-.*/src"
+  dest: "/owl-bot-staging/$1/google-cloud-datastore/src"
 - source: "/google/datastore/admin/(v.*)/.*-java/gapic-google-.*/src"
   dest: "/owl-bot-staging/$1/google-cloud-datastore/src"
@@ -17,8 +17,7 @@ updates:
     # If a security vulnerability comes in, we will be notified about 
     # it via template in the synthtool repository.
     ignore:
-    - dependency-name: "*"
-
+      - dependency-name: "*"
 # rules for the `grpc-experimental` branch
   - package-ecosystem: maven
     directory: "/"
 
@@ -157,22 +157,6 @@ branchProtectionRules:
       - 'Kokoro - Test: Java GraalVM Native Image'
       - 'Kokoro - Test: Java 17 GraalVM Native Image'
       - javadoc
-  - pattern: grpc-experimental
-    isAdminEnforced: true
-    requiredApprovingReviewCount: 1
-    requiresCodeOwnerReviews: true
-    requiresStrictStatusChecks: false
-    requiredStatusCheckContexts:
-      - dependencies (17)
-      - lint
-      - clirr
-      - units (8)
-      - units (11)
-      - 'Kokoro - Test: Integration'
-      - cla/google
-      - 'Kokoro - Test: Java GraalVM Native Image'
-      - 'Kokoro - Test: Java 17 GraalVM Native Image'
-      - javadoc
   - pattern: 2.19.x
     isAdminEnforced: true
     requiredApprovingReviewCount: 1
 
@@ -3,4 +3,4 @@ target/
 *.iml
 __pycache__/
 
-.flattened-pom.xml
+.flattened-pom.xml
@@ -0,0 +1,111 @@
+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.0modelVersion>
+    <groupId>com.google.cloudgroupId>
+    <artifactId>google-cloud-datastore-utilsartifactId>
+    <version>2.27.3-SNAPSHOTversion>
+    <packaging>jarpackaging>
+    <name>Google Cloud Datastore Utilitiesname>
+    <url>https://github.com/googleapis/java-datastoreurl>
+    <description>
+        Java datastore client utility library.
+    description>
+    <parent>
+        <groupId>com.google.cloudgroupId>
+        <artifactId>google-cloud-datastore-parentartifactId>
+        <version>2.27.3-SNAPSHOTversion>
+    parent>
+    <properties>
+        <site.installationModule>google-cloud-datastore-utilssite.installationModule>
+    properties>
+    <dependencies>
+        <dependency>
+            <groupId>com.google.api-clientgroupId>
+            <artifactId>google-api-clientartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.http-clientgroupId>
+            <artifactId>google-http-client-protobufartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.http-clientgroupId>
+            <artifactId>google-http-client-gsonartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.api.grpcgroupId>
+            <artifactId>proto-google-cloud-datastore-v1artifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.apigroupId>
+            <artifactId>api-commonartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.protobufgroupId>
+            <artifactId>protobuf-javaartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.guavagroupId>
+            <artifactId>guavaartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.api.grpcgroupId>
+            <artifactId>proto-google-common-protosartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.http-clientgroupId>
+            <artifactId>google-http-clientartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.http-clientgroupId>
+            <artifactId>google-http-client-jackson2artifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.oauth-clientgroupId>
+            <artifactId>google-oauth-clientartifactId>
+        dependency>
+        <dependency>
+            <groupId>com.google.code.findbugsgroupId>
+            <artifactId>jsr305artifactId>
+        dependency>
+        
+        <dependency>
+            <groupId>junitgroupId>
+            <artifactId>junitartifactId>
+            <scope>testscope>
+        dependency>
+        <dependency>
+            <groupId>com.google.truthgroupId>
+            <artifactId>truthartifactId>
+            <version>1.4.2version>
+            <scope>testscope>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.checkerframeworkgroupId>
+                    <artifactId>checker-qualartifactId>
+                exclusion>
+            exclusions>
+        dependency>
+    dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.pluginsgroupId>
+                <artifactId>maven-surefire-pluginartifactId>
+                <configuration>
+                    <argLine>-Xmx2048margLine>
+                configuration>
+            plugin>
+        plugins>
+    build>
+
+    <profiles>
+        <profile>
+            <id>nativeid>
+            <properties>
+                
+                <skipTests>trueskipTests>
+            properties>
+        profile>
+    profiles>
+project>
@@ -0,0 +1,136 @@
+/*
+ * Copyright 2024 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.google.datastore.utils;
+
+import com.google.datastore.v1.*;
+import com.google.rpc.Code;
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * Provides access to Cloud Datastore.
+ *
+ * This class is thread-safe.
+ */
+public class Datastore {
+
+  final RemoteRpc remoteRpc;
+
+  Datastore(RemoteRpc remoteRpc) {
+    this.remoteRpc = remoteRpc;
+  }
+
+  /** Reset the RPC count. */
+  public void resetRpcCount() {
+    remoteRpc.resetRpcCount();
+  }
+
+  /**
+   * Returns the number of RPC calls made since the client was created or {@link #resetRpcCount} was
+   * called.
+   */
+  public int getRpcCount() {
+    return remoteRpc.getRpcCount();
+  }
+
+  private com.google.datastore.utils.DatastoreException invalidResponseException(
+      String method, IOException exception) {
+    return RemoteRpc.makeException(
+        remoteRpc.getUrl(), method, Code.UNAVAILABLE, "Invalid response", exception);
+  }
+
+  public AllocateIdsResponse allocateIds(AllocateIdsRequest request)
+      throws com.google.datastore.utils.DatastoreException {
+    try (InputStream is =
+        remoteRpc.call("allocateIds", request, request.getProjectId(), request.getDatabaseId())) {
+      return AllocateIdsResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("allocateIds", exception);
+    }
+  }
+
+  public BeginTransactionResponse beginTransaction(BeginTransactionRequest request)
+      throws com.google.datastore.utils.DatastoreException {
+    try (InputStream is =
+        remoteRpc.call(
+            "beginTransaction", request, request.getProjectId(), request.getDatabaseId())) {
+      return BeginTransactionResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("beginTransaction", exception);
+    }
+  }
+
+  public CommitResponse commit(CommitRequest request)
+      throws com.google.datastore.utils.DatastoreException {
+    try (InputStream is =
+        remoteRpc.call("commit", request, request.getProjectId(), request.getDatabaseId())) {
+      return CommitResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("commit", exception);
+    }
+  }
+
+  public LookupResponse lookup(LookupRequest request)
+      throws com.google.datastore.utils.DatastoreException {
+    try (InputStream is =
+        remoteRpc.call("lookup", request, request.getProjectId(), request.getDatabaseId())) {
+      return LookupResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("lookup", exception);
+    }
+  }
+
+  public ReserveIdsResponse reserveIds(ReserveIdsRequest request)
+      throws com.google.datastore.utils.DatastoreException {
+    try (InputStream is =
+        remoteRpc.call("reserveIds", request, request.getProjectId(), request.getDatabaseId())) {
+      return ReserveIdsResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("reserveIds", exception);
+    }
+  }
+
+  public RollbackResponse rollback(RollbackRequest request)
+      throws com.google.datastore.utils.DatastoreException {
+    try (InputStream is =
+        remoteRpc.call("rollback", request, request.getProjectId(), request.getDatabaseId())) {
+      return RollbackResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("rollback", exception);
+    }
+  }
+
+  public RunQueryResponse runQuery(RunQueryRequest request)
+      throws com.google.datastore.utils.DatastoreException {
+    try (InputStream is =
+        remoteRpc.call("runQuery", request, request.getProjectId(), request.getDatabaseId())) {
+      return RunQueryResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("runQuery", exception);
+    }
+  }
+
+  public RunAggregationQueryResponse runAggregationQuery(RunAggregationQueryRequest request)
+      throws DatastoreException {
+    try (InputStream is =
+        remoteRpc.call(
+            "runAggregationQuery", request, request.getProjectId(), request.getDatabaseId())) {
+      return RunAggregationQueryResponse.parseFrom(is);
+    } catch (IOException exception) {
+      throw invalidResponseException("runAggregationQuery", exception);
+    }
+  }
+}
@@ -0,0 +1,49 @@
+/*
+ * Copyright 2024 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.google.datastore.utils;
+
+import com.google.rpc.Code;
+
+/** Indicates an error in a {@link Datastore} call. */
+public class DatastoreException extends Exception {
+  private final String methodName;
+  private final Code code;
+
+  public DatastoreException(String methodName, Code code, String message, Throwable cause) {
+    super(message, cause);
+    this.methodName = methodName;
+    this.code = code;
+  }
+
+  /**
+   * @return the canonical error code
+   */
+  public Code getCode() {
+    return code;
+  }
+
+  /**
+   * @return the datastore method name
+   */
+  public String getMethodName() {
+    return methodName;
+  }
+
+  @Override
+  public String toString() {
+    return String.format("%s, code=%s", super.toString(), code);
+  }
+}