На примере этого переезда разбираемся с работой с MySQL через PDO.

На примере этого переезда разбираемся с работой с MySQL через PDO.

Нашел интересную статью по данному вопросу на хабре. Кто интересуется - может более подробно изучить данный вопрос. 

Итак, приступим.

Имеем сайт на какой-то CMS (честно: особо не интересовался, что то за CMS-ка такая...). Есть доступ к базе данных данного сайта. 

Отключаем ограничение на время исполнения скрипта: 

set_time_limit(0);

Подключаем пролог и необходимые модули: 

require($_SERVER["DOCUMENT_ROOT"]."/bitrix/modules/main/include/prolog_before.php");
CModule::IncludeModule("iblock");
CModule::IncludeModule("sale");

Создаем массив для продуктов:

$products=array();

Создаем функцию, которая будет получать данные:

function GetFromMysqlData(){
    GLOBAL $products;
    $hostname = 'XXX.XXX.XXX.XXX';  // IP сервера
    $port='XXXX';  // порт (если для подключения к серверу MySQL нужен порт)
    $username = 'UNAME';
    $password = 'UPASSWORD';
    $dbname='DBNAME';
    $dsn = 'mysql:dbname='.$dbname.';host='.$hostname.';port='.$port;
// если порт для подключения не нужен последний параметр не нужен

// дальше подключаемся к базе данных:
try{
     $DBH = new PDO($dsn, $username, $password,array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\''));
    }
    catch(PDOException $e) {
     echo $e->getMessage();
    }

$sql="sel ect * from `products`";  // тут пишите свой запрос

// выполняем данный запрос:
$STH = $DBH->query($sql);
$STH->setFetchMode(PDO::FETCH_ASSOC);

// перебираем все строки запроса:
 while($row = $STH->fetch()) {
$products[$row["id"]]=$row;
}

// если нужны еще какие-то запросы получаем данные по ним дальше

// закрывает подключение
    $DBH = null;
    return;
}

Пишем функцию добавления нового элемента инфоблока: 

function addElement($Product) {

$IB=##;  // инфоблок, в который будет добавляться товар

// тут ничего сверхествественного  смотрите формирование массива для добавления тут :
//http://dev.1c-bitrix.ru/api_help/iblock/classes/ciblockelement/add.php
в массив параметров для добавления настоятельно рекомендую добавить вот такую строку:

$arLoadProductArray["XML_ID"]=$Product["productID"];  // , где $Product["productID"] -  ID товара на сайте-оригинале

// добавляем новый элемент инфоблока:

if($PRODUCT_ID = $el->Add($arLoadProductArray)){
$res="New ID: ".$PRODUCT_ID." => ".$Product["productID"];
// добавляем товар в каталог продукции:
$arFields=array(
           "ID"=>$PRODUCT_ID,
           "QUANTITY"=>1
);
if(CCatalogProduct::Add($arFields))
           $res.='
Добавили параметры товара к элементу каталога '.$PRODUCT_ID.'
';
else
           $res.='
Ошибка добавления параметров
';
// устанавливаем цену на товар:

$PRICE_TYPE_ID = 1;

$arFields = Array(
           "PRODUCT_ID" => $PRODUCT_ID,
           "CATALOG_GROUP_ID" => $PRICE_TYPE_ID,
           "PRICE" => $Price,
           "CURRENCY" => "RUB" /*код валюты*/
);


$Priceres = CPrice::GetList(
           array(),
           array(
            "PRODUCT_ID" => $PRODUCT_ID,
            "CATALOG_GROUP_ID" => $PRICE_TYPE_ID
           )
);
if ($arr = $Priceres->Fetch()){
           CPrice::Update($arr["ID"], $arFields);
} else {
           CPrice::Add($arFields);
}

}
    return $res/*=array("array"=>$arLoadProductArray,"res"=>$res)*/;
}

Запускаем функцию получения данных из базы: 

GetFromMysqlData();

Перебираем все товары, полученные из базы. Если нужны какие-то манипуции с данными, полученными из базы, перед подключением добавления нового товара проводим эти манипуляции: 

foreach($products as $element){
    addElement($element);
}

Вот в принципе и все. Получили данные из базы, обработали их, добавили на сайт. 

И вот тут понимаем, что одна из таблиц сайта-оригинала содержит какие-то свойства, которые никак не привязаны напрямую к таблице с товарами. 

Вот тут-то и понадобится параметр

$arLoadProductArray["XML_ID"]

который мы предусмотрительно создали при добавлении товаров. Воспользуемся им для обновления товаров.

Создаем еще один запрос к старой базе (у меня свойство было - доп. изображения товара):

$STH = $DBH->query('select photoID, productID, filename fr om product_pictures');
$STH->setFetchMode(PDO::FETCH_ASSOC);

while($row = $STH->fetch()) {
 // вытаскиваем одну за другой строки, помещаем в $row
 $photos[$row["productID"]][]=array(
  "PhotoID"=>$row["photoID"],
  "Photo"=>$row["filename"],
  "ProductID"=>$row["productID"]
 );
}

перебираем все товары в инфоблоке:

$arSelect = Array("ID", "NAME", "DATE_ACTIVE_FROM", "XML_ID" ,"PROPERTY_PHOTO_TITLE");
$arFilter = Array("IBLOCK_ID"=>IntVal(3), "ACTIVE_DATE"=>"Y", "ACTIVE"=>"Y");
$res = CIBlockElement::GetList(Array(), $arFilter, false, Array("nPageSize"=>5000), $arSelect);
while($arFields = $res->GetNext())
{
    echo AddPhotos($arFields["ID"],$photos[$arFields["XML_ID"]]);
}

AddPhotos - функция добавления значений свойства типа "Файл" к товару: 

function AddPhotos($ID,$photos){
    $value="";
    $k=0;
    foreach($photos as $k=>$photo){
     $img=$photo["Photo"];
     $arFile=false;
     if (file_exists($_SERVER["DOCUMENT_ROOT"]."/upload/oldimages/big/".$img)){
      if(strlen($img)>0){
          $arFile=CFile::MakeFileArray($_SERVER["DOCUMENT_ROOT"]."/upload/oldimages/big/".$img);
      }
     } elseif (file_exists($_SERVER["DOCUMENT_ROOT"]."/upload/oldimages/extra/".$img)){
      if(strlen($img)>0){
          $arFile=CFile::MakeFileArray($_SERVER["DOCUMENT_ROOT"]."/upload/oldimages/extra/".$img);
      }
     }

     if(is_array($arFile)){
      $arFile["MODULE_ID"] = "iblock";
     }

     $value["n".$k]=$arFile;
    }

    $res=CIBlockElement::SetPropertyValueCode($ID, "MORE_PHOTO", $value);
    return $value;
}

Скажу честно: мне повезло, что все изображения для старого сайта хранились в 2-х папках: "big" и "extra" и привязка изображений к товарам делалась просто по имени файла изображения. Эти 2 папки просто перелил по ftp со старого сайта в папку uploads нового... 

Вот и все... всем спасибо за внимание. Если кто-то впустую потратил время прочитав мою статью - звыняйте:) Кому хоть как-то помог - очень рад. У кого есть вопросы - пишите. Не обещаю ответить сразу, но постараюсь по мере возможности. 

P.S. вот предыдущая статья по теме