Validating a MSSQL database connection

package com.mysoft.izpack.validators;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

import com.izforge.izpack.api.data.InstallData;
import com.izforge.izpack.api.installer.DataValidator;

public class MssqlConnectionValidator implements DataValidator {

  private static final String STR_DEFAULT_ERROR_MESSAGE = "Cannot connect to the specified database.";

  protected InstallData installData;

  //Error and Warning Messages
  protected String str_errorMsg;
  protected String str_warningMsg = "";

  @Override
  public boolean getDefaultAnswer() {
    return true;
  }

  @Override
  public String getErrorMessageId() {
    if (str_errorMsg != null) {
      return str_errorMsg;
    } else {
      return STR_DEFAULT_ERROR_MESSAGE;
    }
  }

  @Override
  public String getWarningMessageId() {
    return str_warningMsg;
  }

  @Override
  public Status validateData(InstallData installData) {

    this.installData = installData;

    try {
      Class.forName(getDriver());
    } catch (ClassNotFoundException ex) {
      str_errorMsg = "Problem during loading db-driver.";
      return Status.ERROR;
    }

    //Test if Database is reachable
    try {
      Connection conn = null;
      conn = DriverManager.getConnection(getUrl(), getUser(), getPassword());
      Statement stmt = conn.createStatement();
      ResultSet rs = stmt.executeQuery(getQuery());
      rs.close();
      conn.close();
    } catch (Throwable ex) {
      str_errorMsg = "Could not connect to database: \n\n" + ex.getLocalizedMessage();
      return Status.ERROR;
    }

    return Status.OK;
  }

  public String getDriver()
  {
    return "net.sourceforge.jtds.jdbc.Driver";
  }

  public String getUrl()
  {
    StringBuffer url = new StringBuffer("jdbc:jtds:sqlserver://" + getHost());
    String port = getPort();
    String instance = getInstance();
    if (port != null && !port.isEmpty()) {
      url.append(":" + port);
    }
    if (instance != null && !instance.isEmpty()) {
      url.append(";instance=" + instance);
    }
    return url.toString();
  }

  public String getHost()
  {
    return installData.getVariable("mssql.host");
  }

  public String getPort()
  {
    return installData.getVariable("mssql.port");
  }

  public String getInstance()
  {
    return installData.getVariable("mssql.instance");
  }

  public String getQuery()
  {
    return "SELECT 1";
  }

  public String getUser()
  {
    return installData.getVariable("mssql.user");
  }

  public String getPassword()
  {
    return installData.getVariable("mssql.password");
  }
}