core/Mysql.php
public function exec(string $sql)
    {
        try {
            $sql = str_replace('@pf_', $this->prefix, $sql);
            $ret = $this->pdo->exec($sql);
            return $ret;
        } catch (\Exception $exception) {
            throw new MysqlException($exception->getMessage(), $sql, $exception->getCode(), $exception);
        }
    }
public function exec(string $sql)
    {
        try {
            $sql = str_replace('@pf_', $this->prefix, $sql);
            $ret = $this->pdo->exec($sql);
            return $ret;
        } catch (\Exception $exception) {
            throw new MysqlException($exception->getMessage(), $sql, $exception->getCode(), $exception);
        }
    }
执行sql
@param string $sql
@return int
@throws MysqlException