test(spanner): add IF NOT EXISTS to PostgreSQL DDL statements

Author: cy-yun

Spanner/tests/System/PgBatchTest.php

@@ -53,18 +53,15 @@ public static function setUpTestFixtures(): void
         self::$tableName = uniqid(self::TESTING_PREFIX);
 
         self::$database->updateDdl(sprintf(
-            'CREATE TABLE %s (
+            'CREATE TABLE IF NOT EXISTS %s (
                     id INTEGER PRIMARY KEY,
                     decade INTEGER NOT NULL
                 )',
             self::$tableName
         ))->pollUntilComplete();
 
         if (self::$database->info()['databaseDialect'] == DatabaseDialect::POSTGRESQL) {
-            $statements = [
-                sprintf('CREATE ROLE %s', self::$dbRole),
-                sprintf('CREATE ROLE %s', self::$restrictiveDbRole),
-            ];
+            $statements = [];
 
             if (!self::isEmulatorUsed()) {
                 $statements[] = sprintf(
@@ -119,6 +116,9 @@ public function testBatchWithDbRole($dbRole, $expected)
         try {
             $partitions = $snapshot->partitionQuery($query, ['parameters' => $parameters]);
         } catch (ServiceException $e) {
+            if (is_null($expected)) {
+                throw $e;
+            }
             $error = $e;
         }
 

Spanner/tests/System/PgBatchWriteTest.php

@@ -40,13 +40,13 @@ public static function setUpTestFixtures(): void
         self::setUpTestDatabase();
 
         self::$database->updateDdlBatch([
-            'CREATE TABLE Singers (
+            'CREATE TABLE IF NOT EXISTS Singers (
                 singerid   bigint NOT NULL,
                 firstname  varchar(1024),
                 lastname   varchar(1024),
                 PRIMARY KEY (singerid)
             )',
-            'CREATE TABLE Albums (
+            'CREATE TABLE IF NOT EXISTS Albums (
                 singerid     bigint NOT NULL,
                 albumid      bigint NOT NULL,
                 albumtitle   varchar(1024),

Spanner/tests/System/PgQueryTest.php

@@ -25,6 +25,7 @@
 use Google\Cloud\Spanner\Database;
 use Google\Cloud\Spanner\Date;
 use Google\Cloud\Spanner\Interval;
+use Google\Cloud\Spanner\KeySet;
 use Google\Cloud\Spanner\PgJsonb;
 use Google\Cloud\Spanner\PgNumeric;
 use Google\Cloud\Spanner\Timestamp;
@@ -52,7 +53,7 @@ public static function setUpTestFixtures(): void
         self::setUpTestDatabase();
 
         self::$database->updateDdl(
-            'CREATE TABLE ' . self::TABLE_NAME . ' (
+            'CREATE TABLE IF NOT EXISTS ' . self::TABLE_NAME . ' (
                 id bigint NOT NULL,
                 name varchar(1024),
                 registered bool,
@@ -69,6 +70,8 @@ public static function setUpTestFixtures(): void
 
         self::$timestampVal = new Timestamp(new \DateTime());
 
+        self::$database->delete(self::TABLE_NAME, new KeySet(['all' => true]));
+
         self::$database->insertOrUpdateBatch(self::TABLE_NAME, [
             [
                 'id' => 1,

Spanner/tests/System/PgWriteTest.php

@@ -54,7 +54,7 @@ public static function setUpTestFixtures(): void
         self::setUpTestDatabase();
 
         self::$database->updateDdlBatch([
-            'CREATE TABLE ' . self::TABLE_NAME . ' (
+            'CREATE TABLE IF NOT EXISTS ' . self::TABLE_NAME . ' (
                 id bigint NOT NULL,
                 boolfield boolean,
                 bytesfield bytea,
@@ -78,7 +78,7 @@ public static function setUpTestFixtures(): void
                 arraypgjsonbfield jsonb[],
                 PRIMARY KEY (id)
             )',
-            'CREATE TABLE ' . self::COMMIT_TIMESTAMP_TABLE_NAME . ' (
+            'CREATE TABLE IF NOT EXISTS ' . self::COMMIT_TIMESTAMP_TABLE_NAME . ' (
                 id bigint NOT NULL,
                 commitTimestamp SPANNER.COMMIT_TIMESTAMP NOT NULL,
                 PRIMARY KEY (id, commitTimestamp)