DbRepository: Validate the table when inserting, updating and deleting

This commit is contained in:
Johannes Meyer 2015-10-16 12:36:47 +02:00
parent 33037eebbb
commit 7ef76932d4
2 changed files with 7 additions and 0 deletions

View File

@ -130,6 +130,7 @@ class DbUserBackend extends DbRepository implements UserBackendInterface, Inspec
*/
public function insert($table, array $bind)
{
$this->requireTable($table);
$bind['created_at'] = date('Y-m-d H:i:s');
$this->ds->insert(
$this->prependTablePrefix($table),
@ -150,6 +151,7 @@ class DbUserBackend extends DbRepository implements UserBackendInterface, Inspec
*/
public function update($table, array $bind, Filter $filter = null)
{
$this->requireTable($table);
$bind['last_modified'] = date('Y-m-d H:i:s');
if ($filter) {
$filter = $this->requireFilter($table, $filter);

View File

@ -297,6 +297,7 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
*/
public function insert($table, array $bind)
{
$this->requireTable($table);
$this->ds->insert($this->prependTablePrefix($table), $this->requireStatementColumns($table, $bind));
}
@ -309,6 +310,8 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
*/
public function update($table, array $bind, Filter $filter = null)
{
$this->requireTable($table);
if ($filter) {
$filter = $this->requireFilter($table, $filter);
}
@ -324,6 +327,8 @@ abstract class DbRepository extends Repository implements Extensible, Updatable,
*/
public function delete($table, Filter $filter = null)
{
$this->requireTable($table);
if ($filter) {
$filter = $this->requireFilter($table, $filter);
}