Biblioteca Java - Rev 6

Subversion Repositories:
Rev:
package lab.scd.db.jdbc10;

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

import lab.scd.db.util.DBConfig;

/*
 * TestTranzactii.java
 */

/**
 * Class created by @author Mihai HULEA at Mar 10, 2005.
 *
 * This class is part of the laborator4_db project.
 *
 */
public class TestTranzactii {
   
    Connection conn;
    Statement stat;
    public TestTranzactii() throws Exception{
        Class.forName("com.mysql.jdbc.Driver");
       
        //conectare la baza de date
        Connection conn = DriverManager.getConnection("jdbc:mysql://"+DBConfig.HOST+"/"+DBConfig.DATABASE+"?user="+DBConfig.USER+"&password="+DBConfig.PWD);
        System.out.println("Conexiune la baza de date realizata.");
       
        stat = conn.createStatement();
    }
   
    public void testTranzactie(boolean simulateError) {
        try{
            //start tranzactie
            conn.setAutoCommit(false);
           
            stat.executeUpdate("INSERT INTO STOC VALUES ('produs A' , 2500)");
           
            //simuleaza aparitia unei probleme
            if(simulateError == true)
                throw new SQLException("Eroare update.");
           
            stat.executeUpdate("INSERT INTO STOC VALUES ('produs B' , 7900)");
           
            //sfarsit tranzactie
            conn.commit();
           
        }catch(SQLException ex){
           
            ex.printStackTrace();
            try {
                conn.rollback();
            } catch (SQLException e) {e.printStackTrace();}
       
        }
         
    }//.
   
    public void afiseazaTabel() throws SQLException{
        ResultSet rs = stat.executeQuery("SELECT * FROM STOC;");
       
        while(rs.next()){
            String pname = rs.getString("PROD");
            int ppret = rs.getInt("PRET");
            System.out.println("Produs:"+pname+" Pret:"+ppret);
        }
         
    }
   
    public static void main(String[] args) {
        try{
       
            TestTranzactii t = new TestTranzactii();
           
            t.testTranzactie(true);
           
            t.afiseazaTabel();
           
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}