<?php

$GLOBALS['primary_keys'][MY_DSN]['Shopper'] = 'sid';

class Shopper extends DbTable
{
   /**
   * Initializes a Shopper object.
   *
   * @param int $id (must be a valid primary key, null or zero, or an associative array with values representing a row from the Shopper table)
   */
  public function __construct( $id=null )
  {
     $this->initialize(MY_DSN, __CLASS__, $id);
  }

   /**
   * Returns an array of Shopper objects, all of them
   *
   * @return array of Shopper
   */
  public static function getAll()
  {
    #if ( !$name )
    #  return new Error(ERROR_IMPROPERUSE);

    $result = parent::connect(MY_DSN);
    if ( Error::isError($result) )
    {
      return $result;
    }

    $aDB = parent::$aDB[MY_DSN];
    $aSQL = "SELECT * FROM Shopper";
    $aResult = $aDB->query($aSQL);
    if ( DB::isError($aResult) )
      return new Error(ERROR_BADQUERY, $aSQL);

    $aShoppers = array();
    while ( $aRow = $aResult->fetchRow() )
      $aShoppers[] = new Shopper($aRow);

    return $aShoppers;
  }


   /**
   * Returns an array of Product objects owned by this Shopper
   *
   * @return array of Product
   */
  public function getProducts()
  {
    #if ( !$name )
    #  return new Error(ERROR_IMPROPERUSE);

    $result = parent::connect(MY_DSN);
    if ( Error::isError($result) )
    {
      return $result;
    }

    $aDB = parent::$aDB[MY_DSN];
    $aSQL = "SELECT p.* FROM Shopper s
                        INNER JOIN Shopper_Product sp ON (s.sid=sp.sid)
                        INNER JOIN Product p ON (sp.pid=p.pid)
                        WHERE s.sid=".$this->getField('sid');
    $aResult = $aDB->query($aSQL);
    if ( DB::isError($aResult) )
      return new Error(ERROR_BADQUERY, $aSQL);

    $aProducts = array();
    while ( $aRow = $aResult->fetchRow() )
      $aProducts[] = new Product($aRow);

    return $aProducts;
  }

}
?>