20250419#1
This commit is contained in:
@@ -13,26 +13,23 @@ class MysqlStorage implements MysqlStorageInterface {
|
|||||||
private Mysqli $mysqli;
|
private Mysqli $mysqli;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Внутренний конструктор подключения к БД
|
* @param array $paramsArray
|
||||||
* Mysql constructor.
|
|
||||||
* @param object $params
|
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
public function __construct(
|
public function __construct(array $paramsArray) {
|
||||||
private readonly object $params
|
$params = (object) $paramsArray;
|
||||||
) {
|
|
||||||
$this->mysqli = new mysqli(
|
$this->mysqli = new mysqli(
|
||||||
$this->params->host,
|
$params->host,
|
||||||
$this->params->user,
|
$params->user,
|
||||||
$this->params->pass,
|
$params->pass,
|
||||||
$this->params->base
|
$params->base
|
||||||
);
|
);
|
||||||
// выводим ошибку при неудачном подключении
|
// выводим ошибку при неудачном подключении
|
||||||
if ($this->mysqli->connect_errno) {
|
if ($this->mysqli->connect_errno) {
|
||||||
throw new Exception($this->mysqli->connect_errno);
|
throw new Exception($this->mysqli->connect_errno);
|
||||||
}
|
}
|
||||||
$this->mysqli->set_charset("utf8");
|
$this->mysqli->set_charset($params->chartset ?? "utf8");
|
||||||
if(!empty($this->params->logsEnable)) $this->logsEnabled = true;
|
if(!empty($params->logs)) $this->logsEnabled = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @inheritDoc */
|
/** @inheritDoc */
|
||||||
|
|||||||
Reference in New Issue
Block a user