ConnectionFactory.java

package exemplo05mysql.db;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

/**
 * <p>
 * O arquivo resources/lab01-mysql-dml-ddl.sql contém as instruções DML e DDL
 * para criação
 * do banco de dados necessário para esse exemplo. Crie um esquema em uma
 * instalação
 * MySQL / MariaDB e importe o conteúdo desse arquivo.
 * <p>
 * Faça os ajustes de configuração de conexão nas variáveis dentro do Construtor
 * dessa classe.
 * <p>
 * Verifique se sua instalação MySQL permite receber conexões por meio de
 * sockets TCP
 */
public abstract class ConnectionFactory {

    private static final String DB_PROPERTIES_FILE = "database.properties";

    private static Connection cnx;

    /**
     * Para carregar o arquivo properties que está no diretório resources,
     * funciona dentro da IDEA, nos teste de unidade e dentro de arquivo JAR
     * 
     * @return
     * @throws IOException
     */
    private static InputStream getInputStream() throws IOException {
        InputStream is = ConnectionFactory.class.getClassLoader().getResourceAsStream(DB_PROPERTIES_FILE);

        if (is == null) {
            throw new IOException("arquivo não encontrado " + DB_PROPERTIES_FILE);
        } else {
            return is;
        }
    }

    /**
     * Faz a conexão em um banco de dados MySQL e retorna o objeto Connection
     *
     * @return conexão com um banco MySQL
     * @throws IOException
     * @throws SQLException
     */
    public static synchronized Connection getDBConnection() throws IOException, SQLException {
        Properties properties = new Properties();
        try {
            // carregando as propriedades user, password e useSSL do arquivo
            // database.properties
            properties.load(getInputStream());

            // obtendo valores para host, port e dbname do arquivo properties
            String host = properties.getProperty("host");
            String port = properties.getProperty("port");
            String dbname = properties.getProperty("database");

            String url = "jdbc:mysql://" + host + ":" + port + "/" + dbname;

            cnx = DriverManager.getConnection(url, properties);

        } catch (SQLException ex) {
            throw new SQLException("erro com instrução SQL", ex);
        } catch (IOException ex) {
            throw new IOException("arquivo properties não encontrado", ex);
        }
        return cnx;
    }

}