<?php

namespace Lib;

/**
 * db
 * @author：dc
 * @time 2023/2/13 15:03
 * Class Db
 * @package Lib
 */
class Db {

    use DbQuery;

    /**
     * @var \Lib\Db
     */
    static $instance;


    /**
     * @return mixed
     * @author：dc
     * @time 2023/2/13 9:12
     */
    public function getClient(){
        if(!$this->client){
            $this->connect();
        }

        try {
            // 判断是否链接中
            $status = $this->client->getAttribute(\PDO::ATTR_CONNECTION_STATUS);
            if($status === null || $status === false){
                $this->connect();
            }
        }catch (\Throwable $e){
            $this->connect();
        }

        return $this->client;
    }

    private $host='';
    private $prot='';
    private $user='';
    private $pwd='';
    private $database='';


    public function __construct($host='',$database='',$user='',$pwd='',$prot='')
    {

        $this->host = $host ? $host : DB_HOST;
        $this->prot = $prot ? $prot : DB_PORT;
        $this->user = $user ? $user : DB_USER;
        $this->pwd = $pwd ? $pwd : DB_PASSWORD;
        $this->database = $database ? $database : DB_DATABASE;

//        $this->connect();

    }

    /**
     * 连接sql
     * @author：dc
     * @time 2023/3/23 9:14
     */
    public function connect(){

        $tryNum = 0;

        DBPOOLCONNECTFOR:
        try {
            $this->client = new \PDO(
                'mysql:charset=utf8mb4;dbname='.$this->database.';host='.$this->host.';port='.$this->prot,
                $this->user,
                $this->pwd,
                [
                    \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC,
                    \PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8mb4'",
                    \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
                ]
            );
        }catch (\Throwable $e){
            // 重新链接3次
            if($tryNum < 3){
                $tryNum++;
                goto DBPOOLCONNECTFOR;
            }

            logs($e->getMessage().$e->getTraceAsString());
        }



    }




    /**
     * @return Db
     * @author：dc
     * @time 2023/2/13 9:39
     */
    public static function instance(){
        if(empty(static::$instance)){
            static::$instance = new Db();
        }

//        if(!static::$instance->ping()){
//            static::$instance->close();
//
//            static::$instance = new Db();
//        }

        return static::$instance;
    }


    /**
     * 结束
     */
    public function __destruct(){
        $this->close();
    }


    public function close(){
        $this->client = null;
    }



}