table.php 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. <?php
  2. /*
  3. $table->beginTransaction($query)
  4. ->set($date)
  5. ->commit();
  6. */
  7. require_once "../redis/function.php";
  8. class Table
  9. {
  10. protected $dbh;
  11. protected $table;
  12. protected $redis;
  13. protected $errorMessage;
  14. protected $field_setting;
  15. function __construct($db,$table,$user="",$password="",$redis=false) {
  16. $this->dbh = new PDO($db, $user, $password,array(PDO::ATTR_PERSISTENT=>true));
  17. $this->dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
  18. $this->redis = $redis;
  19. $this->table = $table;
  20. }
  21. public function setField($setting){
  22. $this->field_setting = $setting;
  23. }
  24. protected function fetch($query,$params){
  25. if (isset($params)) {
  26. $stmt = $this->dbh->prepare($query);
  27. if($stmt){
  28. $stmt->execute($params);
  29. }
  30. } else {
  31. $stmt = $PDO->query($query);
  32. }
  33. if($stmt){
  34. return $stmt->fetch(PDO::FETCH_ASSOC);
  35. }
  36. else{
  37. return false;
  38. }
  39. }
  40. function execute($query, $params=null){
  41. if (isset($params)) {
  42. $stmt = $this->dbh->prepare($query);
  43. if($stmt){
  44. $stmt->execute($params);
  45. return $stmt;
  46. }
  47. else{
  48. return false;
  49. }
  50. } else {
  51. return $this->dbh->query($query);
  52. }
  53. }
  54. public function syncList($time){
  55. }
  56. public function syncGet($time){
  57. }
  58. }
  59. ?>