Changeset 5437 for trunk/prototype/services/PostgreSQL.php

Timestamp:

01/27/12 15:37:21 (12 years ago)

Author:

cristiano

Message:

Ticket #2434 - Atualização modulo agenda e API

File:

• trunk/prototype/services/PostgreSQL.php (modified) (8 diffs)

trunk/prototype/services/PostgreSQL.php

@@ -8 +8 @@
     
     public function find ( $uri, $justthese = false, $criteria = false ){
-    
-        $criteria = ($criteria !== false) ? $this->parseCriteria ( $criteria ) : '';
-
-        $justthese = $justthese ? '"'.implode('", "', $justthese).'"' : '*';
-
-        return $this->execResultSql( 'SELECT '.$justthese.' FROM '.$uri['concept'].' '.$criteria );
+         
+        $map =  Config::get($uri['concept'], 'PostgreSQL.mapping');
+        
+        $criteria = ($criteria !== false) ? $this->parseCriteria ( $criteria , $map) : '';
+
+        $justthese = self::parseJustthese($justthese, $map);
+
+        return $this->execResultSql( 'SELECT '.$justthese['select'].' FROM '. (Config::get($uri['concept'],'PostgreSQL.concept')) .' '.$criteria );
     }
 
    public function read ( $uri, $justthese = false ){
-   
-      $justthese = $justthese ? '"'.implode('", "', $justthese).'"' : '*';
-
-      return $this->execResultSql( 'SELECT '.$justthese.' FROM '.$uri['concept'].' WHERE id = \''.addslashes( $uri['id'] ).'\'', true );
-    }
-        
-    public function deleteAll ( $uri,   $justthese = false, $criteria = false ){        
-            if(!self::parseCriteria ( $criteria )) return false; //Validador para não apagar tabela inteira
-            return $this->execSql( 'DELETE FROM '.$uri['concept'].' '.self::parseCriteria ( $criteria ) );
+      
+      $map =  Config::get($uri['concept'], 'PostgreSQL.mapping');
+       
+      $justthese = self::parseJustthese($justthese, $map);
+
+      return $this->execResultSql( 'SELECT '.$justthese['select'].' FROM '. (Config::get($uri['concept'],'PostgreSQL.concept')) .' WHERE id = \''.addslashes( $uri['id'] ).'\'', true );
+    }
+        
+    public function deleteAll ( $uri,   $justthese = false, $criteria = false ){
+            $map = Config::get($uri['concept'], 'PostgreSQL.mapping');
+            if(!self::parseCriteria ( $criteria , $map)) return false; //Validador para não apagar tabela inteira
+            return $this->execSql( 'DELETE FROM '.(Config::get($uri['concept'],'PostgreSQL.concept')).' '.self::parseCriteria ( $criteria ,$map) );
     }
 
     public function delete ( $uri, $justthese = false ){
-            return $this->execSql('DELETE FROM '.$uri['concept'].' WHERE id = '.addslashes($uri['id']));
+            return $this->execSql('DELETE FROM '.(Config::get($uri['concept'],'PostgreSQL.concept')).' WHERE id = '.addslashes($uri['id']));
     }
 
     public function replace ( $uri,  $data, $criteria = false ){
-            return $this->execSql('UPDATE '.$uri['concept'].' '. self::parseUpdateData( $data ).' '.self::parseCriteria($criteria));
+            
+            return $this->execSql('UPDATE '.(Config::get($uri['concept'],'PostgreSQL.concept')).' '. self::parseUpdateData( $data ,$uri['concept']).' '.self::parseCriteria($criteria , $uri['concept']));
     }
                 
     public function update ( $uri,  $data ){
-            return $this->execSql('UPDATE '.$uri['concept'].' '. self::parseUpdateData( $data ).' WHERE id = \''. addslashes( $uri['id']) .'\'');
+            return $this->execSql('UPDATE '.(Config::get($uri['concept'],'PostgreSQL.concept')).' '. self::parseUpdateData( $data ,$uri['concept']).' WHERE id = \''. addslashes( $uri['id']) .'\'');
     }
 
     public function create ( $uri,  $data ){    
-            return $this->execResultSql( 'INSERT INTO '.$uri['concept'].' '.self::parseInsertData( $data ), true );
+            return $this->execResultSql( 'INSERT INTO '.(Config::get($uri['concept'],'PostgreSQL.concept')).' '.self::parseInsertData( $data , $uri['concept'] ), true );
     }
 
@@ -122 +128 @@
     public function teardown(){}
 
-    private static function parseInsertData( $data ){
-            
+    private static function parseInsertData( $data , $concept){
+         
+            $map = Config::get($concept, 'PostgreSQL.mapping');
+        
             $ind = array();
             $val = array();
             
             foreach ($data as $i => $v){
-                    $ind[] = $i;
+                    if(!isset($map[$i])) continue;
+                
+                    $ind[] = $map[$i];
                     $val[] = '\''.addslashes($v).'\'';
             }
@@ -135 +145 @@
     }
         
-    private static function parseUpdateData( $data ){
-            
+    private static function parseUpdateData( $data , $concept){
+            
+            $map = Config::get($concept, 'PostgreSQL.mapping');
+                        
             $d = array();
-
             foreach ($data as $i => $v)
-                $d[] = $i.' = \''.addslashes ($v).'\'';
+            {
+                if(!isset($map[$i])) continue;
+                
+                $d[] = $map[$i].' = \''.addslashes ($v).'\'';
+            }
             
             return 'SET '.implode(',', $d);
@@ -160 +175 @@
     }
         
-    private static function parseCriteria( $criteria ){               
+    private static function parseCriteria( $criteria  , &$map ){               
             
             $result = '';
@@ -177 +192 @@
                 */
 
-                    $result .= 'WHERE '.self::parseFilter( $criteria['filter'] );
+                    $result .= 'WHERE '.self::parseFilter( $criteria['filter'] , $map);
             }
             /*
@@ -210 +225 @@
     }
     
-    private static function parseFilter( $filter ){
+    private static function parseFilter( $filter ,&$map){
     
         if( !is_array( $filter ) || count($filter) <= 0) return null;
-
+                
         $op = self::parseOperator( array_shift( $filter ) );
-
+        
         if( is_array($filter[0]) )
         {
@@ -221 +236 @@
 
             foreach( $filter as $i => $f )
-                $nested[] = self::parseFilter( $f );
+                $nested[] = self::parseFilter( $f , $map);
 
             return( '('.implode( ' '.$op.' ', $nested ).')' );
         }
 
+        
+        if(isset($map[$filter[0]]))
+            $filter[0] = $map[$filter[0]];
+        
         $igSuffix = $igPrefix = '';
-
+                
         if( strpos( $op[0], 'i' ) === 0 )
         {
@@ -258 +277 @@
         }
     }
-        
+    
+    private static function parseJustthese($justthese , &$map)
+    {
+                  
+        if(!is_array($justthese)) //Caso seja um full select pegar todas as keys
+            $justthese = array_keys($map);
+
+        $return = array();
+
+        foreach ($justthese as &$value) 
+        {
+            if(!isset($map[$value])) continue; //Escapa itens não existentes no mapa
+
+            if(is_array($map[$value]))
+                $return['deepness'][$value] = $map[$value];
+            else
+                $return['select'][] = $map[$value] .' as "'. $value. '"';
+        }
+        
+        $return['select'] = implode(', ', $return['select']);
+        return $return;  
+    }
+   
 }