Skip to content

Commit

Permalink
quote name
Browse files Browse the repository at this point in the history
  • Loading branch information
asika32764 committed Sep 4, 2017
1 parent 8c2bd08 commit 43367b2
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion src/Core/Migration/Repository/MigrationsRepository.php
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ public function getVersions()

$query = $this->db->getQuery(true)
->select('version')
->from($this->logTable)
->from($this->db->quoteName($this->logTable))
->order('version ASC');

return $this->db->setQuery($query)->loadColumn();
Expand Down
4 changes: 2 additions & 2 deletions src/Core/Queue/Driver/DatabaseQueueDriver.php
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ public function pop($queue = null)
$query = $this->db->getQuery(true);

$query->select('*')
->from($this->table)
->from($query->quoteName($this->table))
->where('queue = :queue')
->where('visibility <= :now')
->orWhere(function (Query $query)
Expand Down Expand Up @@ -154,7 +154,7 @@ public function delete(QueueMessage $message)

$query = $this->db->getQuery(true);

$query->delete($this->table)
$query->delete($query->quoteName($this->table))
->where('id = :id')
->where('queue = :queue')
->bind('id', $message->getId())
Expand Down
6 changes: 3 additions & 3 deletions src/Core/Queue/Failer/DatabaseQueueFailer.php
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ public function all()
$query = $this->db->getQuery(true);

$query->select('*')
->from($this->table);
->from($query->quoteName($this->table));

return $this->db->setQuery($query)->loadAll(null, 'assoc');
}
Expand All @@ -104,7 +104,7 @@ public function get($conditions)
$query = $this->db->getQuery(true);

$query->select('*')
->from($this->table)
->from($query->quoteName($this->table))
->where('id = :id')
->bind('id', $conditions);

Expand All @@ -122,7 +122,7 @@ public function remove($conditions)
{
$query = $this->db->getQuery(true);

$query->delete($this->table)
$query->delete($query->quoteName($this->table))
->where('id = :id')
->bind('id', $conditions);

Expand Down

0 comments on commit 43367b2

Please sign in to comment.