Problemas con update

[tuuutooo]

Hola amigos, quisiera pedirles si me pueden ayudar con este código que estoy intentando realizar. Les cuento primero que nada que estoy trabajando con dos bdd Postgre que se encuentran en distintos servidores. Deseo realizar el siguiente paso, Primero hago la consulta, si esto tiene datos, que inserte y una vez que realice esto poder actualizar un campo.

Código PHP:

include("include/conn.php"); //Conexión a una bdd
 
 
pg_exec("begin");
$do_commit=true;
 
if($do_commit){
    $sql="select id, trato from ca where trato=1";
    $result=pg_query($conn,$sql);
    if($row=pg_fetch_array($result)){
        $conn2=pg_connect("host=XXXX  port=XXX dbname=miBase user=miUser password=miPass"); //Conexión a mi segunda bdd
        $sql2="insert into ffc(f_id, c_id, u, v, fecha, lonlat, texto, cc_id) values (1, 53, 'Test', 3, now(), '-33.9857541,-70.1204587', 'Test', 268)";
        $result2=pg_query($conn2, $sql2);
        
    }
}
 
if($do_commit){
    if($row['trato']==1){
        $sql3="update ca set trato=3 where id=".$row['id'];
        $result3=pg_query($conn, $sql3);
        
    }
}
 
 
   
if($do_commit){
    pg_exec("COMMIT");
    header("location: miArchivo.php");
    exit();
}
if(!$do_commit){
    pg_exec("ROLLBACK");
    $_SESSION['pdata']=$_POST;
    $_SESSION['errmesg']=$errmesg;
    header("location: Error.php");
    exit();
}
 

El problema que tengo, es que al hacer la consulta me inserta todo bien correctamente, pero el update no me funciona, he intentado hacerlo de varias formas pero el trato nunca cambia, si me pudieran ayudar a ver mi error se los estare muy agradecido.

Muchas Gracias

[toledo_nocturno]

Muy buenas.

No le meto mucha mano a postgre desde php desde hace bastante tiempo, pero vayamos al lio:

En la consulta de la línea 8, del if de la 7 haces:
$sql="select id, trato from ca where trato=1";

Pero luego, en la línea 19 haces:
if($row['trato']==1){

Si ya sabes de antemano que va a estar a 1, ¿para qué comprobarlo? Entiendo que es ese update el que falla.

[tuuutooo]

Exacto amigo, ese update me falla, le volvi a poner la condición para probar, pero no hay caso, supuestamente después de pedir que consulte por los trato=1, que me inserte, no logro actualizar, es más mi log de errores hace el proceso de actualizar, pero si reviso la bdd queda igual el trato en 1, si copio el update que imprimo, no tengo problemas en actualizarlo por consola, entonces voy a lo mismo, donde estoy fallando.

Gracias

[toledo_nocturno]

Buenas,

La primera consulta... ¿Te devuelve más de un resultado?
Y al llegar al update... ¿Estás seguro de que entra en ese if? Por descartar cosas, quiero decir, y ver si hay algo antes de entrar en el if, o ya dentro.

[tuuutooo]

Solo me devuelve un resultado, y si, cuando llego al update llego con datos... Cambie el código nuevamente.

Código PHP:

if($do_commit){
    
    $sql="select id, trato from ca where trato=1";
    $result=pg_query($conn,$sql);
    if($row=pg_fetch_array($result)){
        $id=$row['id_actualizacion'];
    }
        
        
     $conn2=pg_connect("host=XXXX  port=XXX dbname=miBase user=miUser password=miPass"); //Conexión a mi segunda bdd
    $sql2="insert into ffc(f_id, c_id, u, v, fecha, lonlat, texto, cc_id) values (1, 53, 'Test', 3, now(), '-33.9857541,-70.1204587', 'Test', 268)";
    $result2=pg_query($conn2, $sql2);
    if(pg_affected_rows($result2)==0){
        $do_commit=false;
        $errmesg.="Error Inesperado.";
    }
    
    $sql3="update ca set trato=3 where id=$id";
    $result3=pg_query($conn, $sql3);
    if(pg_affected_rows($result3)==0){
        $do_commit=false;
        $errmesg.="Error Inesperado.";
    }
    
}
 

Sigo insistiendo que lo más curioso que me sucede, es que cuando imprimo el log, llegan todos los datos correctamente.... Pero no me cambia el update....

El código que mostraré es el que me da el log cuando termina el proceso.

Código PHP:

Consulta Uno: select id, trato from ca where estado=1
Insertar:insert into ffc(f_id, c_id, u, v, fecha, lonlat, texto, cc_id) values (1, 53, 'Test', 3, now(), '-33.9857541,-70.1204587', 'Test', 268)
Update: update ca set estado=2 where id_actualizacion=1014
 

Si tomo ese update y lo actualizo por consola, me funciona, pero a través del php no...!!!!

Gracias