Renamed all SQL-related functions to camel-case notation
authorRoland Häder <roland@mxchange.org>
Wed, 6 Mar 2013 00:24:19 +0000 (00:24 +0000)
committerRoland Häder <roland@mxchange.org>
Wed, 6 Mar 2013 00:24:19 +0000 (00:24 +0000)
226 files changed:
DOCS/de/SECURITY.txt
DOCS/de/TODO.txt
DOCS/en/SECURITY.txt
DOCS/en/TODO.txt
beg.php
birthday_confirm.php
debug.php
doubler.php
inc/ajax/ajax_installer.php
inc/callback-functions.php
inc/classes/resolver.class.php
inc/config-functions.php
inc/daily/daily_100_bonus.php
inc/daily/daily_birthday.php
inc/daily/daily_holiday.php
inc/daily/daily_order.php
inc/daily/daily_profile.php
inc/daily/daily_user.php
inc/daily/daily_user_subids.php
inc/db/lib-mysql3.php
inc/extensions-functions.php
inc/extensions/ext-mydata.php
inc/extensions/ext-rewrite.php
inc/extensions/order/mode-update.php
inc/filter-functions.php
inc/filter/beg_filter.php
inc/filter/bonus_filter.php
inc/filter/earning_filter.php
inc/filter/online_filter.php
inc/filter/rallye_filter.php
inc/filter/register_filter.php
inc/filter/user_filter.php
inc/filters.php
inc/fix_filters.php
inc/fix_menu.php
inc/fix_refsystem.php
inc/fix_user_points.php
inc/functions.php
inc/gen_mediadata.php
inc/http-functions.php
inc/install-functions.php
inc/install/install_page_finalize.php
inc/language/de.php
inc/libs/admins_functions.php
inc/libs/beg_functions.php
inc/libs/blacklist_functions.php
inc/libs/bonus_functions.php
inc/libs/booking_functions.php
inc/libs/country_functions.php
inc/libs/doubler_functions.php
inc/libs/earning_functions.php
inc/libs/forced_functions.php
inc/libs/grade_functions.php
inc/libs/holiday_functions.php
inc/libs/jackpot_functions.php
inc/libs/mailid_functions.php
inc/libs/mediadata_functions.php
inc/libs/network_functions.php
inc/libs/optimize_functions.php
inc/libs/payout_functions.php
inc/libs/rallye_functions.php
inc/libs/refback_functions.php
inc/libs/register_functions.php
inc/libs/sponsor_functions.php
inc/libs/surfbar_functions.php
inc/libs/task_functions.php
inc/libs/theme_functions.php
inc/libs/transfer_functions.php
inc/libs/user_functions.php
inc/libs/wernis_functions.php
inc/libs/yoomedia_functions.php
inc/loader/load-
inc/loader/load-admins.php
inc/loader/load-config.php
inc/loader/load-earning.php
inc/loader/load-extension.php
inc/loader/load-filter.php
inc/loader/load-imprint.php
inc/loader/load-modules.php
inc/loader/load-payments.php
inc/loader/load-points_data.php
inc/loader/load-refdepths.php
inc/loader/load-refsystem.php
inc/loader/load-themes.php
inc/mails/beg_mails.php
inc/mails/bonus_mails.php
inc/mails/doubler_mails.php
inc/module-functions.php
inc/modules/admin/admin-inc.php
inc/modules/admin/overview-inc.php
inc/modules/admin/what-add_points.php
inc/modules/admin/what-add_rallye.php
inc/modules/admin/what-admin_add.php
inc/modules/admin/what-adminedit.php
inc/modules/admin/what-admins_mails.php
inc/modules/admin/what-config_home.php
inc/modules/admin/what-config_imprint.php
inc/modules/admin/what-config_network_api.php
inc/modules/admin/what-config_network_types.php
inc/modules/admin/what-config_payouts.php
inc/modules/admin/what-config_register.php
inc/modules/admin/what-config_rewrite.php
inc/modules/admin/what-del_email.php
inc/modules/admin/what-del_holiday.php
inc/modules/admin/what-del_sponsor.php
inc/modules/admin/what-del_transfer.php
inc/modules/admin/what-edit_emails.php
inc/modules/admin/what-edit_sponsor.php
inc/modules/admin/what-edit_user.php
inc/modules/admin/what-email_archiv.php
inc/modules/admin/what-email_details.php
inc/modules/admin/what-extensions.php
inc/modules/admin/what-guest_add.php
inc/modules/admin/what-guestedit.php
inc/modules/admin/what-list_admins_acls.php
inc/modules/admin/what-list_autopurge.php
inc/modules/admin/what-list_bank_package.php
inc/modules/admin/what-list_beg.php
inc/modules/admin/what-list_bonus.php
inc/modules/admin/what-list_cats.php
inc/modules/admin/what-list_country.php
inc/modules/admin/what-list_coupon.php
inc/modules/admin/what-list_email_max_rec.php
inc/modules/admin/what-list_holiday.php
inc/modules/admin/what-list_links.php
inc/modules/admin/what-list_mods.php
inc/modules/admin/what-list_network_array_translation.php
inc/modules/admin/what-list_network_data.php
inc/modules/admin/what-list_network_request_params.php
inc/modules/admin/what-list_network_types.php
inc/modules/admin/what-list_notifications.php
inc/modules/admin/what-list_payouts.php
inc/modules/admin/what-list_rallye_prices.php
inc/modules/admin/what-list_rallyes.php
inc/modules/admin/what-list_refs.php
inc/modules/admin/what-list_sponsor.php
inc/modules/admin/what-list_sponsor_pay.php
inc/modules/admin/what-list_sponsor_pays.php
inc/modules/admin/what-list_task.php
inc/modules/admin/what-list_transfer.php
inc/modules/admin/what-list_unconfirmed.php
inc/modules/admin/what-list_user.php
inc/modules/admin/what-list_user_amounts.php
inc/modules/admin/what-list_user_cats.php
inc/modules/admin/what-list_user_subid.php
inc/modules/admin/what-list_wernis.php
inc/modules/admin/what-lock_sponsor.php
inc/modules/admin/what-lock_user.php
inc/modules/admin/what-logs.php
inc/modules/admin/what-mem_add.php
inc/modules/admin/what-memedit.php
inc/modules/admin/what-payments.php
inc/modules/admin/what-refbanner.php
inc/modules/admin/what-repair_amnu.php
inc/modules/admin/what-repair_cats.php
inc/modules/admin/what-repair_gmnu.php
inc/modules/admin/what-repair_mmnu.php
inc/modules/admin/what-send_coupon.php
inc/modules/admin/what-send_newsletter.php
inc/modules/admin/what-stats_mods.php
inc/modules/admin/what-sub_points.php
inc/modules/admin/what-surfbar_stats.php
inc/modules/admin/what-theme_edit.php
inc/modules/admin/what-theme_import.php
inc/modules/admin/what-unlock_emails.php
inc/modules/admin/what-unlock_sponsor.php
inc/modules/admin/what-usage.php
inc/modules/admin/what-usr_online.php
inc/modules/frametester.php
inc/modules/guest/what-active.php
inc/modules/guest/what-login.php
inc/modules/guest/what-mediadata.php
inc/modules/guest/what-rallyes.php
inc/modules/guest/what-register.php
inc/modules/guest/what-sponsor_infos.php
inc/modules/guest/what-sponsor_login.php
inc/modules/guest/what-sponsor_reg.php
inc/modules/guest/what-stats.php
inc/modules/guest/what-top10.php
inc/modules/member/what-beg2.php
inc/modules/member/what-bonus.php
inc/modules/member/what-cash_coupon.php
inc/modules/member/what-categories.php
inc/modules/member/what-earning.php
inc/modules/member/what-holiday.php
inc/modules/member/what-html_mail.php
inc/modules/member/what-list_coupon.php
inc/modules/member/what-mydata.php
inc/modules/member/what-nickname.php
inc/modules/member/what-order.php
inc/modules/member/what-payout.php
inc/modules/member/what-points.php
inc/modules/member/what-rallyes.php
inc/modules/member/what-refback.php
inc/modules/member/what-reflinks.php
inc/modules/member/what-reflist.php
inc/modules/member/what-stats.php
inc/modules/member/what-subids.php
inc/modules/member/what-themes.php
inc/modules/member/what-transfer.php
inc/modules/member/what-unconfirmed.php
inc/modules/member/what-wernis.php
inc/modules/sponsor/account.php
inc/modules/sponsor/settings.php
inc/modules/sponsor/welcome.php
inc/monthly/monthly_beg.php
inc/monthly/monthly_bonus.php
inc/mysql-manager.php
inc/pool-functions.php
inc/pool/pool-bonus.php
inc/pool/pool-user.php
inc/purge/purge-coupon.php
inc/purge/purge-general.php
inc/purge/purge-inact.php
inc/purge/purge-mails.php
inc/purge/purge-tasks.php
inc/purge/purge-unconfirmed.php
inc/referral-functions.php
inc/request-functions.php
inc/session-functions.php
inc/sql-functions.php
inc/stats-functions.php
inc/template-functions.php
inc/wrapper-functions.php
mailid.php
show_bonus.php

index dab710d..ccf07b9 100644 (file)
@@ -125,7 +125,7 @@ Bis zur Version 0.2.0-pre10 mit Patch-Level 485 und aelter war es fuer einen
 entfernten Angreifer theoretisch moeglich, SQL-Befehle einzuschleusen und auch
 Attacken auf die Variable $PHP_SELF durchzufueheren. Seit Patch 486 und 487
 (laden Sie sich am Besten immer die aktuellsten Patches herunter!) sind nun
-entsprechende Zeilen aus der inc/db/lib-mysql3.php (Funktion SQL_QUERY_ESC)
+entsprechende Zeilen aus der inc/db/lib-mysql3.php (Funktion sqlQueryEscaped)
 entfernt und sollten nicht mehr angreifbar sein. Der generierten SQL-Befehl
 wurde vor der Ausfuehrung nochmals "uebersetzt", also alle
 sicherheitsgefaehrdenen Zeichen wieder eingebaut. Zudem existiert im Script
index 90915f1..f755bef 100644 (file)
 
 - Den gesamten HTML-Code auf XHTML portieren und mit http://validator.w3.org validieren
 - Replace all HTTP_GET_VARS and HTTP_POST_VARS with _GET and _POST
-- Replace SQL_QUERY() command with SQL_QUERY_ESC() commands where ever it is
+- Replace sqlQuery() command with sqlQueryEscaped() commands where ever it is
   needed to secure SQL queries.
 - Secure ID numbers with bigintval()
 - Secure other non-numberous data with sprintf() and later with new security
   functions
-- Use the abstract function SQL_FREERESULT() wherever we transfer massive data
+- Use the abstract function sqlFreeResult() wherever we transfer massive data
   from the database to free memory
index 5e50920..e0cea89 100644 (file)
@@ -122,7 +122,7 @@ Bis zur Version 0.2.0-pre10 mit Patch-Level 485 und aelter war es fuer einen
 entfernten Angreifer theoretisch moeglich, SQL-Befehle einzuschleusen und auch
 Attacken auf die Variable $PHP_SELF durchzufueheren. Seit Patch 486 und 487
 (laden Sie sich am Besten immer die aktuellsten Patches herunter!) sind nun
-entsprechende Zeilen aus der inc/db/lib-mysql3.php (Funktion SQL_QUERY_ESC)
+entsprechende Zeilen aus der inc/db/lib-mysql3.php (Funktion sqlQueryEscaped)
 entfernt sollten nicht mehr angreifbar sein. Der generierten SQL-Befehl wurde
 vor der Ausfuehrung nochmals "uebersetzt", also alle sicherheitsgefaehrdenen
 Zeichen wieder eingebaut. Zudem existiert im Script
index 481a7c1..f316a25 100644 (file)
@@ -5,9 +5,9 @@ TODO
 
 - Extend the documenation!
 - Complete english language translation
-- Replace SQL_QUERY() command with SQL_QUERY_ESC() commands where ever it is
+- Replace sqlQuery() command with sqlQueryEscaped() commands where ever it is
   needed to secure SQL queries.
-- Use the abstract function SQL_FREERESULT() wherever we trasnfer massive data
+- Use the abstract function sqlFreeResult() wherever we trasnfer massive data
   from the database to free memory
 - Simplify CSS classes
 - Add more database abstraction layers like ODBC/M$SQL/Oracle
diff --git a/beg.php b/beg.php
index d585e56..81cb992 100644 (file)
--- a/beg.php
+++ b/beg.php
@@ -96,11 +96,11 @@ if (isGetRequestElementSet('userid')) {
        // User id valid and not webmaster's id?
        if ((isValidId(getUserData('userid'))) && (getBegUserid() != getUserData('userid'))) {
                // Update counter
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `beg_clicks`=`beg_clicks`+1 WHERE `userid`=%s LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `beg_clicks`=`beg_clicks`+1 WHERE `userid`=%s LIMIT 1",
                        array(getUserData('userid')), __FILE__, __LINE__);
 
                // Check for last entry for userid w/o IP number                            12              33                               2    23              44            3                                          21     1                              1
-               $result = SQL_QUERY_ESC("SELECT `id` FROM `{?_MYSQL_PREFIX?}_beg_ips` WHERE ((UNIX_TIMESTAMP() - `timeout`) >= {?beg_timeout?} OR ((UNIX_TIMESTAMP() - `timeout`) >= {?beg_userid_timeout?} AND `userid`=%s)) AND (`remote_ip`='%s' OR `sid`='%s') LIMIT 1",
+               $result = sqlQueryEscaped("SELECT `id` FROM `{?_MYSQL_PREFIX?}_beg_ips` WHERE ((UNIX_TIMESTAMP() - `timeout`) >= {?beg_timeout?} OR ((UNIX_TIMESTAMP() - `timeout`) >= {?beg_userid_timeout?} AND `userid`=%s)) AND (`remote_ip`='%s' OR `sid`='%s') LIMIT 1",
                        array(
                                getUserData('userid'),
                                determineRealRemoteAddress(),
@@ -109,7 +109,7 @@ if (isGetRequestElementSet('userid')) {
 
                // Entry not found, points set and not logged in?
                //* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'SQL_HASZERONUMS()=' . intval(SQL_HASZERONUMS($result)) . ',isAdmin()=' . intval(isAdmin()) . ',points=' . $points . ',isMember()=' . intval(isMember()) . ',getBegPayMode()=' . getBegPayMode());
-               if ((SQL_HASZERONUMS($result)) && ($points > 0) && (getBegPayMode() == 'NONE') && ((!isMember()) || (isAdmin()))) {
+               if ((ifSqlHasZeroNums($result)) && ($points > 0) && (getBegPayMode() == 'NONE') && ((!isMember()) || (isAdmin()))) {
                        // Default is result from isAdmin(), mostly false
                        $isPayed = isAdmin();
 
@@ -120,7 +120,7 @@ if (isGetRequestElementSet('userid')) {
                                 * but only when there is no admin begging.
                                 * Admins shall be able to test it!
                                 */
-                               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_beg_ips` (`userid`, `remote_ip`, `sid`, `timeout`) VALUES ('%s','%s','%s', UNIX_TIMESTAMP())",
+                               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_beg_ips` (`userid`, `remote_ip`, `sid`, `timeout`) VALUES ('%s','%s','%s', UNIX_TIMESTAMP())",
                                        array(
                                                getUserData('userid'),
                                                determineRealRemoteAddress(),
@@ -128,7 +128,7 @@ if (isGetRequestElementSet('userid')) {
                                        ), __FILE__, __LINE__);
 
                                // Was is successfull?
-                               $isPayed = (!SQL_HASZEROAFFECTED());
+                               $isPayed = (!ifSqlHasZeroAffectedRows());
                        } // END - if
 
                        // Pay points?
@@ -159,7 +159,7 @@ if (isGetRequestElementSet('userid')) {
                }
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
 
                // Include header
                loadIncludeOnce('inc/header.php');
index 219a15f..e3827d8 100644 (file)
@@ -61,7 +61,7 @@ $userid = bigintval(getRequestElement('userid'));
 $chk = bigintval(getRequestElement('check'), FALSE);
 
 // Check if link is not clicked so far
-$result = SQL_QUERY_ESC("SELECT
+$result = sqlQueryEscaped("SELECT
        `b`.`points`,
        `d`.`userid`,
        `d`.`gender`,
@@ -89,9 +89,9 @@ LIMIT 1",
 $content = array();
 
 // Is an entry there?
-if (SQL_NUMROWS($result) == 1) {
+if (sqlNumRows($result) == 1) {
        // Ok, congratulation again! Here's your gift from us...
-       $data = SQL_FETCHARRAY($result, FALSE);
+       $data = sqlFetchArray($result, FALSE);
 
        // Is the account confirmed?
        if ($data['status'] == 'CONFIRMED') {
@@ -100,7 +100,7 @@ if (SQL_NUMROWS($result) == 1) {
                addPointsThroughReferralSystem('birthday_confirm', $userid, $data['points']);
 
                // Remove entry from table
-               SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_birthday` WHERE `userid`=%s AND `chk_value`='%s' LIMIT 1",
+               sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_birthday` WHERE `userid`=%s AND `chk_value`='%s' LIMIT 1",
                        array($userid, $chk), __FILE__, __LINE__);
 
                // Load message from template
@@ -115,7 +115,7 @@ if (SQL_NUMROWS($result) == 1) {
 }
 
 // Free memory
-SQL_FREERESULT($result);
+sqlFreeResult($result);
 
 // Set this because there is no module in URI
 $GLOBALS['__module'] = 'birthday_confirm';
index 36638d2..10af24c 100644 (file)
--- a/debug.php
+++ b/debug.php
@@ -57,7 +57,7 @@ if ((isExtensionActive('debug')) && (!ifFatalErrorsDetected())) {
                        // Construct FQFN for the module
                        $inc = sprintf("inc/debug/%s/request_%s.php",
                                getConfig('debug_mode'),
-                               SQL_ESCAPE(postRequestElement('request'))
+                               sqlEscapeString(postRequestElement('request'))
                        );
 
                        // Is the module there? Else we log it!
index 72f7123..5d4c3ce 100644 (file)
@@ -99,7 +99,7 @@ if (isFormSent()) {
                        if (($points - getConfig('doubler_left') - postRequestElement('points') * getDoublerCharge() / 100) >= 0) {
                                // Enough points are left so let's continue with the doubling process
                                // Create doubling "account" with *DOUBLED* points
-                               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_doubler` (`userid`, `refid`, `points`, `remote_ip`, `timemark`, `completed`, `is_ref`) VALUES (%s,%s,%s,'%s', UNIX_TIMESTAMP(), 'N','N')",
+                               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_doubler` (`userid`, `refid`, `points`, `remote_ip`, `timemark`, `completed`, `is_ref`) VALUES (%s,%s,%s,'%s', UNIX_TIMESTAMP(), 'N','N')",
                                        array(
                                                getUserData('userid'),
                                                convertZeroToNull(determineReferralId()),
@@ -118,7 +118,7 @@ if (isFormSent()) {
                                // Add second line for the referral but only when userid != refid
                                if ((isValidId(determineReferralId())) && (determineReferralId() != getUserData('userid'))) {
                                        // Okay add a refid line and apply refid percents
-                                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_doubler` (`userid`, `refid`, `points`, `remote_ip`, `timemark`, `completed`, `is_ref`) VALUES (%s,0,%s,'%s',UNIX_TIMESTAMP(),'N','Y')",
+                                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_doubler` (`userid`, `refid`, `points`, `remote_ip`, `timemark`, `completed`, `is_ref`) VALUES (%s,0,%s,'%s',UNIX_TIMESTAMP(),'N','Y')",
                                                array(
                                                        convertZeroToNull(determineReferralId()),
                                                        (postRequestElement('points') * 2 * getDoublerRef() / 100),
index 55b2be0..108fd3e 100644 (file)
@@ -57,7 +57,7 @@ function establishAjaxInstallerDatabaseLink () {
        unsetSqlLinkUp(__FUNCTION__, __LINE__);
 
        // Establish link
-       $linkResource = SQL_CONNECT(getSession('mysql_host'), getSession('mysql_login'), getSession('mysql_password1'), __FUNCTION__, __LINE__);
+       $linkResource = sqlConnectToDatabase(getSession('mysql_host'), getSession('mysql_login'), getSession('mysql_password1'), __FUNCTION__, __LINE__);
 
        // Is this a link resource?
        if (!is_resource($linkResource)) {
@@ -66,7 +66,7 @@ function establishAjaxInstallerDatabaseLink () {
        } // END - if
 
        // Does selecting the database work?
-       if (!SQL_SELECT_DB(getSession('mysql_dbase'), __FUNCTION__, __LINE__)) {
+       if (!sqlSelectDatabase(getSession('mysql_dbase'), __FUNCTION__, __LINE__)) {
                // Could not be selected
                reportBug(__FUNCTION__, __LINE__, 'Could not select database ' . getSession('mysql_dbase'));
        } elseif ((!isFileReadable(getSession('base_path') . 'install/tables.sql')) || (!isFileReadable(getSession('base_path') . 'install/menu-'.getLanguage().'.sql'))) {
@@ -578,7 +578,7 @@ function doAjaxInstallerStepImportTablesSql () {
        runFilterChain('run_sqls');
 
        // Close SQL link
-       SQL_CLOSE(__FUNCTION__, __LINE__);
+       sqlCloseLink(__FUNCTION__, __LINE__);
 }
 
 // Call-back function to import menu SQL file
@@ -602,7 +602,7 @@ function doAjaxInstallerStepImportMenuSql () {
        runFilterChain('run_sqls');
 
        // Close SQL link
-       SQL_CLOSE(__FUNCTION__, __LINE__);
+       sqlCloseLink(__FUNCTION__, __LINE__);
 }
 
 // Call-back function to install some important extensions
index 3a3edeb..821bbd4 100644 (file)
@@ -1349,7 +1349,7 @@ function doXmlNoEntryFoundMessage ($resource, $attributes) {
 // Checks for string without any added extra data
 function isXmlTypeString ($value) {
        // Just let SQL_ESCAPE() do the job
-       return ($value == SQL_ESCAPE($value));
+       return ($value == sqlEscapeString($value));
 }
 
 // Fake-check for array type
index 09846cf..aca38bb 100644 (file)
@@ -66,13 +66,13 @@ class HostnameResolver {
                $ret = '0.0.0.0';
 
                // Search for hostname in cache
-               $result = SQL_QUERY_ESC("SELECT `ip` FROM `{?_MYSQL_PREFIX?}_dns_cache` WHERE `hostname`='%s' LIMIT 1",
+               $result = sqlQueryEscaped("SELECT `ip` FROM `{?_MYSQL_PREFIX?}_dns_cache` WHERE `hostname`='%s' LIMIT 1",
                        array($hostname), __METHOD__, __LINE__);
 
                // Does an entry exist?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Then load the hostname
-                       list($ip) = SQL_FETCHROW($result);
+                       list($ip) = sqlFetchRow($result);
 
                        // Count cache hit
                        incrementStatsEntry('dns_cache_hits');
@@ -93,7 +93,7 @@ class HostnameResolver {
                                // Seems to be an IP! Now check deeper...
                                if (($matches[0] == $ip) && ($matches[1] >= 0) && ($matches[1] <= 255) && ($matches[2] >= 0) && ($matches[2] <= 255) && ($matches[3] >= 0) && ($matches[3] <= 255) && ($matches[4] > 0) && ($matches[4] < 255)) {
                                        // We also cache IP addresses
-                                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_dns_cache` (`ip`, `hostname`, `added`) VALUES ('%s', '%s', NOW())",
+                                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_dns_cache` (`ip`, `hostname`, `added`) VALUES ('%s', '%s', NOW())",
                                                array($ip, $hostname), __METHOD__, __LINE__);
 
                                        // Set return value to $ip
@@ -108,7 +108,7 @@ class HostnameResolver {
                                //* DEBUG: */ logDebugMessage(__METHOD__, __LINE__, sprintf("Cannot lookup: %s", $hostname));
                        } else {
                                // Put entry in DB
-                               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_dns_cache` (`ip`, `hostname`, `added`) VALUES ('%s', '%s', NOW())",
+                               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_dns_cache` (`ip`, `hostname`, `added`) VALUES ('%s', '%s', NOW())",
                                        array($ip, $hostname), __METHOD__, __LINE__);
 
                                // Set return value to $ip
@@ -118,7 +118,7 @@ class HostnameResolver {
                }
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
 
                // Return IP number (let's hope it)
                return $ret;
@@ -127,7 +127,7 @@ class HostnameResolver {
        // Purge old entries
        function purgeEntries() {
                // SQL for cleaning up
-               SQL_QUERY('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_dns_cache` WHERE (UNIX_TIMESTAMP() - UNIX_TIMESTAMP(`added`) >= {?dns_cache_timeout?})',
+               sqlQuery('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_dns_cache` WHERE (UNIX_TIMESTAMP() - UNIX_TIMESTAMP(`added`) >= {?dns_cache_timeout?})',
                        __METHOD__, __LINE__);
        }
 }
index c9925db..4fd2eca 100644 (file)
@@ -334,7 +334,7 @@ function updateConfiguration ($entries, $values, $updateMode = '', $config = '0'
                                        setConfigEntry($entry, $values[$idx]);
                                } else {
                                        // String detected
-                                       $SQL .= sprintf("`%s`='%s',", $entry, SQL_ESCAPE($values[$idx]));
+                                       $SQL .= sprintf("`%s`='%s',", $entry, sqlEscapeString($values[$idx]));
 
                                        // Set it in config as well
                                        setConfigEntry($entry, $values[$idx]);
@@ -368,15 +368,15 @@ function updateConfiguration ($entries, $values, $updateMode = '', $config = '0'
                setConfigEntry($entries, time());
        } else {
                // Regular entry to update
-               $SQL = sprintf("`%s`='%s'", $entries, SQL_ESCAPE($values));
+               $SQL = sprintf("`%s`='%s'", $entries, sqlEscapeString($values));
 
                // Set it in config as well
-               setConfigEntry($entries, SQL_ESCAPE($values));
+               setConfigEntry($entries, sqlEscapeString($values));
        }
 
        // Run database update
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'SQL=' . $SQL);
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_config` SET ".$SQL." WHERE `config`=%s LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_config` SET ".$SQL." WHERE `config`=%s LIMIT 1",
                        array(bigintval($config)), __FUNCTION__, __LINE__);
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'SQL=' . $SQL . ',affectedRows=' . SQL_AFFECTEDROWS());
 
@@ -402,21 +402,21 @@ function FILTER_LOAD_CONFIGURATION ($no = '0') {
                // Load config from cache
                mergeConfig($GLOBALS['cache_array']['config'][$no]);
 
-               // Count cache hits 
+               // Count cache hits
                incrementStatsEntry('cache_hits');
        } elseif ((!isExtensionActive('cache')) || (!isset($GLOBALS['cache_array']['config'][$no]))) {
                // Load config from DB
-               $result_config = SQL_QUERY_ESC("SELECT * FROM `{?_MYSQL_PREFIX?}_config` WHERE `config`='%s' LIMIT 1",
+               $result_config = sqlQueryEscaped("SELECT * FROM `{?_MYSQL_PREFIX?}_config` WHERE `config`='%s' LIMIT 1",
                        array(bigintval($no)), __FUNCTION__, __LINE__);
 
                // Is the config there?
-               if (SQL_NUMROWS($result_config) == 1) {
+               if (sqlNumRows($result_config) == 1) {
                        // Get config from database
-                       mergeConfig(SQL_FETCHARRAY($result_config));
+                       mergeConfig(sqlFetchArray($result_config));
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result_config);
+               sqlFreeResult($result_config);
 
                // Remember this config in the array
                $GLOBALS['cache_array']['config'][$no] = getConfigArray();
index 65575ff..4664ad2 100644 (file)
@@ -50,7 +50,7 @@ if (!defined('__SECURITY')) {
 //* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'Daily reset started.');
 
 // Check for 100% klickrate mails
-$result_bonus = SQL_QUERY("SELECT
+$result_bonus = sqlQuery("SELECT
        `id`,
        `userid`,
        `subject`,
@@ -66,11 +66,11 @@ WHERE
 ORDER BY
        `userid` ASC", __FILE__, __LINE__);
 
-if (!SQL_HASZERONUMS($result_bonus)) {
+if (!ifSqlHasZeroNums($result_bonus)) {
        // We found some mail orders...
-       while ($content = SQL_FETCHARRAY($result_bonus)) {
+       while ($content = sqlFetchArray($result_bonus)) {
                // Add points
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `bonus_stats`=`bonus_stats`+{?bonus_stats?} WHERE `userid`=%s LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `bonus_stats`=`bonus_stats`+{?bonus_stats?} WHERE `userid`=%s LIMIT 1",
                        array(bigintval($content['userid'])), __FILE__, __LINE__);
 
                // Translate some data
@@ -81,7 +81,7 @@ if (!SQL_HASZERONUMS($result_bonus)) {
                sendEmail($content['userid'], '{--MEMBER_BONUS_STATS_SUBJECT--}', $message);
 
                // Update database
-               $result_update = SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_stats` SET `bonus_stats_active`='Y' WHERE `id`=%s LIMIT 1",
+               $result_update = sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_stats` SET `bonus_stats_active`='Y' WHERE `id`=%s LIMIT 1",
                        array(bigintval($content['id'])), __FILE__, __LINE__);
        } // END - while
 
@@ -90,7 +90,7 @@ if (!SQL_HASZERONUMS($result_bonus)) {
 } // END - if
 
 // Free memory
-SQL_FREERESULT($result_bonus);
+sqlFreeResult($result_bonus);
 
 // Debug line
 //* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'Daily reset ended.');
index 97f8b37..81aeb51 100644 (file)
@@ -72,7 +72,7 @@ if (isExtensionActive('holiday')) {
 } // END - if
 
 // Only confirmed members shall receive birthday mails...
-$result_birthday = SQL_QUERY_ESC("SELECT
+$result_birthday = sqlQueryEscaped("SELECT
        `d`.`userid`,
        `d`.`email`,
        `d`.`birth_year`
@@ -89,9 +89,9 @@ ORDER BY
        `d`.`userid` ASC",
        array($day, $month), __FILE__, __LINE__);
 
-if (!SQL_HASZERONUMS($result_birthday)) {
+if (!ifSqlHasZeroNums($result_birthday)) {
        // Start sending out birthday mails
-       while ($content = SQL_FETCHARRAY($result_birthday)) {
+       while ($content = sqlFetchArray($result_birthday)) {
                // Calculate own timestamp for birthday and today
                $bd  = $content['birth_year'] + 12 * $month + 365 * $day;
                $now = $year  + 12 * $month + 365 * $day;
@@ -110,7 +110,7 @@ if (!SQL_HASZERONUMS($result_birthday)) {
                        } // END - for
 
                        // Insert row into database
-                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_birthday` (`userid`, `points`, `chk_value`) VALUES (%s,{?birthday_points?},'%s' )",
+                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_user_birthday` (`userid`, `points`, `chk_value`) VALUES (%s,{?birthday_points?},'%s' )",
                                array(
                                        bigintval($content['userid']),
                                        $content['check']
@@ -127,12 +127,12 @@ if (!SQL_HASZERONUMS($result_birthday)) {
                sendEmail($content['userid'], '{--MEMBER_HAPPY_BIRTHDAY_SUBJECT--}', $message);
 
                // Remember him that he has received a birthday mail
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `birthday_sent`=UNIX_TIMESTAMP() WHERE `userid`=%s LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `birthday_sent`=UNIX_TIMESTAMP() WHERE `userid`=%s LIMIT 1",
                        array(bigintval($content['userid'])), __FILE__, __LINE__);
        } // END - while
 
        // Free memory
-       SQL_FREERESULT($result_birthday);
+       sqlFreeResult($result_birthday);
 } // END - if
 
 // Debug line
index b35ae3e..1470a27 100644 (file)
@@ -50,7 +50,7 @@ if (!defined('__SECURITY')) {
 //* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'Daily reset started.');
 
 // Check for holidays we need to enable and send email to user
-$result_main = SQL_QUERY("SELECT
+$result_main = sqlQuery("SELECT
        `userid`,
        `holiday_activated`
 FROM
@@ -64,14 +64,14 @@ ORDER BY
 __FILE__, __LINE__);
 
 // Entries found?
-if (!SQL_HASZERONUMS($result_main)) {
+if (!ifSqlHasZeroNums($result_main)) {
        // Init SQLs
        initSqls();
 
        // We have found at least one useraccount so let's check it...
-       while ($content = SQL_FETCHARRAY($result_main)) {
+       while ($content = sqlFetchArray($result_main)) {
                // Check if his holiday can be activated
-               $result_holiday = SQL_QUERY_ESC("SELECT
+               $result_holiday = sqlQueryEscaped("SELECT
        `holiday_start`,
        `holiday_end`
 FROM
@@ -84,9 +84,9 @@ LIMIT 1",
                        array(bigintval($content['userid'])), __FILE__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result_holiday) == 1) {
+               if (sqlNumRows($result_holiday) == 1) {
                        // Okay, this user can be send away to holiday...
-                       $content = merge_array($content, SQL_FETCHARRAY($result_holiday));
+                       $content = merge_array($content, sqlFetchArray($result_holiday));
 
                        // Prepare all data for the template
                        $content = merge_array($content, array(
@@ -100,7 +100,7 @@ LIMIT 1",
                        sendEmail($content['userid'], '{--MEMBER_HOLIDAY_ACTIVATED_SUBJECT--}', $message);
 
                        // Update account
-                       addSql(SQL_QUERY_ESC("UPDATE
+                       addSql(sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_user_data`
 SET
        `holiday_active`='Y'
@@ -111,7 +111,7 @@ LIMIT 1",
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result_holiday);
+               sqlFreeResult($result_holiday);
        } // END - while
 
        // Run all SQLs
@@ -119,7 +119,7 @@ LIMIT 1",
 } // END - if
 
 // Free memory
-SQL_FREERESULT($result_main);
+sqlFreeResult($result_main);
 
 // Stop currently activated holidays
 stopHolidays();
index d60e59d..40f14ca 100644 (file)
@@ -50,7 +50,7 @@ if (!defined('__SECURITY')) {
 //* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'Daily reset started.');
 
 // Reset mail order values
-$result_ext = SQL_QUERY('UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `mail_orders`=0 WHERE `mail_orders` > 0', __FILE__, __LINE__);
+$result_ext = sqlQuery('UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `mail_orders`=0 WHERE `mail_orders` > 0', __FILE__, __LINE__);
 
 // Debug line
 //* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'Daily reset ended.');
index 34e7445..6e76ce4 100644 (file)
@@ -52,7 +52,7 @@ if (!defined('__SECURITY')) {
 
 if ((isSendProfileUpdateEnabled()) && (getProfileUpdate() > 0) && (getResendProfileUpdate() > 0)) {
        // Load personal data
-       $result = SQL_QUERY("SELECT
+       $result = sqlQuery("SELECT
        `userid`,
        `email`,
        `last_update`,
@@ -76,9 +76,9 @@ ORDER BY
        `userid` ASC", __FILE__, __LINE__);
 
        // Are there some notifications to sent?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // We need to send-out notifications...
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        // Translate timestamp
                        $content['joined'] = generateDateTime($content['joined'], '0');
 
@@ -95,7 +95,7 @@ ORDER BY
                        sendEmail($content['userid'], '{--MEMBER_PROFILE_OUTDATED_SUBJECT--}', $message);
 
                        // Update profile data
-                       SQL_QUERY_ESC("UPDATE
+                       sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_user_data`
 SET
        `last_profile_sent`=UNIX_TIMESTAMP(),
@@ -108,7 +108,7 @@ LIMIT 1",
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 } // END - if
 
 // Debug line
index 4979448..575f65e 100644 (file)
@@ -52,7 +52,7 @@ if (!defined('__SECURITY')) {
 // Update user profiles
 if (isExtensionInstalledAndNewer('order', '0.1.1')) {
        // Latest version
-       SQL_QUERY('UPDATE
+       sqlQuery('UPDATE
        `{?_MYSQL_PREFIX?}_user_data`
 SET
        `receive_mails`=`max_mails`,
@@ -62,7 +62,7 @@ WHERE
        ' . runFilterChain('user_exclusion_sql', ' ') . '', __FILE__, __LINE__);
 } else {
        // Obsolete version
-       SQL_QUERY('UPDATE
+       sqlQuery('UPDATE
        `{?_MYSQL_PREFIX?}_user_data`
 SET
        `receive_mails`=`max_mails`
@@ -72,7 +72,7 @@ WHERE
 }
 
 // Transfer points from locked_points to points
-$result_daily = SQL_QUERY("SELECT
+$result_daily = sqlQuery("SELECT
        `userid`
 FROM
        `{?_MYSQL_PREFIX?}_user_data`
@@ -84,16 +84,16 @@ ORDER BY
        `userid` ASC", __FILE__, __LINE__);
 
 //* DEBUG: */ debugOutput(basename(__FILE__) . ':payout=0;daily|numRows=' . SQL_NUMROWS($result_daily));
-if (!SQL_HASZERONUMS($result_daily)) {
+if (!ifSqlHasZeroNums($result_daily)) {
        // Init SQLs
        initSqls();
 
        // Run through all 'locked_(foo)_points columsn
        foreach (runFilterChain('locked_points_columns_array', array('points')) as $columnName) {
                // Start checking accounts which are on 0 confirmed-to-go mails
-               while ($content = SQL_FETCHARRAY($result_daily)) {
+               while ($content = sqlFetchArray($result_daily)) {
                        //* DEBUG: */ debugOutput(basename(__FILE__) . ':' . $content['userid']);
-                       $result_points = SQL_QUERY_ESC("SELECT
+                       $result_points = sqlQueryEscaped("SELECT
        `ref_depth`,
        `locked_%s`
 FROM
@@ -110,16 +110,16 @@ ORDER BY
                                ), __FILE__, __LINE__);
 
                        //* DEBUG: */ debugOutput(basename(__FILE__) . ':payout=0;points|numRows=' . SQL_NUMROWS($result_points));
-                       if (!SQL_HASZERONUMS($result_points)) {
+                       if (!ifSqlHasZeroNums($result_points)) {
                                // Ok transfer points
-                               while ($content2 = SQL_FETCHARRAY($result_points)) {
+                               while ($content2 = sqlFetchArray($result_points)) {
                                        // Merge both arrays
                                        $content = merge_array($content, $content2);
 
                                        //* DEBUG: */ debugOutput(basename(__FILE__) . ':userid=' . $content['userid'].',depth='.$content['ref_depth'].',columnName=' . $columnName . ',locked='.$content['locked_' . $columnName]);
                                        if ($content['ref_depth'] > 0) {
                                                // Level 1+
-                                               addSql(SQL_QUERY_ESC("UPDATE
+                                               addSql(sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_user_points`
 SET
        `%s`=`%s`+%s,
@@ -139,7 +139,7 @@ LIMIT 1",
                                                );
                                        } else {
                                                // Level zero
-                                               addSql(SQL_QUERY_ESC("UPDATE
+                                               addSql(sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_user_points`
 SET
        `%s`=`%s`+%s,
@@ -167,7 +167,7 @@ LIMIT 1",
                        } // END - if
 
                        // Free memory
-                       SQL_FREERESULT($result_points);
+                       sqlFreeResult($result_points);
                } // END - while
        } // END - foreach
 
@@ -176,7 +176,7 @@ LIMIT 1",
 } // END - if
 
 // Free memory
-SQL_FREERESULT($result_daily);
+sqlFreeResult($result_daily);
 
 // Debug line
 //* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'Daily reset ended.');
index af0b636..cf4c8f3 100644 (file)
@@ -52,16 +52,16 @@ if (!defined('__SECURITY')) {
 // Is auto-purging activated and configured correctly?
 if ((isApSubidsEnabled()) && (getApSubidsSince() > 0)) {
        // Start purging
-       SQL_QUERY('DELETE LOW_PRIORITY FROM
+       sqlQuery('DELETE LOW_PRIORITY FROM
        `{?_MYSQL_PREFIX?}_subid_log`
 WHERE
        (UNIX_TIMESTAMP() - UNIX_TIMESTAMP(`entry_added`)) >= {?ap_subids_since?}',
                __FILE__, __LINE__);
 
        // Are some entries deleted?
-       if (SQL_AFFECTEDROWS() > 0) {
+       if (sqlAffectedRows() > 0) {
                // Okay, then send an email to the admin
-               sendAdminNotification('{--ADMIN_PURGE_USER_SUBID_LOG_SUBJECT--}', 'admin_purge_user_subid_log', SQL_AFFECTEDROWS());
+               sendAdminNotification('{--ADMIN_PURGE_USER_SUBID_LOG_SUBJECT--}', 'admin_purge_user_subid_log', sqlAffectedRows());
        } // END - if
 } // END - if
 
index 96210d2..969b502 100644 (file)
@@ -41,7 +41,7 @@ if (!defined('__SECURITY')) {
 } // END - if
 
 // SQL queries
-function SQL_QUERY ($sqlString, $F, $L, $enableCodes = TRUE) {
+function sqlQuery ($sqlString, $F, $L, $enableCodes = TRUE) {
        // Is there cache?
        if (!isset($GLOBALS[__FUNCTION__][$sqlString])) {
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Called: ' . $sqlString);
@@ -56,7 +56,7 @@ function SQL_QUERY ($sqlString, $F, $L, $enableCodes = TRUE) {
                                basename($F),
                                $L
                        ));
-               } elseif (!SQL_IS_LINK_UP()) {
+               } elseif (!isSqlLinkUp()) {
                        // We should not quietly ignore this
                        reportBug(__FUNCTION__, __LINE__, sprintf("Cannot query database: sqlString=%s,file=%s,line=%s",
                                $sqlStringModified,
@@ -69,13 +69,13 @@ function SQL_QUERY ($sqlString, $F, $L, $enableCodes = TRUE) {
                $sqlStringModified = str_replace(array(chr(9), PHP_EOL, chr(13)), array(' ', ' ', ' '), $sqlStringModified);
 
                // Compile config entries out
-               $sqlStringModified = SQL_PREPARE_SQL_STRING($sqlStringModified, $enableCodes);
+               $sqlStringModified = sqlPrepareQueryString($sqlStringModified, $enableCodes);
 
                // Cache it and remember as last SQL query
                $GLOBALS[__FUNCTION__][$sqlString] = $sqlStringModified;
                $GLOBALS['last_sql']               = $sqlStringModified;
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Stored cache: ' . $sqlStringModified);
-       } elseif (!SQL_IS_LINK_UP()) {
+       } elseif (!isSqlLinkUp()) {
                // Link went down while using cached SQL
                reportBug(__FUNCTION__, __LINE__, 'Link went down while using cached SQL: sqlString=' . $sqlString . ',F=' . basename($F) . ',L=' . $L . ',enableCodes=' . intval($enableCodes));
        } else {
@@ -92,8 +92,8 @@ function SQL_QUERY ($sqlString, $F, $L, $enableCodes = TRUE) {
 
        // Run SQL command
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'F=' . basename($F) . ',L=' . $L . ',sql=' . $GLOBALS['last_sql']);
-       $result = mysql_query($GLOBALS['last_sql'], SQL_GET_LINK())
-               or SQL_ERROR($F, $L, 'file='. basename($F) . ',line=' . $L . ':mysql_error()=' . mysql_error() . ',last_query=' . $GLOBALS['last_sql']);
+       $result = mysql_query($GLOBALS['last_sql'], getSqlLink())
+               or sqlError($F, $L, 'file='. basename($F) . ',line=' . $L . ':mysql_error()=' . mysql_error() . ',last_query=' . $GLOBALS['last_sql']);
        //* DEBUG: */ logDebugMessage($F, $L, 'sql=' . $GLOBALS['last_sql'] . ',affected=' . SQL_AFFECTEDROWS() . ',numRows='.(is_resource($result) ? SQL_NUMROWS($result) : gettype($result)));
 
        // Calculate query time
@@ -112,7 +112,7 @@ function SQL_QUERY ($sqlString, $F, $L, $enableCodes = TRUE) {
        incrementConfigEntry('sql_count');
 
        // Debug output
-       if (SQL_DEBUG_ENABLED()) {
+       if (isSqlDebugEnabled()) {
                // Is this the first call?
                if (!isset($GLOBALS['sql_first_entry'])) {
                        // Write first entry
@@ -121,7 +121,7 @@ function SQL_QUERY ($sqlString, $F, $L, $enableCodes = TRUE) {
                } // END - if
 
                // Append debug line
-               appendLineToFile(getCachePath() . 'mysql.log', basename($F) . '|LINE=' . $L . '|NUM=' . (is_resource($result) ? SQL_NUMROWS($result) : 'false') . '|AFFECTED=' . SQL_AFFECTEDROWS() . '|QUERYTIME:' . ($queryTime * 1000) . 'ms): ' . str_replace(array(chr(13), PHP_EOL), array('', ' '), $GLOBALS['last_sql']));
+               appendLineToFile(getCachePath() . 'mysql.log', basename($F) . '|LINE=' . $L . '|NUM=' . (is_resource($result) ? sqlNumRows($result) : 'false') . '|AFFECTED=' . sqlAffectedRows() . '|QUERYTIME:' . ($queryTime * 1000) . 'ms): ' . str_replace(array(chr(13), PHP_EOL), array('', ' '), $GLOBALS['last_sql']));
        } // END - if
 
        // Increment stats entry
@@ -132,9 +132,9 @@ function SQL_QUERY ($sqlString, $F, $L, $enableCodes = TRUE) {
 }
 
 // SQL num rows
-function SQL_NUMROWS ($resource) {
+function sqlNumRows ($resource) {
        // Valid link resource?
-       if (!SQL_IS_LINK_UP()) return FALSE;
+       if (!isSqlLinkUp()) return FALSE;
 
        // Link is not up, no rows by default
        $lines = FALSE;
@@ -159,30 +159,30 @@ function SQL_NUMROWS ($resource) {
 }
 
 // SQL affected rows
-function SQL_AFFECTEDROWS () {
+function sqlAffectedRows () {
        // Valid link resource?
-       if (!SQL_IS_LINK_UP()) return FALSE;
+       if (!isSqlLinkUp()) return FALSE;
 
        // Get affected rows
-       $lines = mysql_affected_rows(SQL_GET_LINK());
+       $lines = mysql_affected_rows(getSqlLink());
 
        // Return it
        return $lines;
 }
 
 // SQL fetch row
-function SQL_FETCHROW ($resource) {
+function sqlFetchRow ($resource) {
        // Is $resource valid?
-       if ((!is_resource($resource)) || (!SQL_IS_LINK_UP())) return FALSE;
+       if ((!is_resource($resource)) || (!isSqlLinkUp())) return FALSE;
 
        // Fetch the data and return it
        return mysql_fetch_row($resource);
 }
 
 // SQL fetch array
-function SQL_FETCHARRAY ($resource) {
+function sqlFetchArray ($resource) {
        // Is $resource valid?
-       if ((!is_resource($resource)) || (!SQL_IS_LINK_UP())) return FALSE;
+       if ((!is_resource($resource)) || (!isSqlLinkUp())) return FALSE;
 
        // Load row as array from database
        $row = mysql_fetch_assoc($resource);
@@ -198,9 +198,9 @@ function SQL_FETCHARRAY ($resource) {
 }
 
 // SQL result
-function SQL_RESULT ($resource, $row, $field = '0') {
+function sqlResult ($resource, $row, $field = '0') {
        // Is $resource valid?
-       if ((!is_resource($resource)) || (!SQL_IS_LINK_UP())) return FALSE;
+       if ((!is_resource($resource)) || (!isSqlLinkUp())) return FALSE;
 
        // Run the result command
        $result = mysql_result($resource, $row, $field);
@@ -210,22 +210,22 @@ function SQL_RESULT ($resource, $row, $field = '0') {
 }
 
 // SQL connect
-function SQL_CONNECT ($host, $login, $password, $F, $L) {
+function sqlConnectToDatabase ($host, $login, $password, $F, $L) {
        // Try to connect
-       $linkResource = mysql_connect($host, $login, $password) or SQL_ERROR($F, $L,  mysql_error());
+       $linkResource = mysql_connect($host, $login, $password) or sqlError($F, $L,  mysql_error());
 
        // Set the link resource
        if (is_resource($linkResource)) {
                /*
                 * A non-resource (boolean) may happen on installation phase which
                 * shall not be set here. Only valid link resources shall be set so
-                * SQL_IS_LINK_UP() will only return 'true' if there is really a
+                * isSqlLinkUp() will only return 'true' if there is really a
                 * working database link.
                 */
-               SQL_SET_LINK(__FUNCTION__, __LINE__, $linkResource);
+               setSqlLink(__FUNCTION__, __LINE__, $linkResource);
 
                // Init charsets (UTF-8 is default now)
-               SQL_QUERY("SET
+               sqlQuery("SET
        `character_set_results`='utf8',
        `character_set_client`='utf8',
        `character_set_connection`='utf8',
@@ -239,26 +239,26 @@ function SQL_CONNECT ($host, $login, $password, $F, $L) {
 }
 
 // SQL select database
-function SQL_SELECT_DB ($dbName, $F, $L) {
+function sqlSelectDatabase ($dbName, $F, $L) {
        // Is there still a valid link? If not, skip it.
-       if (!SQL_IS_LINK_UP()) return FALSE;
+       if (!isSqlLinkUp()) return FALSE;
 
        // Return the result
        //* DEBUG: */ logDebugMessage($F . ':' . __FUNCTION__, $L . ':' . __LINE__, 'Selecting database ' . $dbName);
-       return mysql_select_db($dbName, SQL_GET_LINK()) or SQL_ERROR($F, $L,  mysql_error());
+       return mysql_select_db($dbName, getSqlLink()) or sqlError($F, $L,  mysql_error());
 }
 
 // SQL close link
-function SQL_CLOSE ($F, $L) {
+function sqlCloseLink ($F, $L) {
        // Is the link up?
-       if (!SQL_IS_LINK_UP()) {
+       if (!isSqlLinkUp()) {
                // Skip double close
                //* DEBUG: */ logDebugMessage($F . ':' . __FUNCTION__, $L . ':' . __LINE__, 'Called but no link is open.');
                return FALSE;
        } // END - if
 
        // Close database link and forget the link
-       $close = mysql_close(SQL_GET_LINK()) or SQL_ERROR($F . ':' . __FUNCTION__, $L . ':' . __LINE__, mysql_error());
+       $close = mysql_close(getSqlLink()) or sqlError($F . ':' . __FUNCTION__, $L . ':' . __LINE__, mysql_error());
 
        // Close link in this layer
        unsetSqlLinkUp(__FUNCTION__, __LINE__);
@@ -269,8 +269,8 @@ function SQL_CLOSE ($F, $L) {
 }
 
 // SQL free result
-function SQL_FREERESULT ($resource) {
-       if ((!is_resource($resource)) || (!SQL_IS_LINK_UP())) {
+function sqlFreeResult ($resource) {
+       if ((!is_resource($resource)) || (!isSqlLinkUp())) {
                // Abort here
                return FALSE;
        } // END - if
@@ -283,20 +283,20 @@ function SQL_FREERESULT ($resource) {
 }
 
 // Get id from last INSERT command and secure id
-function SQL_INSERT_ID () {
-       if (!SQL_IS_LINK_UP()) return FALSE;
+function getSqlInsertId () {
+       if (!isSqlLinkUp()) return FALSE;
        return bigintval(mysql_insert_id());
 }
 
 // Escape a string for the database
-function SQL_ESCAPE ($str, $secureString = TRUE, $strip = TRUE) {
+function sqlEscapeString ($str, $secureString = TRUE, $strip = TRUE) {
        // Is there cache?
        if (!isset($GLOBALS['sql_escapes']['' . $str . ''])) {
                // Debug message
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'str=' . $str . ' - BEFORE!');
 
                // Prepare the string here
-               $str = SQL_PREPARE_SQL_STRING($str);
+               $str = sqlPrepareQueryString($str);
 
                // Debug message
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'str=' . $str . ' - AFTER!');
@@ -316,7 +316,7 @@ function SQL_ESCAPE ($str, $secureString = TRUE, $strip = TRUE) {
                // Init (invalid) value
                $ret = '!INVALID!';
 
-               if (!SQL_IS_LINK_UP()) {
+               if (!isSqlLinkUp()) {
                        // Fall-back to escapeQuotes() when there is no link
                        $ret = escapeQuotes($str);
                } elseif (function_exists('mysql_real_escape_string')) {
@@ -324,13 +324,13 @@ function SQL_ESCAPE ($str, $secureString = TRUE, $strip = TRUE) {
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'str=' . $str);
 
                        // The new and improved version
-                       $ret = mysql_real_escape_string($str, SQL_GET_LINK());
+                       $ret = mysql_real_escape_string($str, getSqlLink());
 
                        // Debug message
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'str=' . $str . ',ret=' . $ret);
                } elseif (function_exists('mysql_escape_string')) {
                        // The obsolete function
-                       $ret = mysql_escape_string($str, SQL_GET_LINK());
+                       $ret = mysql_escape_string($str, getSqlLink());
                } else {
                        // If nothing else works, fall back to escapeQuotes() again
                        $ret = escapeQuotes($str);
@@ -351,7 +351,7 @@ function SQL_ESCAPE ($str, $secureString = TRUE, $strip = TRUE) {
 }
 
 // Log SQL errors to debug.log in installation phase or call reportBug()
-function SQL_ERROR ($file, $line, $message) {
+function sqlError ($file, $line, $message) {
        // Remember plain error in last_sql_error
        $GLOBALS['last_sql_error'] = mysql_error();
 
index 309897b..2355663 100644 (file)
@@ -373,7 +373,7 @@ function registerExtension ($ext_name, $taskId, $isDryRun = FALSE, $ignoreUpdate
                                if (isExtensionInstalledAndNewer('sql_patches', '0.0.6')) {
                                        // New way, with CSS
                                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ext_name=' . $currentName . ',always_active=' . getThisExtensionAlwaysActive() . ', ext_ver=' . getCurrentExtensionVersion() . 'ext_css=' . getExtensionHasCss());
-                                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_extensions` (`ext_name`, `ext_active`, `ext_version`, `ext_has_css`) VALUES ('%s','%s','%s','%s')",
+                                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_extensions` (`ext_name`, `ext_active`, `ext_version`, `ext_has_css`) VALUES ('%s','%s','%s','%s')",
                                                array(
                                                        $currentName,
                                                        getThisExtensionAlwaysActive(),
@@ -383,7 +383,7 @@ function registerExtension ($ext_name, $taskId, $isDryRun = FALSE, $ignoreUpdate
                                } else {
                                        // Old way, no CSS
                                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ext_name=' . $currentName . ',always_active=' . getThisExtensionAlwaysActive() . ', ext_ver=' . getCurrentExtensionVersion());
-                                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_extensions` (`ext_name`, `ext_active`, `ext_version`) VALUES ('%s','%s','%s')",
+                                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_extensions` (`ext_name`, `ext_active`, `ext_version`) VALUES ('%s','%s','%s')",
                                                array(
                                                        $currentName,
                                                        getThisExtensionAlwaysActive(),
@@ -395,7 +395,7 @@ function registerExtension ($ext_name, $taskId, $isDryRun = FALSE, $ignoreUpdate
                                 * Use the insert id as extension id and "cache" all data for
                                 * this extension for early usage.
                                 */
-                               copyExtensionDataToCacheArray($currentName, SQL_INSERT_ID());
+                               copyExtensionDataToCacheArray($currentName, getSqlInsertId());
 
                                // Mark it as installed
                                $GLOBALS['ext_is_installed'][$currentName] = TRUE;
@@ -432,7 +432,7 @@ function registerExtension ($ext_name, $taskId, $isDryRun = FALSE, $ignoreUpdate
        } elseif ((isValidId($taskId)) && (getCurrentExtensionName() != '')) {
                // Remove task from system when id and extension's name is valid
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'currName=' . getCurrentExtensionName());
-               SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_task_system` WHERE `id`=%s AND `status`='NEW' LIMIT 1",
+               sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_task_system` WHERE `id`=%s AND `status`='NEW' LIMIT 1",
                        array(bigintval($taskId)), __FUNCTION__, __LINE__);
        }
 
@@ -499,7 +499,7 @@ function doExtensionSqls ($ext_id, $load_mode) {
        runFilterChain('extension_' . $load_mode);
 
        // Remove cache file(s) if extension is active
-       if (((isExtensionActive('cache')) && ((!SQL_HASZEROAFFECTED()) || ($sqlRan === TRUE) || ($load_mode == 'activate') || ($load_mode == 'deactivate')))) {
+       if (((isExtensionActive('cache')) && ((!ifSqlHasZeroAffectedRows()) || ($sqlRan === TRUE) || ($load_mode == 'activate') || ($load_mode == 'deactivate')))) {
                // Run filters
                runFilterChain('post_extension_run_sql', getCurrentExtensionName());
        } // END - if
@@ -597,20 +597,20 @@ function isExtensionActive ($ext_name) {
        } elseif (($ext_name == 'cache') || (!isExtensionInstalled('cache'))) {
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'DB! ext_name=' . $ext_name);
                // Load from database
-               $result = SQL_QUERY_ESC("SELECT * FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
+               $result = sqlQueryEscaped("SELECT * FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
                        array($ext_name), __FUNCTION__, __LINE__);
 
                // Entry found?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Load entry
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
 
                        // Set cache
                        setExtensionCacheRow($ext_name, $data);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } else {
                // Extension not active!
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ext_name=' . $ext_name . ': Not active!');
@@ -679,14 +679,14 @@ function getExtensionVersion ($ext_name, $force = FALSE) {
                incrementStatsEntry('cache_hits');
        } elseif ((!isCacheInstanceValid()) || (isset($GLOBALS['cache_array']['extension'])) || (!isHtmlOutputMode())) {
                // Load from database
-               $result = SQL_QUERY_ESC("SELECT * FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
+               $result = sqlQueryEscaped("SELECT * FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
                        array($ext_name), __FUNCTION__, __LINE__);
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ext_name=' . $ext_name . ': DB - '.SQL_NUMROWS($result).'');
 
                // Is the extension there?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Load entry
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
 
                        // Set cache
                        setExtensionCacheRow($ext_name, $data);
@@ -696,7 +696,7 @@ function getExtensionVersion ($ext_name, $force = FALSE) {
                }
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Extension version should not be invalid
@@ -895,17 +895,17 @@ function getExtensionName ($ext_id) {
                incrementStatsEntry('cache_hits');
        } elseif (!isExtensionActive('cache')) {
                // Load from database
-               $result = SQL_QUERY_ESC("SELECT `ext_name` FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `id`=%s LIMIT 1",
+               $result = sqlQueryEscaped("SELECT `ext_name` FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `id`=%s LIMIT 1",
                        array(bigintval($ext_id)), __FUNCTION__, __LINE__);
 
                // Is the entry there?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Get the extension's name from database
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Did we find some extension?
@@ -932,20 +932,20 @@ function getExtensionId ($ext_name) {
                incrementStatsEntry('cache_hits');
        } else {
                // Load from database
-               $result = SQL_QUERY_ESC("SELECT * FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
+               $result = sqlQueryEscaped("SELECT * FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
                        array($ext_name), __FUNCTION__, __LINE__);
 
                // Is the entry there?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Get the extension's id from database
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
 
                        // Set cache
                        setExtensionCacheRow($ext_name, $data);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Return value
@@ -997,7 +997,7 @@ function doActivateExtension ($ext_name) {
        } // END - if
 
        // Activate the extension
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='Y' WHERE `ext_name`='%s' LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='Y' WHERE `ext_name`='%s' LIMIT 1",
                array($ext_name), __FUNCTION__, __LINE__);
 
        // Then run all queries
@@ -1013,7 +1013,7 @@ function doDeactivateExtension ($ext_name, $inRebuild = FALSE) {
        } // END - if
 
        // Activate the extension
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='N' WHERE `ext_name`='%s' LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='N' WHERE `ext_name`='%s' LIMIT 1",
                array($ext_name), __FUNCTION__, __LINE__);
 
        // Then run all queries
@@ -1110,7 +1110,7 @@ function createExtensionDeactivationTask ($ext_name) {
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ext_name=' . $ext_name . ',taskId[' . gettype($taskId) . ']=' . $taskId);
        if ((!isValidId($taskId)) && (isExtensionInstalled($ext_name))) {
                // Task not created so add it
-               $taskId = createNewTask($subject, SQL_ESCAPE(loadTemplate('task_EXTENSION_deactivated', TRUE, $ext_name)), 'EXTENSION_DEACTIVATION');
+               $taskId = createNewTask($subject, sqlEscapeString(loadTemplate('task_EXTENSION_deactivated', TRUE, $ext_name)), 'EXTENSION_DEACTIVATION');
        } // END - if
 
        // Return task id
@@ -1129,17 +1129,17 @@ function determineExtensionTaskId ($ext_name) {
        $data['task_id'] = NULL;
 
        // Search for extension task's id
-       $result = SQL_QUERY_ESC("SELECT `id` AS `task_id` FROM `{?_MYSQL_PREFIX?}_task_system` WHERE `task_type`='EXTENSION' AND `subject`='[%s:]' LIMIT 1",
+       $result = sqlQueryEscaped("SELECT `id` AS `task_id` FROM `{?_MYSQL_PREFIX?}_task_system` WHERE `task_type`='EXTENSION' AND `subject`='[%s:]' LIMIT 1",
                array($ext_name), __FUNCTION__, __LINE__);
 
        // Entry found?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Task found so load task's id and register extension...
-               $data = SQL_FETCHARRAY($result);
+               $data = sqlFetchArray($result);
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return it
        return $data['task_id'];
@@ -1151,17 +1151,17 @@ function determineTaskIdBySubject ($subject) {
        $data['task_id'] = '0';
 
        // Search for task id
-       $result = SQL_QUERY_ESC("SELECT `id` AS `task_id` FROM `{?_MYSQL_PREFIX?}_task_system` WHERE `subject` LIKE '%s%%' LIMIT 1",
+       $result = sqlQueryEscaped("SELECT `id` AS `task_id` FROM `{?_MYSQL_PREFIX?}_task_system` WHERE `subject` LIKE '%s%%' LIMIT 1",
                array($subject), __FUNCTION__, __LINE__);
 
        // Entry found?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Task found so load task's id and register extension...
-               $data = SQL_FETCHARRAY($result);
+               $data = sqlFetchArray($result);
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return it
        return $data['task_id'];
index 8f1c937..b0da362 100644 (file)
@@ -136,7 +136,7 @@ switch (getExtensionMode()) {
 
                        case '0.1.4': // SQL queries for v0.1.4
                                // Update notes (these will be set as task text!)
-                               setExtensionUpdateNotes("SQL-Anweisungen mit SQL_QUERY_ESC() abgesichert.");
+                               setExtensionUpdateNotes("SQL-Anweisungen mit sqlQueryEscaped() abgesichert.");
                                break;
 
                        case '0.1.5': // SQL queries for v0.1.5
index 8636add..ccc62f1 100644 (file)
@@ -69,7 +69,7 @@ switch (getExtensionMode()) {
        case 'activate': // Do stuff when admin activates this extension
                // Check if mod_rewrite is loadeded
                if (!isApacheModuleLoaded('mod_rewrite')) {
-                       SQL_QUERY("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='N' WHERE `ext_name`='rewrite' LIMIT 1", __FILE__, __LINE__);
+                       sqlQuery("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='N' WHERE `ext_name`='rewrite' LIMIT 1", __FILE__, __LINE__);
                        enableExtensionReportingFailure(TRUE);
                        addFatalMessage(__FILE__, __LINE__, '{--MOD_REWRITE_ERROR--}');
         } // END - if
@@ -166,7 +166,7 @@ switch (getExtensionMode()) {
                // Check if mod_rewrite is loadeded
                if (!isApacheModuleLoaded('mod_rewrite')) {
                        enableExtensionReportingFailure(TRUE);
-                       SQL_QUERY("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='N' WHERE `ext_name`='rewrite' LIMIT 1", __FILE__, __LINE__);
+                       sqlQuery("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_active`='N' WHERE `ext_name`='rewrite' LIMIT 1", __FILE__, __LINE__);
                        if (!isAdmin()) {
                                addFatalMessage(__FILE__, __LINE__, '{--MOD_REWRITE_ERROR--}');
                        } // END - if
index 9fe66b1..8dd5abc 100644 (file)
@@ -194,7 +194,7 @@ nicht die vom Mitglied eingegebene. Resultat: Das Script beschwerte sich, der Us
 
                        case '0.3.7': // SQL queries for v0.3.7
                                // Update notes (these will be set as task text!)
-                               setExtensionUpdateNotes("SQL-Anweisungen mit SQL_QUERY_ESC() abgesichert.");
+                               setExtensionUpdateNotes("SQL-Anweisungen mit sqlQueryEscaped() abgesichert.");
                                break;
 
                        case '0.3.8': // SQL queries for v0.3.8
index a9ea543..0fd3e13 100644 (file)
@@ -63,7 +63,7 @@ function initFilterSystem () {
                } // END - if
 
                // Load all filters
-               $result = SQL_QUERY('SELECT
+               $result = sqlQuery('SELECT
        `filter_name`,
        `filter_function`,
        `filter_active`
@@ -74,9 +74,9 @@ ORDER BY
        `filter_id` ASC', __FUNCTION__, __LINE__);
 
                // Are there entries?
-               if (!SQL_HASZERONUMS($result)) {
+               if (!ifSqlHasZeroNums($result)) {
                        // Load all filters
-                       while ($filterArray = SQL_FETCHARRAY($result)) {
+                       while ($filterArray = sqlFetchArray($result)) {
                                // Get filter name and function
                                $filterName     = $filterArray['filter_name'];
                                $filterFunction = $filterArray['filter_function'];
@@ -99,7 +99,7 @@ ORDER BY
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Init filters
index 9865a58..ed1c378 100644 (file)
@@ -67,7 +67,7 @@ function FILTER_BEG_PURGE_IPS_NOTIFY_USER ($filterData) {
        } // END - if
 
        // Run the SQL query
-       SQL_QUERY_ESC('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_beg_ips` WHERE (UNIX_TIMESTAMP() - `timeout`) >= %s',
+       sqlQueryEscaped('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_beg_ips` WHERE (UNIX_TIMESTAMP() - `timeout`) >= %s',
                array($OLD + 60*60), __FUNCTION__, __LINE__);
 
        // Check for beg rallye is active and send mails out
index 4ab41f8..0f86567 100644 (file)
@@ -54,7 +54,7 @@ function FILTER_ADD_LOGIN_BONUS ($filterData) {
        if ((isExtensionInstalledAndNewer('sql_patches', '0.2.8')) && (isBonusRallyeActive()) && (isIncludeBonusLoginEnabled())) {
                // Update last login if far enougth away
                // @TODO This query isn't right, it will only update if the user was for a longer time away!
-               SQL_QUERY_ESC('UPDATE
+               sqlQueryEscaped('UPDATE
        `{?_MYSQL_PREFIX?}_user_data`
 SET
        `last_login`=UNIX_TIMESTAMP()
@@ -68,7 +68,7 @@ LIMIT 1',
                );
 
                // Updated entry?
-               $bonus = (!SQL_HASZEROAFFECTED());
+               $bonus = (!ifSqlHasZeroAffectedRows());
        } // END - if
 
        if (($bonus === TRUE) && (getRequestElement('do') == 'bonus')) {
index fcc23d7..1125cf1 100644 (file)
@@ -50,7 +50,7 @@ function FILTER_ADD_EARNING_GROUP_POPUP ($filterData) {
        } // END - if
 
        // Now check if the user has subscription and amount left
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `d`.`earning_id`,
        `d`.`earning_provider`,
        `u`.`earning_current_amount`,
@@ -77,9 +77,9 @@ ORDER BY
                ), __FUNCTION__, __LINE__);
 
        // Are there entries left?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Load all names
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        // Merge the $filterData array in
                        $content = merge_array($content, $filterData);
 
@@ -96,7 +96,7 @@ ORDER BY
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return filter data
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Done!');
index 118ebf8..fca99bf 100644 (file)
@@ -69,13 +69,13 @@ function FILTER_UPDATE_ONLINE_LIST ($filterData) {
        } // END - if
 
        // Now search for the user
-       $result = SQL_QUERY_ESC("SELECT `timestamp` FROM `{?_MYSQL_PREFIX?}_online` WHERE `sid`='%s' LIMIT 1",
+       $result = sqlQueryEscaped("SELECT `timestamp` FROM `{?_MYSQL_PREFIX?}_online` WHERE `sid`='%s' LIMIT 1",
                array(session_id()), __FUNCTION__, __LINE__);
 
        // Entry found?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Then update it
-               SQL_QUERY_ESC("UPDATE
+               sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_online`
 SET
        `module`='%s',
@@ -87,7 +87,7 @@ SET
        `is_admin`='%s',
        `timestamp`=UNIX_TIMESTAMP(),
        `ip`='%s'
-WHERE 
+WHERE
        `sid`='%s'
 LIMIT 1",
                array(
@@ -103,7 +103,7 @@ LIMIT 1",
                ), __FUNCTION__, __LINE__);
        } else {
                // No entry does exists so we simply add it!
-               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_online` (`module`, `action`, `what`, `userid`, `refid`, `is_member`, `is_admin`, `timestamp`, `sid`, `ip`) VALUES ('%s','%s','%s', %s, %s, '%s','%s', UNIX_TIMESTAMP(), '%s','%s')",
+               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_online` (`module`, `action`, `what`, `userid`, `refid`, `is_member`, `is_admin`, `timestamp`, `sid`, `ip`) VALUES ('%s','%s','%s', %s, %s, '%s','%s', UNIX_TIMESTAMP(), '%s','%s')",
                        array(
                                getModule(),
                                $action,
@@ -118,10 +118,10 @@ LIMIT 1",
        }
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Purge old entries
-       SQL_QUERY('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_online` WHERE (UNIX_TIMESTAMP() - `timestamp`) >= {?online_timeout?}', __FUNCTION__, __LINE__);
+       sqlQuery('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_online` WHERE (UNIX_TIMESTAMP() - `timestamp`) >= {?online_timeout?}', __FUNCTION__, __LINE__);
 
        // Return data
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Done!');
index 286b11d..507a35e 100644 (file)
@@ -63,7 +63,7 @@ function FILTER_RALLYE_NOTIFY_USERS ($filterData) {
                ));
 
                // Check for new started but not notified rallyes
-               $result = SQL_QUERY("SELECT SQL_SMALL_RESULT
+               $result = sqlQuery("SELECT SQL_SMALL_RESULT
        `d`.`id`,
        `d`.`title`,
        `d`.`start_time`,
@@ -79,16 +79,16 @@ WHERE
        `d`.`start_time` <= UNIX_TIMESTAMP() AND
        `d`.`end_time` > UNIX_TIMESTAMP()
 LIMIT 1", __FILE__, __LINE__);
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Start rallye
                        autostartReferralRallyes($result);
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
 
                // Check for expired rallyes
-               $result = SQL_QUERY("SELECT SQL_SMALL_RESULT
+               $result = sqlQuery("SELECT SQL_SMALL_RESULT
        `d`.`id`,
        `d`.`title`,
        `d`.`start_time`,
@@ -103,13 +103,13 @@ WHERE
        `d`.`expired`='N' AND
        (`d`.`end_time` <= UNIX_TIMESTAMP()" . $sqlAddons['or'] . ")
 LIMIT 1", __FILE__, __LINE__);
-               if ((SQL_NUMROWS($result) == 1) && (isExtensionActive('autopurge'))) {
+               if ((sqlNumRows($result) == 1) && (isExtensionActive('autopurge'))) {
                        // End rallye here...
                        stopRallyeByResult($result);
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return data
index 06af7b4..156362c 100644 (file)
@@ -44,11 +44,11 @@ if (!defined('__SECURITY')) {
 function FILTER_REGISTER_MUST_FILLOUT ($filterData) {
        // Get all fields for output
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Called!');
-       $result = SQL_QUERY('SELECT `field_name`, `field_required` FROM `{?_MYSQL_PREFIX?}_must_register` ORDER BY `id` ASC',
+       $result = sqlQuery('SELECT `field_name`, `field_required` FROM `{?_MYSQL_PREFIX?}_must_register` ORDER BY `id` ASC',
                __FUNCTION__, __LINE__);
 
        // Walk through all entries
-       while ($row = SQL_FETCHARRAY($result)) {
+       while ($row = sqlFetchArray($result)) {
                // Must the user fill out this element?
                $value = '';
                if ($row['field_required'] == 'Y') {
@@ -60,7 +60,7 @@ function FILTER_REGISTER_MUST_FILLOUT ($filterData) {
        } // END - while
 
        // Free memory
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return it
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Done!');
index 75e699f..7c731da 100644 (file)
@@ -179,7 +179,7 @@ function FILTER_GENERIC_UPDATE_USER_REFERRAL ($filterData) {
        assert(isReferralIdValid());
 
        // Update ref counter, determineReferralId() must already be called before this filter is executed
-       SQL_QUERY('UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `ref_clicks`=`ref_clicks`+1 WHERE `userid`={%pipe,getReferralId%} LIMIT 1', __FUNCTION__, __LINE__);
+       sqlQuery('UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `ref_clicks`=`ref_clicks`+1 WHERE `userid`={%pipe,getReferralId%} LIMIT 1', __FUNCTION__, __LINE__);
 
        // Return filter data
        return $filterData;
@@ -191,12 +191,12 @@ function FILTER_UPDATE_USER_SUBID ($filterData) {
        assert(isReferralIdValid());
 
        // Get sub id and secure it
-       $subId = SQL_ESCAPE(getRequestElement('subid'));
+       $subId = sqlEscapeString(getRequestElement('subid'));
 
        // Is the sub id available and registered with referral id?
        if (countSumTotalData(getReferralId(), 'user_subids', 'id', 'userid', TRUE, sprintf(" AND `subid`='%s'", $subId)) == 1) {
                // Sub id is assigned to referral id, so add a record
-               SQL_QUERY_ESC("INSERT INTO
+               sqlQueryEscaped("INSERT INTO
        `{?_MYSQL_PREFIX?}_subid_log`
 (
        `refid`,
@@ -212,12 +212,12 @@ function FILTER_UPDATE_USER_SUBID ($filterData) {
        '{%%pipe,detectUserAgent%%}'
 )",
                        array(
-                               // @NOTE: SQL_QUERY_ESC() already escape it, don't use $subId here
+                               // @NOTE: sqlQueryEscaped() already escape it, don't use $subId here
                                getRequestElement('subid')
                        ), __FUNCTION__, __LINE__);
 
                // Add insert id for other filters
-               $filterData['insert_id'] = SQL_INSERT_ID();
+               $filterData['insert_id'] = getSqlInsertId();
 
                // Register sub id in filter
                setSession('subid', $subId);
@@ -247,15 +247,15 @@ function FILTER_MEMBER_REFLINK_USER_SUBIDS_CONTENT ($content = '') {
        // Does the current user have sub ids?
        if (getTotalMemberSubIds() > 0) {
                // Then Load all
-               $result = SQL_QUERY_ESC('SELECT `id`, `subid` FROM `{?_MYSQL_PREFIX?}_user_subids` WHERE `userid`=%s ORDER BY `subid` ASC',
+               $result = sqlQueryEscaped('SELECT `id`, `subid` FROM `{?_MYSQL_PREFIX?}_user_subids` WHERE `userid`=%s ORDER BY `subid` ASC',
                        array(getMemberId()), __FUNCTION__, __LINE__);
 
                // There should be entries left
-               assert(!SQL_HASZERONUMS($result));
+               assert(!ifSqlHasZeroNums($result));
 
                // Load all
                $out = '';
-               while ($row = SQL_FETCHARRAY($result)) {
+               while ($row = sqlFetchArray($result)) {
                        // Load row template
                        $out .= loadTemplate('member_list_reflink_user_subids_row', TRUE, $row);
                } // END - while
@@ -264,7 +264,7 @@ function FILTER_MEMBER_REFLINK_USER_SUBIDS_CONTENT ($content = '') {
                $content .= loadTemplate('member_list_reflink_user_subids', TRUE, $out);
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return data
index 9e135b3..e07fc7b 100644 (file)
@@ -46,10 +46,10 @@ function FILTER_FLUSH_FILTERS () {
        initSqls();
 
        // Is a database link here and not in installation mode?
-       if ((!SQL_IS_LINK_UP()) && (!isInstallationPhase())) {
+       if ((!isSqlLinkUp()) && (!isInstallationPhase())) {
                // Abort here
                reportBug(__FUNCTION__, __LINE__, 'No database link is up. Cannot flush filters.');
-       } elseif ((isInstallationPhase()) && (!SQL_IS_LINK_UP())) {
+       } elseif ((isInstallationPhase()) && (!isSqlLinkUp())) {
                // If the link is not up in installation phase, skip flushing filters
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Cannot flush filters: No link is up.');
                return;
@@ -82,7 +82,7 @@ function FILTER_FLUSH_FILTERS () {
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'FOUND:'.$filterName.'/'.$filterFunction.'='.$active);
                        if (((!isset($GLOBALS['cache_array']['filter']['loaded'][$filterName][$filterFunction])) && ($active != 'R')) || ($active == 'A')) {
                                // Is this filter already in database?
-                               if (countSumTotalData($filterFunction, 'filters', 'filter_name', 'filter_function', TRUE, sprintf(" AND `filter_name`='%s'", SQL_ESCAPE($filterName))) == 0) {
+                               if (countSumTotalData($filterFunction, 'filters', 'filter_name', 'filter_function', TRUE, sprintf(" AND `filter_name`='%s'", sqlEscapeString($filterName))) == 0) {
                                        // Add this filter (all filters are active by default)
                                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ADD:'.$filterName.'/'.$filterFunction);
                                        $insertSQL .= sprintf("('%s','%s','Y'),", $filterName, $filterFunction);
@@ -270,17 +270,17 @@ function FILTER_RUN_SQLS ($filterData) {
                                        if ((substr(strtolower($sql), 0, 11) == 'alter table') && (!isset($filterData['ext_installing']))) {
                                                // Analyse the alteration command
                                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Alterting table: ' . $sql . ',enable_codes=' . intval($filterData['enable_codes']));
-                                               SQL_ALTER_TABLE($sql, __FUNCTION__, __LINE__, $filterData['enable_codes']);
+                                               sqlQueryAlterTable($sql, __FUNCTION__, __LINE__, $filterData['enable_codes']);
                                        } else {
                                                // Run regular SQL command
                                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Running regular query: ' . $sql . ',enable_codes=' . intval($filterData['enable_codes']));
-                                               SQL_QUERY($sql, __FUNCTION__, __LINE__, $filterData['enable_codes']);
+                                               sqlQuery($sql, __FUNCTION__, __LINE__, $filterData['enable_codes']);
                                        }
 
                                        // Has a line changed?
-                                       if (!SQL_HASZEROAFFECTED()) {
+                                       if (!ifSqlHasZeroAffectedRows()) {
                                                // Add it to total account
-                                               $count += SQL_AFFECTEDROWS();
+                                               $count += sqlAffectedRows();
                                        } // END - if
                                } // END - if
                        } // END - foreach
@@ -567,10 +567,10 @@ function FILTER_COMPILE_EXPRESSION_CODE ($filterData) {
 // Runs some generic filter update steps
 function FILTER_UPDATE_EXTENSION_DATA ($ext_name) {
        // Create task (we ignore the task id here)
-       createExtensionUpdateTask(getCurrentAdminId(), $ext_name, $GLOBALS['update_ver'][$ext_name], SQL_ESCAPE(getExtensionNotes(getExtensionNotes())));
+       createExtensionUpdateTask(getCurrentAdminId(), $ext_name, $GLOBALS['update_ver'][$ext_name], sqlEscapeString(getExtensionNotes(getExtensionNotes())));
 
        // Update extension's version
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_version`='%s' WHERE `ext_name`='%s' LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_extensions` SET `ext_version`='%s' WHERE `ext_name`='%s' LIMIT 1",
                array($GLOBALS['update_ver'][$ext_name], $ext_name), __FUNCTION__, __LINE__);
 
        // Remove arrays
@@ -665,7 +665,7 @@ function FILTER_RUN_MONTHLY_INCLUDES () {
 // Filter for removing the given extension
 function FILTER_REMOVE_EXTENSION () {
        // Delete this extension (remember to remove it from your server *before* you click on welcome!
-       SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
+       sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_extensions` WHERE `ext_name`='%s' LIMIT 1",
                array(getCurrentExtensionName()), __FUNCTION__, __LINE__);
 
        // Remove the extension from cache array as well
@@ -943,7 +943,7 @@ function FILTER_COUNT_MODULE () {
 
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'getModule()=' . getModule() . ' - ENTERED!');
        // Count module click
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_mod_reg` SET `clicks`=`clicks`+1 WHERE `module`='%s' LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_mod_reg` SET `clicks`=`clicks`+1 WHERE `module`='%s' LIMIT 1",
                array(getModule()), __FUNCTION__, __LINE__);
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'getModule()=' . getModule() . ',SQL_AFFECTEDROWS()=' . SQL_AFFECTEDROWS() . ' - EXIT!');
 }
@@ -1107,7 +1107,7 @@ function FILTER_RESET_USER_LOGIN_FAILURE () {
        // Remmeber login failures if available
        if (isExtensionInstalledAndNewer('user', '0.3.7')) {
                // Reset login failures
-               SQL_QUERY_ESC("UPDATE
+               sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_user_data`
 SET
        `login_failures`=0,
@@ -1149,7 +1149,7 @@ function FILTER_LOAD_PAGE_HEADER () {
                $GLOBALS['__page_header'] .= loadTemplate(getMenuModeFromModule() . '_metadata', TRUE);
 
                // Add meta description to header
-               if ((isInstalled()) && (isAdminRegistered()) && (SQL_IS_LINK_UP()) && (getModule() == 'index')) {
+               if ((isInstalled()) && (isAdminRegistered()) && (isSqlLinkUp()) && (getModule() == 'index')) {
                        // Add meta description not in admin and login module and when the script is installed
                        generateMetaDescriptionCode();
                } // END - if
@@ -1253,12 +1253,12 @@ function FILTER_HANDLE_HOME_IN_INDEX_SETTING ($filterData) {
 // Filter to add history entry
 function FILTER_ADD_HISTORY_ENTRY ($filterData) {
        // Add the entry
-       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_history` (`history_subject`, `history_userid`, `history_value`) VALUES ('%s',%s,'%s')",
+       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_history` (`history_subject`, `history_userid`, `history_value`) VALUES ('%s',%s,'%s')",
                $filterData,
                __FUNCTION__, __LINE__);
 
        // Remember insert id for other filters
-       $filterData['history_id'] = SQL_INSERT_ID();
+       $filterData['history_id'] = getSqlInsertId();
 
        // Return data
        return $filterData;
@@ -1329,11 +1329,11 @@ function FILTER_HANDLE_REFERRER_BANNER_CLICK ($filterData) {
        // Check required parameters
        if ((isGetRequestElementSet('user')) && (isGetRequestElementSet('banner'))) {
                // Update clicks counter...
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_refbanner` SET `clicks`=`clicks`+1 WHERE `id`=%s LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_refbanner` SET `clicks`=`clicks`+1 WHERE `id`=%s LIMIT 1",
                        array(bigintval(getRequestElement('banner'))), __FUNCTION__, __LINE__);
 
                // A line has been updated?
-               if ((!SQL_HASZEROAFFECTED()) && (isGetRequestElementSet('user'))) {
+               if ((!ifSqlHasZeroAffectedRows()) && (isGetRequestElementSet('user'))) {
                        // Redirect to the user's referral link
                        redirectToUrl('ref.php?refid=' . bigintval(getRequestElement('user')));
                } // END - if
@@ -1348,16 +1348,16 @@ function FILTER_HANDLE_REFERRER_BANNER_VIEW ($filterData) {
        // Are all required parameters set
        if ((isGetRequestElementSet('user')) && (isGetRequestElementSet('banner'))) {
                // For later things... ;-)
-               $result = SQL_QUERY_ESC("SELECT `url` FROM `{?_MYSQL_PREFIX?}_refbanner` WHERE `id`=%s LIMIT 1",
+               $result = sqlQueryEscaped("SELECT `url` FROM `{?_MYSQL_PREFIX?}_refbanner` WHERE `id`=%s LIMIT 1",
                        array(bigintval(getRequestElement('banner'))), __FUNCTION__, __LINE__);
 
                // Is there the banner?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Load the URL
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
 
                        // Update counter
-                       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_refbanner` SET `counter`=`counter`+1 WHERE `id`=%s LIMIT 1",
+                       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_refbanner` SET `counter`=`counter`+1 WHERE `id`=%s LIMIT 1",
                                array(bigintval(getRequestElement('banner'))), __FUNCTION__, __LINE__);
 
                        // Set header and ...
@@ -1371,7 +1371,7 @@ function FILTER_HANDLE_REFERRER_BANNER_VIEW ($filterData) {
                logDebugMessage(__FUNCTION__, __LINE__, 'Banner ' . bigintval(getRequestElement('banner')) . ' not found.');
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Do nothing for now
@@ -1413,16 +1413,16 @@ function FILTER_SERVER_NAME_EXTRA_AUTOPURGE ($filterData) {
        // Is purging configured?
        if ((isApServerNameEnabled()) && (getApServerNameSince() > 0)) {
                // Then start purging
-               SQL_QUERY('DELETE LOW_PRIORITY FROM
+               sqlQuery('DELETE LOW_PRIORITY FROM
        `{?_MYSQL_PREFIX?}_server_name_log`
 WHERE
        (UNIX_TIMESTAMP() - UNIX_TIMESTAMP(`server_name_added`)) >= {?ap_server_name_since?}',
                        __FILE__, __LINE__);
 
                // Are some entries deleted?
-               if (SQL_AFFECTEDROWS() > 0) {
+               if (sqlAffectedRows() > 0) {
                        // Okay, then send an email to the admin
-                       sendAdminNotification('{--ADMIN_PURGE_USER_SERVER_NAME_LOG_SUBJECT--}', 'admin_purge_user_server_name_log', SQL_AFFECTEDROWS());
+                       sendAdminNotification('{--ADMIN_PURGE_USER_SERVER_NAME_LOG_SUBJECT--}', 'admin_purge_user_server_name_log', sqlAffectedRows());
                } // END - if
        } // END - if
 
index 9b87c77..2e05a95 100644 (file)
@@ -41,7 +41,7 @@ if (!defined('__SECURITY')) {
 } // END - if
 
 // Get all filters
-$result = SQL_QUERY('SELECT
+$result = sqlQuery('SELECT
        `filter_name`,
        `filter_function`
 FROM
@@ -51,11 +51,11 @@ ORDER BY
        `filter_function` ASC', __FILE__, __LINE__);
 
 // Are there entries? (there should be!)
-if (!SQL_HASZERONUMS($result)) {
+if (!ifSqlHasZeroNums($result)) {
        // Load row by row
-       while ($filter = SQL_FETCHARRAY($result)) {
+       while ($filter = sqlFetchArray($result)) {
                // Now search again for this filter and get it's total count
-               $count = countSumTotalData($filter['filter_name'], 'filters', 'filter_id', 'filter_name', TRUE, sprintf(" AND `filter_function`='%s'", SQL_ESCAPE($filter['filter_function'])));
+               $count = countSumTotalData($filter['filter_name'], 'filters', 'filter_id', 'filter_name', TRUE, sprintf(" AND `filter_function`='%s'", sqlEscapeString($filter['filter_function'])));
 
                // Is there more than one entry?
                if ($count > 1) {
@@ -70,7 +70,7 @@ if (!SQL_HASZERONUMS($result)) {
 } // END - if
 
 // Free result
-SQL_FREERESULT($result);
+sqlFreeResult($result);
 
 // Now insert our unqiue key
 addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_filters` DROP KEY `name_function`');
index 99e319b..2aad72e 100644 (file)
@@ -43,14 +43,14 @@ if (!defined('__SECURITY')) {
 // Get all menus
 foreach (array('guest','member','admin') as $menu) {
        // Query it
-       $result = SQL_QUERY_ESC("SELECT `action`, `what` FROM `{?_MYSQL_PREFIX?}_%s_menu` ORDER BY `action` ASC,`what` ASC",
+       $result = sqlQueryEscaped("SELECT `action`, `what` FROM `{?_MYSQL_PREFIX?}_%s_menu` ORDER BY `action` ASC,`what` ASC",
                array($menu), __FILE__, __LINE__);
 
        // Init array
        $menus = array();
 
        // Load all entries
-       while ($entry = SQL_FETCHARRAY($result)) {
+       while ($entry = sqlFetchArray($result)) {
                // Is the menu entry set?
                if (!isset($menus['menu'][$entry['action']][$entry['what']])) {
                        // Not found
@@ -71,7 +71,7 @@ foreach (array('guest','member','admin') as $menu) {
                                // Remove all except one
                                if (is_null($entry['what'])) {
                                        // Main menu is double
-                                       SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_%s_menu` WHERE `action`='%s' AND `what` IS NULL LIMIT %s",
+                                       sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_%s_menu` WHERE `action`='%s' AND `what` IS NULL LIMIT %s",
                                                array(
                                                        $menu,
                                                        $entry['action'],
@@ -79,7 +79,7 @@ foreach (array('guest','member','admin') as $menu) {
                                                ), __FILE__, __LINE__);
                                } else {
                                        // Sub menu is double
-                                       SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_%s_menu` WHERE `action`='%s' AND `what`='%s' LIMIT %s",
+                                       sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_%s_menu` WHERE `action`='%s' AND `what`='%s' LIMIT %s",
                                                array(
                                                        $menu,
                                                        $entry['action'],
@@ -92,7 +92,7 @@ foreach (array('guest','member','admin') as $menu) {
        } // END - while
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Init sqls
        initSqls();
index a63edb3..a932a5c 100644 (file)
@@ -41,29 +41,29 @@ if (!defined('__SECURITY')) {
 } // END - if
 
 // Sanity-check: Is there ref level 0? If so, this must be fixed to NULL and `level` must be increased by one
-$result = SQL_QUERY('SELECT `id` FROM `{?_MYSQL_PREFIX?}_refsystem` WHERE `level`=0', __FILE__, __LINE__);
-if (!SQL_HASZERONUMS($result)) {
+$result = sqlQuery('SELECT `id` FROM `{?_MYSQL_PREFIX?}_refsystem` WHERE `level`=0', __FILE__, __LINE__);
+if (!ifSqlHasZeroNums($result)) {
        // Remove index temporaly
-       SQL_ALTER_TABLE('ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` DROP INDEX `userid_level`', __FILE__, __LINE__);
+       sqlQueryAlterTable('ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` DROP INDEX `userid_level`', __FILE__, __LINE__);
 
        // Upgrade refsystem
-       SQL_QUERY('UPDATE `{?_MYSQL_PREFIX?}_refsystem` SET `level`=`level`+1', __FILE__, __LINE__);
+       sqlQuery('UPDATE `{?_MYSQL_PREFIX?}_refsystem` SET `level`=`level`+1', __FILE__, __LINE__);
 
        // Add it again
-       SQL_ALTER_TABLE('ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` ADD UNIQUE INDEX `userid_level` (`userid`, `level`)', __FILE__, __LINE__);
+       sqlQueryAlterTable('ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` ADD UNIQUE INDEX `userid_level` (`userid`, `level`)', __FILE__, __LINE__);
 
        // Rebuild cache
        rebuildCache('refsystem', 'refsystem');
 } // END - if
 
 // Free result
-SQL_FREERESULT($result);
+sqlFreeResult($result);
 
 // Reset the table
-SQL_QUERY('TRUNCATE TABLE `{?_MYSQL_PREFIX?}_user_refs`', __FILE__, __LINE__);
+sqlQuery('TRUNCATE TABLE `{?_MYSQL_PREFIX?}_user_refs`', __FILE__, __LINE__);
 
 // Begin with all users in level one
-$result_direct = SQL_QUERY('SELECT
+$result_direct = sqlQuery('SELECT
        `userid`
 FROM
        `{?_MYSQL_PREFIX?}_user_data`
@@ -74,9 +74,9 @@ ORDER BY
        `userid` ASC', __FILE__, __LINE__);
 
 // Are there entries?
-if (!SQL_HASZERONUMS($result_direct)) {
+if (!ifSqlHasZeroNums($result_direct)) {
        // When 'walk' through all users
-       while ($content = SQL_FETCHARRAY($result_direct)) {
+       while ($content = sqlFetchArray($result_direct)) {
                // Update refback table
                /* DEBUG: */ logDebugMessage(__FILE__, __LINE__, 'userid=' . $content['userid'] . ' - BEFORE!');
                updateReferralTable($content['userid']);
@@ -85,7 +85,7 @@ if (!SQL_HASZERONUMS($result_direct)) {
 } // END - if
 
 // Free result
-SQL_FREERESULT($result_direct);
+sqlFreeResult($result_direct);
 
 // [EOF]
 ?>
index 4d637f3..b4a61ae 100644 (file)
@@ -41,7 +41,7 @@ if (!defined('__SECURITY')) {
 } // END - if
 
 // Get all user points
-$result = SQL_QUERY('SELECT
+$result = sqlQuery('SELECT
        `userid`,
        `points`,
        `locked_points`,
@@ -55,15 +55,15 @@ ORDER BY
        `userid` ASC', __FILE__, __LINE__);
 
 // Are there entries? (there should be!)
-if (!SQL_HASZERONUMS($result)) {
+if (!ifSqlHasZeroNums($result)) {
        // Load row by row
-       while ($row = SQL_FETCHARRAY($result)) {
+       while ($row = sqlFetchArray($result)) {
                // Update the database again
                foreach (array_keys($row) as $column) {
                        // Not userid itself
                        if ($column != 'userid') {
                                // Update amount
-                               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_points` SET `%s`=`%s`+%s WHERE `userid`=%s AND `ref_depth` IS NULL",
+                               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_points` SET `%s`=`%s`+%s WHERE `userid`=%s AND `ref_depth` IS NULL",
                                        array(
                                                $column,
                                                $column,
@@ -72,9 +72,9 @@ if (!SQL_HASZERONUMS($result)) {
                                        ), __FILE__, __LINE__);
 
                                // Nothing has been updated?
-                               if (SQL_HASZEROAFFECTED()) {
+                               if (ifSqlHasZeroAffectedRows()) {
                                        // Then insert it
-                                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_points` (`userid`, `ref_depth`, `%s`) VALUES (%s,NULL,%s)",
+                                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_user_points` (`userid`, `ref_depth`, `%s`) VALUES (%s,NULL,%s)",
                                                array(
                                                        $column,
                                                        $row['userid'],
@@ -87,10 +87,10 @@ if (!SQL_HASZERONUMS($result)) {
 } // END - if
 
 // Free result
-SQL_FREERESULT($result);
+sqlFreeResult($result);
 
 // Remove all entries
-SQL_QUERY('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_points` WHERE `ref_depth`=0', __FILE__, __LINE__);
+sqlQuery('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_points` WHERE `ref_depth`=0', __FILE__, __LINE__);
 
 // [EOF]
 ?>
index 0ae32cc..4cd9373 100644 (file)
@@ -1688,9 +1688,9 @@ function doShutdown () {
        runFilterChain('shutdown', NULL);
 
        // Check if link is up
-       if (SQL_IS_LINK_UP()) {
+       if (isSqlLinkUp()) {
                // Close link
-               SQL_CLOSE(__FUNCTION__, __LINE__);
+               sqlCloseLink(__FUNCTION__, __LINE__);
        } elseif (!isInstallationPhase()) {
                // No database link
                reportBug(__FUNCTION__, __LINE__, 'Database link is already down, while shutdown is running.');
@@ -1889,7 +1889,7 @@ function mapModuleToTable ($moduleName) {
        // Map only these, still lame code...
        switch ($moduleName) {
                case 'index': // 'index' is the guest's menu
-                       $moduleName = 'guest'; 
+                       $moduleName = 'guest';
                        break;
 
                case 'login': // ... and 'login' the member's menu
@@ -1909,7 +1909,7 @@ function addSqlToDebug ($result, $sqlString, $timing, $F, $L) {
                // Check it and cache it in $GLOBALS
                $GLOBALS['debug_sql_available'] = ((isConfigurationLoaded()) && (isDisplayDebugSqlEnabled()));
        } // END - if
-       
+
        // Don't execute anything here if we don't need or ext-other is missing
        if ($GLOBALS['debug_sql_available'] === FALSE) {
                return;
@@ -1926,8 +1926,8 @@ function addSqlToDebug ($result, $sqlString, $timing, $F, $L) {
 
        // Generate record
        $record = array(
-               'num_rows' => SQL_NUMROWS($result),
-               'affected' => SQL_AFFECTEDROWS(),
+               'num_rows' => sqlNumRows($result),
+               'affected' => sqlAffectedRows(),
                'sql_str'  => $sqlString,
                'timing'   => $timing,
                'file'     => basename($F),
@@ -2210,7 +2210,7 @@ function generateAdminMailLinks ($mailType, $mailId) {
        // Is the mail type supported?
        if (!empty($table)) {
                // Query for the mail
-               $result = SQL_QUERY_ESC("SELECT `id`, `%s` AS `mail_status` FROM `{?_MYSQL_PREFIX?}_%s` WHERE `id`=%s LIMIT 1",
+               $result = sqlQueryEscaped("SELECT `id`, `%s` AS `mail_status` FROM `{?_MYSQL_PREFIX?}_%s` WHERE `id`=%s LIMIT 1",
                        array(
                                $statusColumn,
                                $table,
@@ -2218,9 +2218,9 @@ function generateAdminMailLinks ($mailType, $mailId) {
                        ), __FILE__, __LINE__);
 
                // Is there one entry there?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Load the entry
-                       $content = SQL_FETCHARRAY($result);
+                       $content = sqlFetchArray($result);
 
                        // Add output and type
                        $content['type']     = $mailType;
@@ -2234,7 +2234,7 @@ function generateAdminMailLinks ($mailType, $mailId) {
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return generated HTML code
@@ -2447,7 +2447,7 @@ function memberAddEntries ($tableName, $columns = array(), $filterFunctions = ar
        doGenericAddEntries($tableName, $columns, $filterFunctions, $extraValues, $timeColumns, $columnIndex);
 
        // Entry has been added?
-       if ((!SQL_HASZEROAFFECTED()) && ($GLOBALS['__XML_PARSE_RESULT'] === TRUE)) {
+       if ((!ifSqlHasZeroAffectedRows()) && ($GLOBALS['__XML_PARSE_RESULT'] === TRUE)) {
                // Display success message
                displayMessage('{--MEMBER_ENTRY_ADDED--}');
        } else {
@@ -2529,7 +2529,7 @@ function memberDeleteEntriesConfirm ($tableName, $columns = array(), $filterFunc
                        displayMessage('{--MEMBER_ALL_ENTRIES_REMOVED--}');
                } else {
                        // Some are still there :(
-                       displayMessage(sprintf(getMessage('MEMBER_SOME_ENTRIES_NOT_DELETED'), SQL_AFFECTEDROWS(), countPostSelection($idColumn[0])));
+                       displayMessage(sprintf(getMessage('MEMBER_SOME_ENTRIES_NOT_DELETED'), sqlAffectedRows(), countPostSelection($idColumn[0])));
                }
        } else {
                // List for deletion confirmation
@@ -2635,7 +2635,7 @@ function getArrayFromArrayIndex ($array, $key) {
 
 /**
  * Compress given data and encodes it into BASE64 to be stored in database with
- * SQL_QUERY_ESC()
+ * sqlQueryEscaped()
  *
  * @param      $data   Data to be compressed and encoded
  * @return     $data   Compressed+encoded data
index 5dabc85..7f9ff7c 100644 (file)
@@ -50,17 +50,17 @@ $content = array(
 );
 
 // Check for normal mails
-$result_media = SQL_QUERY('SELECT
+$result_media = sqlQuery('SELECT
        SUM(`max_rec`) AS `normal_send`,
        SUM(`clicks`) AS `normal_clicks`
 FROM
        `{?_MYSQL_PREFIX?}_user_stats`', __FILE__, __LINE__);
 
 // Merge data together
-$content = merge_array($content, SQL_FETCHARRAY($result_media));
+$content = merge_array($content, sqlFetchArray($result_media));
 
 // Free memory
-SQL_FREERESULT($result_media);
+sqlFreeResult($result_media);
 
 // Check for bonus extension
 if (isExtensionActive('bonus')) {
@@ -68,7 +68,7 @@ if (isExtensionActive('bonus')) {
        $bcount = countSumTotalData('', 'bonus', 'id', '', TRUE);
 
        // Check for bonus mails
-       $result_media = SQL_QUERY('SELECT
+       $result_media = sqlQuery('SELECT
        SUM(`mails_send`) AS `bonus_send`,
        SUM(`clicks`) AS `bonus_clicks`
 FROM
@@ -76,10 +76,10 @@ FROM
 LIMIT 1', __FILE__, __LINE__);
 
        // Merge data together
-       $content = merge_array($content, SQL_FETCHARRAY($result_media));
+       $content = merge_array($content, sqlFetchArray($result_media));
 
        // Free memory
-       SQL_FREERESULT($result_media);
+       sqlFreeResult($result_media);
 } // END - if
 
 // Load (maybe) missing file
index 16d8b80..8ae5daa 100644 (file)
@@ -896,9 +896,9 @@ function logWrongServerNameRedirect () {
        // Is ext-sql_patches at least version 0.9.2?
        if (isExtensionInstalledAndNewer('sql_patches', '0.9.2')) {
                // Is there an entry?
-               if (countSumTotalData(detectServerName(), 'server_name_log', 'server_name_id', 'server_name', TRUE, str_replace('%', '{PER}', sprintf(" AND `server_name_remote_addr`='%s' AND `server_name_ua`='%s' AND `server_name_referrer`='%s'", SQL_ESCAPE(detectRemoteAddr(TRUE)), SQL_ESCAPE(detectUserAgent(TRUE)), SQL_ESCAPE(detectReferer(TRUE))))) == 1) {
+               if (countSumTotalData(detectServerName(), 'server_name_log', 'server_name_id', 'server_name', TRUE, str_replace('%', '{PER}', sprintf(" AND `server_name_remote_addr`='%s' AND `server_name_ua`='%s' AND `server_name_referrer`='%s'", sqlEscapeString(detectRemoteAddr(TRUE)), sqlEscapeString(detectUserAgent(TRUE)), sqlEscapeString(detectReferer(TRUE))))) == 1) {
                        // Update counter, as all are the same
-                       SQL_QUERY_ESC("UPDATE
+                       sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_server_name_log`
 SET
        `server_name_counter`=`server_name_counter`+1
@@ -916,7 +916,7 @@ LIMIT 1",
                                ), __FUNCTION__, __LINE__);
                } else {
                        // Then log it away
-                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_server_name_log` (`server_name`, `server_name_remote_addr`, `server_name_ua`, `server_name_referrer`) VALUES('%s','%s', '%s', '%s')",
+                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_server_name_log` (`server_name`, `server_name_remote_addr`, `server_name_ua`, `server_name_referrer`) VALUES('%s','%s', '%s', '%s')",
                                array(
                                        detectServerName(),
                                        detectRemoteAddr(TRUE),
index 85b3b9c..4e3605f 100644 (file)
@@ -655,10 +655,10 @@ function isInstallerPostDatabaseConfigValid ($currentTab) {
        unsetSqlLinkUp(__FUNCTION__, __LINE__);
 
        // Try to connect to the database
-       SQL_CONNECT(postRequestElement('mysql_host'), postRequestElement('mysql_login'), postRequestElement('mysql_password1'), __FUNCTION__, __LINE__);
+       sqlConnectToDatabase(postRequestElement('mysql_host'), postRequestElement('mysql_login'), postRequestElement('mysql_password1'), __FUNCTION__, __LINE__);
 
        // Is the link up
-       if (!SQL_IS_LINK_UP()) {
+       if (!isSqlLinkUp()) {
                // Cannot connect to database
                $GLOBALS['installer_post_error'][$currentTab] = '{--INSTALLER_POST_DATABASE_CONNECT_ERROR--}';
                array_push($GLOBALS['installer_failed_fields'][$currentTab], 'mysql_login', 'mysql_password1', 'mysql_password2');
@@ -666,13 +666,13 @@ function isInstallerPostDatabaseConfigValid ($currentTab) {
        } // END - if
 
        // Then attempt to select the database
-       if (!SQL_SELECT_DB(postRequestElement('mysql_dbase'), __FUNCTION__, __LINE__)) {
+       if (!sqlSelectDatabase(postRequestElement('mysql_dbase'), __FUNCTION__, __LINE__)) {
                // Could not find database
                $GLOBALS['installer_post_error'][$currentTab] = '{--INSTALLER_POST_DATABASE_SELECT_FAILED--}';
                array_push($GLOBALS['installer_failed_fields'][$currentTab], 'mysql_dbase');
 
                // Disconnect here, we don't need idle database connections laying around
-               SQL_CLOSE(__FUNCTION__, __LINE__);
+               sqlCloseLink(__FUNCTION__, __LINE__);
 
                // Abort here
                return FALSE;
@@ -692,7 +692,7 @@ function isInstallerPostDatabaseConfigValid ($currentTab) {
                array_push($GLOBALS['installer_failed_fields'][$currentTab], 'mysql_engine');
 
                // Disconnect here, we don't need idle database connections laying around
-               SQL_CLOSE(__FUNCTION__, __LINE__);
+               sqlCloseLink(__FUNCTION__, __LINE__);
 
                // Abort here
                return FALSE;
@@ -702,7 +702,7 @@ function isInstallerPostDatabaseConfigValid ($currentTab) {
                array_push($GLOBALS['installer_failed_fields'][$currentTab], 'mysql_engine');
 
                // Disconnect here, we don't need idle database connections laying around
-               SQL_CLOSE(__FUNCTION__, __LINE__);
+               sqlCloseLink(__FUNCTION__, __LINE__);
 
                // Abort here
                return FALSE;
@@ -728,7 +728,7 @@ function isInstallerPostDatabaseConfigValid ($currentTab) {
                array_push($GLOBALS['installer_failed_fields'][$currentTab], 'mysql_engine');
 
                // Disconnect here, we don't need idle database connections laying around
-               SQL_CLOSE(__FUNCTION__, __LINE__);
+               sqlCloseLink(__FUNCTION__, __LINE__);
 
                // Abort here
                return FALSE;
@@ -784,7 +784,7 @@ function isInstallerPostDatabaseConfigValid ($currentTab) {
        $isValid = (count($tables) == $missingTables);
 
        // Disconnect here, we don't need idle database connections laying around
-       SQL_CLOSE(__FUNCTION__, __LINE__);
+       sqlCloseLink(__FUNCTION__, __LINE__);
 
        // If the status is true, disconnect the database
        if ($isValid === FALSE) {
index 257930f..14c2a0c 100644 (file)
@@ -49,12 +49,12 @@ if ((isPostRequestElementSet('finalize')) && (!isInstalled())) {
        unsetSqlLinkUp(__FILE__, __LINE__);
 
        // Connect to database server
-       SQL_CONNECT($GLOBALS['install_mysql']['host'], $GLOBALS['install_mysql']['login'], $GLOBALS['install_mysql']['password1'], __FILE__, __LINE__);
+       sqlConnectToDatabase($GLOBALS['install_mysql']['host'], $GLOBALS['install_mysql']['login'], $GLOBALS['install_mysql']['password1'], __FILE__, __LINE__);
 
        // Is the link up?
-       if (SQL_IS_LINK_UP()) {
+       if (isSqlLinkUp()) {
                // Seems to work, also right database?
-               if (SQL_SELECT_DB($GLOBALS['install_mysql']['dbase'], __FILE__, __LINE__) === TRUE) {
+               if (sqlSelectDatabase($GLOBALS['install_mysql']['dbase'], __FILE__, __LINE__) === TRUE) {
                        // Check for dumps
                        if ((!isFileReadable(postRequestElement('spath') . 'install/tables.sql')) || (!isFileReadable(postRequestElement('spath') . 'install/menu-'.getLanguage().'.sql'))) {
                                // Installation area not found
index 1d2b257..aa7c6d4 100644 (file)
@@ -89,7 +89,7 @@ addMessages(array(
        'ADMIN_REGISTER_DONE' => "Das Admin-Account wurde soeben erstellt. Sie k&ouml;nnen sich nun mit den eingegeben Login-Daten einloggen.",
        'ADMIN_CANNOT_COMPLETE' => "Kann die Regsitrierung des Admin-Accounts nicht abschliessen.",
        'ADMIN_LOGIN_TITLE' => "Einloggen zum Administrationsbereich",
-       'ADMIN_LOGIN_NOW' => "Sie k&ouml;nnen sich nun in den Administratorbereich einloggen. Geben Sie Ihren Admin-Login und das Passwort dazu ein.",
+       'ADMIN_LOGIN_NOW' => "Login zum Administratorbereich. Geben Sie Ihren Admin-Login und das Passwort dazu ein.",
        'ENTER_ADMIN_LOGIN' => "Administrator-Login",
        'ENTER_ADMIN_PASS' => "Passwort zum Admin-Account",
        'ADMIN_LOGIN_SUBMIT' => "Einloggen",
@@ -869,7 +869,7 @@ addMessages(array(
        'ADMIN_EXTENSION_INITIAL_RELEASE' => "Erstes Release fertiggestellt.",
        'ADMIN_EXTENSION_DEVELOPER_RELEASE' => "Entwickler-Version zum Testen.",
        'ADMIN_EXTENSION_UPDATE_NOTICES_404' => "Keine Update-Hinweise gefunden.",
-       'MYSQL_QUERY_STRING' => "SQL-Abfragebefehl war:",
+       'MYsqlQuery_STRING' => "SQL-Abfragebefehl war:",
        'MEMBER_NO_MAILS_IN_POOL' => "Sie haben noch keine Mailbuchungen aufgegeben! Es k&ouml;nnen somit Ihnen auch keine angezeigt werden.",
        'ADMIN_BACK_TO_GUEST_MENU' => "Zum Gastmen&uuml; zur&uuml;ck...",
        'ADMIN_LOGOUT_NOW' => "Aus dem Admin-Bereich ausloggen",
index 59ce7e3..72d64ec 100644 (file)
@@ -102,22 +102,22 @@ function isAdminsAllowedByAcl ($action, $what) {
                $result = FALSE;
                if (!empty($action)) {
                        // Main menu
-                       $result = SQL_QUERY_ESC("SELECT `access_mode` FROM `{?_MYSQL_PREFIX?}_admins_acls` WHERE `admin_id`=%s AND `action_menu`='%s' LIMIT 1",
+                       $result = sqlQueryEscaped("SELECT `access_mode` FROM `{?_MYSQL_PREFIX?}_admins_acls` WHERE `admin_id`=%s AND `action_menu`='%s' LIMIT 1",
                                array(bigintval($adminId), $action), __FUNCTION__, __LINE__);
                } elseif (!empty($what)) {
                        // Sub menu
-                       $result = SQL_QUERY_ESC("SELECT `access_mode` FROM `{?_MYSQL_PREFIX?}_admins_acls` WHERE `admin_id`=%s AND `what_menu`='%s' LIMIT 1",
+                       $result = sqlQueryEscaped("SELECT `access_mode` FROM `{?_MYSQL_PREFIX?}_admins_acls` WHERE `admin_id`=%s AND `what_menu`='%s' LIMIT 1",
                                array(bigintval($adminId), $what), __FUNCTION__, __LINE__);
                }
 
                // Is an entry found?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Load ACL
-                       list($aclMode) = SQL_FETCHROW($result);
+                       list($aclMode) = sqlFetchRow($result);
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // But default result is failed
@@ -140,7 +140,7 @@ function generateAdminEmailLink ($email, $mod = 'admin') {
        // Is it an email?
        if (isInString('@', $email)) {
                // Create email link
-               $result = SQL_QUERY_ESC("SELECT `id`
+               $result = sqlQueryEscaped("SELECT `id`
 FROM
        `{?_MYSQL_PREFIX?}_admins`
 WHERE
@@ -149,16 +149,16 @@ LIMIT 1",
                array($email), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Load userid
-                       list($adminId) = SQL_FETCHROW($result);
+                       list($adminId) = sqlFetchRow($result);
 
                        // Call this function again
                        $email = generateAdminEmailLink($adminId, $mod);
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } elseif (isValidId($email)) {
                // Direct id given
                $email = '{%url=modules.php?module=' . $mod . '&amp;what=admins_contct&amp;id=' . bigintval($email) . '%}';
@@ -185,7 +185,7 @@ function adminsChangeAdminAccount ($postData, $element = '', $displayMessage = T
                // When both passwords match update admin account
                if ((!empty($element)) && (isset($postData[$element]))) {
                        // Save this setting
-                       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_admins` SET `%s`='%s' WHERE `id`=%s LIMIT 1",
+                       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_admins` SET `%s`='%s' WHERE `id`=%s LIMIT 1",
                                array(
                                        $element,
                                        $postData[$element][$id],
@@ -205,7 +205,7 @@ function adminsChangeAdminAccount ($postData, $element = '', $displayMessage = T
 
                                // Save password when set
                                if (!empty($postData['password1'][$id])) {
-                                       $add = sprintf(",`password`='%s'", SQL_ESCAPE($hash));
+                                       $add = sprintf(",`password`='%s'", sqlEscapeString($hash));
                                } // END - if
 
                                // Get admin's id
@@ -237,7 +237,7 @@ function adminsChangeAdminAccount ($postData, $element = '', $displayMessage = T
                                // Update admin account
                                if ($default == 'allow') {
                                        // Allow changing default ACL
-                                       SQL_QUERY_ESC("UPDATE
+                                       sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_admins`
 SET
        `login`='%s'" . $add . ",
@@ -256,7 +256,7 @@ LIMIT 1",
                                        ), __FUNCTION__, __LINE__);
                                } else {
                                        // Do not allow it here
-                                       SQL_QUERY_ESC("UPDATE
+                                       sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_admins`
 SET
        `login`='%s'" . $add . ",
@@ -284,10 +284,10 @@ LIMIT 1",
                        $SQL = getUpdateSqlFromArray($postData, 'admins', 'id', '%s', array('login', 'id'), $id);
 
                        // Run it
-                       SQL_QUERY_ESC($SQL, array(bigintval($id)), __FUNCTION__, __LINE__);
+                       sqlQueryEscaped($SQL, array(bigintval($id)), __FUNCTION__, __LINE__);
 
                        // Was it updated?
-                       if (SQL_AFFECTEDROWS() == 1) {
+                       if (sqlAffectedRows() == 1) {
                                // Admin account saved
                                $message = '{--ADMIN_ACCOUNT_SAVED--}';
                        } else {
@@ -322,11 +322,11 @@ function adminsEditAdminAccount ($postData) {
                $id = bigintval($id);
 
                // Get the admin's data
-               $result = SQL_QUERY_ESC('SELECT `login`, `email` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
+               $result = sqlQueryEscaped('SELECT `login`, `email` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
                        array($id), __FUNCTION__, __LINE__);
-               if ((SQL_NUMROWS($result) == 1) && ($selected == 1)) {
+               if ((sqlNumRows($result) == 1) && ($selected == 1)) {
                        // Entry found
-                       $content = SQL_FETCHARRAY($result);
+                       $content = sqlFetchArray($result);
 
                        // Prepare some more data for the template
                        $content['id'] = $id;
@@ -345,7 +345,7 @@ function adminsEditAdminAccount ($postData) {
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - foreach
 
        // Load template
@@ -415,7 +415,7 @@ function adminsDeleteAdminAccount ($postData) {
                        $id = bigintval($id);
 
                        // Get the admin's data
-                       $result = SQL_QUERY_ESC('SELECT
+                       $result = sqlQueryEscaped('SELECT
        `login`,
        `email`,
        `default_acl` AS `access_mode`,
@@ -428,9 +428,9 @@ LIMIT 1',
                                array($id), __FUNCTION__, __LINE__);
 
                        // Is there an entry?
-                       if (SQL_NUMROWS($result) == 1) {
+                       if (sqlNumRows($result) == 1) {
                                // Entry found, so load data
-                               $content = SQL_FETCHARRAY($result);
+                               $content = sqlFetchArray($result);
                                $content['access_mode'] = '{--ADMIN_ADMINS_ACCESS_MODE_' . strtoupper($content['access_mode'])    . '--}';
                                $content['la_mode']     = '{--ADMIN_ADMINS_LA_MODE_' . strtoupper($content['la_mode']) . '--}';
 
@@ -442,7 +442,7 @@ LIMIT 1',
                        } // END - if
 
                        // Free result
-                       SQL_FREERESULT($result);
+                       sqlFreeResult($result);
                } // END - foreach
 
                // Load template
@@ -464,11 +464,11 @@ function adminsRemoveAdminAccount ($postData) {
                // Delete only when it's not your own account!
                if (($del == 1) && (getCurrentAdminId() != $id)) {
                        // Rewrite his tasks to all admins
-                       SQL_QUERY_ESC('UPDATE `{?_MYSQL_PREFIX?}_task_system` SET `assigned_admin`=NULL WHERE `assigned_admin`=%s',
+                       sqlQueryEscaped('UPDATE `{?_MYSQL_PREFIX?}_task_system` SET `assigned_admin`=NULL WHERE `assigned_admin`=%s',
                                array($id), __FUNCTION__, __LINE__);
 
                        // Remove account
-                       SQL_QUERY_ESC('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
+                       sqlQueryEscaped('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
                                array($id), __FUNCTION__, __LINE__);
                }
        }
@@ -480,7 +480,7 @@ function adminsRemoveAdminAccount ($postData) {
 // List all admin accounts
 function adminsListAdminAccounts() {
        // Select all admin accounts
-       $result = SQL_QUERY('SELECT
+       $result = sqlQuery('SELECT
        `id`,
        `login`,
        `email`,
@@ -491,7 +491,7 @@ FROM
 ORDER BY
        `login` ASC', __FUNCTION__, __LINE__);
        $OUT = '';
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                // Compile some variables
                $content['access_mode'] = '{--ADMIN_ADMINS_ACCESS_MODE_' . strtoupper($content['access_mode'])    . '--}';
                $content['la_mode']     = '{--ADMIN_ADMINS_LA_MODE_' . strtoupper($content['la_mode']) . '--}';
@@ -501,7 +501,7 @@ ORDER BY
        } // END - while
 
        // Free memory
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Load template
        loadTemplate('admin_list_admins', FALSE, $OUT);
@@ -517,31 +517,31 @@ function sendAdminsEmails ($subject, $template, $content, $userid) {
        $message = loadEmailTemplate($template, $content, $userid);
 
        // Check which admin shall receive this mail
-       $result = SQL_QUERY_ESC("SELECT `admin_id` FROM `{?_MYSQL_PREFIX?}_admins_mails` WHERE `mail_template`='%s' ORDER BY `admin_id` ASC",
+       $result = sqlQueryEscaped("SELECT `admin_id` FROM `{?_MYSQL_PREFIX?}_admins_mails` WHERE `mail_template`='%s' ORDER BY `admin_id` ASC",
                array($template), __FUNCTION__, __LINE__);
 
        // No entries found?
-       if (SQL_HASZERONUMS($result)) {
+       if (ifSqlHasZeroNums($result)) {
                // Is ext-admins' version at least 0.7.9?
                if (isExtensionInstalledAndNewer('admins', '0.7.9')) {
                        // Create new entry (to all admins)
-                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_admins_mails` (`admin_id`, `mail_template`) VALUES (NULL, '%s')",
+                       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_admins_mails` (`admin_id`, `mail_template`) VALUES (NULL, '%s')",
                                array($template), __FUNCTION__, __LINE__);
                } // END - if
 
                // Select all email adresses (default)
-               $result = SQL_QUERY('SELECT `email` FROM `{?_MYSQL_PREFIX?}_admins` ORDER BY `id` ASC',
+               $result = sqlQuery('SELECT `email` FROM `{?_MYSQL_PREFIX?}_admins` ORDER BY `id` ASC',
                        __FUNCTION__, __LINE__);
        } else {
                // Load admin ids...
                // @TODO This can be, somehow, rewritten
                $adminIds = array();
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        array_push($adminIds, $content['admin_id']);
                } // END - while
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
 
                // Init result
                $result = FALSE;
@@ -568,11 +568,11 @@ function sendAdminsEmails ($subject, $template, $content, $userid) {
                        return;
                } elseif (($adminId == '0') || (empty($adminId))) {
                        // Select all email adresses
-                       $result = SQL_QUERY('SELECT `email` FROM `{?_MYSQL_PREFIX?}_admins` ORDER BY `id` ASC',
+                       $result = sqlQuery('SELECT `email` FROM `{?_MYSQL_PREFIX?}_admins` ORDER BY `id` ASC',
                                __FUNCTION__, __LINE__);
                } else {
                        // If Admin-Id is not "to-all" select
-                       $result = SQL_QUERY_ESC('SELECT `email` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id` IN (%s) ORDER BY `id` ASC',
+                       $result = sqlQueryEscaped('SELECT `email` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id` IN (%s) ORDER BY `id` ASC',
                                array($adminId), __FUNCTION__, __LINE__);
                }
        }
@@ -587,12 +587,12 @@ function sendAdminsEmails ($subject, $template, $content, $userid) {
        } // END - if
 
        // Load email addresses and send away
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                sendEmail($content['email'], $subject, $message, 'N', $mailHeader);
        } // END - while
 
        // Free memory
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 }
 
 // "Getter" for current admin's expert settings
@@ -612,20 +612,20 @@ function getAminsExpertSettings () {
                incrementStatsEntry('cache_hits');
        } elseif (!isExtensionInstalled('cache')) {
                // Load from database
-               $result = SQL_QUERY_ESC('SELECT `expert_settings` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
+               $result = sqlQueryEscaped('SELECT `expert_settings` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
                        array($adminId), __FUNCTION__, __LINE__);
 
                // Entry found?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Fetch data
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
 
                        // Set cache
                        $GLOBALS['cache_array']['admin']['expert_settings'][$adminId] = $data['expert_settings'];
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Return the result
@@ -649,20 +649,20 @@ function getAminsExpertWarning () {
                incrementStatsEntry('cache_hits');
        } elseif (!isExtensionInstalled('cache')) {
                // Load from database
-               $result = SQL_QUERY_ESC('SELECT `expert_warning` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
+               $result = sqlQueryEscaped('SELECT `expert_warning` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
                        array($adminId), __FUNCTION__, __LINE__);
 
                // Entry found?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Fetch data
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
 
                        // Set cache
                        $GLOBALS['cache_array']['admin']['expert_warning'][$adminId] = $data['expert_warning'];
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Return the result
@@ -688,17 +688,17 @@ function getAdminLoginFailures ($adminId) {
                incrementStatsEntry('cache_hits');
        } elseif (!isExtensionActive('cache')) {
                // Load from database
-               $result = SQL_QUERY_ESC('SELECT `login_failures` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
+               $result = sqlQueryEscaped('SELECT `login_failures` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
                        array($adminId), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Get it
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Return the login_failures
@@ -724,17 +724,17 @@ function getAdminLastFailure ($adminId) {
                incrementStatsEntry('cache_hits');
        } elseif (!isExtensionActive('cache')) {
                // Load from database
-               $result = SQL_QUERY_ESC('SELECT UNIX_TIMESTAMP(`last_failure`) AS `last_failure` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
+               $result = sqlQueryEscaped('SELECT UNIX_TIMESTAMP(`last_failure`) AS `last_failure` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1',
                        array($adminId), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Get it
-                       $data = SQL_FETCHARRAY($result);
+                       $data = sqlFetchArray($result);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        }
 
        // Return the last_failure
index 01b6300..b93c09d 100644 (file)
@@ -48,11 +48,11 @@ function addPointsBeg ($userid, $points) {
        // Is begging rallye active?
        if (isBegRallyeEnabled()) {
                // Add points to rallye account
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `beg_points`=`beg_points`+%s WHERE `userid`=%s LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `beg_points`=`beg_points`+%s WHERE `userid`=%s LIMIT 1",
                        array($points, $userid), __FUNCTION__, __LINE__);
 
                // We need to set $add here, two
-               $added = (!SQL_HASZEROAFFECTED());
+               $added = (!ifSqlHasZeroAffectedRows());
        } else {
                // Add points to account
                initReferralSystem();
index ab92566..9097b41 100644 (file)
@@ -69,7 +69,7 @@ function isGenericBlacklisted ($type, $data) {
                return FALSE;
        } elseif (!isset($GLOBALS['blacklist_data'][$type][$data])) {
                // Check black-list for given email
-               $result = SQL_QUERY_ESC("SELECT
+               $result = sqlQueryEscaped("SELECT
        `id`,
        `data`,
        `pool_id`,
@@ -88,16 +88,16 @@ LIMIT 1",
                        ), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Jupp, we got one listed
-                       $GLOBALS['blacklist_data'][$type][$data] = SQL_FETCHARRAY($result);
+                       $GLOBALS['blacklist_data'][$type][$data] = sqlFetchArray($result);
 
                        // Mark it as listed
                        $listed = TRUE;
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } else {
                // Is found in cache -> black-listed
                $listed = TRUE;
@@ -133,7 +133,7 @@ function insertGenericInBlacklist ($type, $data, $poolId = NULL, $provider = 'BL
                reportBug(__FUNCTION__, __LINE__, 'Blacklisting of type ' . $type . ' is disabled, data=' . $data . ',poolId=' . convertZeroToNull($poolId));
        } elseif (!isUrlBlacklisted($data)) {
                // Did not find a record so we can add it... :)
-               SQL_QUERY_ESC("INSERT INTO
+               sqlQueryEscaped("INSERT INTO
        `{?_MYSQL_PREFIX?}_blacklist`
 (
        `data`,
@@ -155,7 +155,7 @@ function insertGenericInBlacklist ($type, $data, $poolId = NULL, $provider = 'BL
        } // END - if
 
        // Return insert id for debugging/reporting pursposes
-       return SQL_INSERT_ID();
+       return getSqlInsertId();
 }
 
 // ----------------------------------------------------------------------------
index bb11890..b053c1d 100644 (file)
@@ -96,14 +96,14 @@ function addTurboBonus ($id, $userid, $type) {
        }
 
        // Add points to his account directly
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `turbo_bonus`=`turbo_bonus`+%s WHERE `userid`=%s LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `turbo_bonus`=`turbo_bonus`+%s WHERE `userid`=%s LIMIT 1",
                array(
                        $points,
                        bigintval($userid)
                ), __FUNCTION__, __LINE__);
 
        // Rember this whole data for displaying ranking list
-       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_bonus_turbo` (`userid`, `mail_id`, `bonus_id`, `level`, `points`, `timemark`) VALUES (%s, %s, %s, %s, %s, UNIX_TIMESTAMP())",
+       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_bonus_turbo` (`userid`, `mail_id`, `bonus_id`, `level`, `points`, `timemark`) VALUES (%s, %s, %s, %s, %s, UNIX_TIMESTAMP())",
                array(
                        bigintval($userid),
                        $mailId,
@@ -132,7 +132,7 @@ function addBonusRanks ($data, $type, $userid) {
        $ranks = count(explode(';', getTurboRates())) + 1;
 
        // Load current user's data
-       $result = SQL_QUERY_ESC("SELECT `level`, `points`, `timemark` FROM `{?_MYSQL_PREFIX?}_bonus_turbo` WHERE `%s`=%s AND `userid`=%s LIMIT 1",
+       $result = sqlQueryEscaped("SELECT `level`, `points`, `timemark` FROM `{?_MYSQL_PREFIX?}_bonus_turbo` WHERE `%s`=%s AND `userid`=%s LIMIT 1",
                array(
                        $type,
                        $data,
@@ -140,9 +140,9 @@ function addBonusRanks ($data, $type, $userid) {
                ), __FUNCTION__, __LINE__);
 
        // Entry found?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Load data
-               $GLOBALS['ranking_content'] = merge_array($GLOBALS['ranking_content'], SQL_FETCHARRAY($result));
+               $GLOBALS['ranking_content'] = merge_array($GLOBALS['ranking_content'], sqlFetchArray($result));
 
                // Remember all values for later use
                $self = TRUE;
@@ -155,13 +155,13 @@ function addBonusRanks ($data, $type, $userid) {
        } // END - if
 
        // Load rankings
-       $result = SQL_QUERY_ESC("SELECT `id` FROM `{?_MYSQL_PREFIX?}_bonus_turbo` WHERE `%s`=%s ORDER BY `level` ASC LIMIT {?bonus_lines?}",
+       $result = sqlQueryEscaped("SELECT `id` FROM `{?_MYSQL_PREFIX?}_bonus_turbo` WHERE `%s`=%s ORDER BY `level` ASC LIMIT {?bonus_lines?}",
                array($type, $data), __FUNCTION__, __LINE__);
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Output all ranks (levels)
-               for ($rank = 1; $rank <= SQL_NUMROWS($result); $rank++) {
+               for ($rank = 1; $rank <= sqlNumRows($result); $rank++) {
                        // Load data
-                       $result_users = SQL_QUERY_ESC("SELECT
+                       $result_users = sqlQueryEscaped("SELECT
        `userid`,
        `points`
 FROM
@@ -177,13 +177,13 @@ LIMIT 1",
                        $rows['points'] = '---';
 
                        // Are you one of them?
-                       if (SQL_NUMROWS($result_users) == 1) {
+                       if (sqlNumRows($result_users) == 1) {
                                // Load data
-                               $rows = merge_array($rows, SQL_FETCHARRAY($result_users));
+                               $rows = merge_array($rows, sqlFetchArray($result_users));
                        } // END - if
 
                        // Free result
-                       SQL_FREERESULT($result_users);
+                       sqlFreeResult($result_users);
 
                        // Add more
                        $rows['rank'] = $rank;
@@ -274,11 +274,11 @@ function handleBonusPoints ($mode, $userid) {
 // Purges expired fast-click bonus entries
 function purgeExpiredTurboBonus () {
        // Remove entries
-       $result = SQL_QUERY('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_bonus_turbo` WHERE (UNIX_TIMESTAMP() - `timemark`) >= {?bonus_timeout?}', __FUNCTION__, __LINE__);
+       $result = sqlQuery('DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_bonus_turbo` WHERE (UNIX_TIMESTAMP() - `timemark`) >= {?bonus_timeout?}', __FUNCTION__, __LINE__);
 
-       if (!SQL_HASZEROAFFECTED()) {
+       if (!ifSqlHasZeroAffectedRows()) {
                // Send out email to admin
-               sendAdminNotification('{--ADMIN_AUTOPURGE_TURBO_SUBJECT--}', 'admin_purge_turbo', SQL_AFFECTEDROWS());
+               sendAdminNotification('{--ADMIN_AUTOPURGE_TURBO_SUBJECT--}', 'admin_purge_turbo', sqlAffectedRows());
        } // END - if
 }
 
index 21ae323..758dc7d 100644 (file)
@@ -49,7 +49,7 @@ function addBookingRecord ($subject, $userid, $points, $pointsMode, $accountType
        } // END - if
 
        // Add record entry here
-       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_booking` (`userid`, `subject`, `points_mode`, `points_account_type`, `points`) VALUES (%s, '%s', '%s', '%s', %s)",
+       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_user_booking` (`userid`, `subject`, `points_mode`, `points_account_type`, `points`) VALUES (%s, '%s', '%s', '%s', %s)",
                array(
                        bigintval($userid),
                        $subject,
index 5f54e82..7254ff1 100644 (file)
@@ -46,7 +46,7 @@ function generateCountryInfo ($id) {
        $ret = '{--COUNTRY_CODE_404--}';
 
        // Load code and description
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `code`,
        `descr`
 FROM
@@ -57,9 +57,9 @@ LIMIT 1",
                array(bigintval($id)), __FUNCTION__, __LINE__);
 
        // Is there an entry?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Load entry
-               $content = SQL_FETCHARRAY($result);
+               $content = sqlFetchArray($result);
                //* DEBUG: */ print($id.'=<pre>'.print_r($content, TRUE).'</pre>');
 
                // Construct human-readable description
@@ -67,7 +67,7 @@ LIMIT 1",
        } // END - if
 
        // Free the result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return info
        return $ret;
index 89303d8..4e31210 100644 (file)
@@ -67,7 +67,7 @@ function generateDoublerTable ($userid = NULL, $done = 'N', $ref = 'N', $sort =
        }
 
        // List entries
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `userid`,
        `refid`,
        `points`,
@@ -88,10 +88,10 @@ LIMIT %s",
                        $limit
                ), __FUNCTION__, __LINE__);
 
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // List entries
                $OUT = '';
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        // Rewrite userid/refid only if admin is in
                        // @TODO Can't this be moved into EL?
                        if (isAdmin()) {
@@ -112,7 +112,7 @@ LIMIT %s",
                } // END - while
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } else {
                // List no entries
                $OUT = '<tr>
index 345a06c..cac106a 100644 (file)
@@ -103,7 +103,7 @@ function doMemberEarning ($earningId, $dailyAmount, $isActive = 'Y') {
 // Insert member earning entry
 function insertMemberEarning ($earningId, $dailyAmount, $isActive = 'Y') {
        // Insert the record
-       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_earning` (`earning_id`, `earning_userid`, `earning_daily_amount`, `earning_active`) VALUES(%s,%s,%s,'%s')",
+       sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_user_earning` (`earning_id`, `earning_userid`, `earning_daily_amount`, `earning_active`) VALUES(%s,%s,%s,'%s')",
                array(
                        bigintval($earningId),
                        getMemberId(),
@@ -113,7 +113,7 @@ function insertMemberEarning ($earningId, $dailyAmount, $isActive = 'Y') {
 
        // Prepare content
        $content = array(
-               'insert_id'    => SQL_INSERT_ID(),
+               'insert_id'    => getSqlInsertId(),
                'earning_id'   => bigintval($earningId),
                'daily_amount' => bigintval($dailyAmount),
                'is_active'    => $isActive
@@ -144,7 +144,7 @@ function updateMemberEarning ($earningId, $dailyAmount, $isActive = 'Y') {
        } // END - if
 
        // Update database record
-       SQL_QUERY_ESC("UPDATE
+       sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_user_earning`
 SET
        `earning_daily_amount`=%s,
@@ -161,7 +161,7 @@ LIMIT 1", array(
        ), __FUNCTION__, __LINE__);
 
        // Determine whether something has changed
-       $status = (!SQL_HASZEROAFFECTED());
+       $status = (!ifSqlHasZeroAffectedRows());
 
        // Has the record changed?
        if ($status === TRUE) {
index 0f9c80d..1705959 100644 (file)
@@ -189,11 +189,11 @@ function getArrayFromForcedAdsByType ($forcedType = NULL) {
        // Is forced type not NULL?
        if (!is_null($forcedType)) {
                // Then set proper WHERE
-               $where = sprintf("WHERE `forced_ads_type`='%s'", SQL_ESCAPE($forcedType));
+               $where = sprintf("WHERE `forced_ads_type`='%s'", sqlEscapeString($forcedType));
        } // END - if
 
        // Search all given types
-       $result = SQL_QUERY('SELECT
+       $result = sqlQuery('SELECT
        `forced_ads_id`,
        `forced_ads_ad_url`,
        `forced_ads_click_url`,
@@ -213,16 +213,16 @@ ORDER BY
        `forced_ads_id` ASC', __FUNCTION__, __LINE__);
 
        // Is there at least one entry?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Get all elements
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        // Add it
                        $forcedAds[$content['forced_ads_id']] = $content;
                } // END - while
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return it
        return $forcedAds;
@@ -237,11 +237,11 @@ function getArrayFromForcedCostsByVisibility ($visibility = NULL) {
        // Is visibility not NULL?
        if (!is_null($visibility)) {
                // Then add WHERE statement
-               $where = sprintf(" WHERE `forced_costs_visibility`='%s'", SQL_ESCAPE($visibility));
+               $where = sprintf(" WHERE `forced_costs_visibility`='%s'", sqlEscapeString($visibility));
        } // END - if
 
        // Search all given types
-       $result = SQL_QUERY("SELECT
+       $result = sqlQuery("SELECT
        `forced_costs_id`,
        `forced_costs_price_click`,
        `forced_costs_payment_click`,
@@ -253,16 +253,16 @@ ORDER BY
        `forced_costs_id` ASC", __FUNCTION__, __LINE__);
 
        // Is there at least one entry?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Get all elements
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        // Add it
                        $forcedCosts[$content['forced_costs_id']] = $content;
                } // END - while
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return it
        return $forcedCosts;
@@ -274,7 +274,7 @@ function getArrayFromForcedCampaignsByArray ($ids, $status) {
        $forcedCampaigns = array();
 
        // Search all given types
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `forced_campaign_id`,
        UNIX_TIMESTAMP(`forced_campaign_created`) AS `forced_campaign_created`,
        `forced_campaign_status`,
@@ -301,16 +301,16 @@ ORDER BY
                ), __FUNCTION__, __LINE__);
 
        // Is there at least one entry?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Get all elements
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        // Add it
                        $forcedCampaigns[$content['forced_campaign_id']] = $content;
                } // END - while
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return it
        return $forcedCampaigns;
@@ -372,7 +372,7 @@ function changeForcedCampaignStatus ($campaignId, $prevStatus, $newStatus, $data
 
        // Update the status now
        // ---------- Comment out for debugging/developing member actions! ---------
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_forced_campaigns` SET `forced_campaign_status`='%s' WHERE `forced_campaign_id`=%s LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_forced_campaigns` SET `forced_campaign_status`='%s' WHERE `forced_campaign_id`=%s LIMIT 1",
                array(
                        $newStatus,
                        bigintval($campaignId)
@@ -381,7 +381,7 @@ function changeForcedCampaignStatus ($campaignId, $prevStatus, $newStatus, $data
 
        // Was that fine?
        // ---------- Comment out for debugging/developing member actions! ---------
-       if (SQL_AFFECTEDROWS() != 1) {
+       if (sqlAffectedRows() != 1) {
                // No, something went wrong
                return FALSE;
        } // END - if
index a3dc906..42c781d 100644 (file)
@@ -54,7 +54,7 @@ function generateGradeDataParentIdOptions ($defaultId = NULL) {
                } // END - if
 
                // Look for all
-               $result = SQL_QUERY('SELECT
+               $result = sqlQuery('SELECT
        `grade_id`,
        `grade_name`
 FROM
@@ -68,9 +68,9 @@ ORDER BY
                $gradeValues = array();
 
                // Are there entries?
-               if (!SQL_HASZERONUMS($result)) {
+               if (!ifSqlHasZeroNums($result)) {
                        // Load all entries
-                       while ($grade = SQL_FETCHARRAY($result)) {
+                       while ($grade = sqlFetchArray($result)) {
                                // Add it to arrays
                                array_push($gradeKeys  , $grade['grade_id']);
                                array_push($gradeValues, $grade['grade_name']);
@@ -86,7 +86,7 @@ ORDER BY
                );
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return cache
index 01a2802..340a5ab 100644 (file)
@@ -43,7 +43,7 @@ if (!defined('__SECURITY')) {
 // Stops all expired holidays
 function stopHolidays () {
        // Let's find some expired holiday requests...
-       $result_stop = SQL_QUERY("SELECT
+       $result_stop = sqlQuery("SELECT
        `userid`,
        `holiday_start`,
        `holiday_end`,
@@ -54,7 +54,7 @@ WHERE
        `holiday_end` <= UNIX_TIMESTAMP()
 ORDER BY
        `userid` ASC", __FUNCTION__, __LINE__);
-       if (!SQL_HASZERONUMS($result_stop)) {
+       if (!ifSqlHasZeroNums($result_stop)) {
                // We foud at least one
                $admin = '';
 
@@ -62,13 +62,13 @@ ORDER BY
                initSqls();
 
                // Process all found entries
-               while ($content = SQL_FETCHARRAY($result_stop)) {
+               while ($content = sqlFetchArray($result_stop)) {
                        // Stop holiday
-                       addSql(SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_holidays` WHERE `userid`=%s LIMIT 1",
+                       addSql(sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_holidays` WHERE `userid`=%s LIMIT 1",
                                array(bigintval($content['userid'])), __FUNCTION__, __LINE__, FALSE));
 
                        // Unlock account
-                       addSql(SQL_QUERY_ESC("UPDATE
+                       addSql(sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_user_data`
 SET
        `holiday_active`='N',
@@ -101,7 +101,7 @@ LIMIT 1",
        } // END - if
 
        // Free memory
-       SQL_FREERESULT($result_stop);
+       sqlFreeResult($result_stop);
 }
 
 // ----------------------------------------------------------------------------
index 4c8efb6..a8964e0 100644 (file)
@@ -47,19 +47,19 @@ function getJackpotPoints () {
        $data['points'] = '0.00000';
 
        // Read them
-       $result = SQL_QUERY("SELECT `points` FROM `{?_MYSQL_PREFIX?}_jackpot` WHERE `ok`='ok' LIMIT 1", __FUNCTION__, __LINE__);
+       $result = sqlQuery("SELECT `points` FROM `{?_MYSQL_PREFIX?}_jackpot` WHERE `ok`='ok' LIMIT 1", __FUNCTION__, __LINE__);
 
        // Is there an entry?
-       if (SQL_HASZERONUMS($result)) {
+       if (ifSqlHasZeroNums($result)) {
                // No, so create line
-               SQL_QUERY("INSERT INTO `{?_MYSQL_PREFIX?}_jackpot` (`ok`, `points`) VALUES ('ok','0.00000')", __FUNCTION__, __LINE__);
+               sqlQuery("INSERT INTO `{?_MYSQL_PREFIX?}_jackpot` (`ok`, `points`) VALUES ('ok','0.00000')", __FUNCTION__, __LINE__);
        } else {
                // Read the line
-               $data = SQL_FETCHARRAY($result);
+               $data = sqlFetchArray($result);
        }
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return them
        return $data['points'];
@@ -71,7 +71,7 @@ function addPointsToJackpot ($points) {
        $jackpot = getJackpotPoints();
 
        // Update points
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_jackpot` SET `points`=`points`+%s WHERE `ok`='ok' LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_jackpot` SET `points`=`points`+%s WHERE `ok`='ok' LIMIT 1",
                array($points), __FUNCTION__, __LINE__);
 }
 
@@ -86,13 +86,13 @@ function subtractPointsFromJackpot ($points) {
        // Enougth points i jackpot?
        if ($jackpot >= $points) {
                // Update points when there are enougth points in jackpot
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_jackpot` SET `points`=`points`-%s WHERE `ok`='ok' LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_jackpot` SET `points`=`points`-%s WHERE `ok`='ok' LIMIT 1",
                        array($points), __FUNCTION__, __LINE__);
-               $ret = (!SQL_HASZEROAFFECTED());
+               $ret = (!ifSqlHasZeroAffectedRows());
        } // END - if
 
        // Free memory
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return the result
        return $ret;
index c56b861..7d1aeb7 100644 (file)
@@ -93,7 +93,7 @@ function doMailIdAdd ($data) {
        // @TODO Rewrite this to a filter
        switch ($data['link_type']) {
                case 'NORMAL':
-                       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_stats` SET `clicks`=`clicks`+1 WHERE `id`=%s LIMIT 1",
+                       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_stats` SET `clicks`=`clicks`+1 WHERE `id`=%s LIMIT 1",
                                array(bigintval($data['id'])), __FILE__, __LINE__);
 
                        // Update mediadata as well
@@ -104,7 +104,7 @@ function doMailIdAdd ($data) {
                        break;
 
                case 'BONUS':
-                       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_bonus` SET `clicks`=`clicks`+1 WHERE `id`=%s LIMIT 1",
+                       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_bonus` SET `clicks`=`clicks`+1 WHERE `id`=%s LIMIT 1",
                                array(bigintval($data['id'])), __FILE__, __LINE__);
 
                        // Update mediadata as well
@@ -123,13 +123,13 @@ function doMailIdAdd ($data) {
        // @TODO Rewrite these blocks to filter
        if (isExtensionInstalledAndNewer('user', '0.1.2')) {
                // Update counter
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `mails_confirmed`=`mails_confirmed`+1 WHERE `userid`=%s LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `mails_confirmed`=`mails_confirmed`+1 WHERE `userid`=%s LIMIT 1",
                        array(bigintval($data['userid'])), __FILE__, __LINE__);
 
                // Update random confirmed as well?
                if ((isExtensionInstalledAndNewer('user', '0.3.4')) && (isRandomReferralIdEnabled())) {
                        // Update second counter
-                       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `rand_confirmed`=`rand_confirmed` + 1 WHERE `userid`=%s LIMIT 1",
+                       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `rand_confirmed`=`rand_confirmed` + 1 WHERE `userid`=%s LIMIT 1",
                                array(bigintval($data['userid'])), __FILE__, __LINE__);
                } // END - if
        } // END - if
@@ -152,7 +152,7 @@ function doMailIdAdd ($data) {
                } // END - if
 
                // Count down ref_payout value
-               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `ref_payout`=`ref_payout`-1 WHERE `userid`=%s AND `ref_payout` > 0 LIMIT 1",
+               sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_user_data` SET `ref_payout`=`ref_payout`-1 WHERE `userid`=%s AND `ref_payout` > 0 LIMIT 1",
                        array(bigintval($data['userid'])), __FILE__, __LINE__);
 
                // Add points
@@ -197,7 +197,7 @@ function doMailIdAdd ($data) {
        }
 
        // Remove link from table
-       SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_links` WHERE `id`=%s LIMIT 1",
+       sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_user_links` WHERE `id`=%s LIMIT 1",
                array(bigintval($data['link_id'])), __FILE__, __LINE__);
 }
 
index d59b9ab..27f38ad 100644 (file)
@@ -51,7 +51,7 @@ function updateMediadataEntry ($keys_array, $mode, $value) {
                // Is an array so we can run it through
                foreach ($keys_array as $key) {
                        // First check if it does exist
-                       $result_media = SQL_QUERY_ESC("SELECT
+                       $result_media = sqlQueryEscaped("SELECT
        `media_key`
 FROM
        `{?_MYSQL_PREFIX?}_mediadata`
@@ -59,9 +59,9 @@ WHERE
        `media_key`='%s'
 LIMIT 1", array($key), __FUNCTION__, __LINE__);
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'key=' . $key . ',SQL_NUMROWS()=' . SQL_NUMROWS($result_media));
-                       if (SQL_NUMROWS($result_media) == 0) {
+                       if (sqlNumRows($result_media) == 0) {
                                // Not found so we create it (mode will be ignored here!)
-                               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_mediadata` (`media_key`, `media_value`) VALUES ('%s', '%s')",
+                               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_mediadata` (`media_key`, `media_value`) VALUES ('%s', '%s')",
                                        array($key, $value), __FUNCTION__, __LINE__);
                        } else {
                                // Update entry
@@ -72,17 +72,17 @@ LIMIT 1", array($key), __FUNCTION__, __LINE__);
 
                                if ($mode == 'init') {
                                        // Initialize entry
-                                       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_mediadata` SET `media_value`=%s WHERE `media_key`='%s' LIMIT 1",
+                                       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_mediadata` SET `media_value`=%s WHERE `media_key`='%s' LIMIT 1",
                                                array($value, $key), __FUNCTION__, __LINE__);
                                } else {
                                        // Update entry
-                                       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_mediadata` SET `media_value`=`media_value`".$mode."%s WHERE `media_key`='%s' LIMIT 1",
+                                       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_mediadata` SET `media_value`=`media_value`".$mode."%s WHERE `media_key`='%s' LIMIT 1",
                                                array($value, $key), __FUNCTION__, __LINE__);
                                }
                        }
 
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'added=' . intval($added));
-                       $added = (!SQL_HASZEROAFFECTED());
+                       $added = (!ifSqlHasZeroAffectedRows());
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'added=' . intval($added));
                } // END - foreach
        } // END - if
@@ -104,13 +104,13 @@ function getMediadataEntry ($key) {
        $value = '';
 
        // Check for entry
-       $result = SQL_QUERY_ESC("SELECT `media_value` FROM `{?_MYSQL_PREFIX?}_mediadata` WHERE `media_key`='%s' LIMIT 1",
+       $result = sqlQueryEscaped("SELECT `media_value` FROM `{?_MYSQL_PREFIX?}_mediadata` WHERE `media_key`='%s' LIMIT 1",
                array($key), __FUNCTION__, __LINE__);
 
        // Is there one?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Load data
-               list($value) = SQL_FETCHROW($result);
+               list($value) = sqlFetchRow($result);
        } // END - if
 
        // Return data
index bb5d7c5..e811fae 100644 (file)
@@ -194,7 +194,7 @@ function isNetworkTypeHandleValid ($type, $networkId) {
        // Is there cache?
        if (!isset($GLOBALS[__FUNCTION__][$networkId][$type])) {
                // Does it exist?
-               $GLOBALS[__FUNCTION__][$networkId][$type] = (countSumTotalData(bigintval($networkId), 'network_types', 'network_type_id', 'network_id', TRUE, sprintf(" AND `network_type_handler`='%s'", SQL_ESCAPE($type))) == 1);
+               $GLOBALS[__FUNCTION__][$networkId][$type] = (countSumTotalData(bigintval($networkId), 'network_types', 'network_type_id', 'network_id', TRUE, sprintf(" AND `network_type_handler`='%s'", sqlEscapeString($type))) == 1);
        } // END - if
 
        // Return result
@@ -206,7 +206,7 @@ function isNetworkRequestElementValid ($key, $networkTypeId, $networkId) {
        // Is there cache?
        if (!isset($GLOBALS[__FUNCTION__][$networkId][$networkTypeId][$key])) {
                // Does it exist?
-               $GLOBALS[__FUNCTION__][$networkId][$networkTypeId][$key] = (countSumTotalData(bigintval($networkId), 'network_request_params', 'network_request_param_id', 'network_id', TRUE, sprintf(" AND `network_type_id`=%s AND `network_request_param_key`='%s'", bigintval($networkTypeId), SQL_ESCAPE($key))) == 1);
+               $GLOBALS[__FUNCTION__][$networkId][$networkTypeId][$key] = (countSumTotalData(bigintval($networkId), 'network_request_params', 'network_request_param_id', 'network_id', TRUE, sprintf(" AND `network_type_id`=%s AND `network_request_param_key`='%s'", bigintval($networkTypeId), sqlEscapeString($key))) == 1);
        } // END - if
 
        // Return result
@@ -218,7 +218,7 @@ function isNetworkArrayTranslationValid ($key, $networkTypeId, $networkId) {
        // Is there cache?
        if (!isset($GLOBALS[__FUNCTION__][$networkId][$networkTypeId][$key])) {
                // Does it exist?
-               $GLOBALS[__FUNCTION__][$networkId][$networkTypeId][$key] = (countSumTotalData(bigintval($networkId), 'network_array_translation', 'network_array_id', 'network_id', TRUE, sprintf(" AND `network_type_id`=%s AND `network_array_index`='%s'", bigintval($networkTypeId), SQL_ESCAPE($key))) == 1);
+               $GLOBALS[__FUNCTION__][$networkId][$networkTypeId][$key] = (countSumTotalData(bigintval($networkId), 'network_array_translation', 'network_array_id', 'network_id', TRUE, sprintf(" AND `network_type_id`=%s AND `network_array_index`='%s'", bigintval($networkTypeId), sqlEscapeString($key))) == 1);
        } // END - if
 
        // Return result
@@ -245,7 +245,7 @@ function getNetworkDataFromId ($networkId, $column = '') {
                $GLOBALS['network_data'][$networkId] = array();
 
                // Query for the network data
-               $result = SQL_QUERY_ESC('SELECT
+               $result = sqlQueryEscaped('SELECT
        `network_id`,
        `network_short_name`,
        `network_title`,
@@ -264,13 +264,13 @@ LIMIT 1',
                        array(bigintval($networkId)), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Then get it
-                       $GLOBALS['network_data'][$networkId] = SQL_FETCHARRAY($result);
+                       $GLOBALS['network_data'][$networkId] = sqlFetchArray($result);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return result
@@ -300,7 +300,7 @@ function getNetworkDataByTypeId ($networkTypeId, $column = '') {
                $GLOBALS['network_type_data'][$networkTypeId] = array();
 
                // Query for the network data
-               $result = SQL_QUERY_ESC('SELECT
+               $result = sqlQueryEscaped('SELECT
        `d`.`network_id`,
        `d`.`network_short_name`,
        `d`.`network_title`,
@@ -330,13 +330,13 @@ LIMIT 1',
                        array(bigintval($networkTypeId)), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Then get it
-                       $GLOBALS['network_type_data'][$networkTypeId] = SQL_FETCHARRAY($result);
+                       $GLOBALS['network_type_data'][$networkTypeId] = sqlFetchArray($result);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return result
@@ -366,7 +366,7 @@ function getNetworkTypeDataByTypeId ($networkTypeId) {
                $GLOBALS['network_type_data'][$networkTypeId] = array();
 
                // Query for the network data
-               $result = SQL_QUERY_ESC('SELECT
+               $result = sqlQueryEscaped('SELECT
        `network_type_id`,
        `network_id`,
        `network_type_handler`,
@@ -381,13 +381,13 @@ LIMIT 1',
                        array(bigintval($networkTypeId)), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Then get it
-                       $GLOBALS['network_type_data'][$networkTypeId] = SQL_FETCHARRAY($result);
+                       $GLOBALS['network_type_data'][$networkTypeId] = sqlFetchArray($result);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return result
@@ -408,7 +408,7 @@ function getNetworkTypeDataFromId ($networkId) {
                $GLOBALS['network_types'][$networkId] = array();
 
                // Query for the network data
-               $result = SQL_QUERY_ESC('SELECT
+               $result = sqlQueryEscaped('SELECT
        `network_type_id`,
        `network_id`,
        `network_type_handler`,
@@ -424,16 +424,16 @@ ORDER BY
                        array(bigintval($networkId)), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (!SQL_HASZERONUMS($result)) {
+               if (!ifSqlHasZeroNums($result)) {
                        // Then add all
-                       while ($row = SQL_FETCHARRAY($result)) {
+                       while ($row = sqlFetchArray($result)) {
                                // Add it with new index as it is no longer required
                                $GLOBALS['network_types'][$networkId][] = $row;
                        } // END - if
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return result
@@ -452,7 +452,7 @@ function getNetworkRequestParamsDataFromId ($networkRequestId) {
        $networkRequestData = array();
 
        // Query for the network data
-       $result = SQL_QUERY_ESC('SELECT
+       $result = sqlQueryEscaped('SELECT
        `network_request_param_id`,
        `network_id`,
        `network_type_id`,
@@ -467,13 +467,13 @@ LIMIT 1',
                array(bigintval($networkRequestId)), __FUNCTION__, __LINE__);
 
        // Is there an entry?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Then get it
-               $networkRequestData = SQL_FETCHARRAY($result);
+               $networkRequestData = sqlFetchArray($result);
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return result
        return $networkRequestData;
@@ -491,7 +491,7 @@ function getNetworkArrayTranslationsDataFromId ($networkTranslationId) {
        $networkTranslationData = array();
 
        // Query for the network data
-       $result = SQL_QUERY_ESC('SELECT
+       $result = sqlQueryEscaped('SELECT
        `network_array_id`,
        `network_id`,
        `network_type_id`,
@@ -505,13 +505,13 @@ LIMIT 1',
                array(bigintval($networkTranslationId)), __FUNCTION__, __LINE__);
 
        // Is there an entry?
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Then get it
-               $networkTranslationData = SQL_FETCHARRAY($result);
+               $networkTranslationData = sqlFetchArray($result);
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return result
        return $networkTranslationData;
@@ -531,7 +531,7 @@ function getNetworkRequestParametersByTypeId ($networkTypeId) {
                $GLOBALS['network_request_parameters'][$networkTypeId] = array();
 
                // Search for all
-               $result = SQL_QUERY_ESC('SELECT
+               $result = sqlQueryEscaped('SELECT
        `network_id`,
        `network_type_id`,
        `network_request_param_key`,
@@ -548,16 +548,16 @@ ORDER BY
                ), __FUNCTION__, __LINE__);
 
                // Are there records?
-               if (!SQL_HASZERONUMS($result)) {
+               if (!ifSqlHasZeroNums($result)) {
                        // Load all but make new indexes as the old are not required
-                       while ($row = SQL_FETCHARRAY($result)) {
+                       while ($row = sqlFetchArray($result)) {
                                // Add it
                                $GLOBALS['network_request_parameters'][$networkTypeId][] = $row;
                        } // END - while
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return "cached" values
@@ -578,7 +578,7 @@ function getFullNetworkConfigurationByTypeId ($networkTypeId) {
                $GLOBALS['network_full_config'][$networkTypeId] = array();
 
                // Search for all
-               $result = SQL_QUERY_ESC('SELECT
+               $result = sqlQueryEscaped('SELECT
        `nac`.`network_id`,
        `ntc`.`network_type_id`,
        `nac`.`network_api_affiliate_id`,
@@ -617,13 +617,13 @@ LIMIT 1',
                ), __FUNCTION__, __LINE__);
 
                // Is there one entry?
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Load it
-                       $GLOBALS['network_full_config'][$networkTypeId] = SQL_FETCHARRAY($result);
+                       $GLOBALS['network_full_config'][$networkTypeId] = sqlFetchArray($result);
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return "cached" values
@@ -633,7 +633,7 @@ LIMIT 1',
 // Removes given network entry
 function doAdminRemoveNetworkEntry ($table, $column, $id, $limit = 1) {
        // Remove the entry
-       SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_network_%s` WHERE `%s`=%s LIMIT %s",
+       sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_network_%s` WHERE `%s`=%s LIMIT %s",
                array(
                        $table,
                        $column,
@@ -642,7 +642,7 @@ function doAdminRemoveNetworkEntry ($table, $column, $id, $limit = 1) {
                ), __FUNCTION__, __LINE__);
 
        // Return affected rows
-       return SQL_AFFECTEDROWS();
+       return sqlAffectedRows();
 }
 
 // Generates a list of networks for given script and returns it
@@ -651,7 +651,7 @@ function generateAdminNetworkList ($separated = FALSE, $includeConfigured = TRUE
        $content = '';
 
        // Query for all networks
-       $result = SQL_QUERY('SELECT
+       $result = sqlQuery('SELECT
        `network_id`,
        `network_short_name`,
        `network_title`,
@@ -667,10 +667,10 @@ ORDER BY
        `network_short_name` ASC', __FUNCTION__, __LINE__);
 
        // Are there entries?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // List all entries
                $rows = array();
-               while ($row = SQL_FETCHARRAY($result)) {
+               while ($row = sqlFetchArray($result)) {
                        // Is this valid, then add it
                        if ((is_array($row)) && (isset($row['network_id']))) {
                                // Exclude configured and is it configured or same for unconfired but only if not separated lists?
@@ -717,7 +717,7 @@ ORDER BY
        }
 
        // Free the result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return the list
        return $content;
@@ -729,7 +729,7 @@ function generateAdminNetworkTypeList ($networkId) {
        $content = '';
 
        // Query all types of this network
-       $result = SQL_QUERY_ESC('SELECT
+       $result = sqlQueryEscaped('SELECT
        `network_type_id`,
        `network_type_handler`
 FROM
@@ -744,10 +744,10 @@ ORDER BY
                ), __FUNCTION__, __LINE__);
 
        // Are there entries?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // List all entries
                $rows = array();
-               while ($row = SQL_FETCHARRAY($result)) {
+               while ($row = sqlFetchArray($result)) {
                        // Is this valid, then add it
                        if ((is_array($row)) && (isset($row['network_type_id']))) {
                                // Add entry
@@ -763,7 +763,7 @@ ORDER BY
        }
 
        // Free the result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return content
        return $content;
@@ -775,7 +775,7 @@ function generateAdminDistinctNetworkTypeList () {
        $content = '';
 
        // Query all types of this network
-       $result = SQL_QUERY('SELECT
+       $result = sqlQuery('SELECT
        `t`.`network_type_id`,
        `t`.`network_type_handler`,
        `d`.`network_title`
@@ -791,10 +791,10 @@ ORDER BY
        `t`.`network_type_handler` ASC', __FUNCTION__, __LINE__);
 
        // Are there entries?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // List all entries
                $rows = array();
-               while ($row = SQL_FETCHARRAY($result)) {
+               while ($row = sqlFetchArray($result)) {
                        // Is this valid, then add it
                        if ((is_array($row)) && (isset($row['network_type_id']))) {
                                // Add entry
@@ -810,7 +810,7 @@ ORDER BY
        }
 
        // Free the result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
        //* DEBUG: */ die('<pre>'.encodeEntities($content).'</pre>');
 
        // Return content
@@ -1164,7 +1164,7 @@ function logNetworkResponseHeaders ($networkId, $networkTypeId, $headers, $type)
        // Is debug logging enabled or status code not 200 OK?
        if ((getConfig('network_logging_debug') == 'Y') || (!isHttpStatusOkay($headers[0]))) {
                // Add entry
-               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_network_header_logging` (`network_id`, `network_type_id`, `network_http_status_code`, `network_http_headers`, `network_logging_type`) VALUES(%s, %s, '%s', '%s', '%s')",
+               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_network_header_logging` (`network_id`, `network_type_id`, `network_http_status_code`, `network_http_headers`, `network_logging_type`) VALUES(%s, %s, '%s', '%s', '%s')",
                        array(
                                bigintval($networkId),
                                bigintval($networkTypeId),
@@ -1195,7 +1195,7 @@ function saveNetworkResponseBodyInCache ($networkId, $networkTypeId, $responseBo
        // So is there cache?
        if (countSumTotalData($networkId, 'network_cache', 'network_cache_id', 'network_id', TRUE, ' AND `network_type_id`=' . bigintval($networkTypeId)) == 1) {
                // Entry found, so update it
-               SQL_QUERY_ESC("UPDATE
+               sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_network_cache`
 SET
        `network_cache_data`='%s',
@@ -1217,7 +1217,7 @@ LIMIT 1",
                        ), __FUNCTION__, __LINE__);
        } else {
                // Add entry
-               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_network_cache` (`network_id`, `network_type_id`, `network_cache_data`, `network_cache_body`, `network_cache_type`, `network_cache_admin_id`) VALUES(%s, %s, '%s', '%s', '%s', %s)",
+               sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_network_cache` (`network_id`, `network_type_id`, `network_cache_data`, `network_cache_body`, `network_cache_type`, `network_cache_admin_id`) VALUES(%s, %s, '%s', '%s', '%s', %s)",
                        array(
                                bigintval($networkId),
                                bigintval($networkTypeId),
@@ -1276,13 +1276,13 @@ function countNetworkApiRequest ($networkData) {
        } // END - if
 
        // Okay, so update database
-       $result = SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_network_api_config` SET `network_api_remaining_requests`=`network_api_remaining_requests`-1 WHERE `network_id`=%s LIMIT 1",
+       $result = sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_network_api_config` SET `network_api_remaining_requests`=`network_api_remaining_requests`-1 WHERE `network_id`=%s LIMIT 1",
                array(
                        bigintval($networkData['network_id'])
                ), __FUNCTION__, __LINE__);
 
        // Return affected rows
-       return SQL_AFFECTEDROWS();
+       return sqlAffectedRows();
 }
 
 /**
@@ -1398,7 +1398,7 @@ function translateNetworkApiIndex ($index) {
                $GLOBALS['network_array_index'] = array();
 
                // Get all entries
-               $result = SQL_QUERY('SELECT
+               $result = sqlQuery('SELECT
        `network_array_id`,
        `network_array_index`,
        `network_translation_name`
@@ -1412,16 +1412,16 @@ ORDER BY
        `network_array_sort` ASC', __FUNCTION__, __LINE__);
 
                // Are there entries?
-               if (!SQL_HASZERONUMS($result)) {
+               if (!ifSqlHasZeroNums($result)) {
                        // Get all entries
-                       while ($row = SQL_FETCHARRAY($result)) {
+                       while ($row = sqlFetchArray($result)) {
                                // Add it to our global array
                                $GLOBALS['network_array_index'][$row['network_array_index']] = $row;
                        } // END - while
                } // END - if
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Default name is unknown
@@ -1824,13 +1824,13 @@ function doAdminNetworkProcessAddNetwork () {
        } // END - if
 
        // Add the whole request to database
-       SQL_QUERY(getInsertSqlFromArray(postRequestArray(), 'network_data'), __FUNCTION__, __LINE__);
+       sqlQuery(getInsertSqlFromArray(postRequestArray(), 'network_data'), __FUNCTION__, __LINE__);
 
        // Add the id for output only
-       setPostRequestElement('network_id', SQL_INSERT_ID());
+       setPostRequestElement('network_id', getSqlInsertId());
 
        // Output message
-       if (!SQL_HASZEROAFFECTED()) {
+       if (!ifSqlHasZeroAffectedRows()) {
                // Successfully added
                loadTemplate('admin_network_added', FALSE, postRequestArray());
        } else {
@@ -2101,10 +2101,10 @@ function doAdminNetworkProcessAddNetworkType () {
        } // END - if
 
        // Add the whole request to database
-       SQL_QUERY(getInsertSqlFromArray(postRequestArray(), 'network_types'), __FUNCTION__, __LINE__);
+       sqlQuery(getInsertSqlFromArray(postRequestArray(), 'network_types'), __FUNCTION__, __LINE__);
 
        // Output message
-       if (!SQL_HASZEROAFFECTED()) {
+       if (!ifSqlHasZeroAffectedRows()) {
                // Successfully added
                loadTemplate('admin_network_type_added', FALSE, postRequestArray());
        } else {
@@ -2374,10 +2374,10 @@ function doAdminNetworkProcessAddRequestParam () {
        } // END - if
 
        // Add the whole request to database
-       SQL_QUERY(getInsertSqlFromArray(postRequestArray(), 'network_request_params'), __FUNCTION__, __LINE__);
+       sqlQuery(getInsertSqlFromArray(postRequestArray(), 'network_request_params'), __FUNCTION__, __LINE__);
 
        // Output message
-       if (!SQL_HASZEROAFFECTED()) {
+       if (!ifSqlHasZeroAffectedRows()) {
                // Successfully added
                loadTemplate('admin_network_request_param_added', FALSE, postRequestArray());
        } else {
@@ -2411,10 +2411,10 @@ function doAdminNetworkProcessAddNetworkArrayTranslation () {
        ) + 1));
 
        // Add the whole request to database
-       SQL_QUERY(getInsertSqlFromArray(postRequestArray(), 'network_array_translation'), __FUNCTION__, __LINE__);
+       sqlQuery(getInsertSqlFromArray(postRequestArray(), 'network_array_translation'), __FUNCTION__, __LINE__);
 
        // Output message
-       if (!SQL_HASZEROAFFECTED()) {
+       if (!ifSqlHasZeroAffectedRows()) {
                // Successfully added
                loadTemplate('admin_network_array_translation_added', FALSE, postRequestArray());
        } else {
@@ -2511,10 +2511,10 @@ function doAdminNetworkProcessNetworkApiConfig () {
        }
 
        // Run the query
-       SQL_QUERY($SQL, __FUNCTION__, __LINE__);
+       sqlQuery($SQL, __FUNCTION__, __LINE__);
 
        // Output message
-       if (!SQL_HASZEROAFFECTED()) {
+       if (!ifSqlHasZeroAffectedRows()) {
                // Successfully added
                displayMessage('{--ADMIN_CONFIG_NETWORK_API_SAVED--}');
        } else {
@@ -2566,11 +2566,11 @@ function doAdminNetworkProcessAddHandlerTypesConfig ($displayMessage = TRUE, $co
        // Shall we set for all?
        if ($setAll === TRUE) {
                // Get all handlers
-               $result = SQL_QUERY_ESC('SELECT `network_type_id` FROM `{?_MYSQL_PREFIX?}_network_types` WHERE `network_id`=%s ORDER BY `network_type_id` ASC',
+               $result = sqlQueryEscaped('SELECT `network_type_id` FROM `{?_MYSQL_PREFIX?}_network_types` WHERE `network_id`=%s ORDER BY `network_type_id` ASC',
                        array(bigintval(getRequestElement('network_id'))), __FUNCTION__, __LINE__);
 
                // Are there entries?
-               if (SQL_HASZERONUMS($result)) {
+               if (ifSqlHasZeroNums($result)) {
                        // No, then abort here
                        displayMessage('{--ADMIN_CONFIG_NETWORK_HANDLER_SET_ALL_404--}');
                        return;
@@ -2580,7 +2580,7 @@ function doAdminNetworkProcessAddHandlerTypesConfig ($displayMessage = TRUE, $co
                $numRows = 0;
 
                // Fetch all ids
-               while (list($typeId) = SQL_FETCHROW($result)) {
+               while (list($typeId) = sqlFetchRow($result)) {
                        // Set it in GET data
                        setGetRequestElement('network_type_id', $typeId);
 
@@ -2589,7 +2589,7 @@ function doAdminNetworkProcessAddHandlerTypesConfig ($displayMessage = TRUE, $co
                } // END - while
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
 
                // Output message
                if ($numRows > 0) {
@@ -2604,12 +2604,12 @@ function doAdminNetworkProcessAddHandlerTypesConfig ($displayMessage = TRUE, $co
                $SQL = getInsertSqlFromArray(postRequestArray(), 'network_handler_config');
 
                // Run the query
-               SQL_QUERY($SQL, __FUNCTION__, __LINE__);
+               sqlQuery($SQL, __FUNCTION__, __LINE__);
 
                // Shall we display the message?
                if ($displayMessage === TRUE) {
                        // Output message
-                       if (!SQL_HASZEROAFFECTED()) {
+                       if (!ifSqlHasZeroAffectedRows()) {
                                // Successfully added
                                displayMessage('{--ADMIN_CONFIG_NETWORK_HANDLER_TYPE_HANDLER_SAVED--}');
                        } else {
@@ -2618,7 +2618,7 @@ function doAdminNetworkProcessAddHandlerTypesConfig ($displayMessage = TRUE, $co
                        }
                } else {
                        // Return amount of affected rows (1 or 2)
-                       return SQL_AFFECTEDROWS();
+                       return sqlAffectedRows();
                }
        }
 }
@@ -2662,11 +2662,11 @@ function doAdminNetworkProcessEditHandlerTypesConfig ($displayMessage = TRUE, $c
        // Shall we set for all?
        if ($setAll === TRUE) {
                // Get all data entries
-               $result = SQL_QUERY_ESC('SELECT `network_data_id` FROM `{?_MYSQL_PREFIX?}_network_handler_config` WHERE `network_id`=%s ORDER BY `network_type_id` ASC',
+               $result = sqlQueryEscaped('SELECT `network_data_id` FROM `{?_MYSQL_PREFIX?}_network_handler_config` WHERE `network_id`=%s ORDER BY `network_type_id` ASC',
                        array(bigintval(getRequestElement('network_id'))), __FUNCTION__, __LINE__);
 
                // Are there entries?
-               if (SQL_HASZERONUMS($result)) {
+               if (ifSqlHasZeroNums($result)) {
                        // No, then abort here
                        displayMessage('{--ADMIN_CONFIG_NETWORK_HANDLER_SET_ALL_404--}');
                        return;
@@ -2676,7 +2676,7 @@ function doAdminNetworkProcessEditHandlerTypesConfig ($displayMessage = TRUE, $c
                $numRows = 0;
 
                // Fetch all ids
-               while (list($dataId) = SQL_FETCHROW($result)) {
+               while (list($dataId) = sqlFetchRow($result)) {
                        // Set it in GET data
                        setPostRequestElement('network_data_id', $dataId);
 
@@ -2685,7 +2685,7 @@ function doAdminNetworkProcessEditHandlerTypesConfig ($displayMessage = TRUE, $c
                } // END - while
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
 
                // Output message
                if ($numRows > 0) {
@@ -2700,12 +2700,12 @@ function doAdminNetworkProcessEditHandlerTypesConfig ($displayMessage = TRUE, $c
                $SQL = getUpdateSqlFromArray(postRequestArray(), 'network_handler_config', 'network_data_id', postRequestElement('network_data_id'), array('network_data_id'));
 
                // Run the query
-               SQL_QUERY($SQL, __FUNCTION__, __LINE__);
+               sqlQuery($SQL, __FUNCTION__, __LINE__);
 
                // Shall we display the message?
                if ($displayMessage === TRUE) {
                        // Output message
-                       if (!SQL_HASZEROAFFECTED()) {
+                       if (!ifSqlHasZeroAffectedRows()) {
                                // Successfully added
                                displayMessage('{--ADMIN_CONFIG_NETWORK_HANDLER_TYPE_HANDLER_SAVED--}');
                        } else {
@@ -2714,7 +2714,7 @@ function doAdminNetworkProcessEditHandlerTypesConfig ($displayMessage = TRUE, $c
                        }
                } else {
                        // Return amount of affected rows (1 or 2)
-                       return SQL_AFFECTEDROWS();
+                       return sqlAffectedRows();
                }
        }
 }
@@ -2803,7 +2803,7 @@ function doAdminNetworkProcessExport () {
 // Exports (and displays) the table 'network_data'
 function doAdminNetworkExportData () {
        // Query for all networks
-       $result = SQL_QUERY('SELECT
+       $result = sqlQuery('SELECT
        `network_short_name`,
        `network_title`,
        `network_reflink`,
@@ -2824,7 +2824,7 @@ ORDER BY
        $SQL = 'INSERT INTO `&#123;&#63;_MYSQL_PREFIX&#63;&#125;_network_data` (`network_short_name`, `network_title`, `network_reflink`, `network_data_separator`, `network_row_separator`, `network_request_type`, `network_charset`, `network_require_id_card`, `network_query_amount`, `network_active`) VALUES' . PHP_EOL;
 
        // Load all entries
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                // Add row
                $SQL .= "('" .
                        $content['network_short_name'] . "', '" .
@@ -2843,7 +2843,7 @@ ORDER BY
        $SQL = substr($SQL, 0, -2);
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Output the SQL query
        loadTemplate('admin_export_network_data', FALSE, $SQL);
@@ -2858,7 +2858,7 @@ function doAdminNetworkExportTypes () {
        } // END - if
 
        // Get all network types of given network
-       $result = SQL_QUERY_ESC('SELECT
+       $result = sqlQueryEscaped('SELECT
        `network_type_id`,
        `network_id`,
        `network_type_handler`,
@@ -2881,7 +2881,7 @@ ORDER BY
        $SQL = 'INSERT INTO `&#123;&#63;_MYSQL_PREFIX&#63;&#125;_network_types` (`network_type_id`, `network_id`, `network_type_handler`, `network_type_api_url`, `network_type_click_url`, `network_type_banner_url`, `network_type_reload_time_unit`, `network_text_encoding`) VALUES' . PHP_EOL;
 
        // Load all entries
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                // Add row
                $SQL .= '(' .
                        $content['network_type_id'] . ', ' .
@@ -2915,7 +2915,7 @@ ORDER BY
        $SQL = substr($SQL, 0, -2);
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Output the SQL query
        loadTemplate('admin_export_network_types', FALSE, $SQL);
@@ -2930,7 +2930,7 @@ function doAdminNetworkExportRequestParams () {
        } // END - if
 
        // Get all network types of given network
-       $result = SQL_QUERY_ESC('SELECT
+       $result = sqlQueryEscaped('SELECT
        `network_id`,
        `network_type_id`,
        `network_request_param_key`,
@@ -2951,14 +2951,14 @@ ORDER BY
        $SQL = 'INSERT INTO `&#123;&#63;_MYSQL_PREFIX&#63;&#125;_network_request_params` (`network_id`, `network_type_id`, `network_request_param_key`, `network_request_param_value`, `network_request_param_default`) VALUES' . PHP_EOL;
 
        // Load all entries
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                // Add row
                $SQL .= '(' .
                        $content['network_id'] . ', ' .
                        $content['network_type_id'] . ", '" .
                        $content['network_request_param_key'] . "', '" .
                        $content['network_request_param_value'] . "', ";
-               
+
                // Is the column NULL?
                if (is_null($content['network_request_param_default'])) {
                        // Column is NULL
@@ -2973,7 +2973,7 @@ ORDER BY
        $SQL = substr($SQL, 0, -2);
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Output the SQL query
        loadTemplate('admin_export_network_request_params', FALSE, $SQL);
@@ -2988,7 +2988,7 @@ function doAdminNetworkExportArrayTranslation () {
        } // END - if
 
        // Get all network types of given network
-       $result = SQL_QUERY_ESC('SELECT
+       $result = sqlQueryEscaped('SELECT
        `network_id`,
        `network_type_id`,
        `network_array_index`,
@@ -3008,7 +3008,7 @@ ORDER BY
        $SQL = 'INSERT INTO `&#123;&#63;_MYSQL_PREFIX&#63;&#125;_network_array_translation` (`network_id`, `network_type_id`, `network_array_index`, `network_array_sort`) VALUES' . PHP_EOL;
 
        // Load all entries
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                // Add row
                $SQL .= '(' .
                        $content['network_id'] . ', ' .
@@ -3021,7 +3021,7 @@ ORDER BY
        $SQL = substr($SQL, 0, -2);
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Output the SQL query
        loadTemplate('admin_export_network_array_translation', FALSE, $SQL);
index 9a30d05..cc4f0ac 100644 (file)
@@ -50,17 +50,17 @@ function repairOptimizeDatabase () {
        $tot_all = '0';
 
        // Get table status
-       $result = SQL_QUERY('SHOW TABLE STATUS FROM `{?__DB_NAME?}`', __FUNCTION__, __LINE__);
+       $result = sqlQuery('SHOW TABLE STATUS FROM `{?__DB_NAME?}`', __FUNCTION__, __LINE__);
 
        // Init array
        $ret['total_size'] = '0';
-       $ret['total_tabs'] = SQL_NUMROWS($result);
+       $ret['total_tabs'] = sqlNumRows($result);
        $ret['tables'] = array();
 
        // Are there entries?
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Fetch all rows
-               while ($row = SQL_FETCHARRAY($result)) {
+               while ($row = sqlFetchArray($result)) {
                        $tot_data = $row['Data_length'];
                        $tot_idx  = $row['Index_length'];
                        $total = $tot_data + $tot_idx;
@@ -72,14 +72,14 @@ function repairOptimizeDatabase () {
                        $gain = round ($gain, 3);
 
                        // Repair table
-                       $result1 = SQL_QUERY_ESC("REPAIR TABLE `%s`",
+                       $result1 = sqlQueryEscaped("REPAIR TABLE `%s`",
                                array($row['Name']), __FUNCTION__, __LINE__);
-                       $rep = SQL_FETCHARRAY($result1);
+                       $rep = sqlFetchArray($result1);
 
                        // Optimize table
-                       $result1 = SQL_QUERY_ESC("OPTIMIZE TABLE `%s`",
+                       $result1 = sqlQueryEscaped("OPTIMIZE TABLE `%s`",
                                array($row['Name']), __FUNCTION__, __LINE__);
-                       $opt = SQL_FETCHARRAY($result1);
+                       $opt = sqlFetchArray($result1);
 
                        // Add data to array
                        array_push($ret['tables'], array($row['Name'], $opt['Msg_text'], $rep['Msg_text'], $total, $gain));
@@ -93,15 +93,15 @@ function repairOptimizeDatabase () {
        $ret['total_gain'] = $total_gain;
 
        // Insert new row
-       $result = SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_optimize_gain` (`gain`) VALUES (%s)",
+       $result = sqlQueryEscaped("INSERT INTO `{?_MYSQL_PREFIX?}_optimize_gain` (`gain`) VALUES (%s)",
                array($total_gain), __FUNCTION__, __LINE__);
 
        // Get total runs and total optimization count
-       $result = SQL_QUERY('SELECT COUNT(`id`) AS `total_rows`, SUM(`gain`) AS `total_optimized` FROM `{?_MYSQL_PREFIX?}_optimize_gain`', __FUNCTION__, __LINE__);
-       $ret = merge_array($ret, SQL_FETCHARRAY($result));
+       $result = sqlQuery('SELECT COUNT(`id`) AS `total_rows`, SUM(`gain`) AS `total_optimized` FROM `{?_MYSQL_PREFIX?}_optimize_gain`', __FUNCTION__, __LINE__);
+       $ret = merge_array($ret, sqlFetchArray($result));
 
        // Free memory
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return array
        return $ret;
index a75d112..e8b2e85 100644 (file)
@@ -45,7 +45,7 @@ function outputPayoutList ($points) {
        // Enougth points?
        if ($points > 0) {
                // Pay this out!
-               $result = SQL_QUERY_ESC('SELECT
+               $result = sqlQueryEscaped('SELECT
        `id`,
        `type`,
        `rate`,
@@ -57,12 +57,12 @@ WHERE
 ORDER BY
        `type` ASC',
                        array($points), __FUNCTION__, __LINE__);
-               if (!SQL_HASZERONUMS($result)) {
+               if (!ifSqlHasZeroNums($result)) {
                        // Init output
                        $OUT = '';
 
                        // Now let's check
-                       while ($content = SQL_FETCHARRAY($result)) {
+                       while ($content = sqlFetchArray($result)) {
                                // Are these points enougth?
                                if ($points >= $content['min_points']) {
                                        // Prepare content for template
@@ -81,7 +81,7 @@ ORDER BY
                }
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } else {
                // Points is empty
                displayErrorMessage('{--MEMBER_PAYOUT_NO_POINTS_ENTERED--}');
index 6e349c7..849874b 100644 (file)
@@ -43,13 +43,13 @@ if (!defined('__SECURITY')) {
 // Auto-start referral rallyes
 function autostartReferralRallyes ($result) {
        // Load all rallyes (usally we have only one rallye active per time!
-       $content = SQL_FETCHARRAY($result);
+       $content = sqlFetchArray($result);
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Set notified to Y
-       SQL_QUERY_ESC("UPDATE
+       sqlQueryEscaped("UPDATE
        `{?_MYSQL_PREFIX?}_rallye_data`
 SET
        `notified`='Y'
@@ -59,7 +59,7 @@ LIMIT 1",
                array(bigintval($content['id'])), __FUNCTION__, __LINE__);
 
        // Query all users
-       $result_user = SQL_QUERY("SELECT
+       $result_user = sqlQuery("SELECT
        `userid`
 FROM
        `{?_MYSQL_PREFIX?}_user_data`
@@ -70,7 +70,7 @@ ORDER BY
        `userid` ASC", __FUNCTION__, __LINE__);
 
        // Let's begin with the userids...
-       while ($row = SQL_FETCHARRAY($result_user)) {
+       while ($row = sqlFetchArray($result_user)) {
                // Merge both arrays
                $content = merge_array($content, $row);
 
@@ -81,7 +81,7 @@ ORDER BY
                if (empty($count)) $count = '0'; // Added prevent some unknown troubles... :-?
 
                // Check if line is already included...
-               $result_ref = SQL_QUERY_ESC("SELECT
+               $result_ref = sqlQueryEscaped("SELECT
        `id`
 FROM
        `{?_MYSQL_PREFIX?}_rallye_users`
@@ -92,9 +92,9 @@ LIMIT 1",
                        array(bigintval($content['id']), bigintval($content['userid'])), __FUNCTION__, __LINE__);
 
                // Is there an entry?
-               if (SQL_HASZERONUMS($result_ref)) {
+               if (ifSqlHasZeroNums($result_ref)) {
                        // Add userid and his ref count to table
-                       $result_ref = SQL_QUERY_ESC("SELECT 
+                       $result_ref = sqlQueryEscaped("SELECT
        SUM(`p`.`points`) AS `points`
 FROM
        `{?_MYSQL_PREFIX?}_user_points` AS `p`
@@ -113,15 +113,15 @@ WHERE
                                array(bigintval($content['userid'])), __FUNCTION__, __LINE__);
 
                        // Get points
-                       list($cpoints) = SQL_FETCHROW($result_ref);
+                       list($cpoints) = sqlFetchRow($result_ref);
 
                        // Free result
-                       SQL_FREERESULT($result_ref);
+                       sqlFreeResult($result_ref);
 
                        if (empty($cpoints)) $cpoints = '0.00000';
 
                        // Add info line
-                       SQL_QUERY_ESC("INSERT INTO
+                       sqlQueryEscaped("INSERT INTO
        `{?_MYSQL_PREFIX?}_rallye_users`
 (
        `rallye_id`,
@@ -144,7 +144,7 @@ WHERE
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result_ref);
+               sqlFreeResult($result_ref);
 
                // Ignored but for the template required refs (made before start of rallye)
                $content['refs']  = $count;
@@ -167,7 +167,7 @@ WHERE
        sendAdminNotification('{%message,ADMIN_RALLYE_NOTIFY_SUBJECT=' . $content['title'] . '%}', $templ, $content);
 
        // Free memory
-       SQL_FREERESULT($result_user);
+       sqlFreeResult($result_user);
 }
 
 //
@@ -179,7 +179,7 @@ function addReferralRallyePrices ($rallye, $mode = 'email') {
        } // END - switch
 
        // Load prices
-       $result_prices = SQL_QUERY_ESC("SELECT
+       $result_prices = sqlQueryEscaped("SELECT
        `price_level`,
        `points`,
        `info`
@@ -192,14 +192,14 @@ ORDER BY
                array($rallye), __FUNCTION__, __LINE__);
 
        // Entries found?
-       if (!SQL_HASZERONUMS($result_prices)) {
+       if (!ifSqlHasZeroNums($result_prices)) {
                // Load prices
                $prices = '';
                if ($mode == PHP_EOL) {
                        $prices = '{--RALLYE_MEMBER_PRICES_ADDED--}:' . $mode . '------------------------------' . $mode;
                } // END - if
 
-               while ($content = SQL_FETCHARRAY($result_prices)) {
+               while ($content = sqlFetchArray($result_prices)) {
                        $prices .= $content['price_level']. '{--RALLYE_PRICE--}:';
                        if (!empty($content['info'])) {
                                $prices .= $content['info'];
@@ -210,7 +210,7 @@ ORDER BY
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result_prices);
+               sqlFreeResult($result_prices);
        } else {
                // No prices???
                $prices = '{%message,RALLYE_MEMBER_NO_PRICES=' . $mode . '%}';
@@ -235,7 +235,7 @@ function addReferralRallyeTopUsers ($mode, $rallye, $default=0) {
        $prices = getTotalRallyePrices($rallye);
 
        // And load only limited users
-       $result = SQL_QUERY_ESC("SELECT DISTINCT
+       $result = sqlQueryEscaped("SELECT DISTINCT
        `u`.`userid`,
        `u`.`refs`,
        `u`.`curr_points`,
@@ -266,13 +266,13 @@ ORDER BY
        );
 
        // Load all users
-       while ($row = SQL_FETCHARRAY($result)) {
+       while ($row = sqlFetchArray($result)) {
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $row['userid'] . ',refs=' . $row['refs']);
                // Get current refs
                $count = getReferralRallyeRefsCount($row['userid'], $row['refs']);
 
                // Points of ref's
-               $result_ref = SQL_QUERY_ESC("SELECT
+               $result_ref = sqlQueryEscaped("SELECT
        `p`.`points`
 FROM
        `{?_MYSQL_PREFIX?}_user_points` AS `p`
@@ -291,10 +291,10 @@ LIMIT 1",
                        array(bigintval($row['userid'])), __FUNCTION__, __LINE__);
 
                // Get points
-               list($refpoints) = SQL_FETCHROW($result_ref);
+               list($refpoints) = sqlFetchRow($result_ref);
 
                // Free result
-               SQL_FREERESULT($result_ref);
+               sqlFreeResult($result_ref);
 
                // Fix empty values (ugly code again)
                if (empty($refpoints)) {
@@ -321,7 +321,7 @@ LIMIT 1",
        } // END - while
 
        // Free memory
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Sort whole array
        array_pk_sort($content, array('cpoints', 'ref'), 0, 1, TRUE);
@@ -382,7 +382,7 @@ function addUserToReferralRallye ($userid, $content = array()) {
        } // END - if
 
        // Check for an auto-add rallye
-       $result = SQL_QUERY("SELECT
+       $result = sqlQuery("SELECT
        `id`,
        `title`,
        `start_time`,
@@ -397,16 +397,16 @@ WHERE
        `auto_add_new_user`='Y' AND
        `expired`='N'
 LIMIT 1", __FUNCTION__, __LINE__);
-       if (SQL_NUMROWS($result) == 1) {
+       if (sqlNumRows($result) == 1) {
                // Init variables
                $min_users = '0';
                $min_prices = '0';
 
                // Load and merge data
-               $content = merge_array($content, SQL_FETCHARRAY($result));
+               $content = merge_array($content, sqlFetchArray($result));
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
 
                // Notify the user?
                if ($content['send_notify'] == 'Y') {
@@ -415,7 +415,7 @@ LIMIT 1", __FUNCTION__, __LINE__);
                } // END - if
 
                // Check if line is already included...
-               $result = SQL_QUERY_ESC("SELECT
+               $result = sqlQueryEscaped("SELECT
        `id`
 FROM
        `{?_MYSQL_PREFIX?}_rallye_users`
@@ -429,9 +429,9 @@ LIMIT 1",
                        ), __FUNCTION__, __LINE__);
 
                // Is this user added?
-               if (SQL_HASZERONUMS($result)) {
+               if (ifSqlHasZeroNums($result)) {
                        // Add userid and his ref count to table
-                       SQL_QUERY_ESC("INSERT INTO
+                       sqlQueryEscaped("INSERT INTO
        `{?_MYSQL_PREFIX?}_rallye_users`
 (
        `rallye_id`,
@@ -449,7 +449,7 @@ LIMIT 1",
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 }
 
@@ -483,10 +483,10 @@ function getTotalRallyeWinners ($rallyeId) {
 // Stops the given rallye result (from SQL layer) by marking it as expirced
 function stopRallyeByResult ($result) {
        // Load rallye data
-       $content = SQL_FETCHARRAY($result);
+       $content = sqlFetchArray($result);
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Init array
        $count = '0';
@@ -523,7 +523,7 @@ function stopRallyeByResult ($result) {
        } // END - if
 
        // Expire rallye
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_rallye_data` SET `expired`='Y' WHERE `id`=%s LIMIT 1",
+       sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_rallye_data` SET `expired`='Y' WHERE `id`=%s LIMIT 1",
                array(bigintval($content['id'])), __FUNCTION__, __LINE__);
 
        // Run array through (by userid is the most important 2nd-level-array)
@@ -609,7 +609,7 @@ function getReferralRallyeUserDataFromArray ($userIds) {
        $ret = '';
 
        // Load users
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `userid`, `gender`, `surname`, `family`, `email`
 FROM
        `{?_MYSQL_PREFIX?}_user_data`
@@ -624,7 +624,7 @@ LIMIT %s",
                        $userid_string,
                        count($userIds)
                ), __FUNCTION__, __LINE__);
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                // Construct the message masked and add it
                $ret .= sprintf("{%%pipe,translateGender=%s%} %s %s (%s) - %s\n",
                        $content['gender'],
@@ -649,7 +649,7 @@ function getArrayFromReferralRallyePrices ($rallye) {
        );
 
        // Load prices
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `price_level`,
        `points`,
        `info`
@@ -662,14 +662,14 @@ ORDER BY
                array(bigintval($rallye)), __FUNCTION__, __LINE__);
 
        // Transfer elements
-       while ($content = SQL_FETCHARRAY($result)) {
+       while ($content = sqlFetchArray($result)) {
                $prices['level'][]  = $content['price_level'];
                array_push($prices['points'], $content['points']);
                array_push($prices['info'], $content['info']);
        } // END - while
 
        // Free memory
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return array
        return $prices;
@@ -695,7 +695,7 @@ function getArrayFromReferralRallyeUsers ($rallye) {
         *  - refs        = Old amount of referrals (before the rallye has started)
         *  - curr_points = Current amount of total points
         */
-       $result_user = SQL_QUERY_ESC("SELECT
+       $result_user = sqlQueryEscaped("SELECT
        `userid`,
        `refs`,
        `curr_points`
@@ -706,12 +706,12 @@ WHERE
 ORDER BY
        `userid` ASC",
                array(bigintval($rallye)), __FUNCTION__, __LINE__);
-       while ($content = SQL_FETCHARRAY($result_user)) {
+       while ($content = sqlFetchArray($result_user)) {
                // Load current ref count
                $count = getReferralRallyeRefsCount($content['userid'], $content['refs']);
 
                // Points of ref's
-               $result_ref = SQL_QUERY_ESC("SELECT
+               $result_ref = sqlQueryEscaped("SELECT
        SUM(`p`.`points`) AS `points`
 FROM
        `{?_MYSQL_PREFIX?}_user_points` AS `p`
@@ -731,10 +731,10 @@ LIMIT 1",
                        array(bigintval($content['userid'])), __FUNCTION__, __LINE__);
 
                // Get points
-               list($refpoints) = SQL_FETCHROW($result_ref);
+               list($refpoints) = sqlFetchRow($result_ref);
 
                // Free result
-               SQL_FREERESULT($result_ref);
+               sqlFreeResult($result_ref);
 
                // Fix empty refpoints
                if (empty($refpoints)) $refpoints = '0';
@@ -746,7 +746,7 @@ LIMIT 1",
        } // END - while
 
        // Free memory
-       SQL_FREERESULT($result_user);
+       sqlFreeResult($result_user);
 
        // Sort array for refs (descending)
        array_pk_sort($users, array('cpoints', 'ref'), 0, 1, TRUE);
@@ -836,7 +836,7 @@ function addReferralRallyeWinners ($mode, $rallye, $default=0) {
 function purgeExpiredReferralRallyes () {
        // Check for expired rallyes
        $EXPIRE = 3; // @TODO The hard-coded value...
-       $result_rallye = SQL_QUERY_ESC("SELECT
+       $result_rallye = sqlQueryEscaped("SELECT
        `id`,
        `title`,
        `start_time`,
@@ -848,12 +848,12 @@ WHERE
        `expired`='Y'",
                array($EXPIRE), __FUNCTION__, __LINE__);
 
-       if (!SQL_HASZERONUMS($result_rallye)) {
+       if (!ifSqlHasZeroNums($result_rallye)) {
                // Init SQLs
                initSqls();
 
                // Expire found rallyes and notify admin
-               while ($content = SQL_FETCHARRAY($result_rallye)) {
+               while ($content = sqlFetchArray($result_rallye)) {
                        // Prepare data for mail template
                        $content['start_time'] = generateDateTime($content['start_time'], 1);
                        $content['end_time']   = generateDateTime($content['end_time']  , 1);
@@ -863,11 +863,11 @@ WHERE
                        sendAdminNotification('{%message,ADMIN_RALLYE_PURGED_SUBJECT=' . $content['title'] . '%}', 'admin_rallye_purged', $content);
 
                        // Purge whole rallye
-                       addSql(SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_data` WHERE `id`=%s LIMIT 1",
+                       addSql(sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_data` WHERE `id`=%s LIMIT 1",
                                array(bigintval($content['id'])), __FUNCTION__, __LINE__, FALSE));
-                       addSql(SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_prices` WHERE `rallye_id`=%s LIMIT 1",
+                       addSql(sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_prices` WHERE `rallye_id`=%s LIMIT 1",
                                array(bigintval($content['id'])), __FUNCTION__, __LINE__, FALSE));
-                       addSql(SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_users` WHERE `rallye_id`=%s LIMIT 1",
+                       addSql(sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_users` WHERE `rallye_id`=%s LIMIT 1",
                                array(bigintval($content['id'])), __FUNCTION__, __LINE__, FALSE));
 
                        // Add task (we ignore the task id here
@@ -879,7 +879,7 @@ WHERE
        } // END - if
 
        // Free memory
-       SQL_FREERESULT($result_rallye);
+       sqlFreeResult($result_rallye);
 }
 
 //
@@ -965,7 +965,7 @@ function getReferralRallyeRefsCount ($currUserid, $oldReferralCount = '0') {
                } // END - if
        } else {
                // Load current refs from database
-               $result_ref = SQL_QUERY_ESC("SELECT
+               $result_ref = sqlQueryEscaped("SELECT
        SUM(s.counter) AS `cnt`
 FROM
        `{?_MYSQL_PREFIX?}_refsystem` AS `s`
@@ -981,10 +981,10 @@ WHERE
                        ), __FUNCTION__, __LINE__);
 
                // Load count @TODO Can't we rewrite this to our API?
-               list($count) = SQL_FETCHROW($result_ref);
+               list($count) = sqlFetchRow($result_ref);
 
                // Free result
-               SQL_FREERESULT($result_ref);
+               sqlFreeResult($result_ref);
                if (empty($count)) {
                        $count = '0';
                } else {
index f079c6a..b8f077b 100644 (file)
@@ -50,11 +50,11 @@ function addRefbackPoints ($userid, $ref, $points, $ref_points) {
        $return = $ref_points;
 
        // Get all ref levels
-       $result_refs = SQL_QUERY('SELECT `level`, `percents` FROM `{?_MYSQL_PREFIX?}_refdepths` WHERE `level` > 0 ORDER BY `level` ASC',
+       $result_refs = sqlQuery('SELECT `level`, `percents` FROM `{?_MYSQL_PREFIX?}_refdepths` WHERE `level` > 0 ORDER BY `level` ASC',
                __FUNCTION__, __LINE__);
 
        // "Walk" through all level
-       while ($content = SQL_FETCHARRAY($result_refs)) {
+       while ($content = sqlFetchArray($result_refs)) {
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'level=' . $content['level'] . ',percents=' . $content['percents'] . ' - LOOP START!');
                // Reset ref depths
                initReferralSystem();
@@ -81,7 +81,7 @@ function addRefbackPoints ($userid, $ref, $points, $ref_points) {
                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'points=' . $points . ',percents=' . $content['percents'] . ',refback_percents=' . $content['refback_percents'] . ',level=' . $content['level'] . ',refback_points=' . $refbackPoints);
 
                                // Update refback table ('refid' and 'userid' must be exchanged!)
-                               SQL_QUERY_ESC('UPDATE
+                               sqlQueryEscaped('UPDATE
        `{?_MYSQL_PREFIX?}_user_refs`
 SET
        `refback_points`=`refback_points`+%s
@@ -96,7 +96,7 @@ LIMIT 1',
                                        ), __FUNCTION__, __LINE__);
 
                                // Something must have been updated
-                               if (SQL_HASZEROAFFECTED()) {
+                               if (ifSqlHasZeroAffectedRows()) {
                                        // Please report this bug
                                        reportBug(__FUNCTION__, __LINE__, 'Nothing has been updated in user_refs,userid=' . $userid . ',refid=' . convertNullToZero($refid) . ',refbackPoints=' . $refbackPoints);
                                } // END - if
@@ -117,7 +117,7 @@ LIMIT 1',
        } // END - while
 
        // Free result
-       SQL_FREERESULT($result_refs);
+       sqlFreeResult($result_refs);
 
        // Restore ref depth
        $GLOBALS['ref_level'] = $GLOBALS['refback_depth'][$userid][$ref];
@@ -150,13 +150,13 @@ function getRefbackPercents ($userid, $refid) {
                $GLOBALS['refback_percents'][$userid][$refid] = '0';
 
                // Get percents from database
-               $result = SQL_QUERY_ESC("SELECT `refback_percents` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `userid`=%s AND `refid`=%s LIMIT 1",
+               $result = sqlQueryEscaped("SELECT `refback_percents` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `userid`=%s AND `refid`=%s LIMIT 1",
                        array($userid, $refid), __FUNCTION__, __LINE__);
 
                // Entry found? (Should be!)
-               if (SQL_NUMROWS($result) == 1) {
+               if (sqlNumRows($result) == 1) {
                        // Fetch percents
-                       list($GLOBALS['refback_percents'][$userid][$refid]) = SQL_FETCHROW($result);
+                       list($GLOBALS['refback_percents'][$userid][$refid]) = sqlFetchRow($result);
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refid=' . $refid . ',percents=' . $GLOBALS['refback_percents'][$userid][$refid]);
                } else {
                        // Please report all findings
@@ -164,7 +164,7 @@ function getRefbackPercents ($userid, $refid) {
                }
 
                // Free result
-               SQL_FREERESULT($result);
+               sqlFreeResult($result);
        } // END - if
 
        // Return percents
@@ -179,7 +179,7 @@ function getArrayFromRefbackLevel ($refid, $level) {
        $userIds = array();
 
        // Look for all
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `userid`
 FROM
        `{?_MYSQL_PREFIX?}_user_refs`
@@ -192,16 +192,16 @@ ORDER BY
 
        // Entries found?
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'numRows=' . SQL_NUMROWS($result));
-       if (!SQL_HASZERONUMS($result)) {
+       if (!ifSqlHasZeroNums($result)) {
                // Add all
-               while ($content = SQL_FETCHARRAY($result)) {
+               while ($content = sqlFetchArray($result)) {
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'refid=' . convertNullToZero($refid) . ',level=' . $level . ',userid=' . $content['userid']);
                        array_push($userIds, $content['userid']);
                } // END - while
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return array
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'refid=' . convertNullToZero($refid) . ',userIds()=' . count($userIds) . ' - EXIT!');
@@ -215,7 +215,7 @@ function getArrayFromRefbackUserRefs ($userid, $level) {
        $refs = array();
 
        // Get refs from database
-       $result = SQL_QUERY_ESC("SELECT
+       $result = sqlQueryEscaped("SELECT
        `r`.`id`,
        `r`.`refid`,
        `r`.`refback_percents`,
@@ -239,9 +239,9 @@ ORDER BY
                array(bigintval($userid), bigintval($level)), __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
                        $row['click_rate'] = '0';
 
@@ -257,7 +257,7 @@ ORDER BY
        } // END - if
 
        // Free result
-       SQL_FREERESULT($result);
+       sqlFreeResult($result);
 
        // Return result
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refs()=' . count($refs) . ' - EXIT!');
@@ -274,17 +274,17 @@ function getArrayFromUserRefbackData ($id) {
        $id = bigintval($id);
 
        // Get entry from database
-       $result = SQL_QUERY_ESC("SELECT `id`, `userid`, `refid`, `refback_percents`, `level`, `refback_points` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `id`=%s AND `userid`=%s LIMIT 1",
+       $result = sqlQueryEscaped("SELECT `id`, `userid`, `refid`, `refback_percents`, `level`, `refback_points` FROM `{?_MYSQL_PREFIX?}_user_refs`&nbs