无法初始化\ AsyncMysqlQueryResult对象

Question

我想简单地初始化\AsyncMysqlConnectionResult $connec;对象

<?hh 

namespace Connection; 

require_once("ini.php"); 

/** 
* Class for execute and fetch query 
*/ 
class MyQuery 
{ 
/** 
* if connection isn't valid recreate pool 
*/ 
private ?\AsyncMysqlConnectionPool $pool; 

/** 
* \AsyncMysqlConnection object, store $conn 
*/ 
private \AsyncMysqlConnection $connec; 

/** 
* \AsyncMysqlQueryReturn object, store return query 
*/ 
private \AsyncMysqlQueryResult $result; 

/** 
* check if $conn object isValid(), if not release 
* connection 
*/ 
public function __construct(\AsyncMysqlConnection $conn) 
{ 
    if ($conn->isValid() == false) 
    { 
     $this->pool = new MyPool(); 
     $this->connec = $this->pool->connect(); 
    } 
    else 
     $this->connec = $conn; 

    $this->result = object; 
} 

/** 
* escape query and execute it 
*/ 
public async function query(string $query): Awaitable<\AsyncMysqlQueryResult> 
{ 
    $query = $this->connec->escapeString($query); 
    echo "Query escape\n"; 

    /* Try to execute the query, if fail display error */ 
    try 
    { 
     $this->result = await $this->connec->query($query); 
     //log request with ini 
    } 
    catch (Exception $e) 
    { 
     echo "Couldn't execute the request, error with message :<br>"; 
     var_dump($e->getMessage()); 
     //log request with fail 
    } 

    echo "Query done succefully\n"; 
    return $this->result; 
} 

/** 
* escape Map array and execute the request 
*/ 
public async function queryf(HH\FormatString<HH\SQLFormatter> $query, array<string> $params): Awaitable<\AsyncMysqlQueryResult> 
{ 
    $i = 0; 

    while ($params[$i++]) 
     $params[$i] = $this->connec->escapeString($params[$i]); 

    /* Try to execute the query, if fail display error */ 
    try 
    { 
     $result = await $this->connec->queryf($query, implode(', ', $params)); 
     //log request with ini 
    } 
    catch (Exception $e) 
    { 
     echo "Couldn't execute the request, error with message :<br>"; 
     var_dump($e->getMessage()); 
     //log request with fail 
    } 

    echo "Query done succefully\n"; 
    return $this->result; 
} 
} 

newtype AsyncMysqlConnectionResult = object; 
newtype FormatString<T> = string; 

async function simple_query(\AsyncMysqlConnection $conn): Awaitable<Vector> 
{ 
    $connec = new MyQuery($conn); 
    $ret = await $connec->query('SELECT * FROM users'); 
    return $ret->vectorRows(); 
} 

function run_query(\AsyncMysqlConnection $conn): void 
{ 
    $r = \HH\Asio\join(simple_query($conn)); 
    var_dump($r); 
} 

run_query（$康恩）;

对于此对象，我使用https://docs.hhvm.com/hack/reference/class/AsyncMysqlConnectionPool/connect/类和connect（）方法来获得此：\ AsyncMysqlConnectionResult $ connec对象。

我无法找到一个方法来初始化这个变量的类型，我已经尝试 创建NEWTYPE AsyncMysqlConnectionResult =对象，但filechecker回我： Unbound name: Connection\object (an object type)

Answer 1

这是找到重写queryf（）方法的唯一方法。

public async function queryf($query, array<int, string> $params): Awaitable<\AsyncMysqlQueryResult> 
{ 
    $result = ""; 

    /* Try to execute the query, if fail display error */ 
    try // execute query 
    { 
     $result = await $this->connec->queryf($query, implode(', ', $params)); 

     // If log_request === TRUE log request with ini 
     if ($this->log_request === TRUE) 
      await $this->logRequest($query, 0); 
    } 
    catch (Exception $e) // If the query can't be execute display error 
    { 
     echo "\nCouldn't execute the request, error with message :<br>\n"; 
     var_dump($e->getMessage()); 
     //log request with fail 

     await $this->logRequest((string)$query, -1); 
    } 
    return (object)$result; 
} 

我没有错误，一切工作正常。 如果有人有更好的解决方案，我在这里。

Answer 2

而不是存储在类，为什么结果你的查询方法不是简单地返回结果。例如：

public async function query(string $query): Awaitable<\AsyncMysqlQueryResult> 
{ 
    $query = $this->connec->escapeString($query); 
    return await $this->connec->query($query); 
} 

或者如果您确实希望将结果存储在类中，请将其设置为空。这将允许您不在构造函数中设置它，并且只在查询完成后才设置它。

private ?\AsyncMysqlQueryResult $result;