Opa Bom dia Amigo, desculpa da demora.
Segue o código abaixo.
public class GanhosDAO {
private final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
public void Adicionar (Ganhos ganhos){
Connection con = BdConexaoDAO.getConnection();
PreparedStatement pstmt = null;
try {
String sql = "INSERT INTO TB_GANHO "
+ "(CATEGORIA, "
+ "KMS_PERCORRIDOS, "
+ "HORAS_TRABALHADAS, "
+ "VIAGENS_REALIZADAS, "
+ "VALOR_GANHO, "
+ "DATA, "
+ "OBSERVACAO)" +
" VALUES (?,?,?,?,?,?,?)";
pstmt = con.prepareStatement(sql);
pstmt.setString(1, ganhos.getCategoria_ganhos());
pstmt.setString(2, ganhos.getKmsPercorridos_ganhos());
pstmt.setString(3, ganhos.getHorasTrabalhadas_ganhos());
pstmt.setString(4, ganhos.getViagensRealizadas_ganhos());
pstmt.setString(5, ganhos.getValor_ganhos());
pstmt.setString(6, sdf.format(ganhos.getData_ganhos()));
pstmt.setString(7, ganhos.getObservacao_ganhos());
pstmt.execute();
JOptionPane.showMessageDialog(null,"Registro salvo com sucesso!" ,
"Informação", JOptionPane.INFORMATION_MESSAGE );
} catch (Exception ErroSql) {
JOptionPane.showMessageDialog(null,"Erro ao adicionar registro: "+ErroSql ,
"Erro", JOptionPane.ERROR_MESSAGE );
}
finally
{
BdConexaoDAO.closeConnection(con, pstmt);
}
}
public void Alterar (Ganhos ganhos){
Connection con = BdConexaoDAO.getConnection();
PreparedStatement pstmt = null;
try {
String sql = "UPDATE TB_GANHO SET "
+ "CATEGORIA=?,"
+ "KMS_PERCORRIDOS=?,"
+ "HORAS_TRABALHADAS=?,"
+ "VIAGENS_REALIZADAS=?,"
+ "VALOR_GANHO=?,"
+ "DATA=?,"
+ "OBSERVACAO=? "
+ "WHERE ID_GANHO=? ";
pstmt = con.prepareStatement(sql);
pstmt.setString(1, ganhos.getCategoria_ganhos());
pstmt.setString(2, ganhos.getKmsPercorridos_ganhos());
pstmt.setString(3, ganhos.getHorasTrabalhadas_ganhos());
pstmt.setString(4, ganhos.getViagensRealizadas_ganhos());
pstmt.setString(5, ganhos.getValor_ganhos());
pstmt.setString(6, sdf.format(ganhos.getData_ganhos()));
pstmt.setString(7, ganhos.getObservacao_ganhos());
pstmt.setInt(8, ganhos.getCodigo_ganhos());
pstmt.executeUpdate();
JOptionPane.showMessageDialog(null,"Registro alterado com sucesso!" ,
"Alteração", JOptionPane.INFORMATION_MESSAGE );
} catch (Exception ErroSql) {
JOptionPane.showMessageDialog(null,"Erro ao alterar registro: "+ErroSql ,
"Erro", JOptionPane.ERROR_MESSAGE );
}
finally
{
BdConexaoDAO.closeConnection(con,pstmt);
}
}
public void Remover (Ganhos ganhos){
Connection con = BdConexaoDAO.getConnection();
PreparedStatement pstmt = null;
try {
String sql = "DELETE FROM TB_GANHO WHERE ID_GANHO=?";
pstmt = con.prepareStatement(sql);
pstmt.setInt(1, ganhos.getCodigo_ganhos());
pstmt.executeUpdate();
JOptionPane.showMessageDialog(null,"Registro removido com sucesso!" ,
"Alteração", JOptionPane.INFORMATION_MESSAGE );
} catch (Exception ErroSql) {
JOptionPane.showMessageDialog(null,"Erro ao remover registro: "+ErroSql ,
"Erro", JOptionPane.ERROR_MESSAGE );
}
finally
{
BdConexaoDAO.closeConnection(con, pstmt);
}
}
public List<Ganhos> Listar(){
List<Ganhos> listaGanhos = new ArrayList<>();
Connection con = BdConexaoDAO.getConnection();
PreparedStatement pstmt = null;
ResultSet rs = null;
try{
pstmt = con.prepareStatement("SELECT * FROM TB_GANHO");
rs = pstmt.executeQuery();
while(rs.next()){
Ganhos ganhos = new Ganhos();
ganhos.setCodigo_ganhos(rs.getInt("ID_GANHO"));
ganhos.setCategoria_ganhos(rs.getString("CATEGORIA"));
ganhos.setKmsPercorridos_ganhos(rs.getString("KMS_PERCORRIDOS"));
ganhos.setHorasTrabalhadas_ganhos(rs.getString("HORAS_TRABALHADAS"));
ganhos.setViagensRealizadas_ganhos(rs.getString("VIAGENS_REALIZADAS"));
ganhos.setValor_ganhos(rs.getString("VALOR_GANHO"));
ganhos.setData_ganhos(rs.getDate("DATA"));
ganhos.setObservacao_ganhos(rs.getString("OBSERVACAO"));
listaGanhos.add(ganhos);
}
}
catch (SQLException ErroSql)
{
JOptionPane.showMessageDialog(null, "Erro ao carregar a dados na tabela:" +ErroSql, "Erro", JOptionPane.ERROR_MESSAGE);
}
finally
{
BdConexaoDAO.closeConnection(con, pstmt, rs);
}
return listaGanhos;
}
public List<Ganhos> PesqListarData(String dataInicial, String dataFinal){
List<Ganhos> listaGanhos = new ArrayList<>();
Connection con = BdConexaoDAO.getConnection();
PreparedStatement pstmt = null;
ResultSet rs = null;
try{
String sql = "SELECT * FROM TB_GANHO WHERE DATA BETWEEN ? AND ?";
pstmt = con.prepareStatement(sql);
pstmt.setString(1,dataInicial);
pstmt.setString(2,dataFinal);
rs = pstmt.executeQuery();
while(rs.next()){
Ganhos ganhos = new Ganhos();
ganhos.setCodigo_ganhos(rs.getInt("ID_GANHO"));
ganhos.setCategoria_ganhos(rs.getString("CATEGORIA"));
ganhos.setKmsPercorridos_ganhos(rs.getString("KMS_PERCORRIDOS"));
ganhos.setHorasTrabalhadas_ganhos(rs.getString("HORAS_TRABALHADAS"));
ganhos.setViagensRealizadas_ganhos(rs.getString("VIAGENS_REALIZADAS"));
ganhos.setValor_ganhos(rs.getString("VALOR_GANHO"));
ganhos.setData_ganhos(rs.getDate("DATA"));
ganhos.setObservacao_ganhos(rs.getString("OBSERVACAO"));
listaGanhos.add(ganhos);
}
}
catch (SQLException ErroSql)
{
JOptionPane.showMessageDialog(null, "Erro ao carregar a dados na tabela:" +ErroSql, "Erro", JOptionPane.ERROR_MESSAGE);
}
finally
{
BdConexaoDAO.closeConnection(con, pstmt, rs);
}
return listaGanhos;
}
}