igual si le doy al botón de cancelar lo envío a una página que ejecuta un ROLLBACK.
After I'll write the code....
************************************************** **************
Archivo conexion.php
Código:
(ojó esto e suna prueba en mi código nunca ejecutaría una sentencia sql en un controlador, ni tampoco mostraría codigo html en el controlador)class Conexion {
public static $RDBMS = "PostgreSQL";
public static $id_conn;
private static $dir_serv = "localhost"; //"localhost"
private static $port = "5432";
private static $user = "postgres"; // "postgres"
private static $passw = "postgres"; // "postgres"
private static $database = "invfact_db";
public static $mailadmin = "";
public static $sql;
public static $last_sql;
public $records = 10;
public $pages = 5;
function __construct() {
$this->db_name = self::$database;
$this->db_user = self::$user;
$this->db_pass = self::$passw;
$this->db_host = self::$dir_serv; //conexion directa al servidor
self::getConnection ();
}
/**
* Obtiene una conexión
*
* @return Conección
*/
public static function getConnection() {
$str_conexion = "host=" . self::$dir_serv . " port=" . self::$port . " dbname=" . self::$database . " user=" . self::$user . " password=" . self::$passw ;
//echo $str_conexion;
if(!isset(self::$id_conn) || pg_connection_busy(self::$id_conn)){
if (! (self::$id_conn = pg_pconnect ( $str_conexion ))) {
echo "<div align='center' id=\"error_bd\" style=\"color:#990000\" aling='center'><b>ERROR: Conectando a la Base de Datos.<br>" . utf8_encode(pg_errormessage ()) . "</b></div>";
return FALSE;
}
}
echo "<br />".pg_get_pid(self::$id_conn)."<br />";
return self::$id_conn;
}
/**
* Ejecuta una sentencia SQL en la Base de Datos
*
* @param StringSQL $string_query
* @return Resource
*/
public function executeQuery($string_query) {
$query_result = FALSE;
if (func_num_args () != 1) {
$query_result = FALSE;
} else {
self::$last_sql = $string_query;
self::$id_conn = self::getConnection ();
//echo "<br><br><b style='color: #990000'>".$string_query."</b><br/><br/>";
//$query_result = TRUE;
$query_result = pg_query ( self::$id_conn, $string_query );
}
return $query_result;
}
/**
* Maneja el ciclo de vida de una Transacción
*
* @param String $operacion
* @return Resource
*
*/
function managerTransaction($operacion){
if(func_num_args()==1){
$operacion = strtolower($operacion);
if($operacion=="begin"){
return $this->executeQuery("BEGIN WORK; ");
}
elseif ($operacion=="commit"){
return $this->executeQuery(" COMMIT;");
}
elseif ($operacion=="rollback") {
return $this->executeQuery(" ROLLBACK;");;
}
elseif ($operacion=="end") {
return $this->executeQuery(" END WORK;");;
}
else {
return FALSE;
}
}
else{
return FALSE;
}
}
}
************************************************** **************
Archivo index.php
Código:
************************************************** **************<?php
session_start();
require_once '../../core/conexion.php';
$conexion = @new Conexion();
$_SESSION["conexion_obj"] = serialize($conexion);
$conexion->managerTransaction("BEGIN");
$rs = $conexion->executeQuery("INSERT INTO public.prueba (prueba1, prueba2) VALUES ('HOLA1', 'CHAO1') RETURNING id_prueba, prueba1, prueba2;");
$registros = $conexion->extraerRegistro($rs,"array");
echo "<br />".print_r($registros)."<br />";
if($rs){
?>
<br />
<div style="text-align: center">
<form action="succes.php" method="get">
<input type="hidden" name="id_prueba" id="id_prueba" value="<?php echo $registros["id_prueba"]; ?>">
Prueba 1 : <input type="text" name="prueba1" id="prueba1" value="<?php echo $registros["prueba1"]; ?>">
<br /><br />
Prueba 2 : <input type="text" name="prueba2" id="prueba2" value="<?php echo $registros["prueba2"]; ?>">
<br /><br />
<input type="button" onclick="window.location.href = 'cancelar.php';" name="enviar" value="Cancelar">
<br /><br />
<input type="submit" name="enviar" value="Actualizar Datos">
</form>
</div>
<?php
}
?>
Archvo succes.php
Código:
Archivo Cancelar<?php
session_start();
require_once '../../core/conexion.php';
$conexion = unserialize($_SESSION["conexion_obj"]);
echo "<br />".pg_get_pid(Conehttp://static.forosdelweb.com/images/editor/color.gifxion::$id_conn)."<br />";
//$conexion->managerTransaction("BEGIN");
$rs = $conexion->managerTransaction("COMMIT");
$conexion->managerTransaction("END");
if($rs):
?>
<div style="text-align: center">
TODO FINO
</div>
<?php else: ?>
<div style="text-align: center">
TODO MAL
</div>
<?php endif;?>
Código:
Cómo ven en alguna parte coloqué texto en azul para que vieran donde estoy haciendo la transacción... y además vean que estoy manteniendo el mismo objeto en session para mantener el id de conexión y así la base de datos PostgreSQL me reconózca la transacción (Pero, no lo hace). Necesito hacer este insert previo porque el formulario que estoy haciendo necesita el id de este registro en la misma pantalla... Por ahora estoy marcando este registro con un estatus de precarga y con un id de session php y luego lo actualizo con estatus de cargado y con el id que cerró dicho registro. estoy simulando acá un COMMIT pero, quisiera poder hacerlo de tal forma que la base de datos pudiera hacerlo automáticamente... Espero me puedan ayudar de verdad.<?php
session_start();
require_once '../../core/conexion.php';
$conexion = unserialize($_SESSION["conexion_obj"]);
echo "<br />".pg_get_pid(Conexion::$id_conn)."<br />";
//$conexion->managerTransaction("BEGIN");
$rs = $conexion->managerTransaction("ROLLBACK");
$conexion->managerTransaction("END");
if($rs):
?>
<div style="text-align: center">
SE CANCELÓ
</div>
<?php else: ?>
<div style="text-align: center">
EEEE NO SE
</div>
<?php endif;?>
Muchas Gracias a todos de antemano
Posted By. José Gabriel González.
