Renamed all SQL-related functions to camel-case notation

[mailer.git] / inc / referral-functions.php

diff --git a/inc/referral-functions.php b/inc/referral-functions.php
index 00163231172293bbbae85603989b8849338a1fe2..33d2735297e1a7e12c761e4df026190ca5b791d6 100644 (file)
--- a/inc/referral-functions.php
+++ b/inc/referral-functions.php
@@ -65,17 +65,17 @@ function getReferralLevelPercents ($level) {
                } // END - if
        } elseif (!isExtensionActive('cache')) {
                // Get referral data
-               $result_level = SQL_QUERY_ESC("SELECT `percents` FROM `{?_MYSQL_PREFIX?}_refdepths` WHERE `level`=%s LIMIT 1",
+               $result_level = sqlQueryEscaped("SELECT `percents` FROM `{?_MYSQL_PREFIX?}_refdepths` WHERE `level`=%s LIMIT 1",
                        array(bigintval($level)), __FUNCTION__, __LINE__);
 
                // Entry found?
-               if (SQL_NUMROWS($result_level) == 1) {
+               if (sqlNumRows($result_level) == 1) {
                        // Get percents
-                       $data = SQL_FETCHARRAY($result_level);
+                       $data = sqlFetchArray($result_level);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result_level);
+               sqlFreeResult($result_level);
        }
 
        // Return percent
@@ -137,7 +137,7 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
                        // Update points...
                        if (is_null($GLOBALS['ref_level'])) {
                                // Level NULL (self)
-                               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_points` SET `%s`=`%s`+%s WHERE `userid`=%s AND `ref_depth` IS NULL LIMIT 1",
+                               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_points` SET `%s`=`%s`+%s WHERE `userid`=%s AND `ref_depth` IS NULL LIMIT 1",
                                        array(
                                                $pointsColumn,
                                                $pointsColumn,
@@ -146,7 +146,7 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
                                        ), __FUNCTION__, __LINE__);
                        } else {
                                // Level 1+
-                               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_points` SET `%s`=`%s`+%s WHERE `userid`=%s AND `ref_depth`=%s LIMIT 1",
+                               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_points` SET `%s`=`%s`+%s WHERE `userid`=%s AND `ref_depth`=%s LIMIT 1",
                                        array(
                                                $pointsColumn,
                                                $pointsColumn,
@@ -158,9 +158,9 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'pointsColumn='.$pointsColumn.',ref_points='.$ref_points.',userid='.$userid.',depth='.convertNullToZero($GLOBALS['ref_level']).',mode='.$paymentMethod.' - UPDATE! ('.SQL_AFFECTEDROWS().')');
 
                        // No entry updated?
-                       if (SQL_HASZEROAFFECTED()) {
+                       if (ifSqlHasZeroAffectedRows()) {
                                // First ref in this level! :-)
-                               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_points` (`userid`, `ref_depth`, `%s`) VALUES (%s, %s, %s)",
+                               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_user_points` (`userid`, `ref_depth`, `%s`) VALUES (%s, %s, %s)",
                                        array(
                                                $pointsColumn,
                                                bigintval($userid),
@@ -171,7 +171,7 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
                        } // END - if
 
                        // Check affected rows
-                       $added = (SQL_AFFECTEDROWS() == 1);
+                       $added = (sqlAffectedRows() == 1);
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'added=' . intval($added) . ' - BEFORE FILTER');
 
                        // Prepare data for the filter
@@ -325,7 +325,7 @@ function updateReferralCounter ($userid) {
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refid(' . $refid . ')=' . $GLOBALS['cache_array']['ref_level'][$refid] . ' - ADVANCED!');
 
                // Update counter
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_refsystem` SET `counter`=`counter`+1 WHERE `userid`=%s AND `level`=%s LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_refsystem` SET `counter`=`counter`+1 WHERE `userid`=%s AND `level`=%s LIMIT 1",
                        array(
                                bigintval($refid),
                                bigintval($GLOBALS['cache_array']['ref_level'][$refid])
@@ -333,9 +333,9 @@ function updateReferralCounter ($userid) {
 
                // When no entry was updated then we have to create it here
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'refid=' . $refid . ',level=' . $GLOBALS['cache_array']['ref_level'][$refid] . ',updated=' . SQL_AFFECTEDROWS());
-               if (SQL_HASZEROAFFECTED()) {
+               if (ifSqlHasZeroAffectedRows()) {
                        // First count!
-                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_refsystem` (`userid`, `level`, `counter`) VALUES (%s,%s,1)",
+                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_refsystem` (`userid`, `level`, `counter`) VALUES (%s,%s,1)",
                                array(
                                        bigintval($refid),
                                        convertZeroToNull($GLOBALS['cache_array']['ref_level'][$refid])
@@ -360,7 +360,7 @@ function updateReferralCounter ($userid) {
 // Subtract points from database and mediadata cache
 function subtractPoints ($subject, $userid, $points) {
        // Add points to used points
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `used_points`=`used_points`+%s WHERE `userid`=%s LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `used_points`=`used_points`+%s WHERE `userid`=%s LIMIT 1",
                array(
                        $points,
                        bigintval($userid)
@@ -373,7 +373,7 @@ function subtractPoints ($subject, $userid, $points) {
                'points'      => $points,
                'points_mode' => 'sub',
                'column'      => 'used_points',
-               'added'       => (!SQL_HASZEROAFFECTED())
+               'added'       => (!ifSqlHasZeroAffectedRows())
        );
 
        // Insert booking record
@@ -389,7 +389,7 @@ function getUserReferralPoints ($userid, $level) {
        $refs = array();
 
        // Get refs from database
-       $result = SQL_QUERY_ESC('SELECT
+       $result = sqlQueryEscaped('SELECT
        `ur`.`id`,
        `ur`.`refid`,
        `ud`.`status`,
@@ -419,9 +419,9 @@ ORDER BY
                ), __FUNCTION__, __LINE__);
 
        // Are there some entries?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Fetch all entries
-               while ($row = SQL_FETCHARRAY($result)) {
+               while ($row = sqlFetchArray($result)) {
                        // Init click rate with zero
                        $row['click_rate'] = '0';
 
@@ -451,7 +451,7 @@ ORDER BY
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return result
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ' - EXIT!');
@@ -482,13 +482,13 @@ function getPointsDataArrayFromSubject ($subject) {
        } // END - if
 
        // Now checkout the entry in database table
-       $result = SQL_QUERY_ESC("SELECT `id`, `subject`, `column_name`, `locked_mode`, `payment_method`, `notify_recipient` FROM `{?_MYSQL_PREFIX?}_points_data` WHERE `subject`='%s' LIMIT 1",
+       $result = sqlQueryEscaped("SELECT `id`, `subject`, `column_name`, `locked_mode`, `payment_method`, `notify_recipient` FROM `{?_MYSQL_PREFIX?}_points_data` WHERE `subject`='%s' LIMIT 1",
                array($subject), __FUNCTION__, __LINE__);
 
        // Is there an entry?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Then load it
-               $pointsData = SQL_FETCHARRAY($result);
+               $pointsData = sqlFetchArray($result);
 
                // Add all entries to our cache array
                foreach ($pointsData as $key => $value) {
@@ -496,7 +496,7 @@ function getPointsDataArrayFromSubject ($subject) {
                } // END - foreach
        } else {
                // Register this automatically
-               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_points_data` (`subject`, `column_name`, `locked_mode`, `payment_method`, `notify_recipient`) VALUES ('%s','points','LOCKED','REFERRAL','N')",
+               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_points_data` (`subject`, `column_name`, `locked_mode`, `payment_method`, `notify_recipient`) VALUES ('%s','points','LOCKED','REFERRAL','N')",
                        array($subject), __FUNCTION__, __LINE__);
 
                // Re-request it
@@ -504,7 +504,7 @@ function getPointsDataArrayFromSubject ($subject) {
        }
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return it
        return $GLOBALS['cache_array']['points_data'][$subject];
@@ -577,14 +577,14 @@ function loadReferralTable ($userid) {
        $GLOBALS['referral_refid'][$userid] = array();
 
        // Get all level entries from the refsystem table
-       $GLOBALS['referral_result'][$userid] = SQL_QUERY_ESC('SELECT `level` FROM `{?_MYSQL_PREFIX?}_refsystem` WHERE `userid`=%s ORDER BY `level` ASC',
+       $GLOBALS['referral_result'][$userid] = sqlQueryEscaped('SELECT `level` FROM `{?_MYSQL_PREFIX?}_refsystem` WHERE `userid`=%s ORDER BY `level` ASC',
                array($userid), __FUNCTION__, __LINE__);
 
        // Are there entries?
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',SQL_NUMROWS()=' . SQL_NUMROWS($GLOBALS['referral_result'][$userid]));
-       if (SQL_NUMROWS($GLOBALS['referral_result'][$userid]) > 0) {
+       if (sqlNumRows($GLOBALS['referral_result'][$userid]) > 0) {
                // Then walk through all levels
-               while (list($level) = SQL_FETCHROW($GLOBALS['referral_result'][$userid])) {
+               while (list($level) = sqlFetchRow($GLOBALS['referral_result'][$userid])) {
                        // Init array
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level);
                        $GLOBALS['referral_refid'][$userid][$level] = array();
@@ -592,14 +592,14 @@ function loadReferralTable ($userid) {
                        // Level is = 1?
                        if ($level == 1) {
                                // Load all referrals of this user
-                               $GLOBALS['referral_result_refs'][$userid] = SQL_QUERY_ESC('SELECT `userid` FROM `{?_MYSQL_PREFIX?}_user_data` WHERE `refid`=%s ORDER BY `userid` ASC',
+                               $GLOBALS['referral_result_refs'][$userid] = sqlQueryEscaped('SELECT `userid` FROM `{?_MYSQL_PREFIX?}_user_data` WHERE `refid`=%s ORDER BY `userid` ASC',
                                        array($userid), __FUNCTION__, __LINE__);
 
                                // Are there entries?
                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',SQL_NUMROWS()=' . SQL_NUMROWS($GLOBALS['referral_result_refs'][$userid]));
-                               if (SQL_NUMROWS($GLOBALS['referral_result_refs'][$userid]) > 0) {
+                               if (sqlNumRows($GLOBALS['referral_result_refs'][$userid]) > 0) {
                                        // Then again walk through all
-                                       while (list($refid) = SQL_FETCHROW($GLOBALS['referral_result_refs'][$userid])) {
+                                       while (list($refid) = sqlFetchRow($GLOBALS['referral_result_refs'][$userid])) {
                                                // Add this refid
                                                array_push($GLOBALS['referral_refid'][$userid][$level], $refid);
                                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . $refid . ' - ADDED!');
@@ -610,13 +610,13 @@ function loadReferralTable ($userid) {
                                } // END - if
 
                                // Free result
-                               SQL_FREERESULT($GLOBALS['referral_result_refs'][$userid]);
+                               sqlFreeResult($GLOBALS['referral_result_refs'][$userid]);
                        } // END - if
                } // END - while
        } // END - if
 
        // Free result
-       SQL_FREERESULT($GLOBALS['referral_result'][$userid]);
+       sqlFreeResult($GLOBALS['referral_result'][$userid]);
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ' - EXIT!');
 }
 
@@ -718,7 +718,7 @@ function flushReferralTableToDatabase ($userid) {
        // And run it
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',SQL=' . $SQL);
        if ($executeSql === TRUE) {
-               SQL_QUERY($SQL, __FUNCTION__, __LINE__);
+               sqlQuery($SQL, __FUNCTION__, __LINE__);
        } // END - if
 
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ' - EXIT!');