summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorZuul <zuul@review.opendev.org>2022-07-23 01:31:47 +0000
committerGerrit Code Review <review@openstack.org>2022-07-23 01:31:47 +0000
commit3aaade3b3c288933725f22a307938a7077ea1d86 (patch)
tree0e454050256116ebd8b68ee137e212645645082b
parentf4712396cbca89adafc159fab0e4bbf3cfd063cd (diff)
parent12e42df744807a5806e73726dec5993993fb41d5 (diff)
downloaddesignate-3aaade3b3c288933725f22a307938a7077ea1d86.tar.gz
Merge "Fix sqlalchemy table_names DeprecationWarning"
-rw-r--r--designate/sqlalchemy/base.py5
-rw-r--r--designate/tests/test_storage/test_sqlalchemy.py3
2 files changed, 6 insertions, 2 deletions
diff --git a/designate/sqlalchemy/base.py b/designate/sqlalchemy/base.py
index 905e4b40..d72f36ca 100644
--- a/designate/sqlalchemy/base.py
+++ b/designate/sqlalchemy/base.py
@@ -21,7 +21,7 @@ from oslo_db import exception as oslo_db_exception
from oslo_db.sqlalchemy import utils as oslodb_utils
from oslo_log import log as logging
from oslo_utils import timeutils
-from sqlalchemy import select, or_, between, func, distinct
+from sqlalchemy import select, or_, between, func, distinct, inspect
from designate import exceptions
from designate import objects
@@ -96,6 +96,9 @@ class SQLAlchemy(object, metaclass=abc.ABCMeta):
def rollback(self):
self.session.rollback()
+ def get_inspector(self):
+ return inspect(self.engine)
+
@staticmethod
def _apply_criterion(table, query, criterion):
if criterion is not None:
diff --git a/designate/tests/test_storage/test_sqlalchemy.py b/designate/tests/test_storage/test_sqlalchemy.py
index c70dec91..9a4bf321 100644
--- a/designate/tests/test_storage/test_sqlalchemy.py
+++ b/designate/tests/test_storage/test_sqlalchemy.py
@@ -53,7 +53,8 @@ class SqlalchemyStorageTest(StorageTestCase, TestCase):
u'zone_transfer_requests',
u'zones'
]
- self.assertEqual(table_names, self.storage.engine.table_names())
+ inspector = self.storage.get_inspector()
+ self.assertEqual(table_names, inspector.get_table_names())
def test_schema_table_indexes(self):
indexes_t = self.storage.engine.execute("SELECT * FROM sqlite_master WHERE type = 'index';") # noqa