DataManager_PDO

gistfile1.txt

 /**
   * place query
   * 
   * note: using prepared statements
   * see the filtering in bindValue()
   * 
   * @return mixed
   */
  private static function query($connection, $query, $parameters = array()) {
    $statement = $connection->prepare($query);
    $i = 1;
    foreach ($parameters as $param) {
      if (is_int($param)) {
           $statement->bindValue($i, $param, PDO::PARAM_INT);
      }  
      if (is_string($param)) {
           $statement->bindValue($i, $param, PDO::PARAM_STR);
      }  
      $i++;
    }
    $statement->execute();
    return $statement;
  }

  /**
   * get the key of the last inserted item
   * 
   * @return integer
   */
  private static function lastInsertId($connection) {
    return $connection->lastInsertId();
  }

  /**
   * retrieve an object from the database result set
   * 
   * @param object $cursor result set
   * @return object
   */
  private static function fetchObject($cursor) {
    return $cursor->fetchObject();
  }

  /**
   * remove the result set
   * 
   * @param object $cursor result set
   * @return null
   */
  private static function close($cursor) {
    $cursor->closeCursor();
  }
  
  
  /**
   * get the User item by id
   * 
   * @param integer $userId  uid of that user
   * @return User | false
   */
  public static function getUserForId($userId) {
    $user = null;
    $con = self::getConnection();
    $res = self::query($con, "
      SELECT id, userName, passwordHash 
      FROM users 
      WHERE id = ?;
      ", array($userId));
    if ($u = self::fetchObject($res)) {
      $user = new User($u->id, $u->userName, $u->passwordHash);
    }
    self::close($res);
    self::closeConnection($con);
    return $user;
  }

  /**
   * get the User item by name
   * 
   * @param string $userName  name of that user - must be exact match
   * @return User | false
   */
  public static function getUserForUserName($userName) {
    $user = null;
    $con = self::getConnection();
    $res = self::query($con, "
      SELECT id, userName, passwordHash 
      FROM users 
      WHERE userName = ?;
      ", array($userName));
    if ($u = self::fetchObject($res)) {
      $user = new User($u->id, $u->userName, $u->passwordHash);
    }
    self::close($res);
    self::closeConnection($con);
    return $user;
  }