classes/payment/QueuedPaymentDAO.inc.php

<?php

class QueuedPaymentDAO extends DAO {

   function QueuedPaymentDAO() {
      parent::DAO();
   }
   
   function &getQueuedPayment($queuedPaymentId) {
      $result = &$this->retrieve(
         'SELECT * FROM queued_payments WHERE queued_payment_id = ?',
         $queuedPaymentId
      );

      $queuedPayment = null;
      if ($result->RecordCount() != 0) {
         $queuedPayment = unserialize($result->fields['payment_data']);
         if (!is_object($queuedPayment)) unset($queuedPayment);
      }
      $result->Close();
      unset($result);
      return $queuedPayment;
   }
   
   function insertQueuedPayment(&$queuedPayment) {
      $this->update(
         sprintf('INSERT INTO queued_payments
            (date_created, date_modified, payment_data)
            VALUES
            (%s, %s, ?)',
            $this->datetimeToDB(Core::getCurrentDate()),
            $this->datetimeToDB(Core::getCurrentDate())),
         array(
            serialize($queuedPayment)
         )
      );
      
      return $this->getInsertQueuedPaymentId();
   }
   
   function updateQueuedPayment($queuedPaymentId, &$queuedPayment) {
      return $this->update(
         sprintf('UPDATE queued_payments
            SET
               date_modified = %s,
               payment_data = ?
            WHERE queued_payment_id = ?',
            $this->datetimeToDB(Core::getCurrentDate())),
         array(
            serialize($queuedPayment),
            $queuedPaymentId
         )
      );
   }
   
   function getInsertQueuedPaymentId() {
      return $this->getInsertId('queued_payments', 'queued_payment_id');
   }
   
   function deleteQueuedPayment(&$queuedPayment) {
      return $this->update(
         'DELETE FROM queued_payments WHERE queued_payment_id = ?',
         array($queuedPayment->getQueuedPaymentId())
      );
   }
}

?>

---