TRUE, 'default' => 0)); break; case 'mysql': case 'mysqli': $ret[] = update_sql("ALTER TABLE {node_field_userreference_data} ADD COLUMN nid int(10) NOT NULL DEFAULT 0"); break; } return $ret; } /** * Populate nid column in existing user reference fields. */ function userreference_update_2() { // Multi-part update if (!isset($_SESSION['userreference_update_2'])) { $_SESSION['userreference_update_2'] = 0; $_SESSION['userreference_update_2_max'] = db_result(db_query("SELECT COUNT(*) FROM {node_field_userreference_data}"));; } $limit = 20; $result = db_query_range("SELECT nr.nid, nfud.vid, nfud.field_name, nfud.delta FROM {node_field_userreference_data} nfud LEFT JOIN {node_revisions} nr ON nr.vid = nfud.vid", $_SESSION['userreference_update_2'], $limit); if (db_num_rows($result) == 0) { unset($_SESSION['userreference_update_2']); unset($_SESSION['userreference_update_2_max']); return array(); } while ($data = db_fetch_object($result)) { $_SESSION['userreference_update_2']++; db_query("UPDATE {node_field_userreference_data} SET nid = %d WHERE vid = %d AND field_name = '%s' AND delta = %d", $data->nid, $data->vid, $data->field_name, $data->delta); } return array('#finished' => $_SESSION['userreference_update_2'] / $_SESSION['userreference_update_2_max']); } /** * Data is now stored in per-field tables. */ function userreference_update_3() { $ret = array(); include_once(drupal_get_path('module', 'content') .'/content.module'); include_once(drupal_get_path('module', 'content') .'/content_admin.inc'); $fields = content_fields(); foreach ($fields as $field) { switch ($field['type']) { case 'userreference': $columns = array( 'uid' => array('type' => 'int', 'not null' => TRUE, 'default' => '0'), ); content_alter_db_field(array(), array(), $field, $columns); if ($field['multiple']) { $ret[] = update_sql('INSERT INTO {node_data_'. $field['field_name'] .'} (vid, delta, nid, '. $field['field_name'] ."_uid) SELECT vid, delta, nid, field_uid FROM {node_field_userreference_data} WHERE field_name = '". $field['field_name'] ."'"); } else { $ret[] = update_sql('INSERT INTO {node_data_'. $field['field_name'] .'} (vid, nid, '. $field['field_name'] ."_uid) SELECT vid, nid, field_uid FROM {node_field_userreference_data} WHERE field_name = '". $field['field_name'] ."'"); } break; } } $ret[] = update_sql('DROP TABLE {node_field_userreference_data}'); db_query('DELETE FROM {cache}'); return $ret; }