Comment utiliser ThinkPHP6 pour implémenter la sauvegarde et la récupération de bases de données

Dans le processus de développement de systèmes d'entreprise, la base de données est un élément très important. Par conséquent, la sauvegarde et la restauration de la base de données sont une opération très nécessaire. Cet article combinera des exemples du framework ThinkPHP6 pour présenter comment utiliser ThinkPHP6 pour implémenter la sauvegarde et la récupération de bases de données.

1. Sauvegarde de la base de données

1.1 Préparation de l'environnement

Avant d'effectuer la sauvegarde de la base de données, vous devez confirmer les points suivants :

1 Vous devez définir l'adresse du répertoire bin de la base de données mysql et ajouter son chemin au chemin système. variable ;

2. L'outil de ligne de commande mysqldump doit être installé

3. Confirmez que sur la machine où se trouve la base de données, l'utilisateur qui effectue la sauvegarde a le droit d'exécuter la commande mysqldump sur la base de données.

1.2 Implémentation de la sauvegarde de la base de données

1.2.1 Configurer les paramètres de sauvegarde

Créez le fichier database.php dans le dossier de configuration, définissez les informations de connexion à la base de données et les paramètres requis pour la sauvegarde.

<?php
return [
    // 数据库类型
    'type'        => 'mysql',
    // 数据库连接DSN配置
    'dsn'         => '',
    // 服务器地址
    'hostname'    => 'localhost',
    // 数据库名
    'database'    => 'test',
    // 数据库用户名
    'username'    => 'root',
    // 数据库密码
    'password'    => 'root',
    // 数据库连接端口
    'hostport'    => '3306',
    // 数据库连接参数
    'params'      => [],
    // 数据库编码默认采用utf8
    'charset'     => 'utf8',
    // 数据库表前缀
    'prefix'      => 'think_',
    // 数据库调试模式
    'debug'       => false,
    // 数据库备份路径，没有则自动创建
    'path'        => '',
    // 数据库备份卷大小，单位为字节，设为0表示不限制备份大小
    'part'        => 20971520,
    // 数据库备份文件压缩格式，这里是gzip
    'compress'    => 'gzip',
    // 数据库备份文件名
    'filename'    => '',
    // 数据库备份文件是否需要压缩
    'zip'         => true,
    // 数据库备份文件是否需要分卷备份
    'split'       => true,
    // 数据库备份时是否将存储过程和触发器一起备份
    'level'       => 9,
    // 数据库备份文件的存储路径，最好为绝对路径，这也是最关键的路径
    'path'        => '/data/mysql/',
];

1.2.2 Écrire le code de sauvegarde

Créez le fichier BackupController.php sous app/controller et ajoutez le code suivant.

<?php
declare(strict_types=1);

namespace appcontroller;

use thinkacadeDb;

class BackupController
{
    protected $backupConfig;

    public function __construct()
    {
        $this->backupConfig = config('database');
    }

    public function backup()
    {
        // 防止备份数据过程超时
        set_time_limit(0);

        $database = $this->backupConfig['database'];
        $filename = date('Ymd-His', time()) . ".sql";
        $path = $this->backupConfig['path'].$filename;

        // 检查目录是否存在或者是否有权限写入
        if(!is_dir($this->backupConfig['path'])){
            mkdir($this->backupConfig['path'], 0755, true);
        }else{
            if(!is_writeable($this->backupConfig['path'])){
                chmod($this->backupConfig['path'], 0755);
            }
        }

        // 备份所有数据表
        $result = Db::query("SHOW TABLES");

        $tables = array();
        foreach($result as $index => $row){
            $tables[] = $row['Tables_in_'.$database];
        }

        // 备份所有表结构和表数据
        $content = '';
        foreach($tables as $table){
            $content = $content . "/*" . PHP_EOL;
            $content = $content . "表名：" . $table . PHP_EOL;
            $content = $content . "表结构：" . PHP_EOL;
            $content = $content . "*/" . PHP_EOL;
            $content = $content . $this->backupTableSchema($table);
            $content = $content . "/*" . PHP_EOL;
            $content = $content . "表数据：" . PHP_EOL;
            $content = $content . "*/" . PHP_EOL;
            $content = $content . $this->buildInsertSql($table);
        }

        // 是否需要压缩
        if ($this->backupConfig['zip']) {
            $zip = new ZipArchive();
            $zipfilename = $this->backupConfig['path'] . date('Ymd-His', time()) . ".zip";
            if ($zip->open($zipfilename, ZipArchive::OVERWRITE) === TRUE) {
                $zip->addFile($path,$filename);
                $zip->close();
                // 删除非压缩的文件
                unlink($path);
            } else {
                // 备份失败
            }
        }
    }

    // 备份表结构
    protected function backupTableSchema($table)
    {
        $database = $this->backupConfig['database'];
        $result = Db::query("SHOW CREATE TABLE `" . $table . "`");
        $create = $result[0]['Create Table'] . ";" . PHP_EOL.PHP_EOL;
        return $create;
    }

    // 备份表数据
    protected function buildInsertSql($table)
    {
        $database = $this->backupConfig['database'];
        $result = Db::query("SELECT * FROM `" . $table . "`");
        $insert = '';
        foreach ($result as $key => $value) {
            $keys = array_keys($value);
            $values = array_map(array(Db::class, 'quote'), array_values($value));
            $values = join(",", $values);
            $insert .= "INSERT INTO `" . $table . "` (`" . join("`,`", $keys) . "`) VALUES (" . $values . ");" . PHP_EOL;
        }
        $insert .= PHP_EOL;
        return $insert;
    }
}

1.2.3 Effectuer une sauvegarde

Entrez l'adresse URL suivante dans le navigateur pour effectuer la sauvegarde :

http://localhost/backup/backup

1.3 Récupération de la base de données

1.3.1 Écrire le code de récupération

Créez le fichier RecoveryController.php sous app/controller, et ajoutez le code suivant.

<?php
declare(strict_types=1);

namespace appcontroller;

use thinkacadeDb;

class RecoveryController
{
    protected $backupConfig;

    public function __construct()
    {
        $this->backupConfig = config('database');
    }

    public function recovery()
    {
        // 防止还原数据过程超时
        set_time_limit(0);
        ini_set('memory_limit', '1024M');

        $filename = input('get.filename');

        // 读取备份文件
        if ($this->backupConfig['zip']) {
            $zip = new ZipArchive();
            if ($zip->open($this->backupConfig['path'].$filename) === true) {
                $filename = $zip->getNameIndex(0);
                $zip->extractTo($this->backupConfig['path']);
                $zip->close();
            }
        }

        $content = file_get_contents($this->backupConfig['path'] . $filename);

        // 使用";"分割内容
        $statements = explode(";", $content);

        // 开始事务
        Db::startTrans();

        foreach ($statements as $index => $stmt) {
            if (trim($stmt) === '') {
                continue;
            }
            $results = Db::query($stmt);
            if ($results === false) {
                Db::rollback();
                return false;
            }
        }

        // 提交事务
        Db::commit();

        // 删除非压缩的文件
        unlink($this->backupConfig['path'] . $filename);

        return true;
    }
}

1.3.2 Effectuer une récupération

Entrez l'adresse URL suivante dans le navigateur pour effectuer la récupération :

http://localhost/recovery/recovery?filename=20200101-121212.sql.zip

Ce qui précède est la méthode d'implémentation de sauvegarde et de récupération de base de données dans ThinkPHP6. Les lecteurs peuvent appliquer le code à leurs propres projets, qui. est flexible Utilisez ces conseils pour rendre votre entreprise plus robuste et plus fiable.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!