Create table with TIMESTAMP column

  void 
  
 CreateTableWithTimestamp 
 ( 
  
 google 
 :: 
 cloud 
 :: 
 spanner_admin 
 :: 
 DatabaseAdminClient 
  
 client 
 , 
  
 std 
 :: 
 string 
  
 const 
&  
 project_id 
 , 
  
 std 
 :: 
 string 
  
 const 
&  
 instance_id 
 , 
  
 std 
 :: 
 string 
  
 const 
&  
 database_id 
 ) 
  
 { 
  
 google 
 :: 
 cloud 
 :: 
 spanner 
 :: 
 Database 
  
 database 
 ( 
 project_id 
 , 
  
 instance_id 
 , 
  
 database_id 
 ); 
  
 auto 
  
 metadata 
  
 = 
  
 client 
  
 . 
 UpdateDatabaseDdl 
 ( 
 database 
 . 
 FullName 
 (), 
  
 { 
 R 
 " 
 ""( 
 CREATE TABLE Performances ( 
 SingerId        INT64 NOT NULL, 
 VenueId         INT64 NOT NULL, 
 EventDate       Date, 
 Revenue         INT64, 
 LastUpdateTime  TIMESTAMP NOT NULL OPTIONS 
 (allow_commit_timestamp=true) 
 ) PRIMARY KEY (SingerId, VenueId, EventDate), 
 INTERLEAVE IN PARENT Singers ON DELETE CASCADE 
 )"" 
 " 
 }) 
  
 . 
 get 
 (); 
  
 google 
 :: 
 cloud 
 :: 
 spanner_testing 
 :: 
 LogUpdateDatabaseDdl 
 ( 
  
 //! TODO(#4758) 
  
 client 
 , 
  
 database 
 , 
  
 metadata 
 . 
 status 
 ()); 
  
 //! TODO(#4758) 
  
 if 
  
 ( 
 ! 
 metadata 
 ) 
  
 throw 
  
 std 
 :: 
 move 
 ( 
 metadata 
 ). 
 status 
 (); 
  
 std 
 :: 
 cout 
 << 
 "`Performances` table created, new DDL: 
 \n 
 " 
 << 
 metadata 
 - 
> DebugString 
 (); 
 } 
 

  using 
  
  Google.Cloud.Spanner.Data 
 
 ; 
 using 
  
 System.Threading.Tasks 
 ; 
 public 
  
 class 
  
 CreateTableWithTimestampColumnAsyncSample 
 { 
  
 public 
  
 async 
  
 Task 
  
 CreateTableWithTimestampColumnAsync 
 ( 
 string 
  
 projectId 
 , 
  
 string 
  
 instanceId 
 , 
  
 string 
  
 databaseId 
 ) 
  
 { 
  
 string 
  
 connectionString 
  
 = 
  
 $"Data Source=projects/{projectId}/instances/{instanceId}/databases/{databaseId}" 
 ; 
  
 using 
  
 var 
  
 connection 
  
 = 
  
 new 
  
  SpannerConnection 
 
 ( 
 connectionString 
 ); 
  
 // Define create table statement for table with commit timestamp column. 
  
 string 
  
 createTableStatement 
  
 = 
  
 @"CREATE TABLE Performances ( 
 SingerId       INT64 NOT NULL, 
 VenueId        INT64 NOT NULL, 
 EventDate      Date, 
 Revenue        INT64, 
 LastUpdateTime TIMESTAMP NOT NULL OPTIONS (allow_commit_timestamp=true) 
 ) PRIMARY KEY (SingerId, VenueId, EventDate), 
 INTERLEAVE IN PARENT Singers ON DELETE CASCADE" 
 ; 
  
 var 
  
 cmd 
  
 = 
  
 connection 
 . 
  CreateDdlCommand 
 
 ( 
 createTableStatement 
 ); 
  
 await 
  
 cmd 
 . 
 ExecuteNonQueryAsync 
 (); 
  
 } 
 } 
 

  import 
  
 ( 
  
 "context" 
  
 "fmt" 
  
 "io" 
  
 database 
  
 "cloud.google.com/go/spanner/admin/database/apiv1" 
  
 adminpb 
  
 "cloud.google.com/go/spanner/admin/database/apiv1/databasepb" 
 ) 
 func 
  
 createTableWithTimestamp 
 ( 
 w 
  
 io 
 . 
 Writer 
 , 
  
 db 
  
 string 
 ) 
  
 error 
  
 { 
  
 ctx 
  
 := 
  
 context 
 . 
 Background 
 () 
  
 adminClient 
 , 
  
 err 
  
 := 
  
 database 
 . 
 NewDatabaseAdminClient 
 ( 
 ctx 
 ) 
  
 if 
  
 err 
  
 != 
  
 nil 
  
 { 
  
 return 
  
 err 
  
 } 
  
 defer 
  
 adminClient 
 . 
  Close 
 
 () 
  
 op 
 , 
  
 err 
  
 := 
  
 adminClient 
 . 
 UpdateDatabaseDdl 
 ( 
 ctx 
 , 
  
& adminpb 
 . 
 UpdateDatabaseDdlRequest 
 { 
  
 Database 
 : 
  
 db 
 , 
  
 Statements 
 : 
  
 [] 
 string 
 { 
  
 `CREATE TABLE Performances ( 
 SingerId        INT64 NOT NULL, 
 VenueId         INT64 NOT NULL, 
 EventDate       Date, 
 Revenue         INT64, 
 LastUpdateTime  TIMESTAMP NOT NULL OPTIONS (allow_commit_timestamp=true) 
 ) PRIMARY KEY (SingerId, VenueId, EventDate), 
 INTERLEAVE IN PARENT Singers ON DELETE CASCADE` 
 , 
  
 }, 
  
 }) 
  
 if 
  
 err 
  
 != 
  
 nil 
  
 { 
  
 return 
  
 err 
  
 } 
  
 if 
  
 err 
  
 := 
  
 op 
 . 
 Wait 
 ( 
 ctx 
 ); 
  
 err 
  
 != 
  
 nil 
  
 { 
  
 return 
  
 err 
  
 } 
  
 fmt 
 . 
 Fprintf 
 ( 
 w 
 , 
  
 "Created Performances table in database [%s]\n" 
 , 
  
 db 
 ) 
  
 return 
  
 nil 
 } 
 

  static 
  
 void 
  
 createTableWithTimestamp 
 ( 
 DatabaseAdminClient 
  
 dbAdminClient 
 , 
  
 DatabaseId 
  
 id 
 ) 
  
 { 
  
 OperationFuture<Void 
 , 
  
 UpdateDatabaseDdlMetadata 
>  
 op 
  
 = 
  
 dbAdminClient 
 . 
 updateDatabaseDdl 
 ( 
  
 id 
 . 
 getInstanceId 
 (). 
 getInstance 
 (), 
  
 id 
 . 
 getDatabase 
 (), 
  
 Arrays 
 . 
 asList 
 ( 
  
 "CREATE TABLE Performances (" 
  
 + 
  
 "  SingerId     INT64 NOT NULL," 
  
 + 
  
 "  VenueId      INT64 NOT NULL," 
  
 + 
  
 "  EventDate    Date," 
  
 + 
  
 "  Revenue      INT64, " 
  
 + 
  
 "  LastUpdateTime TIMESTAMP NOT NULL OPTIONS (allow_commit_timestamp=true)" 
  
 + 
  
 ") PRIMARY KEY (SingerId, VenueId, EventDate)," 
  
 + 
  
 "  INTERLEAVE IN PARENT Singers ON DELETE CASCADE" 
 ), 
  
 null 
 ); 
  
 try 
  
 { 
  
 // Initiate the request which returns an OperationFuture. 
  
 op 
 . 
 get 
 (); 
  
 System 
 . 
 out 
 . 
 println 
 ( 
 "Created Performances table in database: [" 
  
 + 
  
 id 
  
 + 
  
 "]" 
 ); 
  
 } 
  
 catch 
  
 ( 
 ExecutionException 
  
 e 
 ) 
  
 { 
  
 // If the operation failed during execution, expose the cause. 
  
 throw 
  
 ( 
 SpannerException 
 ) 
  
 e 
 . 
 getCause 
 (); 
  
 } 
  
 catch 
  
 ( 
 InterruptedException 
  
 e 
 ) 
  
 { 
  
 // Throw when a thread is waiting, sleeping, or otherwise occupied, 
  
 // and the thread is interrupted, either before or during the activity. 
  
 throw 
  
 SpannerExceptionFactory 
 . 
 propagateInterrupt 
 ( 
 e 
 ); 
  
 } 
 } 
 

  // Imports the Google Cloud client library 
 const 
  
 { 
 Spanner 
 } 
  
 = 
  
 require 
 ( 
 ' @google-cloud/spanner 
' 
 ); 
 /** 
 * TODO(developer): Uncomment the following lines before running the sample. 
 */ 
 // const projectId = 'my-project-id'; 
 // const instanceId = 'my-instance'; 
 // const databaseId = 'my-database'; 
 // Creates a client 
 const 
  
 spanner 
  
 = 
  
 new 
  
  Spanner 
 
 ({ 
  
 projectId 
 : 
  
 projectId 
 , 
 }); 
 // Gets a reference to a Cloud Spanner Database Admin Client object 
 const 
  
 databaseAdminClient 
  
 = 
  
 spanner 
 . 
  getDatabaseAdminClient 
 
 (); 
 // Note: Cloud Spanner interprets Node.js numbers as FLOAT64s, so they 
 // must be converted to strings before being inserted as INT64s 
 const 
  
 request 
  
 = 
  
 [ 
  
 `CREATE TABLE Performances ( 
 SingerId    INT64 NOT NULL, 
 VenueId     INT64 NOT NULL, 
 EventDate   DATE, 
 Revenue     INT64, 
 LastUpdateTime TIMESTAMP NOT NULL OPTIONS (allow_commit_timestamp=true) 
 ) PRIMARY KEY (SingerId, VenueId, EventDate), 
 INTERLEAVE IN PARENT Singers ON DELETE CASCADE` 
 , 
 ]; 
 // Creates a table in an existing database 
 const 
  
 [ 
 operation 
 ] 
  
 = 
  
 await 
  
 databaseAdminClient 
 . 
 updateDatabaseDdl 
 ({ 
  
 database 
 : 
  
 databaseAdminClient 
 . 
 databasePath 
 ( 
  
 projectId 
 , 
  
 instanceId 
 , 
  
 databaseId 
 , 
  
 ), 
  
 statements 
 : 
  
 request 
 , 
 }); 
 console 
 . 
 log 
 ( 
 `Waiting for operation on 
 ${ 
 databaseId 
 } 
 to complete...` 
 ); 
 await 
  
  operation 
 
 . 
 promise 
 (); 
 console 
 . 
 log 
 ( 
 `Created table Performances in database 
 ${ 
 databaseId 
 } 
 .` 
 ); 
 

  use Google\Cloud\Spanner\Admin\Database\V1\Client\DatabaseAdminClient; 
 use Google\Cloud\Spanner\Admin\Database\V1\UpdateDatabaseDdlRequest; 
 /** 
 * Creates a table with a commit timestamp column. 
 * Example: 
 * ``` 
 * create_table_with_timestamp_column($projectId, $instanceId, $databaseId); 
 * ``` 
 * 
 * @param string $projectId The Google Cloud project ID. 
 * @param string $instanceId The Spanner instance ID. 
 * @param string $databaseId The Spanner database ID. 
 */ 
 function create_table_with_timestamp_column(string $projectId, string $instanceId, string $databaseId): void 
 { 
 $databaseAdminClient = new DatabaseAdminClient(); 
 $databaseName = DatabaseAdminClient::databaseName($projectId, $instanceId, $databaseId); 
 $statement = 'CREATE TABLE Performances ( 
 SingerId	INT64 NOT NULL, 
 VenueId		INT64 NOT NULL, 
 EventDate	DATE, 
 Revenue		INT64, 
 LastUpdateTime	TIMESTAMP NOT NULL OPTIONS (allow_commit_timestamp=true) 
 ) PRIMARY KEY (SingerId, VenueId, EventDate), 
 INTERLEAVE IN PARENT Singers on DELETE CASCADE'; 
 $request = new UpdateDatabaseDdlRequest([ 
 'database' => $databaseName, 
 'statements' => [$statement] 
 ]); 
 $operation = $databaseAdminClient->updateDatabaseDdl($request); 
 print('Waiting for operation to complete...' . PHP_EOL); 
 $operation->pollUntilComplete(); 
 printf('Created Performances table in database %s on instance %s' . PHP_EOL, 
 $databaseId, $instanceId); 
 } 
 

  def 
  
 create_table_with_timestamp 
 ( 
 instance_id 
 , 
 database_id 
 ): 
  
 """Creates a table with a COMMIT_TIMESTAMP column.""" 
 from 
  
 google.cloud.spanner_admin_database_v1.types 
  
 import 
 spanner_database_admin 
 spanner_client 
 = 
 spanner 
 . 
 Client 
 () 
 database_admin_api 
 = 
 spanner_client 
 . 
 database_admin_api 
 request 
 = 
 spanner_database_admin 
 . 
 UpdateDatabaseDdlRequest 
 ( 
 database 
 = 
 database_admin_api 
 . 
 database_path 
 ( 
 spanner_client 
 . 
 project 
 , 
 instance_id 
 , 
 database_id 
 ), 
 statements 
 = 
 [ 
  
 """CREATE TABLE Performances ( 
 SingerId     INT64 NOT NULL, 
 VenueId      INT64 NOT NULL, 
 EventDate    Date, 
 Revenue      INT64, 
 LastUpdateTime TIMESTAMP NOT NULL 
 OPTIONS(allow_commit_timestamp=true) 
 ) PRIMARY KEY (SingerId, VenueId, EventDate), 
 INTERLEAVE IN PARENT Singers ON DELETE CASCADE""" 
 ], 
 ) 
 operation 
 = 
 database_admin_api 
 . 
 update_database_ddl 
 ( 
 request 
 ) 
 print 
 ( 
 "Waiting for operation to complete..." 
 ) 
 operation 
 . 
 result 
 ( 
 OPERATION_TIMEOUT_SECONDS 
 ) 
 print 
 ( 
 "Created Performances table on database 
 {} 
 on instance 
 {} 
 " 
 . 
 format 
 ( 
 database_id 
 , 
 instance_id 
 ) 
 ) 
 

  # project_id  = "Your Google Cloud project ID" 
 # instance_id = "Your Spanner instance ID" 
 # database_id = "Your Spanner database ID" 
 require 
  
 "google/cloud/spanner" 
 require 
  
 "google/cloud/spanner/admin/database" 
 database_admin_client 
  
 = 
  
 Google 
 :: 
 Cloud 
 :: 
 Spanner 
 :: 
 Admin 
 :: 
 Database 
 . 
 database_admin 
 db_path 
  
 = 
  
 database_admin_client 
 . 
 database_path 
  
 project 
 : 
  
 project_id 
 , 
  
 instance 
 : 
  
 instance_id 
 , 
  
 database 
 : 
  
 database_id 
 job 
  
 = 
  
 database_admin_client 
 . 
 update_database_ddl 
  
 database 
 : 
  
 db_path 
 , 
  
 statements 
 : 
  
 [ 
  
 "CREATE TABLE Performances ( 
 SingerId     INT64 NOT NULL, 
 VenueId      INT64 NOT NULL, 
 EventDate    Date, 
 Revenue      INT64, 
 LastUpdateTime TIMESTAMP NOT NULL OPTIONS (allow_commit_timestamp=true) 
 ) PRIMARY KEY (SingerId, VenueId, EventDate), 
 INTERLEAVE IN PARENT Singers ON DELETE CASCADE" 
  
 ] 
 puts 
  
 "Waiting for update database operation to complete" 
 job 
 . 
 wait_until_done! 
 puts 
  
 "Created table Performances in 
 #{ 
 database_id 
 } 
 "