| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -20,13 +20,15 @@ | |||
| 20 | 20 | from spanner_orm import field | |
| 21 | 21 | from spanner_orm import model | |
| 22 | 22 | from spanner_orm import relationship | |
| 23 | + from spanner_orm.admin import api as admin_api | ||
| 23 | 24 | ||
| 24 | 25 | # add NullHandler to root-module logger so that individual modules | |
| 25 | 26 | # won't have to. | |
| 26 | 27 | logging.getLogger(__name__).addHandler(logging.NullHandler()) | |
| 27 | 28 | ||
| 28 | 29 | # pylint: disable=invalid-name | |
| 29 | 30 | SpannerApi = api.SpannerApi | |
| 31 | + SpannerAdminApi = admin_api.SpannerAdminApi | ||
| 30 | 32 | ||
| 31 | 33 | Model = model.Model | |
| 32 | 34 | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -46,7 +46,7 @@ def connect(cls, | |||
| 46 | 46 | if create_ddl is not None: | |
| 47 | 47 | cls._spanner_connection = instance.database( | |
| 48 | 48 | database, ddl_statements=create_ddl) | |
| 49 | - operation = cls._connection.create() | ||
| 49 | + operation = cls._spanner_connection.create() | ||
| 50 | 50 | operation.result() | |
| 51 | 51 | else: | |
| 52 | 52 | cls._spanner_connection = instance.database(database) | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -51,6 +51,12 @@ def test_admin_api_connection(self, client): | |||
| 51 | 51 | with self.assertRaises(error.SpannerError): | |
| 52 | 52 | api.SpannerApi._connection() | |
| 53 | 53 | ||
| 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 | + | ||
| 54 | 60 | def mock_connection(self, client): | |
| 55 | 61 | connection = mock.Mock() | |
| 56 | 62 | client().instance().database.return_value = connection | |
| Back | FazBrowse Home | New Git URL |
0 commit comments