Db.php 411 B

12345678910111213141516171819202122232425262728293031
  1. <?php
  2. namespace Queue\Src;
  3. use Dever;
  4. class Db
  5. {
  6. private $db;
  7. public function __construct()
  8. {
  9. $this->db = Dever::db('queue/data');
  10. }
  11. public function push($value)
  12. {
  13. $data = array('add_value' => $value);
  14. return $this->db->insert($data);
  15. }
  16. public function pop()
  17. {
  18. $data = $this->db->one();
  19. if ($data) {
  20. $this->db->delete($data['id']);
  21. return $data['value'];
  22. }
  23. return false;
  24. }
  25. }