|
|
@@ -413,16 +413,26 @@ EOF_STRUCT_MYSQL;
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
- // for sql like `select count() from ...`
|
|
|
- public function fetchValue($sql) {
|
|
|
- DBG::log($sql, 'sql');
|
|
|
- $sth = $this->query($sql);
|
|
|
+ public function fetchValue($sql, $values = []) { // for sql like `select count() from ...`
|
|
|
+ $sth = $this->prepare($sql);
|
|
|
+ if (!empty($values)) {
|
|
|
+ $this->bindValues($sth, $values);
|
|
|
+ DBG::log($this->getRawSql($sth), 'sql');
|
|
|
+ } else {
|
|
|
+ DBG::log($sql, 'sql');
|
|
|
+ }
|
|
|
+ $sth->execute();
|
|
|
return $sth->fetchColumn();
|
|
|
}
|
|
|
|
|
|
- public function fetchFirst($sql) {// fetch only first row
|
|
|
- DBG::log($sql, 'sql');
|
|
|
+ public function fetchFirst($sql, $values = []) { // fetch only first row
|
|
|
$sth = $this->prepare($sql);
|
|
|
+ if (!empty($values)) {
|
|
|
+ $this->bindValues($sth, $values);
|
|
|
+ DBG::log($this->getRawSql($sth), 'sql');
|
|
|
+ } else {
|
|
|
+ DBG::log($sql, 'sql');
|
|
|
+ }
|
|
|
$sth->execute();
|
|
|
return $sth->fetch();
|
|
|
}
|