Revision
14947
Author
intralanman
Date
2009-09-21 21:59:03 -0500 (Mon, 21 Sep 2009)

Log Message

start adding db field quoters to actually support multiple DBs

Modified Paths

Diff

Modified: freeswitch/trunk/contrib/intralanman/PHP/fs_curl/fs_curl.php (14946 => 14947)


--- freeswitch/trunk/contrib/intralanman/PHP/fs_curl/fs_curl.php	2009-09-22 02:55:26 UTC (rev 14946)
+++ freeswitch/trunk/contrib/intralanman/PHP/fs_curl/fs_curl.php	2009-09-22 02:59:03 UTC (rev 14947)
@@ -17,13 +17,13 @@
  * Base class for all curl XML output, contains methods for XML output and
  * connecting to a database
  * @return void
-*/
+ */
 class fs_curl {
-    /**
-     * FS_PDO Object
-     * @link http://www.php.net/pdo
-     * @var $db FS_PDO
-     */
+/**
+ * FS_PDO Object
+ * @link http://www.php.net/pdo
+ * @var $db FS_PDO
+ */
     public $db;
     /**
      * Array of _REQUEST parameters passed
@@ -49,7 +49,7 @@
      * This method will instantiate the FS_PDO and XMLWriter classes for use
      * in child classes
      * @return void
-    */
+     */
     public function fs_curl() {
         openlog('fs_curl', LOG_NDELAY | LOG_PID, LOG_USER);
         header('Content-Type: text/xml');
@@ -59,14 +59,14 @@
         $this -> include_files($inc);
         $this -> connect_db(DEFAULT_DSN, DEFAULT_DSN_LOGIN, DEFAULT_DSN_PASSWORD );
         set_error_handler(array($this, 'error_handler'));
-        //trigger_error('blah', E_USER_ERROR);
+    //trigger_error('blah', E_USER_ERROR);
     }
 
     /**
      * Connect to a database via FS_PDO
      * @param mixed $dsn data source for database connection (array or string)
      * @return void
-    */
+     */
     public function connect_db($dsn, $login, $password) {
         try {
             $this -> db = new FS_PDO($dsn, $login, $password);
@@ -74,6 +74,20 @@
             $this -> comment($e->getMessage());
             $this -> file_not_found(); //program terminates in function file_not_found()
         }
+        $driver = $this->db->getAttribute(constant("PDO::ATTR_DRIVER_NAME"));
+        $this->debug("our driver is $driver");
+        switch ($driver) {
+            case 'mysql':
+                $quoter = '`';
+                break;
+            case 'postgres':
+                $quoter = '"';
+                break;
+            default:
+                $quoter = '';
+                break;
+        }
+        define('DB_FIELD_QUOTE', $quoter);
     }
 
     /**
@@ -81,7 +95,7 @@
      * Adds a comment to be displayed in the final XML
      * @param string $comment comment string to be output in XML
      * @return void
-    */
+     */
     public function comment($comment) {
         $this -> comments[] = $comment;
     }
@@ -91,10 +105,10 @@
      * Generates an array from the _REQUEST parameters that were passed, keeping
      * all key => value combinations intact
      * @return void
-    */
+     */
     private function generate_request_array() {
         while (list($req_key, $req_val) = each($_REQUEST)) {
-            //$this -> comment("$req_key => $req_val");
+        //$this -> comment("$req_key => $req_val");
             $this -> request[$req_key] = $req_val;
         }
     }
@@ -103,7 +117,7 @@
      * Actual Instantiation of XMLWriter Object
      * This method creates an XMLWriter Object and sets some needed options
      * @return void
-    */
+     */
     private function open_xml() {
         $this -> xmlw = new XMLWriter();
         $this -> xmlw -> openMemory();
@@ -127,7 +141,7 @@
      * in the event that we are unable to generate a valid configuration file
      * from the passed information
      * @return void
-    */
+     */
     public function file_not_found() {
         $this -> comment('Include Path = ' . ini_get('include_path'));
         $not_found = new XMLWriter();
@@ -160,7 +174,7 @@
      * @param array $comments [Multi-dementional] Array of comments to be added
      * @param integer $space_pad Number of spaces to indent the comments
      * @return void
-    */
+     */
     private function comments2xml($xml_obj, $comments, $space_pad=0) {
         $comment_count = count($comments);
         for ($i = 0; $i < $comment_count; $i++) {
@@ -177,7 +191,7 @@
     /**
      * End open XML elments in XMLWriter object
      * @return void
-    */
+     */
     private function close_xml() {
         $this -> xmlw -> endElement();
         $this -> xmlw -> endElement();
@@ -187,15 +201,15 @@
     /**
      * Close and Output XML and stop script execution
      * @return void
-    */
+     */
     public function output_xml() {
         $this->comment(
             sprintf('Total # of Queries Run: %d', $this->db->counter)
         );
         $this -> comment(sprintf("Estimated Execution Time Is: %s"
-                , (preg_replace(
-                '/^0\.(\d+) (\d+)$/', '\2.\1', microtime()) - START_TIME)
-            ));
+            , (preg_replace(
+            '/^0\.(\d+) (\d+)$/', '\2.\1', microtime()) - START_TIME)
+        ));
 
         $this -> comments2xml($this -> xmlw, $this -> comments);
         $this -> close_xml();
@@ -210,7 +224,7 @@
     /**
      * Recursive method to add an array of comments
      * @return void
-    */
+     */
     public function comment_array($array, $spacepad=0) {
         $spaces = str_repeat(' ', $spacepad);
         foreach ($array as $key => $val) {
@@ -231,14 +245,14 @@
      * @param array $file_array associative array of files to include
      * @return void
      * @todo add other types for different levels of errors
-    */
+     */
     public function include_files($file_array) {
         $return = FS_CURL_SUCCESS;
         while (list($type, $file) = each($file_array)) {
             $inc = @include_once($file);
             if (!$inc) {
                 $comment = sprintf(
-                'Unable To Include %s File %s', $type, $file
+                    'Unable To Include %s File %s', $type, $file
                 );
                 $this -> comment($comment);
                 if ($type == 'required') {
@@ -264,7 +278,7 @@
      * @see RETURN_ON_WARN
      * @return void
      * @todo add other defines that control what, if any, comments gets output
-    */
+     */
     public function error_handler($no, $str, $file, $line) {
         if ($no == E_STRICT) {
             return true;
@@ -274,20 +288,20 @@
 
         switch ($no) {
             case E_USER_NOTICE:
-                case E_NOTICE:
+            case E_NOTICE:
+                break;
+            case E_USER_WARNING:
+            case E_WARNING:
+                if (defined('RETURN_ON_WARN') && RETURN_ON_WARN == true) {
                     break;
-                case E_USER_WARNING:
-                    case E_WARNING:
-                        if (defined('RETURN_ON_WARN') && RETURN_ON_WARN == true) {
-                            break;
-                        }
-                        case E_ERROR:
-                            case E_USER_ERROR:
-                                default:
-                                    $this -> file_not_found();
-                                }
-                                return true;
-                            }
+                }
+            case E_ERROR:
+            case E_USER_ERROR:
+            default:
+                $this -> file_not_found();
+        }
+        return true;
+    }
 
     /**
      * Function to print out debugging info
@@ -297,42 +311,42 @@
      * @param integer $debug_level debug if $debug_level <= FS_CURL_DEBUG
      * @param integer $spaces
      */
-                            public function debug($input, $debug_level=0, $spaces=0) {
-                                if (defined('FS_CURL_DEBUG') && $debug_level <= FS_CURL_DEBUG ) {
-                                    if (is_array($input)) {
-                                        $this -> debug('Array (', $debug_level, $spaces);
-                                        foreach ($input as $key=>$val) {
-                                            if (is_array($val) || is_object($val)) {
-                                                $this -> debug("[$key] => $val", $debug_level, $spaces+4);
-                                                $this -> debug('(', $debug_level, $spaces + 8);
-                                                $this -> debug($val, $debug_level, $spaces + 8);
-                                            } else {
-                                                $this -> debug("[$key] => '$val'", $debug_level, $spaces + 4);
-                                            }
-                                        }
-                                        $this -> debug(")", $debug_level, $spaces);
-                                    } else {
-                                        $debug_str = sprintf("%s%s"
-                                            , str_repeat(' ', $spaces), $input
-                                        );
-                                        switch (FS_DEBUG_TYPE) {
-                                            case 0:
-                                                syslog(LOG_NOTICE, $debug_str);
-                                                break;
-                                            case 1:
-                                                $debug_str = preg_replace('/--/', '- - ', $debug_str);
-                                                $this -> comment($debug_str);
-                                                break;
-                                            case 2:
-                                                $ptr = fopen(FS_DEBUG_FILE, 'a');
-                                                fputs($ptr, "$debug_str\r\n");
-                                                fclose($ptr);
-                                                break;
-                                            default:
-                                                return;
-                                            }
-                                        }
-                                    }
-                                }
-                            }
+    public function debug($input, $debug_level=0, $spaces=0) {
+        if (defined('FS_CURL_DEBUG') && $debug_level <= FS_CURL_DEBUG ) {
+            if (is_array($input)) {
+                $this -> debug('Array (', $debug_level, $spaces);
+                foreach ($input as $key=>$val) {
+                    if (is_array($val) || is_object($val)) {
+                        $this -> debug("[$key] => $val", $debug_level, $spaces+4);
+                        $this -> debug('(', $debug_level, $spaces + 8);
+                        $this -> debug($val, $debug_level, $spaces + 8);
+                    } else {
+                        $this -> debug("[$key] => '$val'", $debug_level, $spaces + 4);
+                    }
+                }
+                $this -> debug(")", $debug_level, $spaces);
+            } else {
+                $debug_str = sprintf("%s%s"
+                    , str_repeat(' ', $spaces), $input
+                );
+                switch (FS_DEBUG_TYPE) {
+                    case 0:
+                        syslog(LOG_NOTICE, $debug_str);
+                        break;
+                    case 1:
+                        $debug_str = preg_replace('/--/', '- - ', $debug_str);
+                        $this -> comment($debug_str);
+                        break;
+                    case 2:
+                        $ptr = fopen(FS_DEBUG_FILE, 'a');
+                        fputs($ptr, "$debug_str\r\n");
+                        fclose($ptr);
+                        break;
+                    default:
+                        return;
+                }
+            }
+        }
+    }
+}
 

Modified: freeswitch/trunk/contrib/intralanman/PHP/fs_curl/fs_dialplan.php (14946 => 14947)


--- freeswitch/trunk/contrib/intralanman/PHP/fs_curl/fs_dialplan.php	2009-09-22 02:55:26 UTC (rev 14946)
+++ freeswitch/trunk/contrib/intralanman/PHP/fs_curl/fs_dialplan.php	2009-09-22 02:59:03 UTC (rev 14947)
@@ -14,7 +14,7 @@
  * @author Raymond Chandler (intralanman) <intralanman@gmail.com>
  * @version 0.1
  * Class for XML dialplan
-*/
+ */
 class fs_dialplan extends fs_curl {
     private $special_class_file;
 
@@ -56,7 +56,7 @@
 
     public function is_specialized_dialplan($context) {
         $query = sprintf(
-        "SELECT * FROM dialplan_special WHERE context='%s'", $context
+            "SELECT * FROM dialplan_special WHERE context='%s'", $context
         );
         $res = $this -> db -> query($query);
         if (FS_PDO::isError($res)) {
@@ -81,23 +81,28 @@
      */
     private function get_dialplan($context) {
         $dp_array = array();
-		$dpQuery = sprintf("SELECT
-			`context`,
-			`name` as extension,
-			`application` as application_name,
-			`data` as application_data,
-			`field` as condition_field,
-			`expression` as condition_expression,
-			`continue` as ext_continue,
-			`type`
+        $dpQuery = sprintf('SELECT
+			%1$scontext%1$s,
+			%1$sname%1$s as extension,
+			%1$sapplication%1$s as application_name,
+			%1$sdata%1$s as application_data,
+			%1$sfield%1$s as condition_field,
+			%1$sexpression%1$s as condition_expression,
+			%1$scontinue%1$s as ext_continue,
+			%1$stype%1$s
 		FROM dialplan
 			INNER JOIN dialplan_context USING(dialplan_id)
 			INNER JOIN dialplan_extension USING(context_id)
 			INNER JOIN dialplan_condition USING(extension_id)
 			INNER JOIN dialplan_actions USING(condition_id)
-		WHERE context = '%s'
-		ORDER BY dialplan_context.weight, dialplan_extension.weight, dialplan_condition.weight, dialplan_actions.weight", $context);
-
+		WHERE context = \'%2$s\'
+		ORDER BY dialplan_context.weight,
+                 dialplan_extension.weight,
+                 dialplan_condition.weight,
+                 dialplan_actions.weight'
+            , DB_FIELD_QUOTE, $context
+        );
+        $this->debug($dpQuery);
         $res = $this -> db -> query($dpQuery);
         if (FS_PDO::isError($res)) {
             $this -> comment($this -> db -> getMessage());
@@ -117,10 +122,10 @@
             //$rcd = $row['re_cdata'];
             $cc = empty($row['cond_break']) ? '0' : $row['cond_break'];
             $dp_array[$ct]["$et;$ec"]["$cf;$ce;$cc"][] = array(
-            'type'=>$type,
-            'application'=>$app,
-            'data'=>$data,
-            'is_cdata'=>(empty($app_cdata) ? '' : $app_cdata)
+                'type'=>$type,
+                'application'=>$app,
+                'data'=>$data,
+                'is_cdata'=>(empty($app_cdata) ? '' : $app_cdata)
             );
         }
         return $dp_array;
@@ -134,21 +139,21 @@
      *
      */
     private function writeDialplan($dpArray) {
-        //print_r($dpArray);
+    //print_r($dpArray);
         if (is_array($dpArray)) {
             $this -> xmlw -> startElement('section');
             $this -> xmlw -> writeAttribute('name', 'dialplan');
             $this -> xmlw -> writeAttribute('description', 'FreeSWITCH Dialplan');
             //$this -> comment('dpArray is an array');
             foreach ($dpArray as $context => $extensions_array) {
-                //$this -> comment($context);
-                //start the context
+            //$this -> comment($context);
+            //start the context
                 $this -> xmlw -> startElement('context');
                 $this -> xmlw -> writeAttribute('name', $context);
                 if (is_array($extensions_array)) {
                     foreach ($extensions_array as $extension => $conditions) {
-                        //start an extension
-                        $ex_split = split(';', $extension);
+                    //start an extension
+                        $ex_split = preg_split('/;/', $extension);
                         $this -> xmlw -> startElement('extension');
                         $this -> xmlw -> writeAttribute('name', $ex_split[0]);
                         if (strlen($ex_split[1]) > 0) {
@@ -156,50 +161,51 @@
                         }
                         $this -> debug($conditions);
                         foreach ($conditions as $condition => $app_array) {
-                            $c_split = split(';', $condition);
+                            $c_split = preg_split('/;/', $condition);
                             $this -> xmlw -> startElement('condition');
                             if (!empty($c_split[0])) {
                                 $this -> xmlw -> writeAttribute('field', $c_split[0]);
                             }
                             if (!empty($c_split[1])) {
                                 if (array_key_exists(3, $c_split)
-                                && $c_split[3] == true) {
+                                    && $c_split[3] == true) {
                                     $this -> xmlw -> startElement('expression');
                                     $this -> xmlw -> writeCdata($c_split[1]);
                                     $this -> xmlw -> endElement();
                                 } else {
                                     $this -> xmlw -> writeAttribute(
-                                    'expression', $c_split[1]
+                                        'expression', $c_split[1]
                                     );
                                 }
                             }
                             //$this -> debug($c_split[2]);
                             if ($c_split[2] != '0') {
                                 $this -> xmlw -> writeAttribute(
-                                'break', $c_split[2]
+                                    'break', $c_split[2]
                                 );
                             }
                             //$this -> debug($app_array);
                             foreach ($app_array as $app) {
                                 if (empty($app['application'])) {
-                                	continue;
+                                    continue;
                                 }
                                 $this -> xmlw -> startElement($app['type']);
                                 $this -> xmlw -> writeAttribute(
-                                'application', $app['application']
+                                    'application', $app['application']
                                 );
                                 if (!empty($app['data'])) {
                                     if (array_key_exists('is_cdata', $app)
-                                    && $app['is_cdata'] == true) {
-                                        //$this -> xmlw -> startElement('data');
+                                        && $app['is_cdata'] == true) {
                                         $this -> xmlw -> writeCdata($app['data']);
-                                        //$this -> xmlw -> endElement();
                                     } else {
                                         $this -> xmlw -> writeAttribute(
-                                        'data', $app['data']
+                                            'data', $app['data']
                                         );
                                     }
                                 }
+                                if ($app['application'] == 'set') {
+                                    $this->xmlw->writeAttribute('inline', 'true');
+                                }
                                 $this -> xmlw -> endElement();
                             }
                             //</condition>