diff --git a/ibm_db_sa/base.py b/ibm_db_sa/base.py
index 54b2401..bcdb09c 100644
--- a/ibm_db_sa/base.py
+++ b/ibm_db_sa/base.py
@@ -733,6 +733,8 @@ def initialize(self, connection):
             _reflector_cls = ibm_reflection.DB2Reflector
         elif "IDS/" in self.dbms_name:
             _reflector_cls = ibm_reflection.DB2Reflector
+        elif self.dbms_name.startswith("DSN"):
+            _reflector_cls = ibm_reflection.OS390Reflector            
         self._reflector = _reflector_cls(self)
 
     def get_columns(self, connection, table_name, schema=None, **kw):