www.fontes.pro.br

Exemplo de Aplicação

Exemplo de Aplicação no NetBeans

import java.sql.*;

public class Javadiscos {

  public static void main(String[] args) throws Exception{
    String driver = "org.hsqldb.jdbcDriver";     // para MySQL com.mysql.jdbc.Driver
    String url = "jdbc:hsqldb:hsql://localhost/javadiscos";    // para MySQ jdbc:mysql://localhost/lojadiscos
    String user = "sa";    // para MySQ root
    String password = "";

    // Carrega o driver do BD
    Class.forName(driver);  

    // Faz a conexão com o BD
    Connection conn = DriverManager.getConnection(url, user, password);

    String sql = "SELECT * FROM artista";

    // Instancia a classe PreparedStatement capaz de executar o comando SQL
    PreparedStatement stmt = conn.prepareStatement(sql);

    // Executa o comando SQL e coloca o resultado em rs (objeto responsável por manipular os dados)
    ResultSet rs = stmt.executeQuery();

    // Percorre o ResultSet
     while (rs.next()){
         String id = rs.getString("id");
         String nome = rs.getString("nome");
         String banda = rs.getString("banda");
         String pais = rs.getString("pais");
         System.out.println("ID -> "+ id);
         System.out.println("Nome -> "+ nome);
         System.out.println("Banda -> "+ banda);
         System.out.println("Pais -> "+ pais);
    }

    // Libera recursos
    rs.close();
    stmt.close();
    conn.close();
  }
}

package p_banco_de_dados;

import java.sql.*;

/**
*
* @author Fontes
*/
public class Executa {

static String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost/bd_aluno";
String user = "root";
String password = "";
Connection conn;

public void carregar(String driver) throws ClassNotFoundException, SQLException {

// Carrega o driver do BD
Class.forName(driver);
// Faz a conexão com o BD
conn = DriverManager.getConnection(url, user, password);

}

public void inserir(String sql) throws SQLException {

PreparedStatement stmt = conn.prepareStatement(sql);
stmt.executeUpdate();
stmt.close();

}

public void alterar(String sql) throws SQLException {

PreparedStatement stmt = conn.prepareStatement(sql);
stmt.executeUpdate();
stmt.close();

}

public void consultar(String sql) throws SQLException {

// Instancia a classe PreparedStatement capaz de executar o comando SQL
PreparedStatement stmt = conn.prepareStatement(sql);
// Executa o comando SQL e coloca o resultado em rs (objeto responsável por manipular os dados)
ResultSet rs = stmt.executeQuery();
// Percorre o ResultSet
while (rs.next()) {

String matricula = rs.getString("matricula");
String nome = rs.getString("nome");
String media = rs.getString("media");

System.out.println("Matrícula -> " + matricula);
System.out.println("Nome -> " + nome);
System.out.println("Média -> " + media);
System.out.println("---------------");

}
// Libera recursos
rs.close();

}

 

public static void main(String[] args) throws Exception {

String sql;
Executa e = new Executa();

//------------ carrega driver
e.carregar(driver);

//------------ consultar

sql = "SELECT * FROM aluno";
e.consultar(sql);

//------------ inserir
// sql = " INSERT INTO `aluno` ( `matricula` , `nome` , `media` ) VALUES ('49', 'Maria', '5.4')";
// e.inserir(sql);

sql = "UPDATE `aluno` SET `media` = '8' WHERE `aluno`.`matricula` = 56";
e.alterar(sql);

}

}

package p_banco_de_dados;

/**
*
* @author Fontes
*/
import java.sql.*;

public class Conexao {

public Connection con;
public Statement stm;
public ResultSet res = null;
private String nome = null;
private int idade = 0;
private String sexo = null;

public Conexao() {

try {

Class.forName("com.mysql.jdbc.Driver");
con = DriverManager.getConnection("jdbc:mysql://localhost/bd_aluno", "root", "");
stm = con.createStatement();

} catch (Exception e) {

System.out.println("não foi possível conectar ao banco" + e.getMessage());

}

}

public void setNome(String nome) {
this.nome = nome;
}

public void setIdade(int idade) {
this.idade = idade;
}

public void setSexo(String sexo) {
this.sexo = sexo;
}

public String getNome() {
return nome;
}

public int getIdade() {
return idade;
}

public String getSexo() {
return sexo;
}

public void inserirDados() {

try {
String query = "insert into pessoa(nome,idade,sexo) values(\"" + nome + "\"," + idade + ",\"" + sexo + "\")";
stm.executeUpdate(query);

} catch (SQLException e) {
System.out.println("Erro na inserção:" + e.getMessage());
}

}

public boolean alterarDados() {

boolean testa = false;

try {
String query = "update pessoa " +
"set idade = " + idade + ", " +
"sexo = \"" + sexo + "\" " +
"where nome = \"" + nome + "\"";

int linhas = stm.executeUpdate(query);

if (linhas > 0) {
testa = true;
} else {
testa = false;
}
} catch (SQLException e) {
System.out.println("Erro na inserção:" + e.getMessage());
}

return testa;

}

public boolean excluirDados() {

boolean testa = false;

try {
String query = "delete from pessoa where nome='" + nome + "'";
int linhas = stm.executeUpdate(query);

if (linhas > 0) {
testa = true;
} else {
testa = false;
}
} catch (SQLException e) {
System.out.println("Erro na exclusão:" + e.getMessage());
}

return testa;

}

public boolean consultarDados() {

boolean testa = false;

try {
String query = "select * from pessoa where nome='" + nome + "'";
res = stm.executeQuery(query);

if (res.next()) {
testa = true;
} else {
testa = false;
}

} catch (SQLException e) {
System.out.println("Erro na inserção:" + e.getMessage());
}

return testa;
}

public void setConsulta() {

try {
res = stm.executeQuery("select * from pessoa");
} catch (SQLException e) {
e.printStackTrace();
}

}

public ResultSet getResultado() {
return res;
}

}

_______________________ MAIN_____________

package p_banco_de_dados;

/**
*
* @author Fontes
*/
public class ExecutaConexao {

public static void main(String[] args) {

Conexao c = new Conexao();

// -------------- inclusão
c.setNome("Ana Lúcia");
c.setIdade(25);
c.setSexo("F");
// c.inserirDados();

// -------------- alteração
c.setIdade(15);
// c.alterarDados();

// -------------- exclusão
c.setNome("Adão");
c.excluirDados();

}

}