Как я могу использовать импорт моих файлов (циклом) sql после импорта основной базы данных?

Question

[Alex Kizyma]

// Mysql connect
$conn = new PDO(
    "mysql:host=".$settings['db']['host'].";dbname=".$settings['db']['name'].";port=".$settings['db']['port'].";",
    $settings['db']['user'],
    $settings['db']['password']
);

if(file_exists($settings['dump'])){

    $query = file_get_contents($settings['dump']);
    $stmt = $conn->prepare($query);

    sleep(1);
    
    // import main DB
    if($stmt->execute()){
        $stmt->closeCursor();

        // Import of additional tables
        importAdditionalTables($conn, $settings);

    }
}



function importAdditionalTables($conn, $prefix){
   $path = './installation/sql/';
   $sqlFilesName = getSqlFileNames($path);
   foreach($sqlFilesName as $fileName){
       $file = $path.$fileName;
       setSQLSettings($file, $prefix);

       $query = file_get_contents($file);
       $stmt = $conn->prepare($query);
       $result = $stmt->execute();
       $stmt->closeCursor();

       if(!$result){
           throw new Exception("Error import additional file: $file");
       }
   }
   sleep(1);
}

Мой метод importAdditionalTables не импортирует мои дополнительные файлы
Возможно, моя проблема в цикле, который я использую неправильно.
Сначала мне нужно импортировать основную базу данных, а затем список файлов sql.

Comments

[Дмитрий]

Возможно подключение не пробрасывается

[Alex Kizyma]

Дмитрий, Пробовать делать подключение повторно?

[Дмитрий]

Alex Kizyma, проверить хотя бы, оно вообще там существует

[Alex Kizyma]

Дмитрий, Даже когда ставлю новое подключение, то результата не имеет

[Дмитрий]

Alex Kizyma, попробуйте собрать весь код в одном месте и отладить

[Alex Kizyma]

Дмитрий,
$result = $stmt->execute(); - тут я получаю false

[Дмитрий]

Alex Kizyma, что возвращает getSqlFileNames($path), лучше весь код покажите, и структуру папок

[Alex Kizyma]

Дмитрий, это список sql файлов в папке для импорта

function getSqlFileNames($path){
    $indir = array_filter(scandir($path, $sorting_order = SCANDIR_SORT_ASCENDING), function($item) {
        return $item[0] !== '.';
    });
    return $indir;
}

[Дмитрий]

Alex Kizyma, а подебажить этот массив? возвращает файлы и пути?

[Alex Kizyma]

@Дмитрий SQLSTATE[HY000]: General error: 2013 Lost connection to MySQL server during query
Вот проблема, а с массивом все хорошо

Answer 1

[ThunderCat]

Для начала, надо видеть ошибки, для этого:

// Mysql connect
$opt = [ PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION];
$conn = new PDO(
    "mysql:host=".$settings['db']['host'].";dbname=".$settings['db']['name'].";port=".$settings['db']['port'].";",
    $settings['db']['user'],
    $settings['db']['password'],
    $opt
);
...

После этого смотреть что вылазит в ошибках.

Comments

[Alex Kizyma]

@ThunderCat
Fatal error: Uncaught exception 'Exception' with message 'An Error occurred: SQLSTATE[HY000]: General error: 2013 Lost connection to MySQL server during query' in /home/swebxhgd6/public_html/hosting_setup_script.php:191 Stack trace: #0 {main} thrown in /home/swebxhgd6/public_html/hosting_setup_script.php on line 191

[ThunderCat]

Alex Kizyma, ну так смотрите где у вас там 191 строка, далее отладка и вперед...

[Alex Kizyma]

ThunderCat,
ошибка в секции catch

} catch (PDOException $pdoE) {

setLog($pdoE->getMessage());
setLog($settings, 'Our_data_from_curl.txt');
throw new Exception('An Error occurred: ' . $pdoE->getMessage()); // тут err
}

[ThunderCat]

Alex Kizyma, скорее всего запрос слишком большой и не хватает размера max_allowed_packet. Можно попробовать перед запросом на инсерт увеличить размер через запрос

set global max_allowed_packet=тут_сколько_не_жалко;

, хотя лучше делать это через консоль мускуля, а не через пых.