transactional control - JDBC

  
	public Connection getConn(){  
	   return conn;  
	}  

  
    try {   
        ((JDBCConnection)e.getCommand().getJDBCConnection()).getConn().setAutoCommit(false);  
    }catch(java.sql.SQLException sql_ex){}  

  
    java.sql.Connection c = e.getCommand().getJDBCConnection().getConn();  
    try {  
        if ( !c.getAutoCommit()) {  
            if (e.getCommand().getJDBCConnection().hasErrors()){   
                try{ c.rollback(); }catch(Exception ex){ }  
            }else{ c.commit(); }  
        }  
    }catch(java.sql.SQLException sql_ex){ }  

  
package com.codecharge;  
import javax.servlet.ServletException;  
import javax.servlet.http.HttpServlet;  
import javax.servlet.http.HttpServletResponse;  
import com.codecharge.*;  
import com.codecharge.components.*;  
import com.codecharge.util.*;  
import com.codecharge.events.*;  
import com.codecharge.db.*;  
import com.codecharge.validation.*;  
import java.util.*;  
import java.io.*;  
import com.codecharge.util.cache.CacheEvent;  
import com.codecharge.util.cache.ICache;  
public class GetValuesConnection extends HttpServlet {  
    private String driverName;  
    private String urlName;  
    private String userName;  
    private String passwordName;  
  
	public void setUser(String userNamex) {  
          this.userName = userNamex;  
    }  
  
	public void setPassword(String passwordNamex) {  
          this.passwordName = passwordNamex;  
    }  
  
	public void setUrl(String urlNamex) {  
          this.urlName = urlNamex;  
    }  
  
	public void setDriver(String driverNamex) {  
          this.driverName = driverNamex;  
    }  
  
    public String getUser() {  
         return userName;  
    }  
  
    public String getPassword() {  
         return passwordName;  
    }  
  
    public String getDriver() {  
         return driverName;  
    }  
  
    public String getUrl() {  
         return urlName;  
    }  
  
    public boolean getvaluesConnName(String sNameConnection){  
	// Este es un Método retorna los valores url, driver, user, password para el Nombre de conexion pasado del Archivo site.properties  
		// Usar:  
		// GetValuesConnection valConn = new GetValuesConnection();  
		// boolean retorno= valConn.getvaluesConnName("ConPRUEBAS");  
		// Resultado:  
		// El retorno es true o false :   
	// si true devuelve valores si no son todos vacios  
	// valConn.getUrl;  
	// valConn.getUser;  
	// valConn.getPassword();  
	// valConn.getDriver();  
	boolean lRet = false;  
	String name_conn = sNameConnection;  
	int long_name_conn = name_conn.length();  
	String name_user = name_conn + ".user=";  
	String name_password = name_conn + ".password=";  
	String name_driver = name_conn + ".driver=";  
	String name_url = name_conn + ".url=";  
	String cFile = "/WEB-INF/site.properties";  
	String rpath = ContextStorage.getContext().getRealPath(cFile);  
	File f = new File( rpath );  
	String s = new String();  
	try {  
		BufferedReader bufferedReader = new BufferedReader(new FileReader( f ));  
		String line;  
		String saco_parte = "";  
		String saco_user = "";  
		String saco_password = "";  
		String saco_driver = "";  
		String saco_url = "";  
		while ((line = bufferedReader.readLine()) != null) {  
			if (line.length() >= long_name_conn){  
				saco_parte = line.substring(0, long_name_conn);  
				//***********  
				// Saco user  
				//***********  
				if (line.length() >= name_user.length() ){  
					saco_user = line.substring(0, name_user.length()); //saco_parte + ".user=";  
					if ( name_user.equals(saco_user) ){  
						this.setUser(line.substring(name_user.length()));  
					}  
				}  
				//***************  
				// Saco password  
				//***************  
				if (line.length() >= name_password.length() ){  
					saco_password = line.substring(0, name_password.length());  
					if ( name_password.equals(saco_password) ){  
						this.setPassword(line.substring(name_password.length()));  
					}  
				}  
				//*************  
				// Saco driver  
				//*************  
				if (line.length() >= name_driver.length() ){  
					saco_driver = line.substring(0, name_driver.length());  
					if ( name_driver.equals(saco_driver) ){  
						this.setDriver(line.substring(name_driver.length()));  
					}  
				}  
				//**********  
				// Saco url  
				//**********  
				if (line.length() >= name_url.length() ){  
					saco_url = line.substring(0, name_url.length());  
					if ( name_url.equals(saco_url) ){  
						this.setUrl(line.substring(name_user.length()));  
					}  
				}  
			}  
		}  
		bufferedReader.close();  
		lRet = true;  
	}  
	catch (java.io.IOException ioex) {  
		this.setUser("");  
		this.setPassword("");  
		this.setDriver("");  
		this.setUrl("");  
	}  
	return lRet;  
    }  
  
 }  
  

  
...  
	GetValuesConnection valConn = new GetValuesConnection();  
 	boolean ret = valConn.getvaluesConnName("ConPRUEBAS");  
	if (ret == false){  
		Utils.printFatalError("Lo Siento !!!, No puedo leer el Archivo de conexiones a la DB !!!", e.getPage().getResponse());  
	}  
	Connection conn = null;  
  
	Statement stmt = null;  
	ResultSet rs = null;  
  
	try {  
		/**** Cargamos el driver ****/  
	    	Class.forName( valConn.getDriver() );  
    		/**** Realizamos la conexión ****/  
	    	conn = DriverManager.getConnection( valConn.getUrl(), valConn.getUser(), valConn.getPassword() );  
	    	/**** Ok: avisamos ****/  
  
		conn.setAutoCommit(false);   
		stmt = conn.createStatement();		  
  
		String sql = "";  
  
		sql = "SELECT TRB_CAB_EXP_SEQ.nextval idcabexp FROM dual";  
		  
		rs = stmt.executeQuery(sql);  
		while (rs.next()) {  
				id_cabexp = Utils.convertToString(rs.getInt("idcabexp"));  
		}  
  
		sql = "INSERT INTO TRB_CAB_EXP (ID,ANOEXP,NROACTA,FECINF,HORAIN,TRB_INSPECTO_ID,FECCAUSA,FIRMADA,LUGINF,ALTURA, APTO,OBSERVACIO,ETAPA,TRB_ESTADOS_ID) VALUES ('" + id_cabexp + "', '" + nselano + "', '" + nroacta + "', '" + dfecinf + "', '" + chorain + "', '" + ntrb_insp_id + "', '" + dfeccausa + "', '" + nfirmada + "', '" + nluginf + "', '" + naltura + "', '" + capto + "', '" + mobservacio + "', '" + ntetapa + "', '1'" + ")";  
		stmt.execute(sql);  
		  
		...  
  
		conn.commit();  
  
	} catch (Exception ex) {  
		try {  
			if (conn != null) {  
				conn.rollback();  
			}  
			Utils.printFatalError("Database error: " + ex.getMessage() + " -> " + pasos, e.getPage().getResponse());  
		} catch (Exception ex2) {  
			Utils.printFatalError("Database error: " + ex2.getMessage() + " -> " + pasos, e.getPage().getResponse());  
		}  
	} finally {  
			if (rs != null) {  
				rs = null;  
			}  
			if (stmt != null) {  
				stmt = null;  
			}  
			try {  
				if (conn != null) {  
					conn.setAutoCommit(true);  
					conn.close();  
					conn = null;  
					e.getPage().setRedirectString( "TRB_CAB_EXP_list.jsp" );  
				}  
			} catch (Exception ex3) {  
				Utils.printFatalError("Database error: " + ex3.getMessage() + " -> " + pasos, e.getPage().getResponse());  
			}  
  
 	}