Backup таблиц MySql в файлы sql и обратно на PHP.

class MysqlExportUtf8mb4
{
    protected $db;
    protected $chunkSize = 10485760; // размер чанка - 10 МБ
    protected $tmpDir = 'tmp_baza/';

    public function __construct($hostname, $username, $password, $database)
    {
        $this->db = new mysqli($hostname, $username, $password, $database);
        if ($this->db->connect_error) {
            die('Connect Error (' . $this->db->connect_errno . ') ' . $this->db->connect_error);
        }
        $this->db->set_charset('utf8mb4');
    }

    /**
     * Функция для создания файлов с данными
     *
     * @param string $tableName Название таблицы
     *
     * @return array Отсортированный массив имён созданных файлов
     */
    public function createFiles($tableName)
    {
        $sql = "SELECT * FROM `$tableName` ORDER BY `id`";
        $result = $this->db->query($sql);

        $totalCount = $result->num_rows;
        $filesCount = ceil($totalCount / $this->chunkSize);
        $fileNames = [];

        for ($i = 0; $i < $filesCount; $i++) {
            $fileName = $this->tmpDir . $tableName . '_' . ($i + 1) . '.sql';

            $file = fopen($fileName, 'w');

            if (!$file) {
                throw new Exception("Не удалось создать файл $fileName");
            }

            for ($j = 0; $j < $this->chunkSize && $row = $result->fetch_assoc(); $j++) {
                $insert = "INSERT INTO `$tableName` VALUES (";
                foreach ($row as $value) {
                    if (is_null($value)) {
                        $insert .= "NULL, ";
                    } else {
                        $insert .= "'" . $this->db->real_escape_string($value) . "', ";
                    }
                }
                $insert = rtrim($insert, ', ') . ");\n";
                fwrite($file, $insert);
            }

            fclose($file);

            $fileNames[] = $fileName;
        }

        return $fileNames;
    }

    /**
     * Функция для записи данных в таблицу
     *
     * @param string $tableName Название таблицы
     * @param array $fileNames Массив с именами файлов
     */
    public function loadData($tableName, $fileNames)
    {
        $sql = "LOAD DATA LOCAL INFILE '%s' INTO TABLE `%s` CHARACTER SET utf8mb4 FIELDS TERMINATED BY ',' ENCLOSED BY '\"' ESCAPED BY '\\\\' LINES TERMINATED BY '\\n'";

        foreach ($fileNames as $fileName) {
            $fullFileName = realpath($fileName);
            $this->db->query(sprintf($sql, $fullFileName, $tableName));
        }
    }
}

$exporter = new MysqlExportUtf8mb4('localhost', 'username', 'password', 'database');

$fileNames = $exporter->createFiles('my_table');

print_r($fileNames);

$exporter->loadData('my_table_new', $fileNames);

<?php

/**
 * Создает дамп таблицы MySQL в формате SQL.
 *
 * @param string $host     Имя хоста базы данных.
 * @param string $username Имя пользователя базы данных.
 * @param string $password Пароль пользователя базы данных.
 * @param string $database Имя базы данных.
 * @param string $table    Имя таблицы для дампа.
 * @param string $filepath Путь к файлу, куда будет сохранен дамп.
 *
 * @return bool Возвращает true в случае успеха, false в случае ошибки.
 */
function create_sql_dump($host, $username, $password, $database, $table, $filepath) {
    // Устанавливаем соединение с базой данных
    $conn = mysqli_connect($host, $username, $password, $database);

    // Проверяем соединение
    if (!$conn) {
        error_log("Ошибка соединения с базой данных: " . mysqli_connect_error());
        return false;
    }

    // Получаем структуру таблицы
    $sql_structure = "SHOW CREATE TABLE `$table`";
    $result_structure = mysqli_query($conn, $sql_structure);

    if (!$result_structure) {
        error_log("Ошибка при получении структуры таблицы: " . mysqli_error($conn));
        mysqli_close($conn);
        return false;
    }

    $row_structure = mysqli_fetch_assoc($result_structure);
    $create_table_statement = $row_structure['Create Table'] . ";\n\n";

    // Получаем данные таблицы
    $sql_data = "SELECT * FROM `$table`";
    $result_data = mysqli_query($conn, $sql_data);

    if (!$result_data) {
        error_log("Ошибка при получении данных таблицы: " . mysqli_error($conn));
        mysqli_close($conn);
        return false;
    }

    // Формируем INSERT запросы
    $insert_statements = "";
    while ($row_data = mysqli_fetch_assoc($result_data)) {
        $columns = array_keys($row_data);
        $values = array_map(function ($value) use ($conn) {
            return "'" . mysqli_real_escape_string($conn, $value) . "'";
        }, array_values($row_data));

        $insert_statements .= "INSERT INTO `$table` (" . implode(", ", $columns) . ") VALUES (" . implode(", ", $values) . ");\n";
    }

    // Собираем весь дамп
    $dump_content = "-- Дамп таблицы `$table`\n\n" .
                    $create_table_statement .
                    $insert_statements;

    // Записываем дамп в файл
    if (file_put_contents($filepath, $dump_content) === false) {
        error_log("Ошибка при записи в файл: $filepath");
        mysqli_close($conn);
        return false;
    }

    // Закрываем соединение
    mysqli_close($conn);
    return true;
}

// Пример использования
$host = "localhost"; // Замените на имя хоста вашей базы данных
$username = "username"; // Замените на имя пользователя вашей базы данных
$password = "password"; // Замените на пароль пользователя вашей базы данных
$database = "your_database"; // Замените на имя вашей базы данных
$table = "genres";
$filepath = "genres_dump.sql";

if (create_sql_dump($host, $username, $password, $database, $table, $filepath)) {
    echo "Дамп таблицы '$table' успешно создан в файле '$filepath'.\n";
} else {
    echo "Произошла ошибка при создании дампа.\n";
}

?>

<?php

class CreateTablesInData {

    private $pdo;
    private $dumpDirectory = '../dampdb/'; // Путь к папке для сохранения дампа

    public function __construct($pdo) {
        $this->pdo = $pdo;
    }

    /**
     * Создает дамп таблицы MySQL в формате SQL.
     *
     * @param string $tableName  Имя таблицы для дампа.
     * @param string $dumpFileName Имя файла для сохранения дампа (например, 'genres_dump.sql').
     *
     * @return bool Возвращает true в случае успеха, false в случае ошибки.
     */
    public function createTableDump($tableName, $dumpFileName) {
        $filePath = $this->dumpDirectory . $dumpFileName;

        try {
            // Получаем структуру таблицы
            $stmtStructure = $this->pdo->query("SHOW CREATE TABLE `$tableName`");
            $rowStructure = $stmtStructure->fetch(PDO::FETCH_ASSOC);

            if (!$rowStructure) {
                error_log("Ошибка при получении структуры таблицы '$tableName'.");
                return false;
            }

            $createTableStatement = $rowStructure['Create Table'] . ";\n\n";

            // Получаем данные таблицы
            $stmtData = $this->pdo->query("SELECT * FROM `$tableName`");
            $insertStatements = "";

            if ($stmtData) {
                while ($rowData = $stmtData->fetch(PDO::FETCH_ASSOC)) {
                    $columns = array_keys($rowData);
                    $values = array_map(function ($value) {
                        return "'" . str_replace("'", "''", $value) . "'"; // Экранируем кавычки
                    }, array_values($rowData));

                    $insertStatements .= "INSERT INTO `$tableName` (" . implode(", ", $columns) . ") VALUES (" . implode(", ", $values) . ");\n";
                }
            } else {
                error_log("Ошибка при получении данных таблицы '$tableName'.");
                return false;
            }

            // Собираем весь дамп
            $dumpContent = "-- Дамп таблицы `$tableName`\n\n" .
                           $createTableStatement .
                           $insertStatements;

            // Записываем дамп в файл
            if (file_put_contents($filePath, $dumpContent) === false) {
                error_log("Ошибка при записи в файл: " . $filePath);
                return false;
            }

            return true;

        } catch (PDOException $e) {
            error_log("Ошибка при создании дампа: " . $e->getMessage());
            return false;
        }
    }
}

// Пример использования (предполагается, что у вас уже есть подключение к PDO)
// $pdo = new PDO(...); // Замените на ваши параметры подключения
// $createTables = new CreateTablesInData($pdo);
// $tableName = 'genres'; // Имя таблицы для дампа
// $dumpFileName = 'genres_dump.sql'; // Имя файла дампа
//
// if ($createTables->createTableDump($tableName, $dumpFileName)) {
//     echo "Дамп таблицы '$tableName' успешно создан в файле '$dumpFileName'.\n";
// } else {
//     echo "Произошла ошибка при создании дампа.\n";
// }

?>

<?php

class CreateTablesInData {

    private $pdo;
    private $dumpDirectory = '../dampdb/'; // Путь к папке с дампом

    public function __construct($pdo) {
        $this->pdo = $pdo;
    }

    /**
     * Создает таблицы из SQL-дампа.
     *
     * @param string $dumpFileName Имя файла SQL-дампа (например, 'genres.sql').
     *
     * @return bool Возвращает true в случае успеха, false в случае ошибки.
     */
    public function createTablesFromDump($dumpFileName) {
        $filePath = $this->dumpDirectory . $dumpFileName;

        if (!file_exists($filePath)) {
            error_log("Файл дампа не найден: " . $filePath);
            return false;
        }

        $sqlStatements = file_get_contents($filePath);

        if ($sqlStatements === false) {
            error_log("Ошибка при чтении файла дампа: " . $filePath);
            return false;
        }

        // Разделяем SQL-скрипт на отдельные запросы
        $statements = explode(';', $sqlStatements);

        try {
            $this->pdo->beginTransaction(); // Начинаем транзакцию

            foreach ($statements as $statement) {
                $statement = trim($statement);
                if (!empty($statement)) {
                    // Выполняем каждый запрос
                    $this->pdo->exec($statement . ';'); // Добавляем точку с запятой, если ее нет
                }
            }

            $this->pdo->commit(); // Фиксируем транзакцию
            return true;

        } catch (PDOException $e) {
            $this->pdo->rollBack(); // Откатываем транзакцию в случае ошибки
            error_log("Ошибка при выполнении SQL запроса: " . $e->getMessage());
            return false;
        }
    }
}

// Пример использования (предполагается, что у вас уже есть подключение к PDO)
// $pdo = new PDO(...); // Замените на ваши параметры подключения
// $createTables = new CreateTablesInData($pdo);
// $dumpFileName = 'genres_dump.sql'; // Имя файла дампа
//
// if ($createTables->createTablesFromDump($dumpFileName)) {
//     echo "Таблицы успешно созданы из дампа '$dumpFileName'.\n";
// } else {
//     echo "Произошла ошибка при создании таблиц из дампа.\n";
// }

?>

<?php

class CreateTablesInData {

    private $pdo;
    private $dumpDirectory = '../dampdb/'; // Путь к папке с дампом

    public function __construct($pdo) {
        $this->pdo = $pdo;
    }

    /**
     * Восстанавливает таблицу из SQL-дампа.
     *
     * @param string $dumpFileName Имя файла SQL-дампа (например, 'genres.sql').
     * @param string $tableName    Имя таблицы, которую нужно восстановить.
     *
     * @return bool Возвращает true в случае успеха, false в случае ошибки.
     */
    public function restoreTableFromDump($dumpFileName, $tableName) {
        $filePath = $this->dumpDirectory . $dumpFileName;

        if (!file_exists($filePath)) {
            error_log("Файл дампа не найден: " . $filePath);
            return false;
        }

        $sqlStatements = file_get_contents($filePath);

        if ($sqlStatements === false) {
            error_log("Ошибка при чтении файла дампа: " . $filePath);
            return false;
        }

        // Разделяем SQL-скрипт на отдельные запросы
        $statements = explode(';', $sqlStatements);

        try {
            $this->pdo->beginTransaction(); // Начинаем транзакцию

            // Удаляем таблицу, если она существует
            $this->pdo->exec("DROP TABLE IF EXISTS `$tableName`");

            foreach ($statements as $statement) {
                $statement = trim($statement);
                if (!empty($statement)) {
                    // Выполняем каждый запрос
                    $this->pdo->exec($statement . ';'); // Добавляем точку с запятой, если ее нет
                }
            }

            $this->pdo->commit(); // Фиксируем транзакцию
            return true;

        } catch (PDOException $e) {
            $this->pdo->rollBack(); // Откатываем транзакцию в случае ошибки
            error_log("Ошибка при выполнении SQL запроса: " . $e->getMessage());
            return false;
        }
    }
}

// Пример использования (предполагается, что у вас уже есть подключение к PDO)
// $pdo = new PDO(...); // Замените на ваши параметры подключения
// $createTables = new CreateTablesInData($pdo);
// $dumpFileName = 'genres_dump.sql'; // Имя файла дампа
// $tableName = 'genres'; // Имя таблицы для восстановления
//
// if ($createTables->restoreTableFromDump($dumpFileName, $tableName)) {
//     echo "Таблица '$tableName' успешно восстановлена из дампа '$dumpFileName'.\n";
// } else {
//     echo "Произошла ошибка при восстановлении таблицы '$tableName' из дампа.\n";
// }

?>