-
Notifications
You must be signed in to change notification settings - Fork 102
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(spanner): add a sample for max commit delays (#1993)
* Add a sample * update copywrite year * Comments. * Lint * Change to transaction.commit * Update test. * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * Remove added lines from merge * Change SingerId * Add an integration test * Add a comment * fix regex --------- Co-authored-by: surbhigarg92 <[email protected]> Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
- Loading branch information
3 people
authored
Mar 8, 2024
1 parent
4381047
commit 91c7204
Showing
4 changed files
with
119 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,87 @@ | ||
| // Copyright 2024 Google LLC | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
| // sample-metadata: | ||
| // title: Executes request with max commit delay | ||
| // usage: node max-commit-delay.js <INSTANCE_ID> <DATABASE_ID> <PROJECT_ID> | ||
|
|
||
| 'use strict'; | ||
|
|
||
| function main( | ||
| instanceId = 'my-instance', | ||
| databaseId = 'my-database', | ||
| projectId = 'my-project-id' | ||
| ) { | ||
| // [START spanner_set_max_commit_delay] | ||
| // Imports the Google Cloud client library. | ||
| const {Spanner, protos} = 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, | ||
| }); | ||
|
|
||
| async function spannerSetMaxCommitDelay() { | ||
| // Gets a reference to a Cloud Spanner instance and database. | ||
| const instance = spanner.instance(instanceId); | ||
| const database = instance.database(databaseId); | ||
|
|
||
| database.runTransaction(async (err, transaction) => { | ||
| if (err) { | ||
| console.error(err); | ||
| return; | ||
| } | ||
| try { | ||
| const [rowCount] = await transaction.runUpdate({ | ||
| sql: 'INSERT Singers (SingerId, FirstName, LastName) VALUES (111, @firstName, @lastName)', | ||
| params: { | ||
| firstName: 'Virginia', | ||
| lastName: 'Watson', | ||
| }, | ||
| }); | ||
|
|
||
| console.log( | ||
| `Successfully inserted ${rowCount} record into the Singers table.` | ||
| ); | ||
|
|
||
| await transaction.commit({ | ||
| // The maximum amount of time to delay the transaction to improve | ||
| // throughput. | ||
| maxCommitDelay: protos.google.protobuf.Duration({ | ||
| seconds: 0, // 0 seconds | ||
| nanos: 100000000, // 100,000,000 nanoseconds = 100 milliseconds | ||
| }), | ||
| }); | ||
| } catch (err) { | ||
| console.error('ERROR:', err); | ||
| } finally { | ||
| // Close the database when finished. | ||
| database.close(); | ||
| } | ||
| }); | ||
| } | ||
| spannerSetMaxCommitDelay(); | ||
| // [END spanner_set_max_commit_delay] | ||
| } | ||
| process.on('unhandledRejection', err => { | ||
| console.error(err.message); | ||
| process.exitCode = 1; | ||
| }); | ||
| main(...process.argv.slice(2)); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters