package Connection;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.swing.JOptionPane;
/**
*
-
@author felip
*/
public class Conexao {private static final String URL = "jdbc:mysql://localhost:3306/sistemapessoa?useTimezone=true&serverTimezone=UTC"; private static final String USUARIO = "root"; private static final String SENHA = ""; public static Connection getConexao(){ try { //Carregar o Driver Class.forName("com.mysql.jdbc.Driver"); //Efetuando a conexao return DriverManager.getConnection(URL, USUARIO, SENHA); } catch (ClassNotFoundException | SQLException ex) { throw new RuntimeException("Problema no momento de carregar o driver do banco", ex); }
}
public static void closeConnection(Connection con){
if(con != null) { try { con.close(); } catch (SQLException ex) { JOptionPane.showMessageDialog(null, "Conectado com sucesso: "+ex); //showMessageDialog(null, "Conectado com sucesso: "+ex); // System.err.println("Erro: ao se conectar: ", ex); } }
}
public static void closeConnection(Connection con, PreparedStatement stm){
if(stm != null) { try { stm.close(); } catch (SQLException ex) { JOptionPane.showMessageDialog(null, "Erro: ao se conectar: "+ex); // System.err.println("Erro: ao se conectar",ex); } } closeConnection(con);
}
public static void closeConnection(Connection con, PreparedStatement stm, ResultSet rs){
if(rs != null) { try { rs.close(); } catch (SQLException ex) { JOptionPane.showMessageDialog(null, "Erro: ao se conectar: "+ex); //System.err.println("Erro: ao se conectar"+ex); } } closeConnection(con,stm);
}
}
package Dao;
import Connection.Conexao;
import Dto.Pessoadto;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import javax.swing.JOptionPane;
/**
*
-
@author felip
*/
public class Pessoadao {private Connection con = null;
public void create(Pessoadto d) {
Connection con = Conexao.getConexao();
PreparedStatement stmt = null;try { stmt = con.prepareStatement("INSERT INTO pessoa (cpf,nome,sexo) VALUES (?,?,?"); stmt.setString(1,d.getNome()); stmt.setString(2,d.getCpf()); stmt.setString(3,d.getSexo()); stmt.executeUpdate(); JOptionPane.showMessageDialog(null, "Cadastrado com sucesso!"); } catch (SQLException ex) { JOptionPane.showMessageDialog(null, "Erro ao cadastrar:! "+ex); }finally{ Conexao.closeConnection(con, stmt);
}
}
public List<Pessoadto> read() {
Connection con = Conexao.getConexao();
PreparedStatement stmt = null;
ResultSet rs = null;
List<Pessoadto> pessoas = new ArrayList<>();
try {
stmt = con.prepareStatement("SELECT * FROM pessoa");
rs = stmt.executeQuery();
while (rs.next()) {
Pessoadto pessoa = new Pessoadto();
pessoa.setNome(rs.getString("nome"));
pessoa.setCpf(rs.getString("cpf"));
pessoa.setSexo(rs.getString("sexo"));
pessoas.add(pessoa);
}
} catch (SQLException ex) {
JOptionPane.showMessageDialog(null, "Error ao adicionar os dados do clientes! "+ex);
}finally{
Conexao.closeConnection(con, stmt, rs);
}
return pessoas;
}
}
package Dto;
/**
*
-
@author felip
*/
public class Pessoadto {private String nome;
private String cpf;
private String sexo;/**
-
@return the nome
*/
public String getNome() {
return nome;
}
/**
-
@param nome the nome to set
*/
public void setNome(String nome) {
this.nome = nome;
}
/**
-
@return the cpf
*/
public String getCpf() {
return cpf;
}
/**
-
@param cpf the cpf to set
*/
public void setCpf(String cpf) {
this.cpf = cpf;
}
/**
-
@return the sexo
*/
public String getSexo() {
return sexo;
}
/**
-
@param sexo the sexo to set
*/
public void setSexo(String sexo) {
this.sexo = sexo;
}
-
@return the nome
}
Tabela mysql
CREATE TABLE pessoa
(
cpf
varchar(11) NOT NULL,
nome
varchar(100) DEFAULT NULL,
sexo
varchar(10) DEFAULT NULL,
PRIMARY KEY (cpf
)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4