ok

Author: wjzhangq

db.php

@@ -146,7 +146,7 @@ function query()
                 throw  new Exception ('Unsuport param for query!', 10);
                 break;
         }
-     echo $sql;
+
         if ($param)
         {
             $sth = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
@@ -219,6 +219,21 @@ function insert($data)
         return $this->table_key ? $this->db->lastInsertId() : null; //有主键返回主键值
     }
 
+    //替换
+    function replace($data){
+        $set = $this->build_query($data);
+        if ($set){
+            $sql = 'REPLACE INTO `'.$this->table_name.'` SET ' . implode(', ', $set[0]);
+
+            $this->db->query($sql, $set[1]);
+
+            return $this->table_key ? $this->db->lastInsertId() : null; //有主键返回主键值
+        }
+        
+        return null;
+
+    }
+    
     //查询
     function query($where){
         $where = $this->offset_parse($where);

test.php

@@ -2,7 +2,6 @@
 require 'db.php';
 
 $db = new db('mysql:host=127.0.0.1;dbname=test', 'root', 'root');
-
-var_dump(count($db['t1']->where(array('id:>'=>0))));
+$db['t1']->replace(array('id'=>7, 'value'=>14));