as2252258/kiri-databases
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

变更

Browse Source
This commit is contained in:
as2252258@163.com
2023-04-01 00:37:52 +08:00
parent afec8be942
commit 98fff7302e
1 changed files with 20 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Command.php
+20 -49
View File
@@ -38,26 +38,23 @@ class Command extends Component
/** @var array */ /** @var array */
public array $params = []; public array $params = [];
/** @var string */
public string $dbname = '';
/** /**
* @return mixed * @return int|bool
* @throws Exception * @throws Exception
*/ */
public function incrOrDecr(): mixed public function incrOrDecr(): int|bool
{ {
return $this->execute(static::EXECUTE); return $this->_execute();
} }
/** /**
* @return mixed * @return int|bool
* @throws Exception * @throws Exception
*/ */
public function save(): mixed public function save(): int|bool
{ {
return $this->execute(static::EXECUTE); return $this->_execute();
} }
@@ -67,7 +64,7 @@ class Command extends Component
*/ */
public function all(): mixed public function all(): mixed
{ {
return $this->execute(static::FETCH_ALL); return $this->search(static::FETCH_ALL);
} }
/** /**
@@ -76,7 +73,7 @@ class Command extends Component
*/ */
public function one(): mixed public function one(): mixed
{ {
return $this->execute(static::FETCH); return $this->search(static::FETCH);
} }
/** /**
@@ -85,7 +82,7 @@ class Command extends Component
*/ */
public function fetchColumn(): mixed public function fetchColumn(): mixed
{ {
return $this->execute(static::FETCH_COLUMN); return $this->search(static::FETCH_COLUMN);
} }
/** /**
@@ -94,36 +91,18 @@ class Command extends Component
*/ */
public function rowCount(): mixed public function rowCount(): mixed
{ {
return $this->execute(static::ROW_COUNT); return $this->search(static::ROW_COUNT);
} }
/** /**
* @return mixed * @return int|bool
* @throws Exception * @throws Exception
*/ */
public function flush(): mixed public function flush(): int|bool
{ {
return $this->execute(static::EXECUTE); return $this->_execute();
} }
/**
* @param string $type
* @return mixed
* @throws Exception
*/
private function execute(string $type): mixed
{
$time = microtime(true);
$result = $type !== static::EXECUTE ? $this->search($type) : $this->_execute();
$this->longExecuteTime($time);
return $result;
}
/** /**
* @return bool|int * @return bool|int
* @throws Exception * @throws Exception
@@ -190,30 +169,22 @@ class Command extends Component
} }
private function longExecuteTime($time)
{
if (($over = microtime(true) - $time) >= 0.05) {
$this->logger->warning($this->sql . '. use time : ' . $over . 'ms');
}
}
/** /**
* @return mixed * @return int|bool
* @throws Exception * @throws Exception
*/ */
public function delete(): mixed public function delete(): int|bool
{ {
return $this->execute(static::EXECUTE); return $this->_execute();
} }
/** /**
* @return mixed * @return int|bool
* @throws Exception * @throws Exception
*/ */
public function exec(): mixed public function exec(): int|bool
{ {
return $this->execute(static::EXECUTE); return $this->_execute();
} }
/** /**
@@ -222,7 +193,7 @@ class Command extends Component
*/ */
public function bindValues(array $data = []): static public function bindValues(array $data = []): static
{ {
if (!empty($data)) { if (count($data) > 0) {
$this->params = array_merge($this->params, $data); $this->params = array_merge($this->params, $data);
} }
return $this; return $this;