<?php
namespace app\admin\command;

use think\console\Command;
use think\console\Input;
use think\console\Output;

class Upgrade extends Command
{
    protected function configure()
    {
        $this->setName('upgrade')->setDescription('Version upgrades');
    }

    protected function execute(Input $input, Output $output)
    {
//        'hostname'        => '47.104.6.21',
    //'hostname'        => '47.104.4.5',
//        'database'        => 'pacsonline',
    //'database'        => 'db_remote_diag',
        // 用户名
//        'username'        => 'pacs',
    // 密码
//    'password'        => 'ZSKK@2017~!@#',
        $username = 'pacs';
        $password = 'ZSKK@2017~!@#';
        $link = @mysqli_connect('localhost', 'root', '');
        if(!mysqli_select_db($link, 'db_remote_diag')){
            echo '数据库选择失败';
            exit;
        }
        $sql = "select * from version";
        $info = mysqli_query($link, $sql);

        $link1 = @mysqli_connect('47.104.4.5', $username, $password);
        if(!mysqli_select_db($link1, 'db_remote_diag')){
            echo '数据库选择失败';
            exit;
        }
        $sql = "select * from version";
        $info1 = mysqli_query($link1, $sql);
        if($info1['version'] > $info['version']){
            $num = $info['version'];
            for($num;$num<=$info1['version'];$num++){
                $return =$this->upgrade_version($num);
                mysqli_set_charset($link, 'utf8');
                $res = mysqli_query($link, $return);
                if($res){
                    $output->writeln("成功");
                }else{
                    $output->writeln("失败");
                }
            }
        }else{
            return '数据错误';
        }


        // mysql_query($sql,$con);
        // ALTER TABLE people ADD COLUMN name VARCHAR(100) DEFAULT NULL COMMENT '姓名'   修改表 people  增加字段 name    长度100  默认为null
        // ALTER TABLE `t_check_store` DROP contract_status;
        // alter table student change physics physisc char(10) not null;
        mysqli_close($link);
        $output->writeln("2");
        $output->writeln("3");
    }

    public function upgrade_version($version){
        switch($version){
            case 1:
                 // 建表
                    $sql = "CREATE TABLE Persons
                    (
                    FirstName varchar(15),=
                    LastName varchar(15),
                    Age int
                    )";
                return sql;
                break;
        }
    }
}