Discussoes de Programacao e Tecnologia

Java Banco de dados

4 respostas
TiagoXavier
TiagoXavier

Ola pessoal tenho a classe conexao logo a baixo, agora to precisando de fazer o seguinte esquema,
tenho um sistema que trabalha com apenas 1 banco de dados (POSTGRES) queria fazer o mesmo trabalhar
com varios bancos. tipo assim

O cara entra no sistema

loguin :
Senha:
Empresa: <— aki ele determina o banco q ele vai esta utilzando

Lembando e um sitema grande e ja esta pronto… queria saber a forma mais facil de eu fazer isso;
e que vai dar mesnos trabalho?

/*
 * Conexao.java
 *
 * Created on 1 de Janeiro de 2008, 22:43
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package refeicaoDAO;


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;



/**
 *
 * @author BETO
 */
public class Conexao {
    static Connection conn = null;
    /** Creates a new instance of Conexao */
    public Conexao() {
    }
    
    
public static Connection ConectDB() throws SQLException{
	try{
		String dsn="Ref01";
		String user="postgres";
		String senha="postdba";
              
                      
		Class.forName("org.postgresql.Driver").getInterfaces();
                String url="jdbc:postgresql://localhost:5432/"+dsn;

                conn = DriverManager.getConnection(url,user,senha);
		return conn;
        }catch (Exception e){
		System.out.println("Problema na abertura de dados"+e.getMessage());
                return null;
	}
}//jdbc:postgresql://<@localhost:5432:ModuloComercial>
public static void CloseDB() throws SQLException{
	
		conn.close();
	}


 public static Connection getConexao() throws ExcRepositorio {
		String dsn="Ref01";
		String user="postgres";
		String password="postdba";  
                String driver="org.postgresql.Driver";
                String url="jdbc:postgresql://localhost:5432/"+dsn;
		try {
			Class.forName(driver);
			conn = DriverManager.getConnection(url, user, password);
		} catch (ClassNotFoundException e) {
			throw new ExcRepositorio("Driver n�o Encontrado: " + e.getMessage());
		} catch (SQLException e) {
			throw new ExcRepositorio("Erro ao Abrir a Conexão: " + e.getMessage());
		}
		return conn;
	}
	
}
Alura Desenvolvimento Front-End React Do primeiro componente à liderança técnica! HTML/CSS/JavaScript fundamental, React com hooks e...

4 Respostas

TiagoXavier
TiagoXavier
aeugenio
aeugenio

Com o que vc forneceu so da pra concluir que vc tem que alterar os metodos ConectDB() e getConexao() usando o que foi digitado no login.
Agora como vc vai usar essa informação nesses metodos depende muito do resto da estrutura do sistema.
Caso vc tenha essas informaçoes numa servlet de sessao basta regastar esses dados e usa-lo.
Acho muito mais facil fazer isso do que mudar esses metodos passando parametros de login - o que acarretaria mudar todas as chamadas dessa classes.

/peace

L
Luiz_Carlos_Gon_lves

Com as devidas alterações esta classe pode te ajudar. Basta usar o método altera propriedades com os parâmetros adequados.

/** 
 * @Autor:  Luiz Carlos
 * @Proposta: Define uma classe geral para conexao com banco de dados usando
 *            JDBC
 * @Versao: 1.0
 * @NotadeVersao: A classe foi testada no acesso de bancos de dados MySQL(5.0), 
 *                SQLServer(2000), Firebird(2.01) e Conexao ODBC(32bits)
 */
package testeconexao;

import java.sql.*;
import javax.swing.JOptionPane;
import java.util.*;
import java.io.*;

/** ****************************************************************************
 * 
 * Define um padrao para objetos de conexao com bancos de dados SQL
 * Versao: 1.0
 * Data: 07/10/2008
 * 
 * @pdOid 1 */
public class Conexao {

    /** @pdOid 2 */
    private static String usuario;
    /** @pdOid 3 */
    private static String senha;
    /** @pdOid 4 */
    private static String servidor;
    /** @pdOid 5 */
    private static String banco;
    /** @pdOid 6 */
    private static String porta;
    /** @pdOid 7 */
    private static String tipoServidor;
    private static Connection con = null;
    private static Statement stm;
    private static Properties propConexao = null;
    private static FileInputStream inputFileProp;
    private static FileOutputStream outputFileProp;
    private static String fileName = "c:/onde vc colocou o arquivo/jdbc.properties";

    /** @pdOid 8 */
    public static String getUsuario() {
        return usuario;
    }

    /**
     * Atualiza usuario
     * @param newUsuario
     */
    public static void setUsuario(String newUsuario) {
        usuario = newUsuario;
    }

    /**
     * Retorna a senha usada para acessar o banco
     * 
     */
    public static String getSenha() {
        return senha;
    }

    /**
     * Altera a senha do usuario
     * @param newSenha
     */
    public static void setSenha(String newSenha) {
        senha = newSenha;
    }

    /**
     * Retorna o servidor atual
     * 
     */
    public static String getServidor() {
        return servidor;
    }

    /**
     * Altera o servidor do banco de dados
     * @param newServidor
     */
    public static void setServidor(String newServidor) {
        servidor = newServidor;
    }

    /**
     * Retorna o banco de dados utilizado
     * @return banco
     */
    public static String getBanco() {
        return banco;
    }

    /**
     * Altera o banco de dados utilizado
     * @param newBanco
     */
    public static void setBanco(String newBanco) {
        banco = newBanco;
    }

    /**
     * Retorna a porta de acesso
     * @return porta
     */
    public static String getPorta() {
        return porta;
    }

    /**
     * Altera a porta de acesso ao servidor do banco de dados
     * @param newPorta
     */
    public static void setPorta(String newPorta) {
        porta = newPorta;
    }

    /**
     * Retorna o tipo de servidor utilizado
     * @return tipoServidor
     */
    public static String getTipoServidor() {
        return tipoServidor;
    }

    /**
     * Altera o tipo de servidor utilizado
     * @param newTypeServer
     */
    public static void setTipoServidor(String newTypeServer) {
        tipoServidor = newTypeServer;
    }
    
    /**
     * Retorna a conexão corrente;
     * @return con
     */
    public static Connection getConexao(){
        return con;
    }

    /**
     * Inicia a conexao com o banco de dados a partir das propriedades
     * contidas no arquivo jdbc.properties 
     * @throws java.lang.Exception
     */
    public static void abrir() throws Exception {

        try {

            //abre o arquivo de propriedades  
            inputFileProp = new FileInputStream(fileName);

            propConexao = new Properties();

            //carrega as propriedades
            propConexao.load(inputFileProp);

            Conexao.setUsuario(propConexao.getProperty("USER_NAME").toString());
            Conexao.setSenha(propConexao.getProperty("PASSWORD").toString());
            Conexao.setServidor(propConexao.getProperty("SERVER").toString());
            Conexao.setBanco(propConexao.getProperty("DATABASE").toString());
            Conexao.setPorta(propConexao.getProperty("PORT").toString());
            Conexao.setTipoServidor(
                    propConexao.getProperty("TYPE_SERVER").toString());

            //fechar o arquivo de propriedades
            inputFileProp.close();

        } catch (FileNotFoundException e) {
            //System.out.println("O arquivo não pode ser localizado!");
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

        String driver = "", url = "";
        //======================================================================
        //INICIO DA SELECAO DO DRIVER DO BANCO DE DADOS
        //======================================================================
        // prepara a conexao para um banco FIREBIRD
        /*
         * A url montada neste caso e muito especifica para o "Firebird"
         * note que ao final dela acrescentamos a string "?sql_dialect=3"
         * que informa o dialeto que sera usado na conexao.
         */ 
        if (Conexao.getTipoServidor().equals("firebird")) {

            driver = "org.firebirdsql.jdbc.FBDriver";
            url = "jdbc:firebirdsql:" + Conexao.getServidor() + ":" +
                    Conexao.getBanco() + "?sql_dialect=3";

        // prepara a conexao para um  banco MICROSOFT SQLSERVER
        } else if (Conexao.getTipoServidor().equals("sqlserver")) {

            driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
            url = "jdbc:microsoft:sqlserver://" + Conexao.getServidor() + ":" +
                    Conexao.getPorta() + ";DatabaseName=" + Conexao.getBanco();

        // prepara a conexao para um banco MYSQL
        } else if (Conexao.getTipoServidor().equals("mysql")) {

            driver = "com.mysql.jdbc.Driver";
            url = "jdbc:mysql://" + Conexao.getServidor() + ":" +
                    Conexao.getPorta() + "/" + Conexao.getBanco();

        // prepara para uma conexao via ODBC    
        } else if (Conexao.getTipoServidor().equals("odbc")) {

            driver = "sun.jdbc.odbc.JdbcOdbcDriver";
            url = "jdbc:odbc:" + Conexao.getBanco();

        }
        //======================================================================
        //FIM DA SELECAO DO DRIVER DO BANCO DE DADOS
        //======================================================================        

        try {

            // instanciando o driver selecionado
            Class.forName(driver);

            try {

                //cria a conexao usando a url montada e demais informacoes

                con = java.sql.DriverManager.getConnection(url,
                        Conexao.getUsuario(), Conexao.getSenha());


            } //senao...
            catch (SQLException ex) { // automatico junto com try 
                // se der erro, nao houver conexao, imprime mensagem de erro
                JOptionPane.showMessageDialog(null, ex.getMessage());
            } // fim catch

        } //fim do try
        catch (ClassNotFoundException ex) {

            // imprime mensagem se tiver erro na escrita do forname

            ex.printStackTrace();

        } // fim catch

    } //fim de abrir()

    /**
     * 
     * Fecha a conexao com o banco de dados e permite a alteracao das
     * propriedades de conexao
     * 
     * @throws java.lang.Exception
     */
    public static void fechar() throws Exception {
        if (stm != null) {
            stm.close();
        }
        if (con != null) {
            con.close();
        }
    }

    /**
     * Permite enviar para o banco instrucoes de atualizacao (update,delete e 
     * insert)
     * @param sql
     * @throws java.lang.Exception
     */
    public static void atualizar(String sql) throws Exception {
        if ((con == null) || (stm == null)) {
            abrir();
        }
        stm = con.createStatement();
        stm.execute(sql);
    }

    /**
     * Permite processar e recuperar consultas SQL
     * @param sql
     * @return
     * @throws java.lang.Exception
     */
    public static ResultSet selecionar(String sql) throws Exception {
        if (stm == null) {
            abrir();
        }
        stm = con.createStatement();
        return stm.executeQuery(sql);
    }

    /**
     * Permite alterar as propriedades de conexao e grava-las no arquivo
     * jdbc.properties
     * @param newUser
     * @param newPass
     * @param newServer
     * @param newDB
     * @param newPort
     * @param newTS
     * @throws java.lang.Exception
     */
    public static void alterarPropriedades(
            String newUser, String newPass,
            String newServer, String newDB,
            String newPort, String newTS) throws Exception {

        //se a conexao estiver ativa, deve ser fechada antes
        if ((con != null) || (stm != null)) {
            fechar();
        }
        try {

            //se propConexao for null, quer dizer que o metodo abrir ainda
            //nao foi chamado
            if (propConexao == null) {

                propConexao = new Properties();

                //abre  o arquivo de propriedades
                inputFileProp = new FileInputStream(fileName);

                //carrega o objeto de propriedades
                propConexao.load(inputFileProp);

                //fecho o arquivo para e passo a editar as propriedades
                inputFileProp.close();
            }

            //proceder o ajuste de cada propriedade se o parametro contiver
            //algum valor

            if (newUser != null) {
                if (!newUser.isEmpty()) {
                    propConexao.setProperty("USER_NAME", newUser);
                }
            }
            if (newPass != null) {
                if (!newPass.isEmpty()) {
                    propConexao.setProperty("PASSWORD", newPass);
                }
            }
            if (newServer != null) {
                if (!newServer.isEmpty()) {
                    propConexao.setProperty("SERVER", newServer);
                }
            }
            if (newDB != null) {
                if (!newDB.isEmpty()) {
                    propConexao.setProperty("DATABASE", newDB);
                }
            }
            if (newPort != null) {
                if (!newPort.isEmpty()) {
                    propConexao.setProperty("PORT", newPort);
                }
            }
            if (newTS != null) {
                if (!newTS.isEmpty()) {
                    propConexao.setProperty("TYPE_SERVER", newTS);            //abre o arquivo para gravacao das informacoes
                }
            }
            outputFileProp = new FileOutputStream(fileName);
            propConexao.store(outputFileProp, "Propriedades ajustadas via soft");
            outputFileProp.close();

        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}//fim da classe Conexao
TiagoXavier
TiagoXavier

aeugenio … perfeito acho
q uma sessao+serlet daria certo
O q não entendedo, e como eu chamaria servlet e rotornaria o valor para uma classe java.

Falando de serlets tenho poca noção como funciona…

Criado 4 de novembro de 2008
Ultima resposta 4 de nov. de 2008
Respostas 4
Participantes 3

Topicos relacionados

Compilar e executar uma classe java pelo prompt do windows 13 respostas [RESOLVIDO] Como executar função JavaScript após página carregada 13 respostas Java.lang.OutOfMemoryError: Java heap space - Como resolver? 11 respostas Como consultar CPF na Receita Federal usando Web Service? 22 respostas Como acessar localhost de forma externa? [RESOLVIDO] 13 respostas
Alura Git Flow: entenda o que é, como e quando utilizar Entenda o que é Git Flow, como funciona seu fluxo com branches como Master, Develop, Feature, Release e Hotfix, além de vantagens e desvantagens.
Casa do Codigo Desmistificando WebAssembly: Alta performance,... Por Raphael Amorim — Casa do Codigo