TweetTable.php

Go to the documentation of this file.

<?
require_once 'HypertableConnection.php';
require_once 'Tweet.php';
require_once 'UserTable.php';
require_once 'User.php';

class TweetTable
{
  // load a tweet from the database
  public function load($id) {
    $result=HypertableConnection::query("SELECT * FROM tweet ".
                "WHERE ROW='$id'");
    if (!$result or !count($result->cells))
      return null;

    $tweet=new Tweet();
    $tweet->setId($id);
    $tweet->setTimestamp($result->cells[0]->key->timestamp);
    $tweet->setMessage($result->cells[0]->value);
    return $tweet;
  }

  // Store a tweet; this function will automatically assign a new ID
  // if necessary 
  public function store($tweet, $author) {
    if (!$tweet->getId())
      $tweet->createId($author);
    HypertableConnection::insert('tweet', $tweet->getId(), 'message',
            $tweet->getMessage());
    $u=UserTable::load($author);
    $u->sendTweet($tweet);
    return true;
  }
}

?>