modules/vbtodrupal/vbtodrupal.module

<?php
// $Id: vbtodrupal.module,v 1.3 2007/11/05 19:55:51 liammcdermott Exp $

define('VBTODRUPAL_DEFAULT_VB_DB_PREFIX', 'vb_');
// We're allowing 2 hours for migration by default (this is in seconds)
define('VBTODRUPAL_ALLOWED_TIME_FOR_MIGRATE', 7200);
// Arbitrary number to add to database id values
// stops imported records from interfering with existing ones
define('VBTODRUPAL_ADD_TO_IDS', 1000000);

/**
 * Implementation of hook_menu()
 */
function vbtodrupal_menu($may_cache) {
  $items = array();

  if(!$may_cache) {
    $items[] = array(
      'path' => 'admin/build/vbtodrupal',
      'title' => t('vB to Drupal'),
      'description' => t('Convert a vBulletin forum into a Drupal forum'),
      'access' => user_access('migrate vbulletin'),
      'callback' => 'vbtodrupal_gui',
      'callback arguments' => 'configure',
      'type' => MENU_NORMAL_ITEM);
    $items[] = array(
      'path' => 'admin/build/vbtodrupal/configure',
      'title' => t('Configure'),
      'access' => user_access('migrate vbulletin'),
      'type' => MENU_DEFAULT_LOCAL_TASK,
      'weight' => -10);
    $items[] = array(
      'path' => 'admin/build/vbtodrupal/test',
      'title' => t('Test'),
      'access' => user_access('migrate vbulletin'),
      'callback' => 'vbtodrupal_gui',
      'callback arguments' => 'test',
      'type' => MENU_LOCAL_TASK,
      'weight' => -8);
    $items[] = array(
      'path' => 'admin/build/vbtodrupal/migrate',
      'title' => t('Migrate data'),
      'access' => user_access('migrate vbulletin'),
      'callback' => 'vbtodrupal_gui',
      'callback arguments' => 'migrate',
      'type' => MENU_LOCAL_TASK);
  }
  return $items;
}

/**
 * Implementation of hook_perm()
 */
function vbtodrupal_perm() {
  return array('migrate vbulletin');
}

function vbtodrupal_gui($type) {

  switch ($type) {
    case 'configure':
      $output .= '<p><em>'. t('Note: if when clicking on the <strong>Test tab</strong> Drupal prints lots of errors these settings are wrong. Simply <strong>click the back button</strong> in your browser to check the configuration.') .'</em></p>';
      $output .= drupal_get_form('vbtodrupal_settings');
      break;
    case 'test':
      $output .= '<h3>'. t('Testing for vBulletin tables') .'</h3>';
      $tablestocheck = array('thread', 'post', 'user', 'pm');
      $tablecheck = _vbtodrupal_check_tables($tablestocheck);
      $output .= $tablecheck['html'];
      if (!$tablecheck['result']) {
        $output .= '<p><strong>'. t('Check failed: The database settings are probably incorrect') .'</strong></p>';
      }
      else {
        $output .= '<p>'. t('Tables check passed!') .'</p>';
      }
      $output .= '<h3>'. t('Testing for PHP safe mode') .'</h3>';
      if (ini_get('safe_mode')) {
        $output .= '<p><strong>'. t('Check failed: importing will probably time out due to restrictions on PHP. Please see your hosts/system administrator to fix this issue (set safe_mode to off in php.ini)') .'</strong></p>';
      }
      else {
        $output .= '<p>'. t('Safe mode check passed!') .'</p>';
      }
      $output .= '<h3>'. t('Testing whether pictures are enabled') .'</h3>';
      if (!variable_get('user_pictures', 0)) {
        $output .= '<p><strong>'. t('Check failed: user pictures are not enabled, please enable them in the Administration area or avatar import will fail!') .'</strong></p>';
      }
      else {
        $output .= '<p>'. t('User picture check passed!') .'</p>';
      }
      $output .= '<h3>'. t('Testing Forum module has been enabled correctly') .'</h3>';

      // Grab the vid for the Forums vocabulary.
      $sql = 'SELECT vid FROM {vocabulary} WHERE module="forum";';
      $forum_vid = db_fetch_object(db_query($sql));
      // Sometimes Drupal hasn't created a vocabulary entry for the forums. If we
      // don't trap the error a SQL warning will be generated.
      if (!$forum_vid->vid) {
        $output .= '<p><strong>'. t('Check failed: you may need to reinstall the Forum module, then visit its Admin pages. This is due to a quirk in the Forum module.') .'</strong></p>';
      }
      else {
        $output .= '<p>'. t('Forum check passed!') .'</p>';
      }


      $output .= '<p>'. t('If the checks have succeeded you may continue with the migration') .'</p>';
      break;
    case 'migrate':
        // Change time allowed for script to run
        if (!ini_get('safe_mode')) {
          set_time_limit(VBTODRUPAL_ALLOWED_TIME_FOR_MIGRATE);
        }
        print '<ol>';
        // Users
        print '<li>'. t('Importing users...') .'</li>';
        flush();
        _vbtodrupal_convusers();
        // Forums
        print '<li>'. t('Importing forums...') .'</li>';
        flush();
        _vbtodrupal_convforums();
        // Threads
        print '<li>'. t('Importing threads...') .'</li>';
        flush();
        _vbtodrupal_convthreads();
        // Posts
        print '<li>'. t('Importing posts...') .'</li>';
        flush();
        _vbtodrupal_convposts();
        // Polls
        print '<li>'. t('Importing polls...') .'</li>';
        flush();
        _vbtodrupal_convpolls();
        // Files
        print '<li>'. t('Importing files...') .'</li>';
        flush();
        _vbtodrupal_convfiles();
        // PMs (only imported if privatemsg module is installed)
        if (module_exists('privatemsg')) {
          print '<li>'. t('Importing private messages...') .'</li>';
          flush();
          _vbtodrupal_convpms();
        }
        else {
          print '<li><strong>'. t('Privatemsg module not installed: skipping Private messages import.') .'</strong></li>';
        }
        // Rebuild stats
        print '<li>'. t('Rebuilding stats...') .'</li>';
        flush();
        _vbtodrupal_updatestats();
        // Fix vBulletin BBCode implementation
        print '<li>'. t('Fixing BBCode...') .'</li>';
        flush();
        _vbtodrupal_fixbbcode();
        print '</ol>';
        print '<p><a href="./">Finished, go back</a></p>';
        flush();
        $message .= '<h3>Migration complete!</h3>';
        $message .= '<p>Have a nice cup of tea and pat yourself on the back, you moved off vBulletin!</p>';
        drupal_set_message($message);
        exit;
      break;
  }
  return $output;
}

function vbtodrupal_settings() {
  global $db_url;
  if (is_array($db_url)) {
    $db_url_for_form = $db_url[0];
  }
  else {
    $db_url_for_form = $db_url;
  }

  $form['vbtodrupal_db_url'] = array(
    '#type' => 'textfield',
    '#title' => t('Where is the vBulletin database?'),
    '#required' => TRUE,
    '#default_value' => variable_get('vbtodrupal_db_url', $db_url_for_form),
  );
  $form['vbtodrupal_db_prefix'] = array(
    '#type' => 'textfield',
    '#title' => t('Table name prefix'),
    '#default_value' => variable_get('vbtodrupal_db_prefix', VBTODRUPAL_DEFAULT_VB_DB_PREFIX),
  );
  return system_settings_form($form);
}

/**
 * Setup database connection for vbtodrupal
 */
function _vbtodrupal_db_setup() {
  global $db_url;
  global $db_prefix;

  // Test whether db_url array has been constructed already
  if ($db_url['vb'] != variable_get('vbtodrupal_db_url', $db_url)) {
    $db_url2['vb'] = variable_get('vbtodrupal_db_url', $db_url);
    $db_url2['default'] = $db_url;
    $db_url =& $db_url2;
    $GLOBALS['db_url'] =& $db_url2;
  }

  if (variable_get('vbtodrupal_db_prefix', '') != $db_prefix) {
    // If the prefix of the vBulletin database tables is different to
    // the prefix of the Drupal database tables...
    variable_set('vbtodrupal_default_db_prefix', $db_prefix);
    $GLOBALS['db_prefix'] = variable_get('vbtodrupal_db_prefix', VBTODRUPAL_DEFAULT_VB_DB_PREFIX);
    // Store the original (for restore function) and switch the prefix
  }

  // Get the Drupal db name from db_url
  $drupal_db_name = explode('/', $db_url['default']);
  $drupal_db_name = $drupal_db_name[count($drupal_db_name)-1];
  $drupal_db_prefix = variable_get('vbtodrupal_default_db_prefix', $db_prefix);
  db_set_active('vb');
  return array(
    'drupal_db_name' => $drupal_db_name,
    'drupal_db_prefix' => $drupal_db_prefix,
  );
}

/**
 * Restore database connection for normal Drupal operations
 * Note: a restore should never be attempted without a setup!
 */
function _vbtodrupal_db_restore() {
  global $db_url;
  global $db_prefix;

  if (variable_get('vbtodrupal_default_db_prefix', '') != $db_prefix) {
    // If the prefix of the Drupal database tables is different to
    // the current prefix then retrieve old prefix
    $GLOBALS['db_prefix'] = variable_get('vbtodrupal_default_db_prefix', $db_prefix);
  }
  db_set_active('default');
}

/**
 * Check if the sql tables are installed.
 * Thank you to the phpbb2drupal project
 * for this function
 * 
 * @return array
 *   $out['html'] = formatted html.
 *   $out['result'] = boolean.
 */
function _vbtodrupal_check_tables($tables = array()) {
  global $db_prefix;

  $out['html'] = '<ul>';
  $out['result']= 1;
  foreach ($tables as $table) {
    _vbtodrupal_db_setup();
    if ($db_prefix) {
      $table = db_prefix_tables('{'.$table.'}');
    }  
    if ($GLOBALS['db_type'] == 'pgsql') {
      $query = "SELECT table_name FROM information_schema.tables WHERE table_schema = 'public' AND table_name LIKE '%s'";
    }
    else {
      $query = "SHOW TABLES LIKE '%s'";
    }
    $result = db_query($query, $table);
    _vbtodrupal_db_restore();
    $result = db_num_rows($result);
    if ($result) {
      $out['html'] .= '<li>'. t('Table %table: Yes', array('%table' => $table)) .'</li>';
    }
    else {
      $out['html'] .= '<li><span class="marker">'. t('Table <strong>%table</strong> does not exist!', array('%table' => $table)) .'</span></li>';
      $out['result']= 0;
    }
  }
  $out['html'] .= '</ul>';
  return $out;
}

/**
 * An copy of db_prefix_tables that uses a parameter instead of a global
 * for $db_prefix.
 *
 * @param $sql
 *   A string containing a partial or entire SQL query.
 * @param $db_prefix
 *   An array or string containing the database table prefix.
 *
 * @return
 *   The properly-prefixed string.
 */
function _vbtodrupal_db_prefix_tables($sql, $db_prefix, $db_name) {
  if (is_array($db_name)) {
    $db_name = $db_name['default'];
  }
  if (is_array($db_prefix)) {
    if (array_key_exists('default', $db_prefix)) {
      $tmp = $db_prefix;
      unset($tmp['default']);
      foreach ($tmp as $key => $val) {
        $sql = strtr($sql, array('{'. $key .'}' => $db_name .'.'. $val . $key));
      }
      return strtr($sql, array('{' => $db_name .'.'. $db_prefix['default'], '}' => ''));
    }
    else {
      foreach ($db_prefix as $key => $val) {
        $sql = strtr($sql, array('{'. $key .'}' => $db_name .'.'. $val . $key));
      }
      return strtr($sql, array('{' => '', '}' => ''));
    }
  }
  else {
    return strtr($sql, array('{' => $db_name .'.'. $db_prefix, '}' => ''));
  } 
}

/**
 * Helper function that does the donkey work of
 * migrating users
 */
function _vbtodrupal_convusers() {
  // create profile fields for icq, aim, msn...etc
  $query = 'INSERT IGNORE INTO {profile_fields} (title, name, explanation, category, page, type, weight, required, register, visibility, options) VALUES ';

  $query .= "('YIM', 'user_yim', '', 'Contact', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('MSN', 'user_msn', '', 'Contact', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('Skype', 'user_skype', '', 'Contact', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('AIM', 'user_aim', '', 'Contact', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('icq', 'user_icq', '', 'Contact', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('Website', 'user_website', '', 'Contact', '', 'url', 0, 0, 1, 2, '')";
  $query .= ",('Location', 'user_from', '', 'Personal', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('Occupation', 'user_occ', '', 'Personal', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('Interests', 'user_interests', '', 'Personal', '', 'textfield', 0, 0, 1, 2, '')";
  $query .= ",('Gender', 'user_gender', '', 'Personal', '', 'selection', 0, 0, 1, 2, 'Male
  Female')";
  db_query($query);

  $drupal_settings = _vbtodrupal_db_setup();
  $drupal_db_name = $drupal_settings['drupal_db_name'];
  $drupal_db_prefix = $drupal_settings['drupal_db_prefix'];

  // Signatures
  $sql  = 'INSERT IGNORE INTO %s (uid, signature) ';
  $sql .= 'SELECT {user}.userid+%d, signature ';
  $sql .= 'FROM {user} INNER JOIN {usertextfield} ON {user}.userid={usertextfield}.userid ';
  $sql .= 'WHERE signature IS NOT NULL ';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{users_signature}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS);

  // Main user table
  $file_path = variable_get('file_directory_path', 'files');
  $picture_path = variable_get('user_picture_path', 'pictures');
  $sql = 'INSERT IGNORE INTO %s (uid, name, pass, mail, created, access, login, status, timezone, picture) ';
  // When avatars are imported from the vB database the filename is prepended with the userid to prevent duplicate file names
  $sql .= 'SELECT {user}.userid+%d, username, password, email, joindate, lastactivity, lastvisit, 1, timezoneoffset*60*60, CONCAT(\'%s/%s/\', {user}.userid+%d, \'_\', filename) ';
  $sql .= 'FROM {user} LEFT OUTER JOIN {usertextfield} ON {user}.userid={usertextfield}.userid ';
  $sql .= '  LEFT OUTER JOIN {customavatar} ON {user}.userid={customavatar}.userid;';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{users}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    $file_path,
    $picture_path,
    VBTODRUPAL_ADD_TO_IDS);

  // Import user salt for vBulletin password auth service.
  // This query is the reason this module depends upon vbpassword
  // (because this table has to exist to import to)
  $sql = 'INSERT IGNORE INTO %s (uid, salt, drupal_updated) ';
  $sql .= 'SELECT userid+%d, salt, 0 ';
  $sql .= 'FROM {user};';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{vbuser_salt}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS);

  // Yahoo
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, yahoo ';
  $sql .= 'FROM {user}, %s ';
  $sql .= 'WHERE name="user_yim" AND yahoo<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // MSN
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, msn ';
  $sql .= 'FROM {user}, %s ';
  $sql .= 'WHERE name="user_msn" AND msn<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // Skype
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, skype ';
  $sql .= 'FROM {user}, %s ';
  $sql .= 'WHERE name="user_skype" AND skype<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // AIM
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, aim ';
  $sql .= 'FROM {user}, %s ';
  $sql .= 'WHERE name="user_aim" AND aim<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // ICQ
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, icq ';
  $sql .= 'FROM {user}, %s ';
  $sql .= 'WHERE name="user_icq" AND icq<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // Website address
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, homepage ';
  $sql .= 'FROM {user}, %s ';
  $sql .= 'WHERE name="user_website" AND homepage<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // Location
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, ';
  $sql .= 'REPLACE(REPLACE(REPLACE(REPLACE(field2, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\') ';
  $sql .= 'FROM {userfield}, %s ';
  $sql .= 'WHERE name="user_from" AND field2<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // Occupation
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, ';
  $sql .= 'REPLACE(REPLACE(REPLACE(REPLACE(field4, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\') ';
  $sql .= 'FROM {userfield}, %s ';
  $sql .= 'WHERE name="user_occ" AND field4<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // Interests
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, ';
  $sql .= 'REPLACE(REPLACE(REPLACE(REPLACE(field3, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\') ';
  $sql .= 'FROM {userfield}, %s ';
  $sql .= 'WHERE name="user_interests" AND field3<>"";';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // Gender
  $sql = 'INSERT IGNORE INTO %s (fid, uid, value) ';
  $sql .= 'SELECT fid, userid+%d, field5 ';
  $sql .= 'FROM {userfield}, %s ';
  $sql .= 'WHERE name="user_gender" AND (field5="Male" OR field5="Female");';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{profile_values}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    _vbtodrupal_db_prefix_tables('{profile_fields}', $drupal_db_prefix, $drupal_db_name));

  // Roles
  $sql = 'INSERT IGNORE INTO %s (rid, name) ';
  $sql .= 'SELECT usergroupid+%d, title ';
  $sql .= 'FROM {usergroup};';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{role}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS);

  // User roles (match the users to their roles)
  $sql = 'INSERT IGNORE INTO %s (uid, rid) ';
  $sql .= 'SELECT userid+%d, usergroupid+%d ';
  $sql .= 'FROM {user}';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{users_roles}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);

  $sql = 'SELECT usergroupid FROM {usergroup};';
  $user_group_query = db_query($sql);
  
  // Each user may be a member of every role, so loop through each
  // user_groupid, inserting user_role records for each user found
  while ($user_group = db_fetch_object($user_group_query)) {
    $sql = 'INSERT IGNORE INTO %s (uid, rid) ';
    $sql .= 'SELECT userid+%d, %d+%d ';
    $sql .= 'FROM {user} ';
    $sql .= 'WHERE FIND_IN_SET(%d, membergroupids)<>0;';
    db_query($sql,
      _vbtodrupal_db_prefix_tables('{users_roles}', $drupal_db_prefix, $drupal_db_name),
      VBTODRUPAL_ADD_TO_IDS,
      $user_group->usergroupid,
      VBTODRUPAL_ADD_TO_IDS,
      $user_group->usergroupid);
  }

  _vbtodrupal_db_restore();
}

/**
 * Helper function that does the donkey work of
 * migrating forums to containers/forums
 */
function _vbtodrupal_convforums() {
  $drupal_settings = _vbtodrupal_db_setup();
  $drupal_db_name = $drupal_settings['drupal_db_name'];
  $drupal_db_prefix = $drupal_settings['drupal_db_prefix'];

  // Grab the vid for the Forums vocabulary. Will need when 
  // inserting into other taxonomy tables
  $sql = 'SELECT vid FROM %s WHERE module="forum";';
  $forum_vid = db_fetch_object(db_query($sql,
    _vbtodrupal_db_prefix_tables('{vocabulary}', $drupal_db_prefix, $drupal_db_name)));

  // Forums
  $sql = 'INSERT IGNORE INTO %s (tid, vid, name, description, weight) ';
  $sql .= 'SELECT forumid+%d, %s, title, description, displayorder ';
  $sql .= 'FROM {forum};';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{term_data}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    $forum_vid->vid);

  // Forum hierachy - Top level containers
  $sql = 'INSERT IGNORE INTO %s (tid, parent) ';
  $sql .= 'SELECT forumid+%d, 0 ';
  $sql .= 'FROM {forum} ';
  $sql .= 'WHERE parentid=(-1);';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{term_hierarchy}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS);

  // Forum hierachy - Rest of the hierarchy
  $sql = 'INSERT IGNORE INTO %s (tid, parent) ';
  $sql .= 'SELECT forumid+%d, parentid+%d ';
  $sql .= 'FROM {forum} ';
  $sql .= 'WHERE parentid>(-1);';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{term_hierarchy}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);

  // Build containers array and save
  $containers = variable_get('forum_containers', array());
  $sql = 'SELECT forumid+%d AS forumid FROM {forum} WHERE parentid=(-1)';
  $containers_query = db_query($sql, VBTODRUPAL_ADD_TO_IDS);
  while ($db_containers = db_fetch_object($containers_query)) {
    if (!in_array($db_containers->forumid, $containers)) {
      $containers[] = $db_containers->forumid;
    }
  }

  _vbtodrupal_db_restore();
  variable_set('forum_containers', $containers);
}

/**
 * Helper function that does the donkey work of
 * migrating threads
 */
function _vbtodrupal_convthreads() {
  $drupal_settings = _vbtodrupal_db_setup();
  $drupal_db_name = $drupal_settings['drupal_db_name'];
  $drupal_db_prefix = $drupal_settings['drupal_db_prefix'];

  // Import threads as Drupal nodes
  $sql = 'INSERT IGNORE INTO %s (nid, vid, type, title, uid, status, created, comment, sticky) ';
  $sql .= 'SELECT threadid+%d, threadid+%d, \'forum\', ';
  $sql .= '  REPLACE(REPLACE(REPLACE(REPLACE(title, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\'), ';
  // post/userid==1 is a deleted user
  $sql .= '  IF(postuserid=0,0,postuserid+%d), ';
  $sql .= '  IF(visible=1,1,0), dateline, '; // status and created
  // open: 1=read/write 0=locked 10=moderated (posts deleted etc.)
  $sql .= '  IF(open=1, %d, %d), ';
  $sql .= '  sticky ';
  $sql .= 'FROM {thread} ';
  // We don't import poll threads at this point
  $sql .= 'WHERE pollid=0;';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{node}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    COMMENT_NODE_READ_WRITE,
    COMMENT_NODE_READ_ONLY);

  // Hook nodes up to taxonomy terms (forums)
  $sql = 'INSERT IGNORE INTO %s (nid, tid) ';
  $sql .= 'SELECT threadid+%d, forumid+%d ';
  $sql .= 'FROM {thread};';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{term_node}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);

  // Fill in Forum table: not sure what this does
  // that term_node doesn't
  $sql = 'INSERT IGNORE INTO %s (nid, vid, tid) ';
  $sql .= 'SELECT threadid+%d, threadid+%d, forumid+%d ';
  $sql .= 'FROM {thread};';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{forum}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);

  // Nodes text
  $sql = 'INSERT IGNORE INTO %s (nid, vid, uid, title, body, teaser, log, timestamp, format) ';
  $sql .= 'SELECT {thread}.threadid+%d, {thread}.threadid+%d, IF(userid=0,0,userid+%d), ';
  $sql .= '  REPLACE(REPLACE(REPLACE(REPLACE({thread}.title, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\'), ';
  $sql .= '  pagetext, LEFT(pagetext, 250) AS teaser, notes, {thread}.dateline, 1 ';
  $sql .= 'FROM {thread} INNER JOIN post ON {thread}.firstpostid={post}.postid ';
  //$sql .= 'WHERE {thread}.visible = 1 AND {post}.visible = 1;';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{node_revisions}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);

  _vbtodrupal_db_restore();
}

/**
 * Helper function that does the donkey work of
 * migrating posts into Drupal comments
 */
function _vbtodrupal_convposts() {
  $drupal_settings = _vbtodrupal_db_setup();
  $drupal_db_name = $drupal_settings['drupal_db_name'];
  $drupal_db_prefix = $drupal_settings['drupal_db_prefix'];
  
  // Import comments
  $sql = 'INSERT IGNORE INTO %s (cid, pid, nid, uid, subject, comment, hostname, timestamp, status, format, users, name, mail, homepage) ';
  $sql .= 'SELECT postid+%d, parentid+%d, threadid+%d, IF({post}.userid=0,0,{post}.userid+%d), ';
  $sql .= '  REPLACE(REPLACE(REPLACE(REPLACE(title, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\'), ';
  $sql .= '  pagetext, {post}.ipaddress, dateline, IF(visible=1,%d,%d), 1, \'%s\', {user}.username, email, homepage ';
  $sql .= 'FROM {post} LEFT OUTER JOIN {user} ON {post}.userid={user}.userid ';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{comments}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    COMMENT_PUBLISHED,
    COMMENT_NOT_PUBLISHED,
    serialize(array(0 => 1)));

  /**
   * Comments to delete as they are already in the topic node. This would
   * be achieved with a simple non-correlated (note: non) but for a
   * bug in MySQL. See: http://bugs.mysql.com/bug.php?id=9090
   * So we do data lifting in the application layer: annoying.
   */
  $sql = 'SELECT firstpostid+%d AS cid FROM {thread};';
  $comments_query = db_query($sql, VBTODRUPAL_ADD_TO_IDS);
  // Loop through dataset, generating array of firstpostids
  while ($comments_query_row = db_fetch_object($comments_query)) {
    $comments_to_delete[] = $comments_query_row->cid;
  }
  // implode firstpostids into comma seperated list for MySQL
  $sql = 'DELETE FROM %s WHERE cid IN (%s);';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{comments}', $drupal_db_prefix, $drupal_db_name),
    implode(',',$comments_to_delete));

  // Rebuild thread column, any optimisations to this code would be welcome
  // this is the slowest part of the migration, and it is SLOW
  $sql = 'SELECT cid, pid, nid, thread ';
  $sql .= 'FROM %s ';
  $sql .= 'WHERE thread="" ';
  $sql .= 'ORDER BY timestamp;';
  $thread_query = db_query($sql,
    _vbtodrupal_db_prefix_tables('{comments}', $drupal_db_prefix, $drupal_db_name));

  while ($empty_threads = db_fetch_object($thread_query)) {
    if ($empty_threads->pid == 0) {
      // No parent
      $max = db_result(db_query('SELECT MAX(thread) FROM %s WHERE nid = %d',
        _vbtodrupal_db_prefix_tables('{comments}', $drupal_db_prefix, $drupal_db_name),
        $empty_threads->nid));

      if ($max == '') {
        $thread = int2vancode(1) . '/';
      }
      else {
        // Strip the "/" from the end of the thread.
        $max = rtrim($max, '/');
        $thread = int2vancode(vancode2int($max)+1) . '/';
      }
    }
    else {
      // Has a parent

      // Get the parent comment:
      $parent = db_fetch_object(db_query('SELECT * FROM %s WHERE cid = %d',
        _vbtodrupal_db_prefix_tables('{comments}', $drupal_db_prefix, $drupal_db_name),
        $empty_threads->pid));

      // Strip the "/" from the end of the parent thread.
      $parent->thread = (string) rtrim((string) $parent->thread, '/');

      // Get the max value in _this_ thread.
      $max = db_result(db_query("SELECT MAX(thread) FROM %s WHERE thread LIKE '%s.%%' AND nid = %d",
        _vbtodrupal_db_prefix_tables('{comments}', $drupal_db_prefix, $drupal_db_name),
        $parent->thread,
        $empty_threads->nid));

      if ($max == '') {
        // First child of this parent.
        $thread = $parent->thread .'.'.int2vancode(1).'/';
      }
      else {
        // Strip the "/" at the end of the thread.
        $max = rtrim($max, '/');

        // We need to get the value at the correct depth.
        $parts = explode('.', $max);
        $parent_depth = count(explode('.', $parent->thread));
        $last = $parts[$parent_depth];

        // Finally, build the thread field for this new comment.
        $thread = $parent->thread .'.'. int2vancode(vancode2int($last) + 1) .'/';
      }
    }
    // Update the value in the db
    $sql = 'UPDATE %s SET thread = \'%s\' WHERE cid = %d';
    db_query($sql,
      _vbtodrupal_db_prefix_tables('{comments}', $drupal_db_prefix, $drupal_db_name),
      $thread,
      $empty_threads->cid);
  }

  _vbtodrupal_db_restore();
}

/**
 * Function to do the donkey work of
 * migrating polls.
 *
 */
function _vbtodrupal_convpolls() {
  $drupal_settings = _vbtodrupal_db_setup();
  $drupal_db_name = $drupal_settings['drupal_db_name'];
  $drupal_db_prefix = $drupal_settings['drupal_db_prefix'];

  // Polls table, not much info in here...
  // By default we flag all polls as 'active'
  $sql = 'INSERT IGNORE INTO %s (nid, runtime, active) ';
  $sql .= 'SELECT threadid+%d, timeout, active ';
  $sql .= 'FROM {poll} INNER JOIN {thread} ON {poll}.pollid={thread}.pollid ';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{poll}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS);

  // Poll node item
  $sql = 'INSERT IGNORE INTO %s (nid, vid, type, title, uid, status, created, comment, sticky) ';
  $sql .= 'SELECT {thread}.threadid+%d, {thread}.threadid+%d, \'poll\', ';
  $sql .= '  REPLACE(REPLACE(REPLACE(REPLACE(question, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\'), ';
  $sql .= '  IF(postuserid=0,0,postuserid+%d), IF(visible=1,1,0), {poll}.dateline, ';
  $sql .= 'IF(open=1, %d, %d), sticky ';
  $sql .= 'FROM {poll} INNER JOIN {thread} ON {poll}.pollid={thread}.pollid ';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{node}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    COMMENT_NODE_READ_WRITE,
    COMMENT_NODE_READ_ONLY);

  $sql = 'SELECT {poll}.pollid, threadid, {poll}.options ';
  $sql .= 'FROM {poll} INNER JOIN {thread} ON {poll}.pollid={thread}.pollid ';
  $poll_query = db_query($sql);
  $primary_key_num = 0;

  while ($poll_query_item = db_fetch_object($poll_query)) {
    $sql = 'INSERT IGNORE INTO %s (chid, nid, chtext, chvotes, chorder) VALUES ';
    $poll_options = explode('|||', $poll_query_item->options);
    for ($poll_option_num = 0; $poll_option_num < count($poll_options); $poll_option_num++) {
      $primary_key_num++;
      // Insert comma between value sets
      if ($poll_option_num > 0) {
        $sql .= ',';
      }
      $sql .= '( ';
      $sql .= (int) $primary_key_num .'+'. (int) VBTODRUPAL_ADD_TO_IDS .', ';
      $sql .= (int) $poll_query_item->threadid .'+'. (int) VBTODRUPAL_ADD_TO_IDS .', ';
      $sql .= "'". db_escape_string($poll_options[$poll_option_num]) ."'" .' , ';
      $sql .= '0, '. (int) $poll_option_num;
      $sql .= '  )';
    }
    db_query($sql,
      _vbtodrupal_db_prefix_tables('{poll_choices}',
      $drupal_db_prefix,
      $drupal_db_name));
  }

    // Poll votes
    $sql = 'INSERT IGNORE INTO %s (nid, uid, chorder) ';
    $sql .= 'SELECT threadid+%d, IF(userid=0,0,userid+%d), voteoption-1 ';
    $sql .= 'FROM {pollvote} INNER JOIN {thread} ON {pollvote}.pollid={thread}.pollid ';
    db_query($sql,
      _vbtodrupal_db_prefix_tables('{poll_votes}', $drupal_db_prefix, $drupal_db_name),
      VBTODRUPAL_ADD_TO_IDS,
      VBTODRUPAL_ADD_TO_IDS);

    // Update vote statistics (this is easier than
    // trying to extract badly stored values from vBulletin!)
    $sql = 'UPDATE %s AS pc ';
    $sql .= 'SET chvotes=( ';
    $sql .= 'SELECT COUNT(*) ';
    $sql .= '  FROM %s ';
    $sql .= '  WHERE %s.nid=pc.nid ';
    $sql .= '  AND %s.chorder=pc.chorder ';
    $sql .= ' )';
    db_query($sql,
      _vbtodrupal_db_prefix_tables('{poll_choices}', $drupal_db_prefix, $drupal_db_name),
      _vbtodrupal_db_prefix_tables('{poll_votes}', $drupal_db_prefix, $drupal_db_name),
      _vbtodrupal_db_prefix_tables('{poll_votes}', $drupal_db_prefix, $drupal_db_name),
      _vbtodrupal_db_prefix_tables('{poll_votes}', $drupal_db_prefix, $drupal_db_name));

  _vbtodrupal_db_restore();

  // Now we have the Drupal db selected...
  // Run poll_cron to close polls that are no longer active
  poll_cron();
}

/**
 * Function to do the donkey work of
 * migrating files.
 *
 */
function _vbtodrupal_convfiles() {
  $file_path = variable_get('file_directory_path', 'files');
  $picture_path = variable_get('user_picture_path', 'pictures');
  $drupal_settings = _vbtodrupal_db_setup();
  $drupal_db_name = $drupal_settings['drupal_db_name'];
  $drupal_db_prefix = $drupal_settings['drupal_db_prefix'];

  /**
   * Attachments in vB are attached to posts, but in Drupal we have deleted
   * posts which are first in topic. So we link attachment to thread by
   * firstpostid to find the Drupal node id the file should be attached to.
   * The comment attachments will be dealt with shortly.
   */
  $sql = 'INSERT IGNORE INTO %s (fid, nid, filename, filepath, filemime, filesize) ';
  // When file attachments are imported from the vB database the filename is prepended with the attachmentid to prevent duplicate file names
  $sql .= 'SELECT attachmentid+%d, threadid+%d, CONCAT((attachmentid+%d), \'_\', filename), CONCAT(\'%s\', (attachmentid+%d), \'_\', filename), ';
  // H4Xx0r serialised data to get the MIME type (sorry for those, including myself, who have
  // to understand this in the future). Try using MySQL Query Browser to debug. :)
  $sql .= 'TRIM(LEFT(MID(mimetype, LOCATE(\'Content-type:\', mimetype)+LENGTH(\'Content-type:\'), LENGTH(mimetype)), LOCATE(\'"\',MID(mimetype, LOCATE(\'Content-type:\', mimetype)+LENGTH(\'Content-type:\'), LENGTH(mimetype)))-1)), ';
  $sql .= 'filesize ';
  $sql .= 'FROM {attachment} ';
  $sql .= '  INNER JOIN {thread} ON {attachment}.postid={thread}.firstpostid ';
  $sql .= '  INNER JOIN {attachmenttype} ON {attachment}.extension={attachmenttype}.extension;';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{files}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    $file_path ."/",
    VBTODRUPAL_ADD_TO_IDS);

  // Populate file_revisions table
  $sql = 'INSERT IGNORE INTO %s (fid, vid, description, list) ';
  $sql .= 'SELECT attachmentid+%d, threadid+%d, filename, {attachment}.visible ';
  $sql .= 'FROM {attachment} ';
  $sql .= '  INNER JOIN {thread} ON {attachment}.postid={thread}.firstpostid ';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{file_revisions}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);

  // Now we work through attachments on posts (comments)
  $sql = 'INSERT IGNORE INTO %s (fid, nid, cid, filename, filepath, filemime, filesize, description, list) ';
  $sql .= 'SELECT attachmentid+%d, threadid+%d, {post}.postid+%d, CONCAT((attachmentid+%d), \'_\', filename), CONCAT(\'%s\', (attachmentid+%d), \'_\', filename), ';
  $sql .= 'TRIM(LEFT(MID(mimetype, LOCATE(\'Content-type:\', mimetype)+LENGTH(\'Content-type:\'), LENGTH(mimetype)), LOCATE(\'"\',MID(mimetype, LOCATE(\'Content-type:\', mimetype)+LENGTH(\'Content-type:\'), LENGTH(mimetype)))-1)), ';
  $sql .= 'filesize, filename, {attachment}.visible ';
  $sql .= 'FROM {attachment} ';
  $sql .= '  INNER JOIN {post} ON {attachment}.postid={post}.postid ';
  $sql .= '  INNER JOIN {attachmenttype} ON {attachment}.extension={attachmenttype}.extension;';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{comment_upload_files}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    $file_path ."/",
    VBTODRUPAL_ADD_TO_IDS);

  // Now the attachments/avatars must be taken from the database and saved to disk
  $sql = 'SELECT attachmentid+%d AS uniqueid, filename, filedata, 0 AS avatar ';
  $sql .= 'FROM {attachment} ';
  $sql .= 'UNION SELECT IF(userid=0,0,userid+%d) AS uniqueid, filename, filedata, 1 AS avatar ';
  $sql .= 'FROM {customavatar};';
  $attachment_query = db_query($sql,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);
  
  // Cycle through all blobs in the query
  while ($attachment_query_item = db_fetch_object($attachment_query)) {
    if ($attachment_query_item->avatar == 0) {
      $filename = $file_path;
    }
    else {
      $filename = $file_path .'/'. $picture_path;
    }
    // Add filename, prepend userid/attachmentid so there are no duplicate files
    $filename .= '/'. $attachment_query_item->uniqueid .'_'. $attachment_query_item->filename;
    file_save_data($attachment_query_item->filedata, $filename, FILE_EXISTS_REPLACE);
  }

  _vbtodrupal_db_restore();
}

/**
 * Function to do the donkey work of
 * migrating private messages.
 * TODO: Make this work with multiple recipients
 *
 */
function _vbtodrupal_convpms() {
  $drupal_settings = _vbtodrupal_db_setup();
  $drupal_db_name = $drupal_settings['drupal_db_name'];
  $drupal_db_prefix = $drupal_settings['drupal_db_prefix'];

  // Note we set the folder ID to 0 here. Set everything to Inbox, then UPDATE later on,
  // this ensures no messages are left without a folder (since we can't import subfolders)
  $sql = 'INSERT IGNORE INTO %s (id, author, recipient, subject, message, timestamp, newmsg, folder, author_del, recipient_del, format) ';
  $sql .= 'SELECT {pm}.pmid+%d, IF(fromuserid=0,0,fromuserid+%d), IF(userid=0,0,userid+%d), ';
  $sql .= '  REPLACE(REPLACE(REPLACE(REPLACE(title, \'&amp;\', \'&\'), \'&quot;\', \'"\'), \'&lt;\', \'<\'), \'&gt;\', \'>\'), ';
  $sql .= '  message, dateline, IF(messageread<>0,0,1), ';
  $sql .= '  IF(folderid>0, CONCAT(IF(fromuserid=0,0,fromuserid+%d), folderid), 0), IF(folderid=0,1,0), IF(folderid=(-1),1,0), 1 ';
  $sql .= 'FROM {pm} INNER JOIN {pmtext} ON {pm}.pmtextid={pmtext}.pmtextid;';
  db_query($sql,
    _vbtodrupal_db_prefix_tables('{privatemsg}', $drupal_db_prefix, $drupal_db_name),
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS,
    VBTODRUPAL_ADD_TO_IDS);

  // PM Folders: more questionable database design, all the folders are stored in
  // usertextfield in a serialised array. More data lifting in the app layer. 
  $sql = 'SELECT IF(userid=0,0,userid+%d) AS userid, pmfolders FROM {usertextfield} WHERE pmfolders<>"";';
  $pmfolder_query = db_query($sql, VBTODRUPAL_ADD_TO_IDS);
  while ($pmfolder_query_item = db_fetch_object($pmfolder_query)) {
    $pmfolder_data = unserialize($pmfolder_query_item->pmfolders);
    $sql = 'INSERT IGNORE INTO %s (fid, uid, name) VALUES ';
    for ($pmfolder_count = 0; $pmfolder_count < count($pmfolder_data); $pmfolder_count++) {
      $pmfolder_details = each($pmfolder_data);
      // Weed out blank values
      if ($pmfolder_details['value']) {
        // Insert comma between value sets
        if ($pmfolder_count > 0) {
          $sql .= ',';
        }
        $unique_id = ($pmfolder_query_item->userid == 0 ? 0 : $pmfolder_query_item->userid) . $pmfolder_details['key'];
        $sql .= '( ';
        $sql .= (int) $unique_id .', ';
        $sql .= (int) ($pmfolder_query_item->userid == 0 ? 0 : $pmfolder_query_item->userid) .', ';
        $sql .= '\''. db_escape_string($pmfolder_details['value']) .'\'';
        $sql .= ') ';
      }
    }

    db_query($sql,
      _vbtodrupal_db_prefix_tables('{privatemsg_folder}', $drupal_db_prefix, $drupal_db_name));
  }

  _vbtodrupal_db_restore();
}

/**
 * Helper function which updates thread statistics
 */
function _vbtodrupal_updatestats() {
  // Truncate stats table
  $sql = 'TRUNCATE TABLE {node_comment_statistics}';
  db_query($sql);

  $sql = 'INSERT INTO {node_comment_statistics} (nid, last_comment_timestamp, last_comment_uid, comment_count) ';
  $sql .= 'SELECT nid, ';
  $sql .= '(SELECT MAX(timestamp) FROM {comments} WHERE {comments}.nid = n.nid), ';
  $sql .= '(SELECT uid FROM {comments} WHERE {comments}.nid = n.nid ORDER BY timestamp DESC LIMIT 1), ';
  $sql .= '(SELECT COUNT(*) FROM {comments} WHERE {comments}.nid = n.nid) ';
  $sql .= 'FROM {node} AS n';
  db_query($sql);
}

/**
 * Helper function that makes vBulletin's different 
 * BBCode implementation work with the BBCode module
 */
function _vbtodrupal_fixbbcode() {

  // Nodes
  // Find any nodes that have BBcode with speech marks in them
  // Shame that MySQL regex can only be used for matching not updates
  $sql = 'SELECT nid, body ';
  $sql .= 'FROM {node_revisions} ';
  $sql .= 'WHERE body REGEXP \'\\[[[:alnum:]]+="[[:alnum:][:punct:]]+"\\]\';';
  $bbnode_query = db_query($sql);
  while($bbnode_item = db_fetch_object($bbnode_query)) {
    $sql = ' UPDATE {node_revisions} SET body=\'%s\' ';
    $sql .= 'WHERE nid=%d;';
    // Scoops out everything from the BBCode except speech mark characters
    db_query($sql, preg_replace('#(\[\w+=)"([\w:;&,%+~!=@\/\.\-\#\?\(\)]+)"(\])#si', '$1$2$3', $bbnode_item->body), $bbnode_item->nid);
  }

  // Comments
  $sql = 'SELECT cid, comment ';
  $sql .= 'FROM {comments} ';
  $sql .= 'WHERE comment REGEXP \'\\[[[:alnum:]]+="[[:alnum:][:punct:]]+"\\]\';';
  $bbcomment_query = db_query($sql);
  while($bbcomment_item = db_fetch_object($bbcomment_query)) {
    $sql = ' UPDATE {comments} SET comment=\'%s\' ';
    $sql .= 'WHERE cid=%d;';
    // Scoops out everything from the BBCode except speech mark characters
    db_query($sql, preg_replace('#(\[\w+=)"([\w:;&,%+~!=@\/\.\-\#\?\(\)]+)"(\])#si', '$1$2$3', $bbcomment_item->comment), $bbcomment_item->cid);
  }

  // Signatures
  $sql = 'SELECT uid, signature ';
  $sql .= 'FROM {users} ';
  $sql .= 'WHERE signature REGEXP \'\\[[[:alnum:]]+="[[:alnum:][:punct:]]+"\\]\';';
  $bbsig_query = db_query($sql);
  while($bbsig_item = db_fetch_object($bbsig_query)) {
    $sql = ' UPDATE {users} SET signature=\'%s\' ';
    $sql .= 'WHERE uid=%d;';
    // Scoops out everything from the BBCode except speech mark characters
    db_query($sql, preg_replace('#(\[\w+=)"([\w:;&,%+~!=@\/\.\-\#\?\(\)]+)"(\])#si', '$1$2$3', $bbsig_item->signature), $bbsig_item->uid);
  }
}