FazBrowse GitHub Viewer | Trending |
URL:
| Home
Tools: [Download Repo ZIP]   [Original HTTPS Page]

Fix admin api create_ddl codepath · 7dracoder/python-spanner-orm@9f7fbd4 · GitHub

Commit 9f7fbd4

Browse files
committed
Fix admin api create_ddl codepath
The unit test didn't cover this codepath. Added a unit test, fixed the codepath, and added a shortcut to the SpannerAdminApi
1 parent 10fd35d commit 9f7fbd4

3 files changed

Lines changed: 9 additions & 1 deletion

File tree

‎spanner_orm/__init__.py‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,13 +20,15 @@
2020
from spanner_orm import field
2121
from spanner_orm import model
2222
from spanner_orm import relationship
23+
from spanner_orm.admin import api as admin_api
2324

2425
# add NullHandler to root-module logger so that individual modules
2526
# won't have to.
2627
logging.getLogger(__name__).addHandler(logging.NullHandler())
2728

2829
# pylint: disable=invalid-name
2930
SpannerApi = api.SpannerApi
31+
SpannerAdminApi = admin_api.SpannerAdminApi
3032

3133
Model = model.Model
3234

‎spanner_orm/admin/api.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ def connect(cls,
4646
if create_ddl is not None:
4747
cls._spanner_connection = instance.database(
4848
database, ddl_statements=create_ddl)
49-
operation = cls._connection.create()
49+
operation = cls._spanner_connection.create()
5050
operation.result()
5151
else:
5252
cls._spanner_connection = instance.database(database)

‎spanner_orm/tests/api_test.py‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,12 @@ def test_admin_api_connection(self, client):
5151
with self.assertRaises(error.SpannerError):
5252
api.SpannerApi._connection()
5353

54+
@mock.patch('google.cloud.spanner.Client')
55+
def test_admin_api_create_ddl_connection(self, client):
56+
connection = self.mock_connection(client)
57+
admin_api.SpannerAdminApi.connect('', '', '', create_ddl=['create ddl'])
58+
self.assertEqual(admin_api.SpannerAdminApi._connection(), connection)
59+
5460
def mock_connection(self, client):
5561
connection = mock.Mock()
5662
client().instance().database.return_value = connection

0 commit comments

Comments
 (0)

Back | FazBrowse Home | New Git URL