moeFlix/inc/database.php

<?php

class Database {
  private $handle = null;

  public function __construct($config) {
    $this->handle = new mysqli($config['dbHost'], $config['dbUser'], $config['dbPass'], $config['dbName']);
    $this->handle->set_charset("utf8");

    if($this->handle->connect_error) {
      echo "DB failed.";
      trigger_error('Database connection failed: '  . $this->handle->connect_error, E_USER_ERROR);
      exit(1);
    }
  }

  public function getString($what, $from, $where, $like) {
    $query = "SELECT `" . $what . "` FROM `" . $from . "` WHERE `" . $where . "` LIKE '" . $like . "';";

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->connect_error, E_USER_ERROR);
      exit(1);
    } else if($res->num_rows > 1 || $res->num_rows < 1) {
      echo "This shouldn't happen..1";
      exit(1);
    }

    return $res->fetch_row()[0];
  }

  public function getAllAssoc($from, $where = null, $like = null) {
    if($where && $like) {
      $query = "SELECT * FROM `" . $from . "` WHERE `" . $where . "` LIKE '" . $like . "';";
    } else {
      $query = "SELECT * FROM `" . $from . "`;";
    }


    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->connect_error, E_USER_ERROR);
      exit(1);
    } else if($res->num_rows < 1) {
      error_log($query);
      error_log("This shouldn't happen..2");
      //exit(1);
    }

    return $res->fetch_all(MYSQLI_ASSOC);
  }

  public function getAllAssocCustom($from, $custom, $where = null, $like = null) {
    if($where && $like) {
      $query = "SELECT * FROM `" . $from . "` WHERE `" . $where . "` LIKE '" . $like . "' " . $custom . ";";
    } else {
      $query = "SELECT * FROM `" . $from . "` " . $custom . ";";
    }

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->connect_error, E_USER_ERROR);
      exit(1);
    } else if($res->num_rows < 1) {
      error_log("This shouldn't happen..3");
      //exit(1);
    }

    return $res->fetch_all(MYSQLI_ASSOC);
  }

  public function getAllRow($from, $where, $like) {
    $query = "SELECT * FROM `" . $from . "` WHERE `" . $where . "` LIKE '" . $like . "';";

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->connect_error, E_USER_ERROR);
      exit(1);
    } else if($res->num_rows < 1) {
      error_log("This shouldn't happen..4");
      exit(1);
    }

    return $res->fetch_all(MYSQLI_NUM);
  }

  public function getAllRowCustom($from, $custom) {
    $query = "SELECT * FROM `" . $from . "` " . $custom . ";";

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->connect_error, E_USER_ERROR);
      exit(1);
    } else if($res->num_rows < 1) {
      error_log("This shouldn't happen..5");
      //exit(1);
    }

    return $res->fetch_all(MYSQLI_NUM);
  }

  public function countRows($from, $where, $like) {
    $query = "SELECT * FROM `" . $from . "` WHERE `" . $where . "` LIKE '" . $like . "';";

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->connect_error, E_USER_ERROR);
      exit(1);
    } else {
      return $res->num_rows;
    }
  }

  /*

  $cols = array(
    "moviedb-id",
    "name",
    "path",
    "poster",
    "backdrop",
    "overview"
  );

  $vals = array(
    "31295",
    "Misfits",
    "Misfits",
    "hia44dQ66CIfYPlLyaVcHRA9DtG.jpg",
    "m26kKegbYKyLvQZlctSh56j9KlO.jpg",
    "Misfits is a British science fiction comedy-drama television show, on [...]"
  );

  insertRow("series", $cols, $vals);

  */

  public function insertRow($into, $cols, $vals) {
    foreach($vals as $key => $val) {
      $vals[$key] = $this->handle->real_escape_string($val);
    }
    $colString = "(`" . implode('`, `', $cols) . "`)";
    $valString = "('" . implode("', '", $vals) . "')";

    $query = "INSERT INTO `" . $into . "` " . $colString . " VALUES " . $valString . ";";

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->error, E_USER_ERROR);
      exit(1);
    } else {
      return $this->handle->insert_id;
    }
  }

  public function deleteRows($from, $where, $like) {
    $query = "DELETE FROM `" . $from . "` WHERE `" . $where . "` LIKE '" . $like . "';";

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->error, E_USER_ERROR);
      exit(1);
    } else {
      return true;
    }
  }

  public function updateRow($update, $col, $val, $where, $like) {
    $query = "UPDATE `" . $update . "` SET `" . $col . "` = " . $val . " WHERE `" . $where . "` LIKE '" . $like . "';";

    $res = $this->handle->query($query);
    if($res === false) {
      echo "DB failed.";
      trigger_error('Database failed: '  . $this->handle->error, E_USER_ERROR);
      error_log("Query: " . $query);
      exit(1);
    } else {
      return true;
    }
  }
}