Viewing file: db.php (12.12 KB) -rw-rw-rw- Select action/file-type: (+) | (+) | (+) | Code (+) | Session (+) | (+) | SDB (+) | (+) | (+) | (+) | (+) | (+) |
<?php /* vim: set expandtab tabstop=4 shiftwidth=4: */ // +----------------------------------------------------------------------+ // | PEAR :: Mail :: Queue :: DB Container | // +----------------------------------------------------------------------+ // | Copyright (c) 1997-2004 The PHP Group | // +----------------------------------------------------------------------+ // | This source file is subject to version 3.0 of the PHP license, | // | that is bundled with this package in the file LICENSE, and is | // | available at through the world-wide-web at | // | http://www.php.net/license/3_0.txt. | // | If you did not receive a copy of the PHP license and are unable to | // | obtain it through the world-wide-web, please send a note to | // | license@php.net so we can mail you a copy immediately. | // +----------------------------------------------------------------------+ // | Authors: Radek Maciaszek <chief@php.net> | // | Lorenzo Alberton <l.alberton at quipo.it> | // +----------------------------------------------------------------------+ // // $Id: db.php,v 1.16 2004/08/17 14:30:53 quipo Exp $
/** * Storage driver for fetching mail queue data from a PEAR_DB database * * This storage driver can use all databases which are supported * by the PEAR DB abstraction layer. * * @author Radek Maciaszek <chief@php.net> * @package Mail_Queue * @version $Revision: 1.16 $ */ require_once 'DB.php'; require_once 'Mail/Queue/Container.php';
/** * Mail_Queue_Container_db - Storage driver for fetching mail queue data * from a PEAR_DB database * * @author Radek Maciaszek <chief@php.net> * @version $Id: db.php,v 1.16 2004/08/17 14:30:53 quipo Exp $ * @package Mail_Queue * @access public */ class Mail_Queue_Container_db extends Mail_Queue_Container { // {{{ class vars
/** * Reference to the current database connection. * @var object PEAR_DB */ var $db;
/** * Table for sql database * @var string */ var $mail_table = 'mail_queue';
/** * @var string the name of the sequence for this table */ var $sequence = null;
// }}} // {{{ Mail_Queue_Container_db()
/** * Contructor * * Mail_Queue_Container_db:: Mail_Queue_Container_db() * * @param mixed $options An associative array of option names and * their values. See DB_common::setOption * for more information about connection options. * * @access public */ function Mail_Queue_Container_db($options) { if (!is_array($options) || !isset($options['dsn'])) { return new Mail_Queue_Error(MAILQUEUE_ERROR_NO_OPTIONS, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'No dns specified!'); } if (isset($options['mail_table'])) { $this->mail_table = $options['mail_table']; } $this->sequence = (isset($options['sequence']) ? $options['sequence'] : $this->mail_table);
if (!empty($options['pearErrorMode'])) { $this->pearErrorMode = $options['pearErrorMode']; } $this->db =& DB::connect($options['dsn'], true); if (DB::isError($this->db)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_CANNOT_CONNECT, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::connect failed: '. DB::errorMessage($this->db)); } else { $this->db->setFetchMode(DB_FETCHMODE_ASSOC); } $this->setOption(); }
// }}} // {{{ _preload()
/** * Preload mail to queue. * * @return mixed True on success else Mail_Queue_Error object. * @access private */ function _preload() { $query = sprintf("SELECT * FROM %s WHERE sent_time IS NULL AND try_sent < %d AND %s > time_to_send ORDER BY time_to_send", $this->mail_table, $this->try, $this->db->quote(date("Y-m-d H:i:s")) ); $query = $this->db->modifyLimitQuery($query, $this->offset, $this->limit); if (DB::isError($query)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::modifyLimitQuery failed - '.$query->toString()); } $res = $this->db->query($query); if (DB::isError($res)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); }
$this->_last_item = 0; $this->queue_data = array(); //reset buffer while ($row = $res->fetchRow(DB_FETCHMODE_ASSOC)) { if (!is_array($row)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); } $this->queue_data[$this->_last_item] = new Mail_Queue_Body( $row['id'], $row['create_time'], $row['time_to_send'], $row['sent_time'], $row['id_user'], $row['ip'], $row['sender'], $row['recipient'], unserialize($row['headers']), unserialize($row['body']), $row['delete_after_send'], $row['try_sent'] ); $this->_last_item++; }
return true; }
// }}} // {{{ put()
/** * Put new mail in queue and save in database. * * Mail_Queue_Container::put() * * @param string $time_to_send When mail have to be send * @param integer $id_user Sender id * @param string $ip Sender ip * @param string $from Sender e-mail * @param string $to Reciepient e-mail * @param string $hdrs Mail headers (in RFC) * @param string $body Mail body (in RFC) * @param bool $delete_after_send Delete or not mail from db after send * * @return mixed ID of the record where this mail has been put * or Mail_Queue_Error on error * @access public **/ function put($time_to_send, $id_user, $ip, $sender, $recipient, $headers, $body, $delete_after_send=true) { $id = $this->db->nextId($this->sequence); if (empty($id) || DB::isError($id)) { return new Mail_Queue_Error(MAILQUEUE_ERROR, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'Cannot create id in: '.$this->sequence); } $query = sprintf("INSERT INTO %s (id, create_time, time_to_send, id_user, ip, sender, recipient, headers, body, delete_after_send) VALUES(%d, now(), '%s', %d, '%s', '%s', '%s', '%s', '%s', %d)", $this->mail_table, $id, addslashes($time_to_send), addslashes($id_user), addslashes($ip), addslashes($sender), addslashes($recipient), addslashes($headers), addslashes($body), $delete_after_send );
$res = $this->db->query($query); if (DB::isError($res)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); } return $id; }
// }}} // {{{ countSend()
/** * Check how many times mail was sent. * * @param object Mail_Queue_Body * @return mixed Integer or Mail_Queue_Error class if error. * @access public */ function countSend($mail) { if (!is_object($mail) || !is_a($mail, 'mail_queue_body')) { return new Mail_Queue_Error('Expected: Mail_Queue_Body class', __FILE__, __LINE__); } $count = $mail->_try(); $query = sprintf("UPDATE %s SET try_sent = %d WHERE id = %d", $this->mail_table, $count, $mail->getId() );
$res = $this->db->query($query); if (DB::isError($res)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); } return $count; }
// }}} // {{{ setAsSent()
/** * Set mail as already sent. * * @param object Mail_Queue_Body object * @return bool * @access public */ function setAsSent($mail) { if (!is_object($mail) || !is_a($mail, 'mail_queue_body')) { return new Mail_Queue_Error(MAILQUEUE_ERROR_UNEXPECTED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'Expected: Mail_Queue_Body class'); } $query = sprintf("UPDATE %s SET sent_time = now() WHERE id = %d", $this->mail_table, $mail->getId() );
$res = $this->db->query($query); if (DB::isError($res)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); } return true; }
// }}} // {{{ getMailById()
/** * Return mail by id $id (bypass mail_queue) * * @param integer $id Mail ID * @return mixed Mail object or false on error. * @access public */ function getMailById($id) { $query = sprintf("SELECT * FROM %s WHERE id = %d", $this->mail_table, (int)$id ); $res = $this->db->query($query);
if (DB::isError($res)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); } $row = $res->fetchRow(DB_FETCHMODE_ASSOC); if (!is_array($row)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); } return new Mail_Queue_Body( $row['id'], $row['create_time'], $row['time_to_send'], $row['sent_time'], $row['id_user'], $row['ip'], $row['sender'], $row['recipient'], unserialize($row['headers']), unserialize($row['body']), $row['delete_after_send'], $row['try_sent'] ); }
// }}} // {{{ deleteMail()
/** * Remove from queue mail with $id identifier. * * @param integer $id Mail ID * @return bool True on success else Mail_Queue_Error class * * @access public */ function deleteMail($id) { $query = sprintf("DELETE FROM %s WHERE id = %d", $this->mail_table, addslashes($id) ); $res = $this->db->query($query);
if (DB::isError($res)) { return new Mail_Queue_Error(MAILQUEUE_ERROR_QUERY_FAILED, $this->pearErrorMode, E_USER_ERROR, __FILE__, __LINE__, 'DB::query failed - "'.$query.'" - '.$res->toString()); } return true; }
// }}} } ?>
|