com.google.cloud.spanner

Interface DatabaseAdminClient

public interface DatabaseAdminClient

Client to do admin operations on a Cloud Spanner Database.

Method Summary

Modifier and Type	Method and Description
OperationFuture<Database,com.google.spanner.admin.database.v1.CreateDatabaseMetadata>	createDatabase(String instanceId, String databaseId, Iterable<String> statements) Creates a new database in a Cloud Spanner instance.
void	dropDatabase(String instanceId, String databaseId) Drops a Cloud Spanner database.
Database	getDatabase(String instanceId, String databaseId) Gets the current state of a Cloud Spanner database.
List<String>	getDatabaseDdl(String instanceId, String databaseId) Returns the schema of a Cloud Spanner database as a list of formatted DDL statements.
Page<Database>	listDatabases(String instanceId, Options.ListOption... options) Returns the list of Cloud Spanner database in the given instance.
OperationFuture<Void,com.google.spanner.admin.database.v1.UpdateDatabaseDdlMetadata>	updateDatabaseDdl(String instanceId, String databaseId, Iterable<String> statements, String operationId) Enqueues the given DDL statements to be applied, in order but not necessarily all at once, to the database schema at some point (or points) in the future.

Method Detail

createDatabase

OperationFuture<Database,com.google.spanner.admin.database.v1.CreateDatabaseMetadata> createDatabase(String instanceId,
                                                                                                     String databaseId,
                                                                                                     Iterable<String> statements)
                                                                                              throws SpannerException

Creates a new database in a Cloud Spanner instance.

Example to create database.

 String instanceId = my_instance_id;
 String databaseId = my_database_id;
 Operation<Database, CreateDatabaseMetadata> op = dbAdminClient
     .createDatabase(
         instanceId,
         databaseId,
         Arrays.asList(
             "CREATE TABLE Singers (\n"
                 + "  SingerId   INT64 NOT NULL,\n"
                 + "  FirstName  STRING(1024),\n"
                 + "  LastName   STRING(1024),\n"
                 + "  SingerInfo BYTES(MAX)\n"
                 + ") PRIMARY KEY (SingerId)",
             "CREATE TABLE Albums (\n"
                 + "  SingerId     INT64 NOT NULL,\n"
                 + "  AlbumId      INT64 NOT NULL,\n"
                 + "  AlbumTitle   STRING(MAX)\n"
                 + ") PRIMARY KEY (SingerId, AlbumId),\n"
                 + "  INTERLEAVE IN PARENT Singers ON DELETE CASCADE"));
 Database db = op.waitFor().getResult();
 

Parameters:

instanceId - the id of the instance in which to create the database.

databaseId - the id of the database which will be created. It must conform to the regular expression [a-z][a-z0-9_\-]*[a-z0-9] and be between 2 and 30 characters in length

statements - DDL statements to run while creating the database, for example CREATE TABLE MyTable ( ... ). This should not include CREATE DATABASE statement.

Throws:

SpannerException

getDatabase

Database getDatabase(String instanceId,
                     String databaseId)
              throws SpannerException

Gets the current state of a Cloud Spanner database.

Example to getDatabase.

 String instanceId = my_instance_id;
 String databaseId = my_database_id;
 Database db = dbAdminClient.getDatabase(instanceId, databaseId);
 

Throws:

SpannerException

updateDatabaseDdl

OperationFuture<Void,com.google.spanner.admin.database.v1.UpdateDatabaseDdlMetadata> updateDatabaseDdl(String instanceId,
                                                                                                       String databaseId,
                                                                                                       Iterable<String> statements,
                                                                                                       @Nullable
                                                                                                       String operationId)
                                                                                                throws SpannerException

Enqueues the given DDL statements to be applied, in order but not necessarily all at once, to the database schema at some point (or points) in the future. The server checks that the statements are executable (syntactically valid, name tables that exist, etc.) before enqueueing them, but they may still fail upon later execution (e.g., if a statement from another batch of statements is applied first and it conflicts in some way, or if there is some data-related problem like a `NULL` value in a column to which `NOT NULL` would be added). If a statement fails, all subsequent statements in the batch are automatically cancelled.

Example to update the database DDL.

 String instanceId = my_instance_id;
 String databaseId = my_database_id;
 dbAdminClient.updateDatabaseDdl(instanceId,
     databaseId,
     Arrays.asList("ALTER TABLE Albums ADD COLUMN MarketingBudget INT64"),
     null).waitFor();
 

Parameters:

operationId - Operation id assigned to this operation. If null, system will autogenerate one. This must be unique within a database abd must be a valid identifier [a-zA-Z][a-zA-Z0-9_]*.

Throws:

SpannerException

dropDatabase

void dropDatabase(String instanceId,
                  String databaseId)
           throws SpannerException

Drops a Cloud Spanner database.

Example to drop a Cloud Spanner database.

 String instanceId = my_instance_id;
 String databaseId = my_database_id;
 dbAdminClient.dropDatabase(instanceId, databaseId);
 

Throws:

SpannerException

getDatabaseDdl

List<String> getDatabaseDdl(String instanceId,
                            String databaseId)

Returns the schema of a Cloud Spanner database as a list of formatted DDL statements. This method does not show pending schema updates.

Example to get the schema of a Cloud Spanner database.

 String instanceId = my_instance_id;
 String databaseId = my_database_id;
 List<String> statementsInDb = dbAdminClient.getDatabaseDdl(instanceId, databaseId);
 

listDatabases

Page<Database> listDatabases(String instanceId,
                             Options.ListOption... options)

Returns the list of Cloud Spanner database in the given instance.

Example to get the list of Cloud Spanner database in the given instance.

 String instanceId = my_instance_id;
 Page<Database> page = dbAdminClient.listDatabases(instanceId, Options.pageSize(1));
 List<Database> dbs = new ArrayList<>();
 while (page != null) {
   Database db = Iterables.getOnlyElement(page.getValues());
   dbs.add(db);
   page = page.getNextPage();
 }