Changeset 12763

Timestamp:

Aug 26, 2009, 7:57:15 PM (13 years ago)

Author:

fukamachi

Message:

db converter - fixed convertMemberProfile for performance and debugging. and add note of Notice

File:

• OpenPNE3/branches/fukamachi/db-convert-from-2.x/lib/task/openpneUpgradeFrom2Task.class.php (modified) (6 diffs)

OpenPNE3/branches/fukamachi/db-convert-from-2.x/lib/task/openpneUpgradeFrom2Task.class.php

@@ -233 +233 @@
       ->fetchOne();
 
+    // NOTICE: ignore if the file with same name had saved
     if ($dupNamedFile)
     {
       $dupNamedFile->free();
+
       return;
     }
@@ -335 +337 @@
 
       $community->setName($cCommu->getName());
-      // add index if already created same name community
+      // NOTICE: add index if already created same name community
       if ($this->_isDuplicateCommunityName($cCommu->getName()))
       {
@@ -594 +596 @@
     }
 
+    // NOTICE: ignore if the member image isn't exist
+    if (!($fileId = $this->getFileIdByName($param['image_filename'])))
+    {
+      return;
+    }
+
     $memberImage = new TempMemberImage();
     $memberImage->setMemberId($param['member_id']);
-    $memberImage->setFileId($this->getFileIdByName($param['image_filename']));
+    $memberImage->setFileId($fileId);
     if ($param['image_filename'] === $param['primary_image'])
     {
@@ -752 +760 @@
   protected function convertMemberProfile()
   {
-    $this->connectTo2();
-    $cMemberProfiles = Doctrine::getTable('CMemberProfile')->findAll();
     $this->connectTo3();
     $this->clearDbTable('MemberProfile');
     $treeProfile = Doctrine::getTable('MemberProfile')->getTree();
 
-    foreach ($cMemberProfiles as $cMemberProfile)
-    {
-      $memberProfile = $this->_getMemberProfile(array(
-        'id'                => $cMemberProfile->getCMemberProfileId(),
-        'member_id'         => $cMemberProfile->getCMemberId(),
-        'profile_id'        => $cMemberProfile->getCProfileId(),
-        'profile_option_id' => $cMemberProfile->getCProfileOptionId(),
-        'value'             => $cMemberProfile->getValue(),
-        'public_flag'       => $cMemberProfile->getPublicFlag(),
-      ));
-
-      $memberProfile->save();
-
-      $this->connectTo2();
-      $cMember = Doctrine::getTable('CMember')->find($cMemberProfile->getCMemberId());
-      $this->connectTo3();
-
-      $birthdayRoot = new TempMemberProfile();
-
-      $birthdayYear = $this->_getMemberProfile(array(
-        'member_id'   => $cMemberProfile->getCMemberId(),
-        'profile_id'  => $this->birthdayProfileId,
-        'value'       => $cMember->getBirthYear(),
-        'public_flag' => $cMember->getPublicFlagBirthYear(),
-      ));
-      $birthdayMonth = $this->_getMemberProfile(array(
-        'member_id'    => $cMemberProfile->getCMemberId(),
-        'profile_id'   => $this->birthdayProfileId,
-        'value'        => $cMember->getBirthMonth(),
-        'public_flag'  => $cMember->getPublicFlagBirthMonthDay(),
-      ));
-      $birthdayDay = $this->_getMemberProfile(array(
-        'member_id'    => $cMemberProfile->getCMemberId(),
-        'profile_id'   => $this->birthdayProfileId,
-        'value'        => $cMember->getBirthDay(),
-        'public_flag'  => $cMember->getPublicFlagBirthMonthDay(),
-      ));
-
-      $birthdayYear->getNode()->insertAsLastChildOf($birthdayRoot);
-      $birthdayMonth->getNode()->insertAsLastChildOf($birthdayRoot);
-      $birthdayDay->getNode()->insertAsLastChildOf($birthdayRoot);
-      $birthdayRoot->save();
-
-      $cMember->free();
-      $memberProfile->free();
-      $birthdayRoot->free();
+    $offset = 0;
+    while ($cMemberProfiles = $this->getModelsIterator('CMemberProfile', 100, $offset))
+    {
+      foreach ($cMemberProfiles as $cMemberProfile)
+      {
+        $memberProfile = $this->_getMemberProfile(array(
+          'member_id'         => $cMemberProfile->getCMemberId(),
+          'profile_id'        => $cMemberProfile->getCProfileId(),
+          'profile_option_id' => $cMemberProfile->getCProfileOptionId(),
+          'value'             => $cMemberProfile->getValue(),
+          'public_flag'       => $cMemberProfile->getPublicFlag(),
+        ));
+
+        $memberProfile->save();
+
+        $this->connectTo2();
+        $cMember = Doctrine::getTable('CMember')->find($cMemberProfile->getCMemberId());
+        $this->connectTo3();
+
+        $birthdayRoot = $this->_getMemberProfile(array(
+          'member_id'   => $cMemberProfile->getCMemberId(),
+          'profile_id'  => $this->birthdayProfileId,
+        ));
+        $birthdayYear = $this->_getMemberProfile(array(
+          'member_id'   => $cMemberProfile->getCMemberId(),
+          'profile_id'  => $this->birthdayProfileId,
+          'value'       => $cMember->getBirthYear(),
+          'public_flag' => $cMember->getPublicFlagBirthYear(),
+        ));
+        $birthdayMonth = $this->_getMemberProfile(array(
+          'member_id'    => $cMemberProfile->getCMemberId(),
+          'profile_id'   => $this->birthdayProfileId,
+          'value'        => $cMember->getBirthMonth(),
+          'public_flag'  => $cMember->getPublicFlagBirthMonthDay(),
+        ));
+        $birthdayDay = $this->_getMemberProfile(array(
+          'member_id'    => $cMemberProfile->getCMemberId(),
+          'profile_id'   => $this->birthdayProfileId,
+          'value'        => $cMember->getBirthDay(),
+          'public_flag'  => $cMember->getPublicFlagBirthMonthDay(),
+        ));
+
+        $birthdayYear->getNode()->insertAsLastChildOf($birthdayRoot);
+        $birthdayMonth->getNode()->insertAsLastChildOf($birthdayRoot);
+        $birthdayDay->getNode()->insertAsLastChildOf($birthdayRoot);
+        $birthdayRoot->save();
+
+        $cMemberProfile->free();
+        $cMember->free();
+        $memberProfile->free();
+        $birthdayRoot->free();
+      }
+      $offset += 100;
     }
   }
@@ -809 +822 @@
   protected function _getMemberProfile($param = array())
   {
+    // NOTICE: ignore if c_member_profile.c_profile_id = 0
+    if (!array_key_exists('profile_id', $param) || !$param['profile_id'])
+    {
+      return;
+    }
+
     $memberProfile = new TempMemberProfile();
-    if (array_key_exists('id', $param))
-    {
-      $memberProfile->setId($param['id']);
-    }
     $memberProfile->setMemberId($param['member_id']);
     $memberProfile->setProfileId($param['profile_id']);
-    if (array_key_exists('profile_option_id', $param))
+    if (array_key_exists('profile_option_id', $param) && $param['profile_option_id'])
     {
       $memberProfile->setProfileOptionId($param['profile_option_id']);
     }
-    $memberProfile->setValue($param['value']);
-    $memberProfile->setPublicFlag($param['public_flag']);
+    if (array_key_exists('value', $param) && $param['value'])
+    {
+      $memberProfile->setValue($param['value']);
+    }
+    if (array_key_exists('public_flag', $param) && $param['public_flag'])
+    {
+      $memberProfile->setPublicFlag($param['public_flag']);
+    }
     $memberProfile->setCreatedAt($this->date);
     $memberProfile->setUpdatedAt($this->date);
@@ -955 +976 @@
     if ($file)
     {
-      return $file->getId();
+      $id = $file->getId();
+      $file->free();
+
+      return $id;
     }
   }