tyler.durden
/
icingaweb2
mirror of https://github.com/Icinga/icingaweb2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DbRepository: Return the number of affected rows for cud operations

This commit is contained in:
Johannes Meyer 2015-10-30 15:34:57 +01:00
parent df7a2ee0a9
commit a60ad3ecf0
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
library/Icinga/Repository/DbRepository.php
View File

@ -294,11 +294,16 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
* *
* @param string $table * @param string $table
* @param array $bind * @param array $bind
*
* @return int The number of affected rows
*/ */
public function insert($table, array $bind) public function insert($table, array $bind)
{ {
$this->requireTable($table); $this->requireTable($table);
$this->ds->insert($this->prependTablePrefix($table), $this->requireStatementColumns($table, $bind)); return $this->ds->insert(
$this->prependTablePrefix($table),
$this->requireStatementColumns($table, $bind)
);
} }
/** /**
@ -307,6 +312,8 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
* @param string $table * @param string $table
* @param array $bind * @param array $bind
* @param Filter $filter * @param Filter $filter
*
* @return int The number of affected rows
*/ */
public function update($table, array $bind, Filter $filter = null) public function update($table, array $bind, Filter $filter = null)
{ {
@ -316,7 +323,11 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
$filter = $this->requireFilter($table, $filter); $filter = $this->requireFilter($table, $filter);
} }
$this->ds->update($this->prependTablePrefix($table), $this->requireStatementColumns($table, $bind), $filter); return $this->ds->update(
$this->prependTablePrefix($table),
$this->requireStatementColumns($table, $bind),
$filter
);
} }
/** /**
@ -324,6 +335,8 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
* *
* @param string $table * @param string $table
* @param Filter $filter * @param Filter $filter
*
* @return int The number of affected rows
*/ */
public function delete($table, Filter $filter = null) public function delete($table, Filter $filter = null)
{ {
@ -333,7 +346,7 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
$filter = $this->requireFilter($table, $filter); $filter = $this->requireFilter($table, $filter);
} }
$this->ds->delete($this->prependTablePrefix($table), $filter); return $this->ds->delete($this->prependTablePrefix($table), $filter);
} }
/** /**