File Source for Sql.php

<?php
/**
* MediaSearch
*
* LICENSE
*
* "THE BEER-WARE LICENSE" (Revision 42):
* "Sven Strittmatter" <ausserirdisch@sven-space.de> wrote this file.
* As long as you retain this notice you can do whatever you want with
* this stuff. If we meet some day, and you think this stuff is worth it,
* you can buy me a beer in return.
*
* $Author$
* $Revision$
*
* @category MediaSearch
* @package MediaSearch_Config
* @copyright Copyright (c) 2009 Sven Strittmatter
*/
/**
* @see MediaSearch_Config_Abstract
*/
require_once('MediaSearch/Config/Abstract.php');
/**
* @see MediaSearch_Interface_Command
*/
require_once('MediaSearch/Interface/Command.php');
/**
* A concrete implemetation for SQL config files. The file can contain
* any SQL statement. The filename extensions need to be .sql.
*
* This type of config also implement MediaSearch_Interface_Command.
* Thatt means that you can execute the configuration on a database.
* To do this its neccessary to provide a proper PDO and Database name
* to the config object.
*
* @category MediaSearch
* @package MediaSearch_Config
* @copyright Copyright (c) 2009 Sven Strittmatter
*/
class MediaSearch_Config_Sql extends MediaSearch_Config_Abstract
implements MediaSearch_Interface_Command {
const TRACE_LELVEL = 12;
/**
* Optional PDO connection obejct. NEccessary for executing
* the config object on a database.
*
* @access protected
* @var PDO
*/
protected $pdoConnection;
/**
* The database name the PDO should work on.
*
* @access proteced
* @var string
*/
protected $databaseName;
/**
* Sets PDO object and a database name. Thats neccessary if you want
* to execute the loaded SQL config on a databse.
*
* @accesss public
* @param PDO $pdo
* @param string $databaseName
*/
public function setPdo(PDO $pdo, $databaseName) {
$this->pdoConnection = $pdo;
$this->databaseName = $databaseName;
}
/**
* MediaSearch_Interface_Command implementation.
*
* Executes the loaded SQL config on the database setted by setPdo().
*
* @todo Specify the return type of PDO!
*
* @access public
* @throws RuntimeException On any error executing the SQL on the PDO.
* @return <type>
*/
public function execute() {
if (null === $this->pdoConnection) {
$message = 'Please set a PDO connection object by ';
$message .= 'PDO::setPdo() before execute this object!';
throw new RuntimeException($message);
}
$result = $this->pdoConnection->query("USE {$this->databaseName};");
if (false === $result) {
$message = "Cant select database {$this->databaseName}.\n";
$message .= 'PDO-Error: ';
$message .= implode(', ', $this->pdoConnection->errorInfo());
throw new RuntimeException($message);
}
$sql = $this->get();
$result = $this->pdoConnection->query($sql);
if (false === $result) {
$message = "Cant execute sql:\n";
$message .= "$sql\n";
$message .= 'PDO-Error: ';
$message .= implode(', ', $this->pdoConnection->errorInfo());
throw new RuntimeException($message);
}
return $result;
}

Source for file Sql.php