@@ -143,11 +143,12 @@ def read_stale_data(instance_id, database_id):
143
143
keyset = spanner .KeySet (all_ = True )
144
144
results = snapshot .read (
145
145
table = 'Albums' ,
146
- columns = ('SingerId' , 'AlbumId' , 'AlbumTitle ' ,),
146
+ columns = ('SingerId' , 'AlbumId' , 'MarketingBudget ' ,),
147
147
keyset = keyset )
148
148
149
149
for row in results :
150
- print (u'SingerId: {}, AlbumId: {}, AlbumTitle: {}' .format (* row ))
150
+ print (u'SingerId: {}, AlbumId: {}, MarketingBudget: {}' .format (
151
+ * row ))
151
152
# [END spanner_read_stale_data]
152
153
153
154
@@ -562,9 +563,8 @@ def update_data_with_timestamp(instance_id, database_id):
562
563
columns = (
563
564
'SingerId' , 'AlbumId' , 'MarketingBudget' , 'LastUpdateTime' ),
564
565
values = [
565
- (1 , 4 , 11000 , spanner .COMMIT_TIMESTAMP ),
566
- (1 , 19 , 15000 , spanner .COMMIT_TIMESTAMP ),
567
- (2 , 42 , 7000 , spanner .COMMIT_TIMESTAMP )])
566
+ (1 , 1 , 1000000 , spanner .COMMIT_TIMESTAMP ),
567
+ (2 , 2 , 750000 , spanner .COMMIT_TIMESTAMP )])
568
568
569
569
print ('Updated data.' )
570
570
# [END spanner_update_data_with_timestamp_column]
@@ -590,11 +590,11 @@ def query_data_with_timestamp(instance_id, database_id):
590
590
591
591
with database .snapshot () as snapshot :
592
592
results = snapshot .execute_sql (
593
- 'SELECT SingerId, AlbumId, AlbumTitle FROM Albums '
593
+ 'SELECT SingerId, AlbumId, MarketingBudget FROM Albums '
594
594
'ORDER BY LastUpdateTime DESC' )
595
595
596
596
for row in results :
597
- print (u'SingerId: {}, AlbumId: {}, AlbumTitle : {}' .format (* row ))
597
+ print (u'SingerId: {}, AlbumId: {}, MarketingBudget : {}' .format (* row ))
598
598
# [END spanner_query_data_with_timestamp_column]
599
599
600
600
0 commit comments