Changeset 21390 for branches/version-2_12-dev/data/class/SC_Query.php

Timestamp:

2012/01/06 19:54:03 (12 years ago)

Author:

kotani

Message:

Merge from version-2_11-dev

File:

• branches/version-2_12-dev/data/class/SC_Query.php (modified) (11 diffs)

branches/version-2_12-dev/data/class/SC_Query.php

@@ -106 +106 @@
 
     /**
-     *  エラー判定を行う.
+     * エラー判定を行う.
      *
      * @deprecated PEAR::isError() を使用して下さい
@@ -126 +126 @@
      * @return integer 件数
      */
-    function count($table, $where = "", $arrWhereVal = array()) {
-        if(strlen($where) <= 0) {
-            $sqlse = "SELECT COUNT(*) FROM $table";
-        } else {
-            $sqlse = "SELECT COUNT(*) FROM $table WHERE $where";
-        }
-        $sqlse = $this->dbFactory->sfChangeMySQL($sqlse);
-        return $this->getOne($sqlse, $arrWhereVal);
+    function count($table, $where = '', $arrWhereVal = array()) {
+        return $this->get('COUNT(*)', $table, $where, $arrWhereVal);
+    }
+
+    /**
+     * EXISTS文を実行する.
+     *
+     * @param string $table テーブル名
+     * @param string $where where句
+     * @param array $arrWhereVal プレースホルダ
+     * @return boolean 有無
+     */
+    function exists($table, $where = '', $arrWhereVal = array()) {
+        $sql_inner = $this->getSql('*', $table, $where, $arrWhereVal);
+        $sql = "SELECT CASE WHEN EXISTS($sql_inner) THEN 1 ELSE 0 END";
+        $res = $this->getOne($sql, $arrWhereVal);
+        return (bool)$res;
     }
 
@@ -270 +279 @@
         }
 
-        return $affected->fetchAll($fetchmode);
+        // MySQL での不具合対応のため、一旦変数に退避
+        $arrRet = $affected->fetchAll($fetchmode);
+
+        // PREPAREの解放
+        $sth->free();
+
+        return $arrRet;
     }
 
@@ -454 +469 @@
      * @param string $table テーブル名
      * @param array $sqlval array('カラム名' => '値',...)の連想配列
+     * @param array $arrSql array('カラム名' => 'SQL文',...)の連想配列
+     * @param array $arrSqlVal SQL文の中で使用するプレースホルダ配列
      * @return
      */
-    function insert($table, $sqlval) {
+    function insert($table, $sqlval, $arrSql = array(), $arrSqlVal = array()) {
         $strcol = '';
         $strval = '';
         $find = false;
+        $arrVal = array();
 
         if(count($sqlval) <= 0 ) return false;
@@ -470 +488 @@
             } else {
                 $strval .= '?,';
-                $arrval[] = $val;
+                $arrVal[] = $val;
             }
             $find = true;
         }
+
+        foreach($arrSql as $key => $val) {
+            $strcol .= $key . ',';
+            $strval .= $val . ',';
+        }
+
+        $arrVal = array_merge($arrVal, $arrSqlVal);
+
         if(!$find) {
             return false;
@@ -482 +508 @@
         $sqlin = "INSERT INTO $table(" . $strcol. ") VALUES (" . $strval . ")";
         // INSERT文の実行
-        $ret = $this->query($sqlin, $arrval, false, null, MDB2_PREPARE_MANIP);
+        $ret = $this->query($sqlin, $arrVal, false, null, MDB2_PREPARE_MANIP);
 
         return $ret;
@@ -609 +635 @@
         }
 
-        return $affected->fetchOne();
+        // MySQL での不具合対応のため、一旦変数に退避
+        $arrRet = $affected->fetchOne();
+
+        // PREPAREの解放
+        $sth->free();
+
+        return $arrRet;
     }
 
@@ -637 +669 @@
         }
 
-        return $affected->fetchRow($fetchmode);
+        // MySQL での不具合対応のため、一旦変数に退避
+        $arrRet = $affected->fetchRow($fetchmode);
+
+        // PREPAREの解放
+        $sth->free();
+
+        return $arrRet;
     }
 
@@ -663 +701 @@
         }
 
-        return $affected->fetchCol();
+        // MySQL での不具合対応のため、一旦変数に退避
+        $arrRet = $affected->fetchCol();
+
+        // PREPAREの解放
+        $sth->free();
+
+        return $arrRet;
     }
 
@@ -744 +788 @@
         }
 
-        //PREPAREの解放
+        // PREPAREの解放
         $sth->free();
 
@@ -973 +1017 @@
         }
         $arrRet = $result->getColumnNames();
-        //PREPAREの解放
+        // PREPAREの解放
         $sth->free();