Consultor

Código :

<?php
//Clase de conexión simple y consulta a base de datos "Consultor"
//  Devuelve un recordset de una consulta a Flash
//  Facilmente extensible usando programación orientada a objetos
//  Freddie® - http://www.cristalab.com/
class Consultor{
   function Consultor(){
      $this->methodTable = array(
         "consulta" =>array (
            "description" => "Devuelve un objeto RecordSet a Flash de una consulta pasada por parametro",
            "access" => "remote",
            "arguments" => array("sql")
         )
      );
   }
   function consulta($sql){
      /*
         Los datos de la base de datos MySQl
         El nombre de usuario, el password de acceso y obviamente el nombre de la base de datos
         
         CAMBIALOS!!! a los tuyos del servidor o no funcionara
      */
      //$cons_user = "root";
      //$cons_pass = "";
      //$cons_db = "cc05";
      //Conecta a la base de datos
      $dbh=pg_connect("host=xxx.xxx.xxx.xxx port=5432 user=xxx dbname=xxx" ) or die("No se pudo conectar a la base de datos");
      //Selecciona la base de datos
      //mysql_select_db ($cons_db);
      //Guarda el resultado de la consulta en un identificador (Puntero)
      $resultado=pg_query($sql);
      pg_close($dbh);
      //Retorna lo obtenido
      return $resultado;
   }
}
?>

Código :

import Conexion;
import mx.remoting.RecordSet;
var db:Conexion = new Conexion();
db.consulta("SELECT id_edo, descripcion FROM estados");
db.onConsulta = function(rs) {
   nombre_txt.text = rs.getItemAt(0).id_edo;
};

Código :

import mx.remoting.NetServices;
import mx.remoting.Connection;
import mx.remoting.RecordSet;
import mx.remoting.NetServiceProxy;
dynamic class Conexion {
   private var conn:Connection;
   private var serv:NetServiceProxy;
   private var servSend:NetServiceProxy;
   private var padre;
   public var onConsulta:Function;
   function Conexion() {
      NetServices.setDefaultGatewayUrl("http://xxx/metrologia/remoting/gateway.php");
      conn = NetServices.createGatewayConnection();
   }
   private function errorAMF(data) {
      trace("AMFPHP Error");
      trace("En la linea "+data.line);
      trace("Nivel del error: "+data.level);
      trace("------------------------------");
      trace(data.description);
      padre.traceObj(data);
   }
   public function consulta(SQL:String) {
      trace("Consultando");
      var envio:Object = new Object();
      envio.padre = this;
      envio.onStatus = this.errorAMF;
      envio.consulta_Result = function(data) {
         var rs:RecordSet = data;
         //trace("Datos: "+rs.getLength());
         this.padre.onConsulta(rs);
      };
      servSend = conn.getService("Consultor", envio);
      servSend.consulta(SQL);
   }
   function traceObj(obj) {
      trace("TrazandoObjeto");
      for (var i in obj) {
         trace("\\t"+i+"->"+obj[i]);
      }
   }
}