[SOLUCIONADO] Duda con transacciones.

[CHAEEZ]

buenas noches chiquillos! tengo una duda con unos metodos que cree para las transacciones (commit() y rollback())
Por ejemplo, este metodo lo utilizo para la conectarme a BD.

Código Java:

public static void conectar() {
           
        try {
            Class.forName(driver);
            conexion = DriverManager.getConnection(server, user, password);
            conexion.setAutoCommit(false);
            System.out.println("Éxito: Se hizo la conexión a BD.");
        } catch (Exception e) {
            JOptionPane.showMessageDialog(null, "Error: Imposible realizar la conexion a BD.");
            e.printStackTrace();
        }
        
    }
 

Luego, el siguiente metodo lo utilizo para realizar insert, update o delete en su defecto.

Código Java:

public boolean consultaActualiza(String sql) {
        try {
            Statement sentencia = conexion.createStatement();
            sentencia.executeUpdate(sql);
            
        } catch (SQLException e) {
           
            e.printStackTrace();
            return false;
        }
        return true;
        }
 

Y estos dos ultimos metodos solo los que utilizo para el commit y rollback:

Código Java:

public static void Commit() {
        try {
            conexion.commit();
            JOptionPane.showMessageDialog(null, "Transacción exitosa.");
        } catch (SQLException ex) {
            Logger.getLogger(bdConexion.class.getName()).log(Level.SEVERE, null, ex);
        }
        
    }
    
    public static void Rollback() {
        try {
            conexion.rollback();
        } catch (SQLException ex) {
            Logger.getLogger(bdConexion.class.getName()).log(Level.SEVERE, null, ex);
        }
        JOptionPane.showMessageDialog(null, "No se completó la transacción.");
    }
 

No los he probado, pero quiero sacarme las dudas y si tienen alguna sugerencia bacan seria.

Para utilizarlas seria algo como :

Código Java:

MySQLBD baseDatos = new MySQLBD();
         
        if (baseDatos.consultaActualiza("INSERT INTO TEST(IDENTIFICADOR,DESCRIPCION) VALUES(3,'TRES')")) {
          baseDatos.Commit();
            System.out.println("Ejecución correcta!");
        } else {
           baseDatos.Rollback();
            System.out.println("Ocurrió un problema al ejecutar!");
        }        ResultSet resultados = baseDatos.consultar("SELECT * FROM TEST");        if (resultados != null) {
            try {
                System.out.println("IDENTIFICADOR       DESCRIPCION");
                System.out.println("--------------------------------");
                while (resultados.next()) {
                    System.out.println(""+resultados.getBigDecimal("IDENTIFICADOR")+"       "+resultados.getString("DESCRIPCION"));
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
 

Ayudenme porfavor a salir de mi duda!! :D

[jelastic]

Pero haz probado si funciona, si inserta o actualiza el registro en la bd, esta bien de la forma que trabajas, si no guarda o actualiza, el problema no nos dice nada.

[CHAEEZ]

mas que nada es una duda, el lunes probare insitu los metodos. estoy haciendo un aporte por si alguien le sirve..
la verdad es que tenia mis dudas si tomaba bien los commit y los rollback. espero funcione. si tu dices que la forma en que se esta haciendo esta bien, igual es un alivio :D

[jelastic]

Bueno, yo ya no trabajo de esa forma, ahora con los frameworks de persistencia me facilito un poco la vida.
Pero es casi igual a como lo trabajaba, yo solo creaba una conexion que es asi:

Código Java:

public class ConexionBD {
    
    private final String servidor = "localhost";
    private final String bd = "bd";
    private final String usuario = "root";
    private final String password = "jelastic";
 
    public Connection getConexion() {
        Connection cn = null;
        try {
            //MySQL
            Class.forName("com.mysql.jdbc.Driver");
            cn = DriverManager.getConnection("jdbc:mysql://"+servidor+"/"+bd+"", ""+usuario+"", ""+password+"");
 
        } catch (ClassNotFoundException e) {
            cn = null;
        } catch (SQLException e) {
            cn = null;
        }
        return cn;
    }
 
}
 

Y para insertar, actualizar, eliminar, buscar y mostrar una lista de objetos asi:

Código Java:

public class Operacion {
    
    public static String exeOperacion(String sql)//Metodo insertar, actualizar y eliminar
    {
        String msg=null;
        try{
            Connection cn=new ConexionBD().getConexion();
            if(cn==null){
                msg="No hay Conexion con la Base de Datos";
            }else{
                Statement st=cn.createStatement();
                st.executeUpdate(sql);
                cn.close();
            }          
        }catch(SQLException e){
            msg=e.getMessage();
            System.out.println(e.getMessage());
        }
        return msg;
    }
    
    public static List getTabla(String sql){//Metodo para mostrar la tabla completa
        List lista=new ArrayList();
        try{
            Connection cn=new ConexionBD().getConexion();
            if(cn==null){//Comprobamos la conexion
                lista=null;
            }else{//Hay conexion
                Statement st=cn.createStatement();
                ResultSet rs=st.executeQuery(sql);
                ResultSetMetaData rm=rs.getMetaData();
                int numCol=rm.getColumnCount();
                String[] titCol=new String[numCol];
                for(int i=0;i<numCol;i++)
                   titCol[i]=rm.getColumnName(i+1);
                lista.add(titCol);
                while(rs.next()){
                    Object[]fila=new Object[numCol];
                    for(int i=0;i<numCol;i++)
                        fila[i]=rs.getObject(i+1);
                    lista.add(fila);
                }
                cn.close();
            }
        }catch(SQLException e){
            lista=null;
        }
        return lista;
    }
    public static Object[] getFila(String sql){//Metodo que solo retorna una fila
        Object[]fila=null;
        List lista=getTabla(sql);//Llamamos al metodo getTabla
        if(lista!=null){
            if(lista.size()>1)
                fila=(Object[])lista.get(1);
        }
        return fila;
    }
 

A mi me parece que trabajas igual, si en caso no sale, no olvides hacer debug.

[CHAEEZ]

Si, bastante parecido. El tema es que yo debo trabajar con commit y rollback ya que trabajo con una base de datos un poco desactualizado, Interbase 7.5 xD. Y si, hare un debug de algun error, y en caso de que el error persista, comentare en este post.

[Xerelo]

El tema es que yo debo trabajar con commit y rollback ya que trabajo con una base de datos un poco desactualizado, Interbase 7.5

Si el driver funciona, puedes usar cualquier framework de persistencia, si controlas los commit y rollback es porque tú quieres.

[CHAEEZ]

Pude hacer transacciones. Funciona.! Lo marco como solucionado.