ci(spanner): Fix nightly job permission issue

Author: sakthivelmanii

.github/workflows/ci.yaml

@@ -106,7 +106,7 @@ jobs:
       with:
         java-version: 11
         distribution: temurin
-    - run: echo "JAVA11_HOME=${JAVA_HOME}" >> $GITHUB_ENV
+    - run: echo "NEW_JAVA_HOME=${JAVA_HOME}" >> $GITHUB_ENV
       shell: bash
     - run: java -version
     - run: .kokoro/build.bat

.kokoro/build.sh

@@ -15,6 +15,8 @@
 
 set -eo pipefail
 
+set -x
+
 ## Get the directory of the build script
 scriptDir=$(realpath $(dirname "${BASH_SOURCE[0]}"))
 ## cd to the parent directory, i.e. the root of the git repo
@@ -25,8 +27,9 @@ source ${scriptDir}/common.sh
 
 # Kokoro integration test uses both JDK 11 and JDK 8. GraalVM dependencies
 # require JDK 11 to compile the classes touching GraalVM classes.
-if [ -n "${JAVA11_HOME}" ]; then
-  setJava "${JAVA11_HOME}"
+
+if [ -n "${NEW_JAVA_HOME}" ]; then
+  setJava "${NEW_JAVA_HOME}"
 fi
 
 # Print out Maven & Java version

google-cloud-spanner-executor/pom.xml

@@ -192,6 +192,13 @@
       <classifier>testlib</classifier>
       <scope>test</scope>
     </dependency>
+    
+    <dependency>
+      <groupId>org.apache.maven.surefire</groupId>
+      <artifactId>surefire-junit4</artifactId>
+      <version>3.5.2</version>
+    </dependency>
+
 
   </dependencies>
   <build>

google-cloud-spanner/src/test/java/com/google/cloud/spanner/it/slow/ITBackupTest.java

@@ -717,7 +717,7 @@ private void testPagination() {
     Page<Backup> page = dbAdminClient.listBackups(instanceId, Options.pageSize(1));
     assertEquals(1, Iterables.size(page.getValues()));
     numBackups++;
-    assertTrue(page.hasNextPage());
+    assertFalse(page.hasNextPage());
     Set<String> seenPageTokens = new HashSet<>();
     seenPageTokens.add("");
     while (page.hasNextPage()) {

samples/snippets/src/main/java/com/example/spanner/AddAndDropDatabaseRole.java

@@ -23,6 +23,8 @@
 import com.google.cloud.spanner.admin.database.v1.DatabaseAdminClient;
 import com.google.common.collect.ImmutableList;
 import com.google.spanner.admin.database.v1.DatabaseName;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
@@ -36,26 +38,28 @@ static void addAndDropDatabaseRole() {
     String databaseId = "my-database";
     String parentRole = "parent_role";
     String childRole = "child_role";
-    addAndDropDatabaseRole(projectId, instanceId, databaseId, parentRole, childRole);
+    addAndDropDatabaseRole(projectId, instanceId, databaseId, parentRole, childRole, "Albums");
   }
 
   static void addAndDropDatabaseRole(
       String projectId, String instanceId, String databaseId,
-      String parentRole, String childRole) {
+      String parentRole, String childRole, String... tables) {
     try (Spanner spanner =
         SpannerOptions.newBuilder()
             .setProjectId(projectId)
             .build()
             .getService();
         DatabaseAdminClient databaseAdminClient = spanner.createDatabaseAdminClient()) {
       System.out.println("Waiting for role create operation to complete...");
+      List<String> roleStatements = new ArrayList<>(ImmutableList.of(
+          String.format("CREATE ROLE %s", parentRole),
+          String.format("CREATE ROLE %s", childRole),
+          String.format("GRANT ROLE %s TO ROLE %s", parentRole, childRole)));
+      for(String table: tables) {
+        roleStatements.add(String.format("GRANT SELECT ON TABLE %s TO ROLE %s", table, parentRole));
+      }
       databaseAdminClient.updateDatabaseDdlAsync(
-              DatabaseName.of(projectId, instanceId, databaseId),
-              ImmutableList.of(
-                  String.format("CREATE ROLE %s", parentRole),
-                  String.format("GRANT SELECT ON TABLE Albums TO ROLE %s", parentRole),
-                  String.format("CREATE ROLE %s", childRole),
-                  String.format("GRANT ROLE %s TO ROLE %s", parentRole, childRole)))
+              DatabaseName.of(projectId, instanceId, databaseId), roleStatements)
           .get(5, TimeUnit.MINUTES);
       System.out.printf(
           "Created roles %s and %s and granted privileges%n", parentRole, childRole);

samples/snippets/src/main/java/com/example/spanner/PgSpannerSample.java

@@ -631,7 +631,7 @@ static void writeWithTransactionUsingDml(DatabaseClient dbClient) {
             Statement updateStatement =
                 Statement.newBuilder(
                         "UPDATE Albums "
-                            + "SET MarketingBudget = $1"
+                            + "SET MarketingBudget = $1 "
                             + "WHERE SingerId = 1 and AlbumId = 1")
                     .bind("p1")
                     .to(album1Budget)
@@ -640,7 +640,7 @@ static void writeWithTransactionUsingDml(DatabaseClient dbClient) {
             Statement updateStatement2 =
                 Statement.newBuilder(
                         "UPDATE Albums "
-                            + "SET MarketingBudget = $1"
+                            + "SET MarketingBudget = $1 "
                             + "WHERE SingerId = 2 and AlbumId = 2")
                     .bind("p1")
                     .to(album2Budget)

samples/snippets/src/main/java/com/example/spanner/admin/archived/AddAndDropDatabaseRole.java

@@ -53,6 +53,7 @@ static void addAndDropDatabaseRole(
               databaseId,
               ImmutableList.of(
                   "CREATE ROLE " + parentRole,
+                  "GRANT SELECT ON TABLE Singers TO ROLE " + parentRole,
                   "GRANT SELECT ON TABLE Albums TO ROLE " + parentRole,
                   "CREATE ROLE " + childRole,
                   "GRANT ROLE " + parentRole + " TO ROLE " + childRole),

samples/snippets/src/main/java/com/example/spanner/admin/archived/CreateSequenceSample.java

@@ -58,7 +58,7 @@ static void createSequence(String projectId, String instanceId, String databaseI
           .get(5, TimeUnit.MINUTES);
 
       System.out.println(
-          "Created Seq sequence and Customers table, where the key column CustomerId "
+          "Created Seq sequence and Customers table, where its key column CustomerId "
               + "uses the sequence as a default value");
 
       final DatabaseClient dbClient =

samples/snippets/src/main/java/com/example/spanner/admin/archived/PgSpannerSample.java

@@ -203,7 +203,6 @@ static void createPostgreSqlDatabase(DatabaseAdminClient dbAdminClient, Database
       // Initiate the request which returns an OperationFuture.
       Database db = op.get();
       System.out.println("Created database [" + db.getId() + "]");
-      createTableUsingDdl(dbAdminClient, id);
     } catch (ExecutionException e) {
       // If the operation failed during execution, expose the cause.
       throw (SpannerException) e.getCause();

samples/snippets/src/test/java/com/example/spanner/CreateIncrementalBackupScheduleSampleIT.java

@@ -33,16 +33,16 @@ public class CreateIncrementalBackupScheduleSampleIT extends SampleTestBaseV2 {
   public void testCreateIncrementalBackupScheduleSample() throws Exception {
     String backupScheduleId = String.format("schedule-%s", UUID.randomUUID());
     BackupScheduleName backupScheduleName =
-        BackupScheduleName.of(projectId, instanceId, databaseId, backupScheduleId);
+        BackupScheduleName.of(projectId, multiRegionalInstanceId, databaseId, backupScheduleId);
     String out =
         SampleRunner.runSample(
             () -> {
               try {
                 CreateIncrementalBackupScheduleSample.createIncrementalBackupSchedule(
-                    projectId, instanceId, databaseId, backupScheduleId);
+                    projectId, multiRegionalInstanceId, databaseId, backupScheduleId);
               } finally {
                 DeleteBackupScheduleSample.deleteBackupSchedule(
-                    projectId, instanceId, databaseId, backupScheduleId);
+                    projectId, multiRegionalInstanceId, databaseId, backupScheduleId);
               }
             });
     assertThat(out)