commit en postgres

sergiop21 · #1 (**permalink**) 02/11/2009, 10:13

buenos dias compañeros

una pregunta, alguien me puede ayudar o dar información como buscar sobre START TRANSACTION, COMMIT, and ROLLBACK en postgres

huesos52 · #2 (**permalink**) 02/11/2009, 10:29

http://www.postgresql.org/docs/8.3/s...nsactions.html

En la documentacion oficial.

sergiop21 · #3 (**permalink**) 02/11/2009, 11:01

Muchas gracias compañero ahora empiezo a leer un poco

sergiop21 · #4 (**permalink**) 03/11/2009, 08:20

vi este ejemplo de begin, commit y rollback, pero.. hay algo que no entiendo

BEGIN : Comienza la transaccion
RollBack: Retrocede la transaccion por cualquier error
COMMIT: Finaliza la transaccion

hasta creo que es asi.

ejemplo:
BEGIN;
UPDATE accounts SET balance = balance - 100.00
WHERE name = 'Alice';
SAVEPOINT my_savepoint;
UPDATE accounts SET balance = balance + 100.00
WHERE name = 'Bob';
-- oops ... forget that and use Wally's account
ROLLBACK TO my_savepoint;
UPDATE accounts SET balance = balance + 100.00
WHERE name = 'Wally';
COMMIT;

hay una funcion que se llama SAVEPOINT me imagino que es "guardar punto", esto hay que colocarlo cada vez que se hace una consulta, actualizacion, o inserccion, por que aca solo lo muestra en un solo lado, ahh y tambien hay que colocar el rollback la cantidad de veces que ponemos los savepoint??
gracias desde ya

huesos52 · #5 (**permalink**) 03/11/2009, 08:37

Imagina que administras una base de datos de millones de datos.
Un update a un campo te puede dañar toda la información sin posibilidad de recuperarla. Para hacer cambios a la base de datos se debe ser muy cuidadoso y tener las herramientas para recuperarse de posibles daños.

Lo que dices es exactamente lo que es.
begin; Es el inicio de una transacción. Con solo poner esta clausula es posible recuperar errores que puedas sufrir.
savepoint; Con esta sentencia haces un commit hasta el punto que estes seguro no tienes errores. La diferencia con commit es que no se finaliza la transacción.
rollback; Deshace todos los cambios que se hayan realizado desde la sentencia begin. o hasta donde hayas confirmado con savepoint.
commit; Confirma y termina la transacción con los cambios establecidos.

Con un ejemplo:

Código sql:

Ver originalpruebas=>  SELECT *FROM producto;
 id |    descr
----+-------------
  1 | hoja
  2 | hoja carta
  3 | hoja oficio
  4 | lapicero
(4 filas)
 
pruebas=> BEGIN;
BEGIN
pruebas=> UPDATE producto SET descr=REPLACE(descr,'hoja','papel');
UPDATE 4
pruebas=>  SELECT *FROM producto;
 id |    descr
----+--------------
  1 | papel
  2 | papel carta
  3 | papel oficio
  4 | lapicero
(4 filas)

Hemos cambiado la palabra hoja por papel. Todo anda muy bien. Entonces vamos a confirmar hasta este punto que todo va bien haciendo uso de savepint.

Código sql:

Ver originalpruebas=> SAVEPOINT a;
SAVEPOINT
pruebas=> UPDATE producto SET descr=REPLACE(descr,'lapicero','boligrafo');
UPDATE 4
pruebas=>  SELECT *FROM producto;
 id |    descr
----+--------------
  1 | papel
  2 | papel carta
  3 | papel oficio
  4 | boligrafo
(4 filas)

Mierda!!! no era bolígrafo sino pluma. Debemos deshacer todos los cambios!!!. Pero si ya tenia todo bueno hasta aca y no quiero volver a empezar.

Utilizamos savepoint para deshacer los cambios hasta ese punto.

Código sql:

Ver originalpruebas=> ROLLBACK TO a;
ROLLBACK
pruebas=>  SELECT *FROM producto;
 id |    descr
----+--------------
  1 | papel
  2 | papel carta
  3 | papel oficio
  4 | lapicero
(4 filas)

Mira que el cambio de hoja a papel se conserva y solo se recupera la palabra lapicero.
Corregimos el error.

Código sql:

Ver originalpruebas=> UPDATE producto SET descr=REPLACE(descr,'lapicero','pluma');
UPDATE 4

ahora todo está bien. Solo nos queda confirmar la terminación de la transacción y terminarla.

Código sql:

Ver originalpruebas=> commit;
COMMIT
pruebas=>  SELECT *FROM producto;
 id |    descr
----+--------------
  1 | papel
  2 | papel carta
  3 | papel oficio
  4 | pluma
(4 filas)

con respecto a tu pregunta:

Cita:

hay una funcion que se llama SAVEPOINT me imagino que es "guardar punto", esto hay que colocarlo cada vez que se hace una consulta, actualizacion, o inserccion, por que aca solo lo muestra en un solo lado, ahh y tambien hay que colocar el rollback la cantidad de veces que ponemos los savepoint??

No es necesario. Cada sentencia se usa deacuerdo a las necesidades que tengas.
Si no tienes errores, solo es necesario el begin y el commit

sergiop21 · #6 (**permalink**) 03/11/2009, 08:49

bien me haz aclarado un monton, mira yo te cuento lo que deseo hacer

resulta que tengo que insertar en una tabla todo los detalles de ventas, en la otra tabla actualizar el stock y en otra insertar el total de la factura, entonces lo que yo quiero es que se complete todo o nada, por que sino me va a modificar por parte los registro y voy a estar hasta las manos o sea que con un begin y el commit suficiente, puede ser????

huesos52 · #7 (**permalink**) 03/11/2009, 08:54

Entiendo.

Pero entonces te recomiendo algo.
Haz todas estas operaciones dentro de una función o un store procedure de postgresql.
Cada función maneja transacciones implicitas y si se cae en alguna parte de las operaciones, se deshacen todos los cambios desde el inicio de la función.

Por ejemplo, yo tengo una función que haciendo operaciones matematicas, tarda apoximadamente 14 segundos operando. Si en ese tiempo hubiese un corte de energía o se cae el servidor, la función hace un rollback implicito y me permite mantener la consistencia de mis datos.

Imaginate que en el segundo 10, se cayera el servidor y guardara todos los cambios hasta ese punto y los otros no los alcanzara a realizar? Como detectaría hasta que punto llegó?

Con toda seguridad, el uso de funciones te va a solucionar tu problema y lo que tratas de hacer.

sergiop21 · #8 (**permalink**) 03/11/2009, 09:36

muchas gracias huesos, ahora estoy buscando información sobre eso para ver como es o que hay que hacer

sergiop21 · #9 (**permalink**) 03/11/2009, 10:08

volvi huesos, mira me puede seguir ayudando, por que lo que consegui es create function pero no sale mas nada, vos me podes dar un ejemplo?? si no es molestia

huesos52 · #10 (**permalink**) 03/11/2009, 10:19

En el foro de postgresql hay muchos ejemplos.
http://www.forosdelweb.com/search.php?searchid=2810762

si quieres, puedes poner la estructura de las tablas y las acciones que quieres tomar. (de las que hablabas en un principio) y con esta información te ayudo a sacar la función para esto.

saludops

sergiop21 · #11 (**permalink**) 03/11/2009, 10:42

ESTA ES MI ESTRUCTURA DE LAS TRES TABLAS Y AL FINAL PONGO MI CODIGO EN PHP
[/CODE]
FACTURA

CREATE TABLE factura
(
idfactura int4 NOT NULL,
fecha date,
total varchar(10),
pago varchar(10),
deuda varchar(10),
a_cuenta varchar(10),
idclientes int4,
CONSTRAINT pk_idfactura PRIMARY KEY (idfactura),
CONSTRAINT fk_idclientes FOREIGN KEY (idclientes)
REFERENCES clientes (idclientes) MATCH SIMPLE
ON UPDATE NO ACTION ON DELETE NO ACTION

STOCK
CREATE TABLE stock
(
idstock int4 NOT NULL,
codigo varchar(15),
detalle varchar(80),
fecha_alta date,
t32 varchar(3),
t34 varchar(3),
t35 varchar(3),
t36 varchar(3),
t37 varchar(3),
t38 varchar(3),
t39 varchar(3),
t40 varchar(3),
t42 varchar(3),
t44 varchar(3),
t46 varchar(3),
t48 varchar(3),
t50 varchar(3),
t52 varchar(3),
t54 varchar(3),
t56 varchar(3),
p_vta varchar(5),
cant_pa varchar(3),
vta_cur varchar(10),
por_u varchar(3),
por_cur varchar(3),
cantidad varchar(10),
idprenda int4,
CONSTRAINT idstock PRIMARY KEY (idstock),
CONSTRAINT fk_idprenda FOREIGN KEY (idprenda)
REFERENCES prendas (idprenda) MATCH SIMPLE
ON UPDATE NO ACTION ON DELETE NO ACTION

VENTAS
CREATE TABLE ventas
(
idventas int4 NOT NULL,
fecha date,
codigo varchar(15),
idusuario int4,
precio_unit varchar(10),
cantidad varchar(5),
total varchar(10),
"desc" varchar(3),
CONSTRAINT pk_ventas PRIMARY KEY (idventas),
CONSTRAINT fk_user FOREIGN KEY (idusuario)
REFERENCES usuario (idusuario) MATCH SIMPLE
ON UPDATE NO ACTION ON DELETE NO ACTION

[CODE]

Código PHP:

  <?php 
require("librerias/conn.php"); 
$conexion= Conec_con_pass(); 
 
$total = $_POST['cant_rows']; 
 
$n_fac = "select nextval('seq_factura')"; 
$Conn = ConectarBD(); 
 $res_fac = EjecutarBD($Conn, $n_fac);    
 
$can_fac = pg_fetch_result($res_fac,0); 
 
 
$clie = $_POST['txtclie']; 
$tot_ven = $_POST['pagar']; 
$pago = $_POST['pagar']; 
$seña = $_POST['pagar']; 
$fec_fac = $_POST['txtfecha']; 
 
$query2    = "insert into factura values ('$can_fac','$fec_fac', '$tot_ven', '$pago', '0', '$seña', '$clie' )"; 
           $resul_fac = pg_query($query2); 
            
   for($i=0; $i < $total; $i++) { 
    
            // $var = $_POST['fec'][$i]; 
            $var = cambiaf_a_bd($_POST['fec'][$i]); 
            $var1 = $_POST['cod'][$i]; 
            $var2 = $_POST['use'][$i]; 
            $var3 = $_POST['pre'][$i]; 
            $var4 = $_POST['can'][$i]; 
            $var5 = $_POST['pre_t'][$i]; 
            $var6 = $_POST['des'][$i]; 
            $var7 = $_POST['f_p'][$i]; 
            $var8 = $_POST['tal'][$i]; 
            $var9 = $_POST['sto'][$i]; 
             
     
    BEGIN; 
                $query= "INSERT INTO ventas values ((select nextval('seq_ventas')),'$var','$var1','$var2','$var3','$var4','1','1','$can_fac')"; 
                $result = pg_query($query); 
 
$sql = "select $var8 from stock where codigo = $var1"; 
 
 
 $Conn = ConectarBD(); 
 $resultad = EjecutarBD($Conn, $sql);    
//$fdev= pg_num_rows($result); 
 
$total = pg_fetch_result($resultad,0); 
$total = $total - $var4; 
$tot_prenda = $var9 - $var4; 
 
$query1 = "update stock set $var8 = $total, cant_pa =$tot_prenda  where codigo  = $var1"; 
      $resulta = pg_query($query1); 
                 
 
} 
 
 COMMIT; 
 
         
                ?>

sergiop21 · #12 (**permalink**) 03/11/2009, 10:54

ESTA ES MI ESTRUCTURA DE LAS TRES TABLAS Y AL FINAL PONGO MI CODIGO EN PHP
[/CODE]
FACTURA

CREATE TABLE factura
(
idfactura int4 NOT NULL,
fecha date,
total varchar(10),
pago varchar(10),
deuda varchar(10),
a_cuenta varchar(10),
idclientes int4,
CONSTRAINT pk_idfactura PRIMARY KEY (idfactura),
CONSTRAINT fk_idclientes FOREIGN KEY (idclientes)
REFERENCES clientes (idclientes) MATCH SIMPLE
ON UPDATE NO ACTION ON DELETE NO ACTION

STOCK
CREATE TABLE stock
(
idstock int4 NOT NULL,
codigo varchar(15),
detalle varchar(80),
fecha_alta date,
t32 varchar(3),
t34 varchar(3),
t35 varchar(3),
t36 varchar(3),
t37 varchar(3),
t38 varchar(3),
t39 varchar(3),
t40 varchar(3),
t42 varchar(3),
t44 varchar(3),
t46 varchar(3),
t48 varchar(3),
t50 varchar(3),
t52 varchar(3),
t54 varchar(3),
t56 varchar(3),
p_vta varchar(5),
cant_pa varchar(3),
vta_cur varchar(10),
por_u varchar(3),
por_cur varchar(3),
cantidad varchar(10),
idprenda int4,
CONSTRAINT idstock PRIMARY KEY (idstock),
CONSTRAINT fk_idprenda FOREIGN KEY (idprenda)
REFERENCES prendas (idprenda) MATCH SIMPLE
ON UPDATE NO ACTION ON DELETE NO ACTION

VENTAS
CREATE TABLE ventas
(
idventas int4 NOT NULL,
fecha date,
codigo varchar(15),
idusuario int4,
precio_unit varchar(10),
cantidad varchar(5),
total varchar(10),
"desc" varchar(3),
CONSTRAINT pk_ventas PRIMARY KEY (idventas),
CONSTRAINT fk_user FOREIGN KEY (idusuario)
REFERENCES usuario (idusuario) MATCH SIMPLE
ON UPDATE NO ACTION ON DELETE NO ACTION

[CODE]

Código PHP:

  <?php 
require("librerias/conn.php"); 
$conexion= Conec_con_pass(); 
 
$total = $_POST['cant_rows']; 
 
$n_fac = "select nextval('seq_factura')"; 
$Conn = ConectarBD(); 
 $res_fac = EjecutarBD($Conn, $n_fac);    
 
$can_fac = pg_fetch_result($res_fac,0); 
 
 
$clie = $_POST['txtclie']; 
$tot_ven = $_POST['pagar']; 
$pago = $_POST['pagar']; 
$seña = $_POST['pagar']; 
$fec_fac = $_POST['txtfecha']; 
 
$query2    = "insert into factura values ('$can_fac','$fec_fac', '$tot_ven', '$pago', '0', '$seña', '$clie' )"; 
           $resul_fac = pg_query($query2); 
            
   for($i=0; $i < $total; $i++) { 
    
            // $var = $_POST['fec'][$i]; 
            $var = cambiaf_a_bd($_POST['fec'][$i]); 
            $var1 = $_POST['cod'][$i]; 
            $var2 = $_POST['use'][$i]; 
            $var3 = $_POST['pre'][$i]; 
            $var4 = $_POST['can'][$i]; 
            $var5 = $_POST['pre_t'][$i]; 
            $var6 = $_POST['des'][$i]; 
            $var7 = $_POST['f_p'][$i]; 
            $var8 = $_POST['tal'][$i]; 
            $var9 = $_POST['sto'][$i]; 
             
     
    BEGIN; 
                $query= "INSERT INTO ventas values ((select nextval('seq_ventas')),'$var','$var1','$var2','$var3','$var4','1','1','$can_fac')"; 
                $result = pg_query($query); 
 
$sql = "select $var8 from stock where codigo = $var1"; 
 
 
 $Conn = ConectarBD(); 
 $resultad = EjecutarBD($Conn, $sql);    
//$fdev= pg_num_rows($result); 
 
$total = pg_fetch_result($resultad,0); 
$total = $total - $var4; 
$tot_prenda = $var9 - $var4; 
 
$query1 = "update stock set $var8 = $total, cant_pa =$tot_prenda  where codigo  = $var1"; 
      $resulta = pg_query($query1); 
                 
 
} 
 
 COMMIT; 
 
         
                ?>

huesos52 · #13 (**permalink**) 03/11/2009, 12:11

Cita:

for($i=0; $i < $total; $i++) {

// $var = $_POST['fec'][$i];
$var = cambiaf_a_bd($_POST['fec'][$i]);
$var1 = $_POST['cod'][$i];
$var2 = $_POST['use'][$i];
$var3 = $_POST['pre'][$i];
$var4 = $_POST['can'][$i];
$var5 = $_POST['pre_t'][$i];
$var6 = $_POST['des'][$i];
$var7 = $_POST['f_p'][$i];
$var8 = $_POST['tal'][$i];
$var9 = $_POST['sto'][$i];

No entiendo bien esto, pero plpgsql (Creación de funciones) soporta la clausula for y podrías simular esto en una función.

sergiop21 · #14 (**permalink**) 03/11/2009, 18:01

ahh eso es lo que hace es recorrer una matriz que envio de otro archivo, pero lo que mas me interesa es saber como utilizar la funcion, sobre lo que inserto y actualizo, muchas gracias

sergiop21 · #15 (**permalink**) 03/11/2009, 22:23

HOla huesos, Cuando puedas dame una mano que no me sale nada de nada

huesos52 · #16 (**permalink**) 04/11/2009, 08:17

Un ejemplo de una función

Código sql:

Ver originalCREATE OR REPLACE FUNCTION multiplicar(INTEGER,INTEGER)
  RETURNS INTEGER AS
$BODY$
DECLARE 
resultado INTEGER;
BEGIN
resultado:=$1*$2;
RETURN resultado;
END;
$BODY$
  LANGUAGE 'plpgsql' VOLATILE;

si la ejecutas:

Código sql:

Ver originalpruebas=> SELECT multiplicar(4,5);
 multiplicar
-------------
          20
(1 fila)

Un ejemplo de función con for.

Código sql:

Ver originalCREATE OR REPLACE FUNCTION sumar_dias_a_fecha(DATE,INTEGER)
  RETURNS DATE AS
$BODY$
DECLARE 
fecha_final DATE;
contador INTEGER;
BEGIN
fecha_final=$1;
FOR contador IN 1..$2
loop
 fecha_final = fecha_final + 1;
END loop;
RETURN fecha_final;
END;
$BODY$
  LANGUAGE 'plpgsql' VOLATILE;

Si lo corremos

Código sql:

Ver originalpruebas=> SELECT sumar_dias_a_fecha('2009-11-04'::DATE,5);
 sumar_dias_a_fecha
--------------------
 2009-11-09
(1 fila)

le suma 5 días a una fecha.

Espero esta sea una base para que logres tu objetivo

sergiop21 · #17 (**permalink**) 04/11/2009, 11:11

muchisimas gracias, ahora lo voy a poner en practica y enseguida te aviso compañero como me fue