/**
 * Loads a SQL file and executes all queries.
 * Before executing a query, $replaced is... replaced by $replacing. This is
 * useful when the SQL file contains generic words. Drop table queries are
 * not executed.
 *
 * @param string $filepath
 * @param string $replaced
 * @param string $replacing
 */
function execute_sqlfile($filepath, $replaced, $replacing, $dblayer)
{
    $sql_lines = file($filepath);
    $query = '';
    foreach ($sql_lines as $sql_line) {
        $sql_line = trim($sql_line);
        if (preg_match('/(^--|^$)/', $sql_line)) {
            continue;
        }
        $query .= ' ' . $sql_line;
        // if we reached the end of query, we execute it and reinitialize the
        // variable "query"
        if (preg_match('/;$/', $sql_line)) {
            $query = trim($query);
            $query = str_replace($replaced, $replacing, $query);
            // we don't execute "DROP TABLE" queries
            if (!preg_match('/^DROP TABLE/i', $query)) {
                if ('mysql' == $dblayer) {
                    if (preg_match('/^(CREATE TABLE .*)[\\s]*;[\\s]*/im', $query, $matches)) {
                        $query = $matches[1] . ' DEFAULT CHARACTER SET utf8' . ';';
                    }
                }
                pwg_query($query);
            }
            $query = '';
        }
    }
}

function upgrade_250_255()
{
    global $conf;
    // Add new field in Register_FluxBB ID links table
    $query = 'ALTER TABLE ' . Register_FluxBB_ID_TABLE . ' ADD PwdSynch VARCHAR(3) NULL DEFAULT NULL;';
    pwg_query($query);
}

function upgrade65_change_table_to_charset($table, $field_definitions, $db_charset)
{
    $changes = array();
    foreach ($field_definitions as $row) {
        if (!isset($row['Collation']) or $row['Collation'] == 'NULL') {
            continue;
        }
        $query = $row['Field'] . ' ' . $row['Type'];
        $query .= ' CHARACTER SET ' . $db_charset;
        if (strpos($row['Collation'], '_bin') !== false) {
            $query .= ' BINARY';
        }
        if ($row['Null'] != 'YES') {
            $query .= ' NOT NULL';
            if (isset($row['Default'])) {
                $query .= ' DEFAULT "' . addslashes($row['Default']) . '"';
            }
        } else {
            if (!isset($row['Default'])) {
                $query .= ' DEFAULT NULL';
            } else {
                $query .= ' DEFAULT "' . addslashes($row['Default']) . '"';
            }
        }
        if ($row['Extra'] == 'auto_increment') {
            $query .= ' auto_increment';
        }
        $changes[] = 'MODIFY COLUMN ' . $query;
    }
    if (count($changes)) {
        $query = 'ALTER TABLE `' . $table . '` ' . implode(', ', $changes);
        pwg_query($query);
    }
}

 function uninstall()
 {
     global $conf;
     conf_delete_param('forecast_conf');
     $q = 'DROP VIEW forecast;';
     pwg_query($q);
 }

function vjs_begin_delete_elements($ids)
{
    if (count($ids) == 0) {
        return 0;
    }
    $vjs_extensions = array('ogg', 'ogv', 'mp4', 'm4v', 'webm', 'webmv');
    $files_ext = array_merge(array(), $vjs_extensions, array_map('strtoupper', $vjs_extensions));
    // Find details base on ID and if supported video files
    $query = '
SELECT
    id,
    path,
    representative_ext
  FROM ' . IMAGES_TABLE . '
  WHERE id IN (' . implode(',', $ids) . ') AND ' . SQL_VIDEOS . '
;';
    $result = pwg_query($query);
    while ($row = pwg_db_fetch_assoc($result)) {
        if (url_is_remote($row['path'])) {
            continue;
        }
        $files = array();
        $files[] = get_element_path($row);
        $ok = true;
        if (!isset($conf['never_delete_originals'])) {
            foreach ($files as $path) {
                // Don't delete the actual video or representative
                // It is done by PWG core
                // Delete any other video source format
                $file_wo_ext = pathinfo($path);
                $file_dir = dirname($path);
                foreach ($files_ext as $file_ext) {
                    $path_ext = $file_dir . "/pwg_representative/" . $file_wo_ext['filename'] . "." . $file_ext;
                    if (is_file($path_ext) and !unlink($path_ext)) {
                        $ok = false;
                        trigger_error('"' . $path_ext . '" cannot be removed', E_USER_WARNING);
                        break;
                    }
                }
                // Delete video thumbnails
                $filematch = $file_dir . "/pwg_representative/" . $file_wo_ext['filename'] . "-th_*";
                $matches = glob($filematch);
                if (is_array($matches)) {
                    foreach ($matches as $filename) {
                        if (is_file($filename) and !unlink($filename)) {
                            $ok = false;
                            trigger_error('"' . $filename . '" cannot be removed', E_USER_WARNING);
                            break;
                        }
                    }
                }
                // End videos thumbnails
            }
            // End for each files
        }
        // End IF
    }
    // End While
}

 function uninstall()
 {
     global $prefixeTable;
     $query = 'ALTER TABLE ' . IMAGES_TABLE . ' DROP pqv_validated;';
     pwg_query($query);
     $query = 'DROP TABLE ' . GROUPS_TABLE . ' DROP pqv_enabled;';
     pwg_query($query);
 }

function plugin_uninstall()
{
    $query = '
    DELETE FROM ' . CONFIG_TABLE . '
    WHERE param=\'eml\'
  ;';
    pwg_query($query);
}

 function uninstall()
 {
     global $prefixeTable;
     pwg_query('DROP TABLE ' . $prefixeTable . 'pshare_keys;');
     pwg_query('DROP TABLE ' . $prefixeTable . 'pshare_log;');
     $query = 'DROP TABLE ' . GROUPS_TABLE . ' DROP pshare_enabled;';
     pwg_query($query);
 }

function plugin_uninstall()
{
    if (is_dir(PHPWG_ROOT_PATH . PWG_LOCAL_DIR . 'GThumb')) {
        gtdeltree(PHPWG_ROOT_PATH . PWG_LOCAL_DIR . 'GThumb');
    }
    $query = 'DELETE FROM ' . CONFIG_TABLE . ' WHERE param="GThumb" LIMIT 1;';
    pwg_query($query);
}

function plugin_uninstall()
{
    global $prefixeTable;
    $query = '
    DROP TABLE ' . $prefixeTable . 'stereo
    ;';
    pwg_query($query);
}

function get_summary($year = null, $month = null, $day = null)
{
    $query = '
SELECT
    year,
    month,
    day,
    hour,
    nb_pages
  FROM ' . HISTORY_SUMMARY_TABLE;
    if (isset($day)) {
        $query .= '
  WHERE year = ' . $year . '
    AND month = ' . $month . '
    AND day = ' . $day . '
    AND hour IS NOT NULL
  ORDER BY
    year ASC,
    month ASC,
    day ASC,
    hour ASC
;';
    } elseif (isset($month)) {
        $query .= '
  WHERE year = ' . $year . '
    AND month = ' . $month . '
    AND day IS NOT NULL
    AND hour IS NULL
  ORDER BY
    year ASC,
    month ASC,
    day ASC
;';
    } elseif (isset($year)) {
        $query .= '
  WHERE year = ' . $year . '
    AND month IS NOT NULL
    AND day IS NULL
  ORDER BY
    year ASC,
    month ASC
;';
    } else {
        $query .= '
  WHERE year IS NOT NULL
    AND month IS NULL
  ORDER BY
    year ASC
;';
    }
    $result = pwg_query($query);
    $output = array();
    while ($row = pwg_db_fetch_assoc($result)) {
        $output[] = $row;
    }
    return $output;
}

function plugin_uninstall()
{
    $q = 'DELETE FROM ' . CONFIG_TABLE . ' WHERE param = "jplayer_skin";';
    pwg_query($q);
    $q = 'DELETE FROM ' . CONFIG_TABLE . ' WHERE param = "jplayer_autoplay";';
    pwg_query($q);
    $q = 'DELETE FROM ' . CONFIG_TABLE . ' WHERE param = "jplayer_jplayer_representative_as_poster";';
    pwg_query($q);
    // TODO : Do we need to purge the videos from the images table?
}

 function uninstall()
 {
     global $prefixeTable;
     $query = 'DROP TABLE ' . $prefixeTable . 'pfemail_mailboxes;';
     pwg_query($query);
     $query = 'DROP TABLE ' . $prefixeTable . 'pfemail_pendings;';
     pwg_query($query);
     // delete configuration
     pwg_query('DELETE FROM `' . CONFIG_TABLE . '` WHERE param IN ("pfemail_last_check");');
 }

function plugin_uninstall()
{
    global $conf;
    if (isset($conf['PruneHistory'])) {
        $q = '
DELETE FROM ' . CONFIG_TABLE . '
WHERE param="PruneHistory"
;';
        pwg_query($q);
    }
}

function get_site_url($category_id)
{
    global $page;
    $query = '
SELECT galleries_url
  FROM ' . SITES_TABLE . ' AS s,' . CATEGORIES_TABLE . ' AS c
  WHERE s.id = c.site_id
    AND c.id = ' . $category_id . '
;';
    $row = pwg_db_fetch_assoc(pwg_query($query));
    return $row['galleries_url'];
}

function plugin_uninstall()
{
    global $conf;
    if (isset($conf['Register_PhpBB'])) {
        $q = '
DELETE FROM ' . CONFIG_TABLE . '
WHERE param="Register_PhpBB" LIMIT 1
;';
        pwg_query($q);
    }
    $q = 'DROP TABLE ' . Register_PhpBB_ID_TABLE . ';';
    pwg_query($q);
}

function osm_items_have_latlon($items)
{
    $query = '
SELECT id FROM ' . IMAGES_TABLE . '
WHERE latitude IS NOT NULL
  AND id IN (' . implode(',', $items) . ')
ORDER BY NULL
LIMIT 0,1';
    if (pwg_db_num_rows(pwg_query($query)) > 0) {
        return true;
    }
    return false;
}

 function activate($theme_version, &$errors = array())
 {
     global $conf, $prefixeTable;
     if (empty($conf['smartpocket'])) {
         $conf['smartpocket'] = serialize($this->default_conf);
         $query = "\n  INSERT INTO " . CONFIG_TABLE . " (param,value,comment)\n  VALUES ('smartpocket' , '" . pwg_db_real_escape_string($conf['smartpocket']) . "' , 'loop#autohide');";
         pwg_query($query);
     } elseif (count(unserialize($conf['smartpocket'])) != 2) {
         $conff = unserialize($conf['smartpocket']);
         $config = array('loop' => !empty($conff['loop']) ? $conff['loop'] : true, 'autohide' => !empty($conff['autohide']) ? $conff['autohide'] : 5000);
         conf_update_param('smartpocket', pwg_db_real_escape_string(serialize($config)));
         load_conf_from_db();
     }
     $this->installed = true;
 }

/**
 * search an available feed_id
 *
 * @return string feed identifier
 */
function find_available_feed_id()
{
    while (true) {
        $key = generate_key(50);
        $query = '
SELECT COUNT(*)
  FROM ' . USER_FEED_TABLE . '
  WHERE id = \'' . $key . '\'
;';
        list($count) = pwg_db_fetch_row(pwg_query($query));
        if (0 == $count) {
            return $key;
        }
    }
}

function get_oauth_id($user_id)
{
    $query = '
SELECT oauth_id FROM ' . USER_INFOS_TABLE . '
  WHERE user_id = ' . $user_id . '
  AND oauth_id != ""
;';
    $result = pwg_query($query);
    if (!pwg_db_num_rows($result)) {
        return null;
    } else {
        list($oauth_id) = pwg_db_fetch_row($result);
        return $oauth_id;
    }
}