More fixes, lesser "caching" and more wrapper functions introduced:
authorRoland Häder <roland@mxchange.org>
Sat, 24 Nov 2012 11:57:50 +0000 (11:57 +0000)
committerRoland Häder <roland@mxchange.org>
Sat, 24 Nov 2012 11:57:50 +0000 (11:57 +0000)
- Wrapper function addExtensionAddTableIndexSql() introduced
- Wrapper function addExtensionAddTableUniqueSql() introduced
- Wrapper function addExtensionAddTableFulltextSql() introduced
- Wrapper function addExtensionDropTableIndexSql() introduced
- Function ifSqlTableExists() renamed to ifSqlTableColumnExists() and it does
  no longer "cache" its results
- Other fixes which prevents extensions being installed/uninstalled

inc/db/lib-mysql3.php
inc/extensions-functions.php
inc/extensions/ext-bonus.php
inc/extensions/ext-sql_patches.php
inc/extensions/ext-user.php
inc/filters.php

index 4dfca09fd0a1bb53fe2b6bb4b24323125217ffd6..2457c6a4741ff78c03f77616ac844ff8710d7ff0 100644 (file)
@@ -448,32 +448,32 @@ function SQL_ALTER_TABLE ($sql, $F, $L, $enableCodes = TRUE) {
                        $columnName = $tableArray[$idx];
 
                        // Debug log
-                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'columnName=' . $columnName . ',idx=' . $idx . ',sql=' . $sql . ',hasZeroNums=' . intval(ifSqlColumnExists($tableName, $columnName)));
+                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'columnName=' . $columnName . ',idx=' . $idx . ',sql=' . $sql . ',hasZeroNums=' . intval(ifSqlTableColumnExists($tableName, $columnName)));
 
                        // Is there no entry on ADD or an entry on DROP/CHANGE?
-                       if (((!ifSqlColumnExists($tableName, $columnName)) && (isInString('ADD', $sql))) || ((ifSqlColumnExists($tableName, $columnName)) && ((isInString('DROP', $sql)) || ((isInString('CHANGE', $sql)) && ($idx == 4) && ((!ifSqlColumnExists($tableName, $tableArray[5])) || ($columnName == $tableArray[5])))))) {
+                       if (((!ifSqlTableColumnExists($tableName, $columnName)) && (isInString('ADD', $sql))) || ((ifSqlTableColumnExists($tableName, $columnName)) && ((isInString('DROP', $sql)) || ((isInString('CHANGE', $sql)) && ($idx == 4) && ((!ifSqlTableColumnExists($tableName, $tableArray[5])) || ($columnName == $tableArray[5])))))) {
                                // Do the query
                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Executing: ' . $sql);
                                $result = SQL_QUERY($sql, $F, $L, FALSE);
 
                                // Skip further attempt(s)
                                break;
-                       } elseif ((((ifSqlColumnExists($tableName, $columnName)) && (isInString('ADD', $sql))) || ((!ifSqlColumnExists($tableName, $columnName)) && ((isInString('DROP', $sql))) || (isInString('CHANGE', $sql)))) && ($columnName != 'KEY')) {
+                       } elseif ((((ifSqlTableColumnExists($tableName, $columnName)) && (isInString('ADD', $sql))) || ((!ifSqlTableColumnExists($tableName, $columnName)) && ((isInString('DROP', $sql))) || (isInString('CHANGE', $sql)))) && ($columnName != 'KEY')) {
                                // Abort here because it is alreay there
                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Skipped: sql=' . $sql . ',columnName=' . $columnName . ',idx=' . $idx);
                                break;
-                       } elseif ((!ifSqlColumnExists($tableName, $columnName)) && (isInString('DROP', $sql))) {
+                       } elseif ((!ifSqlTableColumnExists($tableName, $columnName)) && (isInString('DROP', $sql))) {
                                // Abort here because we tried to drop a column which is not there (never created maybe)
                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'No drop: ' . $sql);
                                break;
                        } elseif ($columnName != 'KEY') {
                                // Something didn't fit, we better log it
-                               logDebugMessage(__FUNCTION__, __LINE__, 'Possible problem: ' . $sql . ',hasZeroNums=' . intval(ifSqlColumnExists($tableName, $columnName)) . '');
+                               logDebugMessage(__FUNCTION__, __LINE__, 'Possible problem: ' . $sql . ',hasZeroNums=' . intval(ifSqlTableColumnExists($tableName, $columnName)) . '');
                        }
                } // END - foreach
        } elseif ((getTableType() == 'InnoDB') && (isInString('FULLTEXT', $sql))) {
                // Skip this query silently because InnoDB does not understand fulltext indexes
-               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, sprintf("Skipped FULLTEXT: sql=%s,tableName=%s,hasZeroNums=%d,file=%s,line=%s", $sql, $tableName, intval((is_bool($result)) ? 0 : ifSqlColumnExists($columnName)), $F, $L));
+               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, sprintf("Skipped FULLTEXT: sql=%s,tableName=%s,hasZeroNums=%d,file=%s,line=%s", $sql, $tableName, intval((is_bool($result)) ? 0 : ifSqlTableColumnExists($columnName)), $F, $L));
        } elseif ($isAlterIndex === TRUE) {
                // And column name as well without backticks
                $keyName = str_replace('`', '', $tableArray[5]);
@@ -632,7 +632,12 @@ function SQL_ERROR ($file, $line, $message) {
 
 // Check if there is a SQL table created
 function ifSqlTableExists ($tableName) {
+       // Make sure double-prefixes are being removed
+       $tableName = str_replace('{?_MYSQL_PREFIX?}_', '', $tableName);
+
+       // Log message
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ' - ENTERED!');
+
        // Is there cache?
        if (!isset($GLOBALS[__FUNCTION__][$tableName])) {
                // Check if the table is there
@@ -663,98 +668,101 @@ function ifSqlTableExists ($tableName) {
 }
 
 // Is a table column there?
-function ifSqlColumnExists ($tableName, $columnName) {
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $columnName . ' - ENTERED!');
-       // Is there cache?
-       if (!isset($GLOBALS[__FUNCTION__][$tableName][$columnName])) {
-               // And column name as well
-               $columnName = str_replace('`', '', $columnName);
+function ifSqlTableColumnExists ($tableName, $columnName) {
+       // Remove back-ticks
+       $columnName = str_replace('`', '', $columnName);
 
-               // If the table is not there, it is okay
-               if (!ifSqlTableExists($tableName)) {
-                       // Then abort here
-                       return FALSE;
-               } // END - if
+       // Debug message
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $columnName . ' - ENTERED!');
 
-               // Get column information
-               $result = SQL_QUERY_ESC("SHOW COLUMNS FROM `%s` LIKE '%s'",
-                       array(
-                               $tableName,
-                               $columnName
-                       ), __FUNCTION__, __LINE__);
+       // If the table is not there, it is okay
+       if (!ifSqlTableExists($tableName)) {
+               // Then abort here
+               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Table ' . $tableName . ' does not exist.');
+               return FALSE;
+       } // END - if
 
-               // Is a link there?
-               if (!is_resource($result)) {
-                       // Is installation phase?
-                       if (isInstallationPhase()) {
-                               // Then silently abort here
-                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ',isLinkUp=' . intval(SQL_IS_LINK_UP()) . ',tableName=' . $tableName . ',columnName=' . $columnName . ' - Returning FALSE ...');
-                               return FALSE;
-                       } else {
-                               // Please report this
-                               reportBug(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ' is not a resource.');
-                       }
-               } // END - if
+       // Get column information
+       $result = SQL_QUERY_ESC("SHOW COLUMNS FROM `%s` LIKE '%s'",
+               array(
+                       $tableName,
+                       $columnName
+               ), __FUNCTION__, __LINE__);
+
+       // Is a link there?
+       if (!is_resource($result)) {
+               // Is installation phase?
+               if (isInstallationPhase()) {
+                       // Then silently abort here
+                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ',isLinkUp=' . intval(SQL_IS_LINK_UP()) . ',tableName=' . $tableName . ',columnName=' . $columnName . ' - Returning FALSE ...');
+                       return FALSE;
+               } else {
+                       // Please report this
+                       reportBug(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ' is not a resource.');
+               }
+       } // END - if
 
-               // Determine it
-               $GLOBALS[__FUNCTION__][$tableName][$columnName] = (!SQL_HASZERONUMS($result));
-               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $columnName . ',hasZeroNums=' . intval(SQL_HASZERONUMS($result)) . ',numRows=' . intval($GLOBALS[__FUNCTION__][$tableName][$columnName]));
+       // Determine it
+       $doesExist = (!SQL_HASZERONUMS($result));
 
-               // Free result
-               SQL_FREERESULT($result);
-       } // END - if
+       // Free result
+       SQL_FREERESULT($result);
 
        // Return cache
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $columnName . ',result=' . intval($GLOBALS[__FUNCTION__][$tableName][$columnName]) . ' - EXIT!');
-       return $GLOBALS[__FUNCTION__][$tableName][$columnName];
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $columnName . ',doesExist=' . intval($doesExist) . ' - EXIT!');
+       return $doesExist;
 }
 
 // Checks depending on the mode if the index is there
 function ifSqlTableIndexExist ($tableName, $keyName) {
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $keyName . ' - ENTERED!');
-       // Is there cache?
-       if (!isset($GLOBALS[__FUNCTION__][$tableName][$keyName])) {
-               // If the table is not there, it is okay
-               if (!ifSqlTableExists($tableName)) {
-                       // Then abort here
-                       return FALSE;
-               } // END - if
+       // Remove back-ticks
+       $keyName = str_replace('`', '', $keyName);
 
-               // Show indexes
-               $result = SQL_QUERY_ESC("SHOW INDEX FROM `%s`", array($tableName), __FUNCTION__, __LINE__);
-
-               // Is a link there?
-               if (!is_resource($result)) {
-                       // Is installation phase?
-                       if (isInstallationPhase()) {
-                               // Then silently abort here
-                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ',isLinkUp=' . intval(SQL_IS_LINK_UP()) . ',tableName=' . $tableName . ',keyName=' . $keyName . ' - Returning FALSE ...');
-                               return FALSE;
-                       } else {
-                               // Please report this
-                               reportBug(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ' is not a resource.');
-                       }
-               } // END - if
+       // Debug message
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',keyName=' . $keyName . ' - ENTERED!');
 
-               // The column is not found by default
-               $GLOBALS[__FUNCTION__][$tableName][$keyName] = FALSE;
+       // If the table is not there, it is okay
+       if (!ifSqlTableExists($tableName)) {
+               // Then abort here
+               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Table ' . $tableName . ' does not exist.');
+               return FALSE;
+       } // END - if
 
-               // Walk through all
-               while ($content = SQL_FETCHARRAY($result)) {
-                       // Add all entries for better caching behavior
-                       $GLOBALS[__FUNCTION__][$tableName][$content['Key_name']] = TRUE;
-               } // END - while
+       // Show indexes
+       $result = SQL_QUERY_ESC("SHOW INDEX FROM `%s`", array($tableName), __FUNCTION__, __LINE__);
 
-               // Free result
-               SQL_FREERESULT($result);
-       } else {
-               // Cache used
-               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $keyName . ',result=' . intval($GLOBALS[__FUNCTION__][$tableName][$keyName]) . ' - CACHE!');
+       // Is a link there?
+       if (!is_resource($result)) {
+               // Is installation phase?
+               if (isInstallationPhase()) {
+                       // Then silently abort here
+                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ',isLinkUp=' . intval(SQL_IS_LINK_UP()) . ',tableName=' . $tableName . ',keyName=' . $keyName . ' - Returning FALSE ...');
+                       return FALSE;
+               } else {
+                       // Please report this
+                       reportBug(__FUNCTION__, __LINE__, 'result[]=' . gettype($result) . ' is not a resource.');
+               }
        } // END - if
 
+       // The column is not found by default
+       $doesExist = FALSE;
+
+       // Walk through all
+       while ($content = SQL_FETCHARRAY($result)) {
+               // Is it the requested one?
+               if ($content['Key_name'] == $keyName) {
+                       // Then it is found and exit
+                       $doesExist = TRUE;
+                       break;
+               } // END - if
+       } // END - while
+
+       // Free result
+       SQL_FREERESULT($result);
+
        // Return cache
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',columnName=' . $keyName . ',result=' . intval($GLOBALS[__FUNCTION__][$tableName][$keyName]) . ' - EXIT!');
-       return $GLOBALS[__FUNCTION__][$tableName][$keyName];
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',keyName=' . $keyName . ',doesExist=' . intval($doesExist) . ' - EXIT!');
+       return $doesExist;
 }
 
 // Init database layer
index c5f03b20974538a99d5a601c028bbcbf7ebc0d53..435f7b92d3d9fa44f3bf49b8825227924890d450 100644 (file)
@@ -1837,8 +1837,8 @@ CHARACTER SET utf8
 COLLATE utf8_general_ci
 COMMENT ' . chr(39) . $comment . chr(39));
        } else {
-               // Is already there, which should not happen
-               reportBug(__FUNCTION__, __LINE__, 'The table ' . $tableName . ' is already created which should not happen.');
+               // Is already there
+               logDebugMessage(__FUNCTION__, __LINE__, 'The table ' . $tableName . ' is already created.');
        }
 }
 
@@ -1846,8 +1846,10 @@ COMMENT ' . chr(39) . $comment . chr(39));
 function addDropTableSql ($tableName) {
        // Is the table there?
        if (ifSqlTableExists($tableName)) {
-               // Then add it, non-existing tables can be ignored because it will
-               // happen with every newly installed extension.
+               /*
+                * Then add it, non-existing tables can be ignored because it will
+                * happen with every newly installed extension.
+                */
                addExtensionSql('DROP TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '`');
 
                // Mark it as gone
@@ -1857,6 +1859,9 @@ function addDropTableSql ($tableName) {
 
 // Adds a RENAME TABLE stament if 'from' table exist and 'to' table not
 function addRenameTableSql ($fromTable, $toTable) {
+       // Make sure both are not the same
+       assert($fromTable != $toTable);
+
        // Is renaming required?
        if ((ifSqlTableExists($fromTable)) && (!ifSqlTableExists($toTable))) {
                // Add it
@@ -1995,7 +2000,7 @@ function addSponsorMenuSql ($action, $what, $title, $active, $sort) {
 // Add ALTER TABLE `foo` ADD sql if not found
 function addExtensionAddTableColumnSql ($tableName, $columnName, $columnSql) {
        // Is the column there?
-       if (!ifSqlColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $columnName)) {
+       if (!ifSqlTableColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $columnName)) {
                // Then add it
                addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '` ADD `' . $columnName . '` ' . $columnSql);
        } elseif (isDebugModeEnabled()) {
@@ -2004,10 +2009,46 @@ function addExtensionAddTableColumnSql ($tableName, $columnName, $columnSql) {
        }
 }
 
+// Add ALTER TABLE `foo` ADD INDEX sql if not found
+function addExtensionAddTableIndexSql ($tableName, $indexName, $columnSql) {
+       // Is the column there?
+       if (!ifSqlTableIndexExist('{?_MYSQL_PREFIX?}_' . $tableName, $indexName)) {
+               // Then add it
+               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '` ADD INDEX `' . $indexName . '` ' . $columnSql);
+       } elseif (isDebugModeEnabled()) {
+               // Add debug line
+               logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',indexName=' . $indexName . ',columnSql=' . $columnSql . ': does already exist.');
+       }
+}
+
+// Add ALTER TABLE `foo` ADD UNIQUE INDEX sql if not found
+function addExtensionAddTableUniqueSql ($tableName, $indexName, $columnSql) {
+       // Is the column there?
+       if (!ifSqlTableIndexExist('{?_MYSQL_PREFIX?}_' . $tableName, $indexName)) {
+               // Then add it
+               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '` ADD UNIQUE INDEX `' . $indexName . '` ' . $columnSql);
+       } elseif (isDebugModeEnabled()) {
+               // Add debug line
+               logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',indexName=' . $indexName . ',columnSql=' . $columnSql . ': does already exist.');
+       }
+}
+
+// Add ALTER TABLE `foo` ADD FULLTEXT sql if not found
+function addExtensionAddTableFulltextSql ($tableName, $indexName, $columnSql) {
+       // Is the column there?
+       if (!ifSqlTableIndexExist('{?_MYSQL_PREFIX?}_' . $tableName, $indexName)) {
+               // Then add it
+               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '` ADD FULLTEXT `' . $indexName . '` ' . $columnSql);
+       } elseif (isDebugModeEnabled()) {
+               // Add debug line
+               logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',indexName=' . $indexName . ',columnSql=' . $columnSql . ': does already exist.');
+       }
+}
+
 // Add ALTER TABLE `foo` CHANGE sql if not found
 function addExtensionChangeTableColumnSql ($tableName, $fromColumnName, $toColumnName, $columnSql) {
        // Is the column there?
-       if ((ifSqlColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $fromColumnName)) && (($fromColumnName == $toColumnName) || (!ifSqlColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $toColumnName)))) {
+       if ((ifSqlTableColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $fromColumnName)) && (($fromColumnName == $toColumnName) || (!ifSqlTableColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $toColumnName)))) {
                // Then add it
                addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '` CHANGE `' . $fromColumnName . '` `' . $toColumnName . '` ' . $columnSql);
        } elseif (isDebugModeEnabled()) {
@@ -2019,7 +2060,7 @@ function addExtensionChangeTableColumnSql ($tableName, $fromColumnName, $toColum
 // Add ALTER TABLE `foo` DROP sql if not found
 function addExtensionDropTableColumnSql ($tableName, $columnName) {
        // Is the column there?
-       if (ifSqlColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $columnName)) {
+       if (ifSqlTableColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $columnName)) {
                // Then add it
                addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '` DROP `' . $columnName . '`');
        } elseif (isDebugModeEnabled()) {
@@ -2028,10 +2069,22 @@ function addExtensionDropTableColumnSql ($tableName, $columnName) {
        }
 }
 
+// Add ALTER TABLE `foo` DROP INDEX sql if not found
+function addExtensionDropTableIndexSql ($tableName, $indexName) {
+       // Is the column there?
+       if (ifSqlTableColumnExists('{?_MYSQL_PREFIX?}_' . $tableName, $indexName)) {
+               // Then add it
+               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_' . $tableName . '` DROP INDEX `' . $indexName . '`');
+       } elseif (isDebugModeEnabled()) {
+               // Add debug line
+               logDebugMessage(__FUNCTION__, __LINE__, 'tableName=' . $tableName . ',indexName=' . $indexName . ': does not exist.');
+       }
+}
+
 // Add configuration entry if not found for actual extension
 function addConfigAddSql ($columnName, $columnSql) {
        // Is the column there?
-       if (!ifSqlColumnExists('{?_MYSQL_PREFIX?}_config', $columnName)) {
+       if (!ifSqlTableColumnExists('{?_MYSQL_PREFIX?}_config', $columnName)) {
                // Not found, so add it
                addExtensionAddTableColumnSql('config', $columnName, $columnSql);
        } elseif (isDebugModeEnabled()) {
@@ -2043,7 +2096,7 @@ function addConfigAddSql ($columnName, $columnSql) {
 // Drop configuration entry if found for actual extension
 function addConfigDropSql ($columnName) {
        // Is the column there?
-       if (ifSqlColumnExists('{?_MYSQL_PREFIX?}_config', $columnName)) {
+       if (ifSqlTableColumnExists('{?_MYSQL_PREFIX?}_config', $columnName)) {
                // Found, so add it
                addExtensionDropTableColumnSql('config', $columnName);
        } elseif (isDebugModeEnabled()) {
index f6b69eff7755c79aa24a5b3e141cdd8d0bd39c44..140b809cc91fa2bc4b7e7cc36ba699ef7769ab82 100644 (file)
@@ -74,7 +74,7 @@ INDEX (`cat_id`)",
                        'Bonus mails');
 
                addExtensionAddTableColumnSql('user_links', 'bonus_id', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
-               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_user_links` ADD INDEX (`bonus_id`)");
+               addExtensionAddTableIndexSql('user_links', 'bonus_id', '(`bonus_id`)');
                addExtensionAddTableColumnSql('bonus', 'html_msg', "ENUM('Y','N') NOT NULL DEFAULT 'N'");
                break;
 
@@ -490,9 +490,9 @@ ORDER BY
                                addConfigAddSql('bonus_new_mem_notify', "ENUM('Y','N') NOT NULL DEFAULT 'N'");
                                addConfigAddSql('bonus_notify_points', 'FLOAT(20,5) UNSIGNED NOT NULL DEFAULT 0.00000');
                                addConfigAddSql('bonus_notify_wait', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 30');
-                               addExtensionAddTableColumnSql('online', 'bonus_ral_en_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
-                               addExtensionAddTableColumnSql('online', 'bonus_ral_di_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
-                               addExtensionAddTableColumnSql('online', 'bonus_ral_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
+                               addExtensionAddTableColumnSql('user_data', 'bonus_ral_en_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
+                               addExtensionAddTableColumnSql('user_data', 'bonus_ral_di_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
+                               addExtensionAddTableColumnSql('user_data', 'bonus_ral_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
 
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Optionale automatische Benachrichtigung &uuml;ber aktivierte und/oder deaktivierte Aktiv-Rallye einstellbar.");
@@ -581,9 +581,9 @@ ORDER BY
                                break;
 
                        case '0.9.2': // SQL queries for v0.9.2
-                               addExtensionChangeTableColumnSql('user_data', 'bonus_ral_en_notify', 'bonus_ralley_enable_notifyBIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
-                               addExtensionChangeTableColumnSql('user_data', 'bonus_ral_di_notify', 'bonus_ralley_disable_notifyBIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
-                               addExtensionChangeTableColumnSql('user_data', 'bonus_ral_notify', 'bonus_rallley_notify` BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
+                               addExtensionChangeTableColumnSql('user_data', 'bonus_ral_en_notify', 'bonus_ralley_enable_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
+                               addExtensionChangeTableColumnSql('user_data', 'bonus_ral_di_notify', 'bonus_ralley_disable_notify', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT 0');
+                               addExtensionChangeTableColumnSql('user_data', 'bonus_ral_notify', 'bonus_rallley_notify` BIGINT(20)', 'UNSIGNED NOT NULL DEFAULT 0');
 
                                // Update notes
                                setExtensionUpdateNotes("Umbenannt nach neuer Konvention (bitte Einstellungen kontrollieren).");
index 234811379c42828873b371f0990d67b8bb01bdb0..20c046c163a0201de9bcc635ab32f21cd8daa02e 100644 (file)
@@ -346,32 +346,32 @@ IN (
                                break;
 
                        case '0.3.1': // SQL queries for v0.3.1
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_extensions` ADD UNIQUE INDEX `ext_name` (`ext_name`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_admins` ADD UNIQUE INDEX `login` (`login`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_refbanner` ADD INDEX `visible` (`visible`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_refdepths` ADD UNIQUE INDEX `level` (`level`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` ADD INDEX `level` (`level`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_pool` ADD INDEX `data_type` (`data_type`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_mod_reg` ADD UNIQUE INDEX `module` (`module`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_admin_menu` ADD INDEX `action` (`action`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_admin_menu` ADD INDEX `what` (`what`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_task_system` ADD INDEX `task_type` (`task_type`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_task_system` ADD INDEX `status` (`status`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_task_system` ADD INDEX `task_created` (`task_created`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_task_system` ADD FULLTEXT `subject` (`subject`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_task_system` ADD INDEX `subject` (`subject`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_extensions` ADD INDEX `ext_active` (`ext_active`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_guest_menu` ADD INDEX `action` (`action`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_guest_menu` ADD INDEX `what` (`what`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_guest_menu` ADD INDEX `sort` (`sort`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_guest_menu` ADD INDEX `visible` (`visible`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_guest_menu` ADD INDEX `locked` (`locked`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_member_menu` ADD INDEX `what` (`what`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_member_menu` ADD INDEX `sort` (`sort`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_member_menu` ADD INDEX `visible` (`visible`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_member_menu` ADD INDEX `locked` (`locked`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_cats` ADD INDEX `visible` (`visible`)");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_cats` ADD INDEX `sort` (`sort`)");
+                               addExtensionAddTableUniqueSql('extensions', 'ext_name', '(`ext_name`)');
+                               addExtensionAddTableUniqueSql('admins', 'login', '(`login`)');
+                               addExtensionAddTableIndexSql('refbanner', 'visible', '(`visible`)');
+                               addExtensionAddTableUniqueSql('refdepths', 'level', '(`level`)');
+                               addExtensionAddTableIndexSql('refsystem', 'level', '(`level`)');
+                               addExtensionAddTableIndexSql('pool', 'data_type', '(`data_type`)');
+                               addExtensionAddTableUniqueSql('mod_reg', 'module', '(`module`)');
+                               addExtensionAddTableIndexSql('admin_menu', 'action', '(`action`)');
+                               addExtensionAddTableIndexSql('admin_menu', 'what', '(`what`)');
+                               addExtensionAddTableIndexSql('task_system', 'task_type', '(`task_type`)');
+                               addExtensionAddTableIndexSql('task_system', 'status', '(`status`)');
+                               addExtensionAddTableIndexSql('task_system', 'task_created', '(`task_created`)');
+                               addExtensionAddTableFulltextSql('task_system', 'subject', '(`subject`)');
+                               addExtensionAddTableIndexSql('task_system', 'subject', '(`subject`)');
+                               addExtensionAddTableIndexSql('extensions', 'ext_active', '(`ext_active`)');
+                               addExtensionAddTableIndexSql('guest_menu', 'action', '(`action`)');
+                               addExtensionAddTableIndexSql('guest_menu', 'what', '(`what`)');
+                               addExtensionAddTableIndexSql('guest_menu', 'sort', '(`sort`)');
+                               addExtensionAddTableIndexSql('guest_menu', 'visible', '(`visible`)');
+                               addExtensionAddTableIndexSql('guest_menu', 'locked', '(`locked`)');
+                               addExtensionAddTableIndexSql('member_menu', 'what', '(`what`)');
+                               addExtensionAddTableIndexSql('member_menu', 'sort', '(`sort`)');
+                               addExtensionAddTableIndexSql('member_menu', 'visible', '(`visible`)');
+                               addExtensionAddTableIndexSql('member_menu', 'locked', '(`locked`)');
+                               addExtensionAddTableIndexSql('cats', 'visible', '(`visible`)');
+                               addExtensionAddTableIndexSql('cats', 'sort', '(`sort`)');
 
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Eindeutige Schl&uuml;ssel (UNIQUE) und normale Schl&uuml;ssel (INDEX) gesetzt.");
@@ -549,7 +549,7 @@ INDEX (`admin_id`)",
                                break;
 
                        case '0.4.8': // SQL queries for v0.4.8
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_task_system` ADD INDEX (`subject`)');
+                               addExtensionAddTableIndexSql('task_system', 'subject', '(`subject`)');
 
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Index f&uuml;r Betreff eingef&uuml;gt.");
@@ -561,9 +561,9 @@ INDEX (`admin_id`)",
                                break;
 
                        case '0.5.0': // SQL queries for v0.5.0
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` DROP INDEX `level`');
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` DROP INDEX `userid`');
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_refsystem` ADD UNIQUE INDEX `userid_level` (`userid`, `level`)');
+                               addExtensionDropTableIndexSql('refsystem', 'level`');
+                               addExtensionDropTableIndexSql('refsystem', 'userid`');
+                               addExtensionAddTableIndexSql('refsystem', 'userid_level', '(`userid`, `level`)');
 
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Referral-System unterst&uuml;tzt nun detailierte Referral-&Uuml;bersicht und vieles mehr.");
@@ -618,7 +618,7 @@ INDEX (`admin_id`)",
                                break;
 
                        case '0.5.8': // SQL queries for v0.5.8
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_extensions` DROP `ext_lang_file`');
+                               addExtensionDropTableColumnSql('extensions` DROP `ext_lang_file`');
 
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Sprachdateinamen werden nicht mehr in der Datenbank behalten.");
@@ -840,9 +840,8 @@ UNIQUE KEY (`subject`)",
                                break;
 
                        case '0.8.2': // SQL queries for v0.8.2
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_points_data` DROP INDEX `ext_name`");
+                               addExtensionDropTableIndexSql('points_data', 'ext_name');
                                addExtensionChangeTableColumnSql('points_data', 'ext_name', 'subject', "VARCHAR(255) NOT NULL DEFAULT ''");
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_points_data` ADD INDEX `subject` (`subject`)");
                                addExtensionAddTableColumnSql('points_data', 'notify_recipient', "ENUM('Y','N') NOT NULL DEFAULT 'N'");
 
                                // Register points data
@@ -907,7 +906,8 @@ INDEX (`history_last_used` DESC)",
                                break;
 
                        case '0.8.8': // SQL queries for v0.8.8
-                               addExtensionSql("ALTER TABLE `{?_MYSQL_PREFIX?}_points_data` DROP INDEX `subject`, ADD UNIQUE `subject` (`subject`)");
+                               addExtensionDropTableIndexSql('points_data', 'subject');
+                               addExtensionAddTableUniqueSql('points_data', 'subject', '(`subject`)');
 
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Der Wert in der Spalte <strong>subject</strong> sollte nur einmal vorkommen, damit eventuell nichts mehrfach durchfl&auuml;ft.");
index 91136eaf0515522c1feddf1e0865b9d0ce347775..5b2aebf6eada95e2c7656f10d0a2847450739341 100644 (file)
@@ -386,8 +386,8 @@ INDEX (`userid`)",
                                break;
 
                        case '0.3.6': // SQL queries for v0.3.6
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_user_cats` DROP INDEX `userid`');
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_user_cats` ADD UNIQUE `userid_catid` (`userid`, `cat_id`)');
+                               addExtensionDropTableIndexSql('user_cats', 'userid`');
+                               addExtensionAddTableUniqueSql('user_cats', 'userid_catid', '(`userid`, `cat_id`)');
 
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Der Sperrgrund wird nun mit abgespeichert und beim L&ouml;schen des Users mit ausgesendet.");
@@ -607,7 +607,7 @@ INDEX (`subid`)",
                                addDropTableSql('subid_log');
                                addCreateTableSql('subid_log', "
 `id` BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
-`refid` BIGINT(20) UNSIGNED NOT NULL DEFAULT 0,
+`refid` BIGINT(20) UNSIGNED NULL DEFAULT NULL,
 `subid` VARCHAR(255) NOT NULL DEFAULT '',
 `referral_url` TINYTEXT NOT NULL,
 `remote_address` VARCHAR(15) NOT NULL DEFAULT '0.0.0.0',
@@ -619,7 +619,7 @@ INDEX (`subid`)",
 
                                // For saving used subid in user_data table
                                addExtensionAddTableColumnSql('user_data', 'subid', 'VARCHAR(255) NULL DEFAULT NULL');
-                               addExtensionSql('ALTER TABLE `{?_MYSQL_PREFIX?}_user_data` ADD INDEX (`subid`)');
+                               addExtensionAddTableIndexSql('user_data', 'subid', '(`subid`)');
 
                                // Configuration entry for purging old subid logs (7 days default)
                                addConfigAddSql('user_subid_purge', 'BIGINT(20) UNSIGNED NOT NULL DEFAULT ' . (getOneDay() * 7));
@@ -674,6 +674,20 @@ INDEX (`subid`)",
                                // Update notes (these will be set as task text!)
                                setExtensionUpdateNotes("Bereinigung von Sub-Ids und deren Einstellungen hinzugef&uuml;gt.");
                                break;
+
+                       case '0.5.9': // SQL queries for v0.5.9
+                               addExtensionChangeTableColumnSql('subid_log', 'refid', 'refid', 'BIGINT(20) UNSIGNED NULL DEFAULT NULL');
+                               addExtensionChangeTableColumnSql('user_stats', 'cat_id', 'cat_id', 'BIGINT(20) UNSIGNED NULL DEFAULT NULL');
+                               addExtensionChangeTableColumnSql('user_stats', 'payment_id', 'payment_id', 'BIGINT(20) UNSIGNED NULL DEFAULT NULL');
+                               addExtensionChangeTableColumnSql('user_stats', 'pool_id', 'pool_id', 'BIGINT(20) UNSIGNED NULL DEFAULT NULL');
+                               addExtensionSql('UPDATE `{?_MYSQL_PREFIX?}_subid_log` SET `refid`=NULL WHERE `refid`=0');
+                               addExtensionSql('UPDATE `{?_MYSQL_PREFIX?}_user_stats` SET `cat_id`=NULL WHERE `cat_id`=0');
+                               addExtensionSql('UPDATE `{?_MYSQL_PREFIX?}_user_stats` SET `payment_id`=NULL WHERE `payment_id`=0');
+                               addExtensionSql('UPDATE `{?_MYSQL_PREFIX?}_user_stats` SET `pool_id`=NULL WHERE `pool_id`=0');
+
+                               // Update notes (these will be set as task text!)
+                               setExtensionUpdateNotes("Besser NULL anstelle 0.");
+                               break;
                } // END - switch
                break;
 
index e5120cb50ffef667bc390fc2dca5b04b004f1662..ceaaa50cec874ae0fafc5710fd24bab3a4552b4a 100644 (file)
@@ -80,10 +80,16 @@ function FILTER_FLUSH_FILTERS () {
                        // Is this filter loaded?
                        //* DEBUG: */ debugOutput('FOUND:'.$filterName.'/'.$filterFunction.'='.$active);
                        if (((!isset($GLOBALS['cache_array']['filter']['loaded'][$filterName][$filterFunction])) && ($active != 'R')) || ($active == 'A')) {
-                               // Add this filter (all filters are active by default)
-                               //* DEBUG: */ debugOutput('ADD:'.$filterName.'/'.$filterFunction);
-                               $insertSQL .= sprintf("('%s','%s','Y'),", $filterName, $filterFunction);
-                               $inserted++;
+                               // Is this filter already in database?
+                               if (countSumTotalData($filterFunction, 'filters', 'filter_name', 'filter_function', TRUE, sprintf(" AND `filter_name`='%s'", SQL_ESCAPE($filterName))) == 0) {
+                                       // Add this filter (all filters are active by default)
+                                       //* DEBUG: */ debugOutput('ADD:'.$filterName.'/'.$filterFunction);
+                                       $insertSQL .= sprintf("('%s','%s','Y'),", $filterName, $filterFunction);
+                                       $inserted++;
+                               } elseif (isDebugModeEnabled()) {
+                                       // Log already registered filters
+                                       logDebugMessage(__FUNCTION__, __LINE__, 'Already registered: filterName=' . $filterName . ',filterFunction=' . $filterFunction . ',active=' . $active);
+                               }
                        } elseif ($active == 'R') {
                                // Remove this filter
                                //* DEBUG: */ debugOutput('REMOVE:'.$filterName.'/'.$filterFunction);