WebSVN – Applications.gtt – Diff – /trunk/bibliotheque/pear/DB/mssql.php

 /**
  * The PEAR DB driver for PHP's mssql extension
  * for interacting with Microsoft SQL Server databases
  *
- * PHP versions 4 and 5
+ * PHP version 5
+ *
  * LICENSE: This source file is subject to version 3.0 of the PHP license
  * that is available through the world-wide-web at the following URI:
  * http://www.php.net/license/3_0.txt.  If you did not receive a copy of
+ *
  * @category   Database
  * @package    DB
  * @author     Sterling Hughes <sterling@php.net>
  * @author     Daniel Convissor <danielc@php.net>
- * @copyright  1997-2005 The PHP Group
+ * @copyright  1997-2007 The PHP Group
  * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
- * @version    CVS: $Id: mssql.php,v 1.83 2005/03/07 18:24:51 danielc Exp $
+ * @version    CVS: $Id$
  * @link       http://pear.php.net/package/DB
  */
 /**
  * The methods PEAR DB uses to interact with PHP's mssql extension
  * for interacting with Microsoft SQL Server databases
+ *
  * These methods overload the ones declared in DB_common.
+ *
+ * DB's mssql driver is only for Microsfoft SQL Server databases.
+ *
+ * If you're connecting to a Sybase database, you MUST specify "sybase"
+ * as the "phptype" in the DSN.
+ *
+ * This class only works correctly if you have compiled PHP using
+ * --with-mssql=[dir_to_FreeTDS].
+ *
  * @category   Database
  * @package    DB
  * @author     Sterling Hughes <sterling@php.net>
  * @author     Daniel Convissor <danielc@php.net>
- * @copyright  1997-2005 The PHP Group
+ * @copyright  1997-2007 The PHP Group
  * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
- * @version    Release: 1.7.6
+ * @version    Release: 1.9.2
  * @link       http://pear.php.net/package/DB
  */
 class DB_mssql extends DB_common
+{
     // {{{ properties
      * A mapping of native error codes to DB error codes
      * @var array
      */
     // XXX Add here error codes ie: 'S100E' => DB_ERROR_SYNTAX
     var $errorcode_map = array(
+=> DB_ERROR_SYNTAX,
 => DB_ERROR_VALUE_COUNT_ON_ROW,
 => DB_ERROR_NOSUCHFIELD,
+=> DB_ERROR_SYNTAX,
 => DB_ERROR_SYNTAX,
 => DB_ERROR_NOSUCHFIELD,
 => DB_ERROR_NOSUCHTABLE,
 => DB_ERROR_INVALID_NUMBER,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_NOSUCHFIELD,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
 => DB_ERROR_CONSTRAINT_NOT_NULL,
 => DB_ERROR_CONSTRAINT,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
 => DB_ERROR_ALREADY_EXISTS,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
 => DB_ERROR_CONSTRAINT,
 => DB_ERROR_ALREADY_EXISTS,
+=> DB_ERROR_DIVZERO,
 => DB_ERROR_NOSUCHTABLE,
+=> DB_ERROR_SYNTAX,
 => DB_ERROR_DIVZERO,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
+=> DB_ERROR_SYNTAX,
     );
     /**
      * The raw database connection created by PHP
     // }}}
     // {{{ constructor
     /**
-     * This constructor calls <kbd>$this->DB_common()</kbd>
+     * This constructor calls <kbd>parent::__construct()</kbd>
+     *
      * @return void
      */
-    function DB_mssql()
+    function __construct()
+    {
-        $this->DB_common();
+        parent::__construct();
+    }
      *                + the DB_OK constant for other successful queries
      *                + a DB_Error object on failure
      */
     function simpleQuery($query)
+    {
-        $ismanip = DB::isManip($query);
+        $ismanip = $this->_checkManip($query);
         $this->last_query = $query;
         if (!@mssql_select_db($this->_db, $this->connection)) {
             return $this->mssqlRaiseError(DB_ERROR_NODBSELECTED);
+        }
         $query = $this->modifyQuery($query);
             if (!@mssql_data_seek($result, $rownum)) {
                 return null;
+            }
+        }
         if ($fetchmode & DB_FETCHMODE_ASSOC) {
-            $arr = @mssql_fetch_array($result, MSSQL_ASSOC);
+            $arr = @mssql_fetch_assoc($result);
             if ($this->options['portability'] & DB_PORTABILITY_LOWERCASE && $arr) {
                 $arr = array_change_key_case($arr, CASE_LOWER);
+            }
         } else {
             $arr = @mssql_fetch_row($result);
+     *
      * @see DB_result::free()
      */
     function freeResult($result)
+    {
-        return @mssql_free_result($result);
+        return is_resource($result) ? mssql_free_result($result) : false;
+    }
     // }}}
+     *
      * @return int  the number of rows.  A DB_Error object on failure.
      */
     function affectedRows()
+    {
-        if (DB::isManip($this->last_query)) {
+        if ($this->_last_query_manip) {
             $res = @mssql_query('select @@rowcount', $this->connection);
             if (!$res) {
                 return $this->mssqlRaiseError();
+            }
             $ar = @mssql_fetch_row($res);
                 $result = $this->createSequence($seq_name);
                 if (DB::isError($result)) {
                     return $this->raiseError($result);
+                }
             } elseif (!DB::isError($result)) {
+                $result = $this->query("SELECT IDENT_CURRENT('$seqname')");
+                if (DB::isError($result)) {
+                    /* Fallback code for MS SQL Server 7.0, which doesn't have
+                     * IDENT_CURRENT. This is *not* safe for concurrent
+                     * requests, and really, if you're using it, you're in a
+                     * world of hurt. Nevertheless, it's here to ensure BC. See
+                     * bug #181 for the gory details.*/
-                $result =& $this->query("SELECT @@IDENTITY FROM $seqname");
+                    $result = $this->query("SELECT @@IDENTITY FROM $seqname");
+                }
                 $repeat = 0;
             } else {
                 $repeat = false;
+            }
         } while ($repeat);
+    {
         return $this->query('DROP TABLE ' . $this->getSequenceName($seq_name));
+    }
+    // }}}
+    // {{{ escapeSimple()
+    /**
+     * Escapes a string in a manner suitable for SQL Server.
+     *
+     * @param string $str  the string to be escaped
+     * @return string  the escaped string
+     *
+     * @see DB_common::quoteSmart()
+     * @since Method available since Release 1.6.0
+     */
+    function escapeSimple($str)
+    {
+        return str_replace(
+            array("'", "\\\r\n", "\\\n"),
+            array("''", "\\\\\r\n\r\n", "\\\\\n\n"),
+            $str
+        );
+    }
     // }}}
     // {{{ quoteIdentifier()
     /**
         if ($mode) {
             $res['num_fields'] = $count;
+        }
+        for ($i = 0; $i < $count; $i++) {
+            if ($got_string) {
+                $flags = $this->_mssql_field_flags($result,
+                        @mssql_field_name($id, $i));
+                if (DB::isError($flags)) {
+                    return $flags;
+                }
+            } else {
+                $flags = '';
+            }
         for ($i = 0; $i < $count; $i++) {
             $res[$i] = array(
                 'table' => $got_string ? $case_func($result) : '',
                 'name'  => $case_func(@mssql_field_name($id, $i)),
                 'type'  => @mssql_field_type($id, $i),
-                'len'   => @mssql_field_length($id, $i),
-                // We only support flags for table
+                'len'   => @mssql_field_length($id, $i),
-                'flags' => $got_string
-                           ? $this->_mssql_field_flags($result,
-                                                       @mssql_field_name($id, $i))
-                           : '',
+                'flags' => $flags,
             );
             if ($mode & DB_TABLEINFO_ORDER) {
                 $res['order'][$res[$i]['name']] = $i;
+            }
             $flags = array();
             $tableName = $table;
+            // get unique and primary keys
+            $res = $this->getAll("EXEC SP_HELPINDEX $table", DB_FETCHMODE_ASSOC);
+            if (DB::isError($res)) {
-            // get unique and primary keys
+                return $res;
             $res = $this->getAll("EXEC SP_HELPINDEX[$table]", DB_FETCHMODE_ASSOC);
+                    }
+                }
+            }
             // get auto_increment, not_null and timestamp
+            $res = $this->getAll("EXEC SP_COLUMNS $table", DB_FETCHMODE_ASSOC);
+            if (DB::isError($res)) {
+                return $res;
             $res = $this->getAll("EXEC SP_COLUMNS[$table]", DB_FETCHMODE_ASSOC);
             foreach ($res as $val) {
                 $val = array_change_key_case($val, CASE_LOWER);

Subversion Repositories Applications.gtt

(root)/trunk/bibliotheque/pear/DB/mssql.php – Rev 94 → 187