@Override
  public Connection getNewConnection() {
    try {
      Properties properties = new Properties();
      properties.setProperty(USER, configuration.getDatabaseUser());
      properties.setProperty(PASSWORD, configuration.getDatabasePassword());
      if (configuration.getDatabaseUrl().contains("mysql")
          && DriverManager.getDriver(configuration.getDatabaseUrl()).getMajorVersion() > SUPPORT_CONNECTOR_VERSION) {
        properties.setProperty(NULL_CATALOG_MEANS_CURRENT, TRUE);// jdbc mysql connector 8.x turn on legacy behaviour
      }
      return DriverManager.getConnection(configuration.getDatabaseUrl(),properties);
    } catch (SQLException e) {
      throw new RuntimeException("Unable to connect to database", e);
    }
  }
Map SQL datatype to Java Class type

@param type  SQL datatype
@return Java class or null if no mapping found
ambari-server/src/main/java/org/apache/ambari/server/orm/DBAccessorImpl.java