24
24
25
25
26
26
client ._DATASET_ENV_VAR_NAME = 'GCLOUD_TESTS_DATASET_ID'
27
- client = datastore .Client ()
27
+ CLIENT = datastore .Client ()
28
28
29
29
30
30
class TestDatastore (unittest2 .TestCase ):
@@ -33,16 +33,16 @@ def setUp(self):
33
33
self .case_entities_to_delete = []
34
34
35
35
def tearDown (self ):
36
- with client .transaction ():
36
+ with CLIENT .transaction ():
37
37
keys = [entity .key for entity in self .case_entities_to_delete ]
38
- client .delete_multi (keys )
38
+ CLIENT .delete_multi (keys )
39
39
40
40
41
41
class TestDatastoreAllocateIDs (TestDatastore ):
42
42
43
43
def test_allocate_ids (self ):
44
44
num_ids = 10
45
- allocated_keys = client .allocate_ids (client .key ('Kind' ), num_ids )
45
+ allocated_keys = CLIENT .allocate_ids (CLIENT .key ('Kind' ), num_ids )
46
46
self .assertEqual (len (allocated_keys ), num_ids )
47
47
48
48
unique_ids = set ()
@@ -56,7 +56,7 @@ def test_allocate_ids(self):
56
56
57
57
class TestDatastoreSave (TestDatastore ):
58
58
59
- PARENT = client .key ('Blog' , 'PizzaMan' )
59
+ PARENT = CLIENT .key ('Blog' , 'PizzaMan' )
60
60
61
61
def _get_post (self , id_or_name = None , post_content = None ):
62
62
post_content = post_content or {
@@ -71,7 +71,7 @@ def _get_post(self, id_or_name=None, post_content=None):
71
71
# Create an entity with the given content.
72
72
# NOTE: Using a parent to ensure consistency for query
73
73
# in `test_empty_kind`.
74
- key = client .key ('Post' , parent = self .PARENT )
74
+ key = CLIENT .key ('Post' , parent = self .PARENT )
75
75
entity = datastore .Entity (key = key )
76
76
entity .update (post_content )
77
77
@@ -83,7 +83,7 @@ def _get_post(self, id_or_name=None, post_content=None):
83
83
84
84
def _generic_test_post (self , name = None , key_id = None ):
85
85
entity = self ._get_post (id_or_name = (name or key_id ))
86
- client .put (entity )
86
+ CLIENT .put (entity )
87
87
88
88
# Register entity to be deleted.
89
89
self .case_entities_to_delete .append (entity )
@@ -92,7 +92,7 @@ def _generic_test_post(self, name=None, key_id=None):
92
92
self .assertEqual (entity .key .name , name )
93
93
if key_id is not None :
94
94
self .assertEqual (entity .key .id , key_id )
95
- retrieved_entity = client .get (entity .key )
95
+ retrieved_entity = CLIENT .get (entity .key )
96
96
# Check the given and retrieved are the the same.
97
97
self .assertEqual (retrieved_entity , entity )
98
98
@@ -106,7 +106,7 @@ def test_post_with_generated_id(self):
106
106
self ._generic_test_post ()
107
107
108
108
def test_save_multiple (self ):
109
- with client .transaction () as xact :
109
+ with CLIENT .transaction () as xact :
110
110
entity1 = self ._get_post ()
111
111
xact .put (entity1 )
112
112
# Register entity to be deleted.
@@ -127,11 +127,11 @@ def test_save_multiple(self):
127
127
self .case_entities_to_delete .append (entity2 )
128
128
129
129
keys = [entity1 .key , entity2 .key ]
130
- matches = client .get_multi (keys )
130
+ matches = CLIENT .get_multi (keys )
131
131
self .assertEqual (len (matches ), 2 )
132
132
133
133
def test_empty_kind (self ):
134
- query = client .query (kind = 'Post' )
134
+ query = CLIENT .query (kind = 'Post' )
135
135
query .ancestor = self .PARENT
136
136
posts = list (query .fetch (limit = 2 ))
137
137
self .assertEqual (posts , [])
@@ -140,16 +140,16 @@ def test_empty_kind(self):
140
140
class TestDatastoreSaveKeys (TestDatastore ):
141
141
142
142
def test_save_key_self_reference (self ):
143
- parent_key = client .key ('Residence' , 'NewYork' )
144
- key = client .key ('Person' , 'name' , parent = parent_key )
143
+ parent_key = CLIENT .key ('Residence' , 'NewYork' )
144
+ key = CLIENT .key ('Person' , 'name' , parent = parent_key )
145
145
entity = datastore .Entity (key = key )
146
146
entity ['fullName' ] = u'Full name'
147
147
entity ['linkedTo' ] = key # Self reference.
148
148
149
- client .put (entity )
149
+ CLIENT .put (entity )
150
150
self .case_entities_to_delete .append (entity )
151
151
152
- query = client .query (kind = 'Person' )
152
+ query = CLIENT .query (kind = 'Person' )
153
153
# Adding ancestor to ensure consistency.
154
154
query .ancestor = parent_key
155
155
query .add_filter ('linkedTo' , '=' , key )
@@ -164,10 +164,10 @@ class TestDatastoreQuery(TestDatastore):
164
164
def setUpClass (cls ):
165
165
super (TestDatastoreQuery , cls ).setUpClass ()
166
166
cls .CHARACTERS = populate_datastore .CHARACTERS
167
- cls .ANCESTOR_KEY = client .key (* populate_datastore .ANCESTOR )
167
+ cls .ANCESTOR_KEY = CLIENT .key (* populate_datastore .ANCESTOR )
168
168
169
169
def _base_query (self ):
170
- return client .query (kind = 'Character' , ancestor = self .ANCESTOR_KEY )
170
+ return CLIENT .query (kind = 'Character' , ancestor = self .ANCESTOR_KEY )
171
171
172
172
def test_limit_queries (self ):
173
173
limit = 5
@@ -212,7 +212,7 @@ def test_ancestor_query(self):
212
212
self .assertEqual (len (entities ), expected_matches )
213
213
214
214
def test_query___key___filter (self ):
215
- rickard_key = client .key (* populate_datastore .RICKARD )
215
+ rickard_key = CLIENT .key (* populate_datastore .RICKARD )
216
216
217
217
query = self ._base_query ()
218
218
query .add_filter ('__key__' , '=' , rickard_key )
@@ -327,16 +327,16 @@ def test_query_group_by(self):
327
327
class TestDatastoreTransaction (TestDatastore ):
328
328
329
329
def test_transaction (self ):
330
- entity = datastore .Entity (key = client .key ('Company' , 'Google' ))
330
+ entity = datastore .Entity (key = CLIENT .key ('Company' , 'Google' ))
331
331
entity ['url' ] = u'www.google.com'
332
332
333
- with client .transaction () as xact :
334
- result = client .get (entity .key )
333
+ with CLIENT .transaction () as xact :
334
+ result = CLIENT .get (entity .key )
335
335
if result is None :
336
336
xact .put (entity )
337
337
self .case_entities_to_delete .append (entity )
338
338
339
339
# This will always return after the transaction.
340
- retrieved_entity = client .get (entity .key )
340
+ retrieved_entity = CLIENT .get (entity .key )
341
341
self .case_entities_to_delete .append (retrieved_entity )
342
342
self .assertEqual (retrieved_entity , entity )
0 commit comments