Changeset 3714

Timestamp:

07/19/07 20:49:13 (3 years ago)

Author:

coolengineer

Message:

• #454
• mysql_tc_query 를 DBQuery::query 로 모두 바꿈.

Location:

trunk

Files:

• components/Eolin.PHP.Core.php (modified) (11 diffs)
• plugins/PN_Subscription_Default/index.php (modified) (1 diff)

trunk/components/Eolin.PHP.Core.php

@@ -958 +958 @@
 }
 
-function mysql_tc_query($query) {
-    global $_queryCache;
-    if( function_exists( '__tcSqlLogBegin' ) ) {
-        __tcSqlLogBegin($query);
-    }
-    $result = mysql_query($query);
-    if( function_exists( '__tcSqlLogEnd' ) ) {
-        __tcSqlLogEnd($result,false);
-    }
-    return $result;
-}
-
-function mysql_tc_clear_cache() {
-    global $cachedResult;
-    $cachedResult = array();
-}
+global $cachedResult;
+global $fileCachedResult;
+$cachedResult = array();
 
 class DBQuery { 
     /*@static@*/ 
     function queryExistence($query) {
-        $query = DBQuery::queryPostProcessing($query);
-        if ($result = mysql_tc_query($query)) {
+        if ($result = DBQuery::query($query)) {
             if (mysql_num_rows($result) > 0) {
                 mysql_free_result($result);
@@ -991 +977 @@
     /*@static@*/
     function queryCount($query) {
-        $query = DBQuery::queryPostProcessing($query);
         $count = 0;
-        if ($result = mysql_tc_query($query)) {
+        if ($result = DBQuery::query($query)) {
             $count = mysql_num_rows($result);
             mysql_free_result($result);
@@ -1035 +1020 @@
     /*@static@*/
     function queryColumn($query, $useCache=true) {
-        $query = DBQuery::queryPostProcessing($query);
-
         global $cachedResult;
         $cacheKey = "{$query}_queryColumn";
@@ -1049 +1032 @@
 
         $column = null;
-        if ($result = mysql_tc_query($query)) {
+        if ($result = DBQuery::query($query)) {
             $column = array();
             while ($row = mysql_fetch_row($result))
@@ -1064 +1047 @@
     /*@static@*/
     function queryAll($query, $type = MYSQL_BOTH, $count = -1) {
-        $query = DBQuery::queryPostProcessing($query);
         $all = array();
-        if ($result = mysql_tc_query($query)) {
+        if ($result = DBQuery::query($query)) {
             while ( ($count-- !=0) && $row = mysql_fetch_array($result, $type))
                 array_push($all, $row);
@@ -1093 +1075 @@
     /*@static@*/
     function execute($query) {
-        $query = DBQuery::queryPostProcessing($query);
-        return mysql_tc_query($query) ? true : false;
-    }
-
-    /*@static@*/
-    function query($query) {
-        $query = DBQuery::queryPostProcessing($query);
-        return mysql_tc_query($query);
-    }
+        return DBQuery::query($query) ? true : false;
+    }
+
+    /*@static@*/
     function queryPostProcessing($query) {
         global $service;
@@ -1107 +1084 @@
 
     }
+
+    /*@static@*/
+    function query($query) {
+        $query = DBQuery::queryPostProcessing($query);
+        if( function_exists( '__tcSqlLogBegin' ) ) {
+            __tcSqlLogBegin($query);
+            $result = mysql_query($query);
+            __tcSqlLogEnd($result,false);
+        } else {
+            $result = mysql_query($query);
+        }
+        if( stristr($query, 'update ') ||
+            stristr($query, 'insert ') ||
+            stristr($query, 'update ') ||
+            stristr($query, 'replace ') ) {
+            DBQuery::clearCache();
+        }
+        return $result;
+    }
+
+    function clearCache() {
+        global $cachedResult;
+        $cachedResult = array();
+        if( function_exists( '__tcSqlLogBegin' ) ) {
+            __tcSqlLogBegin("Cache cleared");
+            __tcSqlLogEnd(null,true);
+        }
+    }
+
+    function cacheSave() {
+    }
+}
+
+register_shutdown_function( array('DBQuery',cacheSave) );
+
+function mysql_tc_query($sql) {
+    return DBQuery::query($sql);
 }
 
@@ -1204 +1218 @@
             return false;
         $this->_query = 'INSERT INTO ' . $this->table . '(' . implode(',', array_keys($attributes)) . ') VALUES(' . implode(',', $attributes) . ')';
-        if (mysql_tc_query($this->_query)) {
+        if (DBQuery::query($this->_query)) {
             $this->id = mysql_insert_id();
             return true;
@@ -1218 +1232 @@
             array_push($attributes, $name . '=' . $value);
         $this->_query = 'UPDATE ' . $this->table . ' SET ' . implode(',', $attributes) . $this->_makeWhereClause();
-        if (mysql_tc_query($this->_query))
+        if (DBQuery::query($this->_query))
             return true;
         return false;
@@ -1231 +1245 @@
             return false;
         $this->_query = 'REPLACE INTO ' . $this->table . '(' . implode(',', array_keys($attributes)) . ') VALUES(' . implode(',', $attributes) . ')';
-        if (mysql_tc_query($this->_query)) {
+        if (DBQuery::query($this->_query)) {
             $this->id = mysql_insert_id();
             return true;
@@ -1242 +1256 @@
             return false;
         $this->_query = 'DELETE FROM ' . $this->table . $this->_makeWhereClause();
-        if (mysql_tc_query($this->_query))
+        if (DBQuery::query($this->_query))
             return true;
         return false;

trunk/plugins/PN_Subscription_Default/index.php

@@ -234 +234 @@
     global $database;
     $statistics = array();
-    if ($result = mysql_query("select ip, host, useragent, subscribed, referred from {$database['prefix']}SubscriptionStatistics where blogid = $blogid order by referred desc")) {
+    if ($result = DBQuery::query("select ip, host, useragent, subscribed, referred from {$database['prefix']}SubscriptionStatistics where blogid = $blogid order by referred desc")) {
         while ($record = mysql_fetch_array($result))
             array_push($statistics, $record);