<?php
/**
 * $Project: Pastebin $
 * $Id: db.mysql.class.php,v 1.3 2006/04/27 16:20:06 paul Exp $
 * 
 * Pastebin Collaboration Tool
 * http://pastebin.com/
 *
 * This file copyright (C) 2005 Paul Dixon (paul@elphin.com)
 * 
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */
 
/**
* Database handler
* Very simple, bare bones database handler - if your database isn't supported,
* write another version of this class and change the relevant line of the 
* config file to pull it in, i.e. for Postgres support, write a class in
* db.postgres.class.php and set $CONF['dbsystem']='postgres';
*
* All of the SQL used by the rest of the code is contained in here
*/
class DB
{
	var $dblink;
	var $dbresult;
	
	/**
	* Constructor - establishes DB connection
	*/
	function DB()
	{
		global $CONF;
		$this->dblink=mysql_pconnect( $CONF["localhost"], $CONF["rseterni_paste"], $CONF["a64042640"]) or die("Unable to connect to database"); mysql_select_db($CONF["rseterni_paste"], $this-&gt;dblink) or die("Unable to select database {$GLOBALS[dbname]}"); } /** * How many posts on domain $subdomain? * access public */ function getPostCount($subdomain) { $this-&gt;_query('select count(*) as cnt from pastebin where domain=?', $subdomain); return $this-&gt;_next_record() ? $this-&gt;_f('cnt') : 0; } /** * Delete oldest $deletecount posts from $subdomain * access public */ function trimDomainPosts($subdomain, $deletecount) { //build a one-shot statement to delete old posts $sql='delete from pastebin where pid in ('; $sep=''; $this-&gt;_query("select * from pastebin where domain=? order by posted asc limit $deletecount", $subdomain); while ($this-&gt;_next_record()) { $sql.=$sep.$this-&gt;_f('pid'); $sep=','; } $sql.=')'; //delete extra posts $this-&gt;_query($sql); } /** * Delete all expired posts * access public */ function deleteExpiredPosts() { $this-&gt;_query("delete from pastebin where expires is not null and now() &gt; expires"); } /** * Add post and return id * access public */ function addPost($poster,$subdomain,$format,$code,$parent_pid,$expiry_flag) { //figure out expiry time switch ($expiry_flag) { case 'd'; $expires="DATE_ADD(NOW(), INTERVAL 1 DAY)"; break; case 'f'; $expires="NULL"; default: case 'm'; $expires="DATE_ADD(NOW(), INTERVAL 1 MONTH)"; break; } $this-&gt;_query('insert into pastebin (poster, domain, posted, format, code, parent_pid, expires,expiry_flag) '. "values (?, ?, now(), ?, ?, ?, $expires, ?)", $poster,$subdomain,$format,$code,$parent_pid, $expiry_flag); $id=$this-&gt;_get_insert_id(); return $id; } /** * Return entire pastebin row for given id/subdomdain * access public */ function getPost($id, $subdomain) { $this-&gt;_query('select *,date_format(posted, \'%a %D %b %H:%i\') as postdate '. 'from pastebin where pid=? and domain=?', $id, $subdomain); if ($this-&gt;_next_record()) return $this-&gt;row; else return false; } /** * Return summaries for $count posts ($count=0 means all) * access public */ function getRecentPostSummary($subdomain, $count) { $limit=$count?"limit $count":""; $posts=array(); $this-&gt;_query("select pid,poster,unix_timestamp()-unix_timestamp(posted) as age, ". "date_format(posted, '%a %D %b %H:%i') as postdate ". "from pastebin ". "where domain=? ". "order by posted desc, pid desc $limit", $subdomain); while ($this-&gt;_next_record()) { $posts[]=$this-&gt;row; } return $posts; } /** * Get follow up posts for a particular post * access public */ function getFollowupPosts($pid, $limit=5) { //any amendments? $childposts=array(); $this-&gt;_query("select pid,poster,". "date_format(posted, '%a %D %b %H:%i') as postfmt ". "from pastebin where parent_pid=? ". "order by posted limit $limit", $pid); while ($this-&gt;_next_record()) { $childposts[]=$this-&gt;row; } return $childposts; } /** * Save formatted code for a post * access public */ function saveFormatting($pid, $codefmt, $codecss) { $this-&gt;_query("update pastebin set codefmt=?,codecss=? where pid=?", $codefmt, $codecss, $pid); } /** * execute query - show be regarded as private to insulate the rest of * the application from sql differences * @access private */ function _query($sql) { //been passed more parameters? do some smart replacement if (func_num_args() &gt; 1) { //query contains ? placeholders, but it's possible the //replacement string have ? in too, so we replace them in //our sql with something more unique $q=md5(uniqid(rand(), true)); $sql=str_replace('?', $q, $sql); $args=func_get_args(); for ($i=1; $i&lt;=count($args); $i++) { $sql=preg_replace("/$q/", "'".preg_quote(mysql_real_escape_string($args[$i]))."'", $sql,1); } //we shouldn't have any $q left, but it will help debugging if we change them back! $sql=str_replace($q, '?', $sql); } $this-&gt;dbresult=mysql_query($sql, $this-&gt;dblink); if (!$this-&gt;dbresult) { die("Query failure: ".mysql_error()."<BR>$sql"); } return $this-&gt;dbresult; } /** * get next record after executing _query * @access private */ function _next_record() { $this-&gt;row=mysql_fetch_array($this-&gt;dbresult); return $this-&gt;row!=FALSE; } /** * get result column $field * @access private */ function _f($field) { return $this-&gt;row[$field]; } /** * get last insertion id * @access private */ function _get_insert_id() { return mysql_insert_id($this-&gt;dblink); } /** * get last error * @access public */ function get_db_error() { return mysql_last_error(); } } ?&gt;