in wrapper/src/main/java/software/amazon/jdbc/dialect/MysqlDialect.java [69:103]
public boolean isDialect(final Connection connection) {
Statement stmt = null;
ResultSet rs = null;
try {
stmt = connection.createStatement();
rs = stmt.executeQuery(this.getServerVersionQuery());
while (rs.next()) {
final int columnCount = rs.getMetaData().getColumnCount();
for (int i = 1; i <= columnCount; i++) {
final String columnValue = rs.getString(i);
if (columnValue != null && columnValue.toLowerCase().contains("mysql")) {
return true;
}
}
}
} catch (final SQLException ex) {
// ignore
} finally {
if (stmt != null) {
try {
stmt.close();
} catch (SQLException ex) {
// ignore
}
}
if (rs != null) {
try {
rs.close();
} catch (SQLException ex) {
// ignore
}
}
}
return false;
}