@@ -84,7 +84,7 @@ static class Album {
84
84
}
85
85
}
86
86
87
- // [START write ]
87
+ // [START spanner_insert_data ]
88
88
static final List <Singer > SINGERS =
89
89
Arrays .asList (
90
90
new Singer (1 , "Marc" , "Richards" ),
@@ -100,8 +100,9 @@ static class Album {
100
100
new Album (2 , 1 , "Green" ),
101
101
new Album (2 , 2 , "Forever Hold Your Peace" ),
102
102
new Album (2 , 3 , "Terrified" ));
103
- // [END write ]
103
+ // [END spanner_insert_data ]
104
104
105
+ // [START spanner_create_database]
105
106
static void createDatabase (DatabaseAdminClient dbAdminClient , DatabaseId id ) {
106
107
Operation <Database , CreateDatabaseMetadata > op = dbAdminClient
107
108
.createDatabase (
@@ -123,8 +124,9 @@ static void createDatabase(DatabaseAdminClient dbAdminClient, DatabaseId id) {
123
124
Database db = op .waitFor ().getResult ();
124
125
System .out .println ("Created database [" + db .getId () + "]" );
125
126
}
127
+ // [END spanner_create_database]
126
128
127
- // [START write ]
129
+ // [START spanner_insert_data ]
128
130
static void writeExampleData (DatabaseClient dbClient ) {
129
131
List <Mutation > mutations = new ArrayList <>();
130
132
for (Singer singer : SINGERS ) {
@@ -151,9 +153,9 @@ static void writeExampleData(DatabaseClient dbClient) {
151
153
}
152
154
dbClient .write (mutations );
153
155
}
154
- // [END write ]
156
+ // [END spanner_insert_data ]
155
157
156
- // [START query ]
158
+ // [START spanner_query_data ]
157
159
static void query (DatabaseClient dbClient ) {
158
160
// singleUse() can be used to execute a single read or query against Cloud Spanner.
159
161
ResultSet resultSet =
@@ -165,9 +167,9 @@ static void query(DatabaseClient dbClient) {
165
167
"%d %d %s\n " , resultSet .getLong (0 ), resultSet .getLong (1 ), resultSet .getString (2 ));
166
168
}
167
169
}
168
- // [END query ]
170
+ // [END spanner_query_data ]
169
171
170
- // [START read ]
172
+ // [START spanner_read_data ]
171
173
static void read (DatabaseClient dbClient ) {
172
174
ResultSet resultSet =
173
175
dbClient
@@ -182,21 +184,21 @@ static void read(DatabaseClient dbClient) {
182
184
"%d %d %s\n " , resultSet .getLong (0 ), resultSet .getLong (1 ), resultSet .getString (2 ));
183
185
}
184
186
}
185
- // [END read ]
187
+ // [END spanner_read_data ]
186
188
187
- // [START add_marketing_budget ]
189
+ // [START spanner_add_column ]
188
190
static void addMarketingBudget (DatabaseAdminClient adminClient , DatabaseId dbId ) {
189
191
adminClient .updateDatabaseDdl (dbId .getInstanceId ().getInstance (),
190
192
dbId .getDatabase (),
191
193
Arrays .asList ("ALTER TABLE Albums ADD COLUMN MarketingBudget INT64" ),
192
194
null ).waitFor ();
193
195
System .out .println ("Added MarketingBudget column" );
194
196
}
195
- // [END add_marketing_budget ]
197
+ // [END spanner_add_column ]
196
198
197
199
// Before executing this method, a new column MarketingBudget has to be added to the Albums
198
200
// table by applying the DDL statement "ALTER TABLE Albums ADD COLUMN MarketingBudget INT64".
199
- // [START update ]
201
+ // [START spanner_update_data ]
200
202
static void update (DatabaseClient dbClient ) {
201
203
// Mutation can be used to update/insert/delete a single row in a table. Here we use
202
204
// newUpdateBuilder to create update mutations.
@@ -221,9 +223,9 @@ static void update(DatabaseClient dbClient) {
221
223
// This writes all the mutations to Cloud Spanner atomically.
222
224
dbClient .write (mutations );
223
225
}
224
- // [END update ]
226
+ // [END spanner_update_data ]
225
227
226
- // [START transaction ]
228
+ // [START spanner_read_write_transaction ]
227
229
static void writeWithTransaction (DatabaseClient dbClient ) {
228
230
dbClient
229
231
.readWriteTransaction ()
@@ -270,9 +272,9 @@ public Void run(TransactionContext transaction) throws Exception {
270
272
}
271
273
});
272
274
}
273
- // [END transaction ]
275
+ // [END spanner_read_write_transaction ]
274
276
275
- // [START query_new_column ]
277
+ // [START spanner_query_with_new_column ]
276
278
static void queryMarketingBudget (DatabaseClient dbClient ) {
277
279
// Rows without an explicit value for MarketingBudget will have a MarketingBudget equal to
278
280
// null.
@@ -290,21 +292,21 @@ static void queryMarketingBudget(DatabaseClient dbClient) {
290
292
resultSet .isNull ("MarketingBudget" ) ? "NULL" : resultSet .getLong ("MarketingBudget" ));
291
293
}
292
294
}
293
- // [END query_new_column ]
295
+ // [END spanner_query_with_new_column ]
294
296
295
- // [START add_index ]
297
+ // [START spanner_create_index ]
296
298
static void addIndex (DatabaseAdminClient adminClient , DatabaseId dbId ) {
297
299
adminClient .updateDatabaseDdl (dbId .getInstanceId ().getInstance (),
298
300
dbId .getDatabase (),
299
301
Arrays .asList ("CREATE INDEX AlbumsByAlbumTitle ON Albums(AlbumTitle)" ),
300
302
null ).waitFor ();
301
303
System .out .println ("Added AlbumsByAlbumTitle index" );
302
304
}
303
- // [END add_index ]
305
+ // [END spanner_create_index ]
304
306
305
307
// Before running this example, add the index AlbumsByAlbumTitle by applying the DDL statement
306
308
// "CREATE INDEX AlbumsByAlbumTitle ON Albums(AlbumTitle)".
307
- // [START query_index ]
309
+ // [START spanner_query_data_with_index ]
308
310
static void queryUsingIndex (DatabaseClient dbClient ) {
309
311
Statement statement = Statement
310
312
// We use FORCE_INDEX hint to specify which index to use. For more details see
@@ -327,9 +329,9 @@ static void queryUsingIndex(DatabaseClient dbClient) {
327
329
resultSet .isNull ("MarketingBudget" ) ? "NULL" : resultSet .getLong ("MarketingBudget" ));
328
330
}
329
331
}
330
- // [END query_index ]
332
+ // [END spanner_query_data_with_index ]
331
333
332
- // [START read_index ]
334
+ // [START spanner_read_data_with_index ]
333
335
static void readUsingIndex (DatabaseClient dbClient ) {
334
336
ResultSet resultSet =
335
337
dbClient
@@ -343,9 +345,9 @@ static void readUsingIndex(DatabaseClient dbClient) {
343
345
System .out .printf ("%d %s\n " , resultSet .getLong (0 ), resultSet .getString (1 ));
344
346
}
345
347
}
346
- // [END read_index ]
348
+ // [END spanner_read_data_with_index ]
347
349
348
- // [START add_storing_index ]
350
+ // [START spanner_create_storing_index ]
349
351
static void addStoringIndex (DatabaseAdminClient adminClient , DatabaseId dbId ) {
350
352
adminClient .updateDatabaseDdl (dbId .getInstanceId ().getInstance (),
351
353
dbId .getDatabase (),
@@ -354,11 +356,11 @@ static void addStoringIndex(DatabaseAdminClient adminClient, DatabaseId dbId) {
354
356
null ).waitFor ();
355
357
System .out .println ("Added AlbumsByAlbumTitle2 index" );
356
358
}
357
- // [END add_storing_index ]
359
+ // [END spanner_create_storing_index ]
358
360
359
361
// Before running this example, create a storing index AlbumsByAlbumTitle2 by applying the DDL
360
362
// statement "CREATE INDEX AlbumsByAlbumTitle2 ON Albums(AlbumTitle) STORING (MarketingBudget)".
361
- // [START read_storing_index ]
363
+ // [START spanner_read_data_with_storing_index ]
362
364
static void readStoringIndex (DatabaseClient dbClient ) {
363
365
// We can read MarketingBudget also from the index since it stores a copy of MarketingBudget.
364
366
ResultSet resultSet =
@@ -377,9 +379,9 @@ static void readStoringIndex(DatabaseClient dbClient) {
377
379
resultSet .isNull ("MarketingBudget" ) ? "NULL" : resultSet .getLong ("MarketingBudget" ));
378
380
}
379
381
}
380
- // [END read_storing_index ]
382
+ // [END spanner_read_data_with_storing_index ]
381
383
382
- // [START read_only_transaction ]
384
+ // [START spanner_read_only_transaction ]
383
385
static void readOnlyTransaction (DatabaseClient dbClient ) {
384
386
// ReadOnlyTransaction must be closed by calling close() on it to release resources held by it.
385
387
// We use a try-with-resource block to automatically do so.
@@ -402,9 +404,9 @@ static void readOnlyTransaction(DatabaseClient dbClient) {
402
404
}
403
405
}
404
406
}
405
- // [END read_only_transaction ]
407
+ // [END spanner_read_only_transaction ]
406
408
407
- // [START read_stale_data ]
409
+ // [START spanner_read_stale_data ]
408
410
static void readStaleData (DatabaseClient dbClient ) {
409
411
ResultSet resultSet =
410
412
dbClient
@@ -418,7 +420,7 @@ static void readStaleData(DatabaseClient dbClient) {
418
420
resultSet .isNull (2 ) ? "NULL" : resultSet .getLong ("MarketingBudget" ));
419
421
}
420
422
}
421
- // [END read_stale_data ]
423
+ // [END spanner_read_stale_data ]
422
424
423
425
static void run (DatabaseClient dbClient , DatabaseAdminClient dbAdminClient , String command ,
424
426
DatabaseId database ) {
0 commit comments