const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');constcount=5;database.batchCreateSession(count,(err,sessions,response)=>{if(err){// Error handling omitted.}// `sessions` is an array of Session objects.});

const[sessions,response]=awaitdatabase.batchCreateSessions(count);

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');consttransaction=database.batchTransaction({session:'my-session',transaction:'my-transaction',readTimestamp:1518464696657});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.close(function(err){if(err){// Error handling omitted.}});//-// In the event of a session leak, the error object will contain a// `messages` field.//-database.close(function(err){if(err &&err.messages){err.messages.forEach(function(message){console.error(message);});}});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.createSession(function(err,session,apiResponse){if(err){// Error handling omitted.}// `session` is a Session object.});//-// If the callback is omitted, we'll return a Promise.//-database.createSession().then(function(data){constsession=data[0];constapiResponse=data[1];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');constschema='CREATE TABLE Singers ('+'  SingerId INT64 NOT NULL,'+'  FirstName STRING(1024),'+'  LastName STRING(1024),'+'  SingerInfo BYTES(MAX),'+') PRIMARY KEY(SingerId)';database.createTable(schema,function(err,table,operation,apiResponse){if(err){// Error handling omitted.}operation.on('error',function(err){}).on('complete',function(){// Table created successfully.});});//-// If the callback is omitted, we'll return a Promise.//-database.createTable(schema).then(function(data){consttable=data[0];constoperation=data[1];returnoperation.promise();}).then(function(){// Table created successfully.});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.delete(function(err,apiResponse){if(err){// Error handling omitted.}// Database was deleted successfully.});//-// If the callback is omitted, we'll return a Promise.//-database.delete().then(function(data){constapiResponse=data[0];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.exists(function(err,exists){});//-// If the callback is omitted, we'll return a Promise.//-database.exists().then(function(data){constexists=data[0];});

Database.formatName_('projects/grape-spaceship-123/instances/my-instance','my-database');// 'projects/grape-spaceship-123/instances/my-instance/databases/my-database'

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.get(function(err,database,apiResponse){// `database.metadata` has been populated.});//-// If the callback is omitted, we'll return a Promise.//-database.get().then(function(data){constdatabase=data[0];constapiResponse=data[0];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.getDatabaseRoles(function(err,roles){// `roles` is an array of `DatabaseRoles` objects.});//-// To control how many API requests are made and page through the results// manually, set `autoPaginate` to `false`.//-functioncallback(err,roles,nextQuery,apiResponse){if(nextQuery){// More results exist.database.getDatabaseRoles(nextQuery,callback);}}database.getInstances({gaxOptions:{autoPaginate:false}},callback);//-// If the callback is omitted, we'll return a Promise.//-database.getInstances().then(function(data){constroles=data[0];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');constpolicy=awaitdatabase.getIamPolicy();console.log(policy.bindings,policy.version,policy.etag,policy.auditConfigs)constpolicyWithVersionspecified=awaitdatabase.getIamPolicy({requestedPolicyVersion:3});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.getMetadata(function(err,metadata){if(err){// Error handling omitted.}// Database was deleted successfully.});//-// If the callback is omitted, we'll return a Promise.//-database.getMetadata().then(function(data){constmetadata=data[0];constapiResponse=data[1];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');const[operations]=awaitdatabase.getOperations();//-// To manually handle pagination, set autoPaginate:false in gaxOptions.//-letpageToken=undefined;do{const[operations,,response]=awaitdatabase.getOperations({pageSize:3,pageToken,gaxOptions:{autoPaginate:false},});operations.forEach(operation=>{// Do something with operation});pageToken=response.nextPageToken;}while(pageToken);

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');constrestoreInfo=awaitdatabase.getRestoreInfo();console.log(`Database restored from${restoreInfo.backupInfo.backup}`);

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.getSchema(function(err,statements,apiResponse){});//-// If the callback is omitted, we'll return a Promise.//-database.getSchema().then(function(data){conststatements=data[0];constapiResponse=data[1];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.getSessions(function(err,sessions){// `sessions` is an array of `Session` objects.});//-// To control how many API requests are made and page through the results// manually, set `autoPaginate` to `false`.//-functioncallback(err,sessions,nextQuery,apiResponse){if(nextQuery){// More results exist.database.getSessions(nextQuery,callback);}}database.getInstances({gaxOptions:{autoPaginate:false}},callback);//-// If the callback is omitted, we'll return a Promise.//-database.getInstances().then(function(data){constsessions=data[0];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.getSessionsStream().on('error',console.error).on('data',function(database){// `sessions` is a `Session` object.}).on('end',function(){// All sessions retrieved.});//-// If you anticipate many results, you can end a stream early to prevent// unnecessary processing and API requests.//-database.getSessionsStream().on('data',function(session){this.end();});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.getSnapshot(function(err,transaction){if(err){// Error handling omitted.}// Should be called when finished with Snapshot.transaction.end();});

database.getSnapshot().then(function(data){consttransaction=data[0];});

// Imports the Google Cloud client libraryconst{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 clientconstspanner=newSpanner({projectId:projectId,});// Gets a reference to a Cloud Spanner instance and databaseconstinstance=spanner.instance(instanceId);constdatabase=instance.database(databaseId);// Gets a transaction object that captures the database state// at a specific point in timedatabase.getSnapshot(async(err,transaction)=>{if(err){console.error(err);return;}constqueryOne='SELECT SingerId, AlbumId, AlbumTitle FROM Albums';try{// Read #1, using SQLconst[qOneRows]=awaittransaction.run(queryOne);qOneRows.forEach(row=>{constjson=row.toJSON();console.log(`SingerId:${json.SingerId}, AlbumId:${json.AlbumId}, AlbumTitle:${json.AlbumTitle}`);});constqueryTwo={columns:['SingerId','AlbumId','AlbumTitle'],};// Read #2, using the `read` method. Even if changes occur// in-between the reads, the transaction ensures that both// return the same data.const[qTwoRows]=awaittransaction.read('Albums',queryTwo);qTwoRows.forEach(row=>{constjson=row.toJSON();console.log(`SingerId:${json.SingerId}, AlbumId:${json.AlbumId}, AlbumTitle:${json.AlbumTitle}`);});console.log('Successfully executed read-only transaction.');}catch(err){console.error('ERROR:',err);}finally{transaction.end();// Close the database when finished.awaitdatabase.close();}});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');conststate=awaitdatabase.getState();constisReady=(state==='READY');

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');database.getTransaction(function(err,transaction){});

database.getTransaction().then(function(data){consttransaction=data[0];});

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');constbackupName='projects/my-project/instances/my-instance/backups/my-backup';const[,restoreOperation]=awaitdatabase.restore(backupName);// Wait for restore to completeawaitrestoreOperation.promise();//-// Restore database with a different encryption key to the one used by the// backup.//-const[,restoreWithKeyOperation]=awaitdatabase.restore(backupName,{encryptionConfig:{encryptionType:'CUSTOMER_MANAGED_ENCRYPTION',kmsKeyName:'projects/my-project-id/my-region/keyRings/my-key-ring/cryptoKeys/my-key',}},);// Wait for restore to completeawaitrestoreWithKeyOperation.promise();

const{Spanner}=require('@google-cloud/spanner');constspanner=newSpanner();constinstance=spanner.instance('my-instance');constdatabase=instance.database('my-database');constquery='SELECT * FROM Singers';database.run(query,function(err,rows){if(err){// Error handling omitted.}constfirstRow=rows[0];// firstRow = [//   {//     name: 'SingerId',//     value: '1'//   },//   {//     name: 'Name',//     value: 'Eddie Wilson'//   }// ]});//-// Rows are returned as an array of object arrays. Each object has a `name`// and `value` property. To get a serialized object, call `toJSON()`.//-database.run(query,function(err,rows){if(err){// Error handling omitted.}constfirstRow=rows[0];// firstRow.toJSON() = {//   SingerId: '1',//   Name: 'Eddie Wilson'// }});//-// Alternatively, set `query.json` to `true`, and this step will be performed// automatically.//-database.run(query,function(err,rows){if(err){// Error handling omitted.}constfirstRow=rows[0];// firstRow = {//   SingerId: '1',//   Name: 'Eddie Wilson'// }});//-// The SQL query string can contain parameter placeholders. A parameter// placeholder consists of '@' followed by the parameter name.//-constquery={sql:'SELECT * FROM Singers WHERE name = @name',params:{name:'Eddie Wilson'}};database.run(query,function(err,rows){});//-// If you need to enforce a specific param type, a types map can be provided.// This is typically useful if your param value can be null.//-constquery={sql:'SELECT * FROM Singers WHERE name = @name AND id = @id',params:{id:spanner.int(8),name:null},types:{id:'int64',name:'string'}};database.run(query,function(err,rows){});//-// If the callback is omitted, we'll return a Promise.//-database.run(query).then(function(data){constrows=data[0];});

// Imports the Google Cloud client libraryconst{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 clientconstspanner=newSpanner({projectId:projectId,});// Gets a reference to a Cloud Spanner instance and databaseconstinstance=spanner.instance(instanceId);constdatabase=instance.database(databaseId);constquery={sql:'SELECT SingerId, AlbumId, AlbumTitle FROM Albums',};// Queries rows from the Albums tabletry{const[rows]=awaitdatabase.run(query);rows.forEach(row=>{constjson=row.toJSON();console.log(`SingerId:${json.SingerId}, AlbumId:${json.AlbumId}, AlbumTitle:${json.AlbumTitle}`);});}catch(err){console.error('ERROR:',err);}finally{// Close the database when finished.awaitdatabase.close();}

// Imports the Google Cloud client libraryconst{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';// const startTitle = 'Ardvark';// const endTitle = 'Goo';// Creates a clientconstspanner=newSpanner({projectId:projectId,});// Gets a reference to a Cloud Spanner instance and databaseconstinstance=spanner.instance(instanceId);constdatabase=instance.database(databaseId);constquery={sql:`SELECT AlbumId, AlbumTitle, MarketingBudget          FROM Albums@{FORCE_INDEX=AlbumsByAlbumTitle}          WHERE AlbumTitle >= @startTitle AND AlbumTitle <= @endtitle`,=""params:=""{=""starttitle:=""starttitle,=""endtitle:=""endtitle,=""},=""};=""queries=""rows=""from=""the=""albums=""table=""try=""{=""const=""[rows]="await"database.run(query);=""rows.foreach(row="">{constjson=row.toJSON();constmarketingBudget=json.MarketingBudget?json.MarketingBudget:null;// This value is nullableconsole.log(`AlbumId:${json.AlbumId}, AlbumTitle:${json.AlbumTitle}, MarketingBudget:${marketingBudget}`);});}catch(err){console.error('ERROR:',err);}finally{// Close the database when finished.database.close();}