tonyair/silverstripe-framework
1
0
Fork 0
mirror of https://github.com/silverstripe/silverstripe-framework synced 2024-10-22 12:05:37 +00:00
Code Issues Projects Releases Wiki Activity

pkrenn: Added methods needed for testing, namely databaseExists and selectDatabase (merged from branches/gsoc)

Browse Source 
git-svn-id: svn://svn.silverstripe.com/silverstripe/open/modules/sapphire/trunk@41713 467b73ca-7a2a-4603-9d3b-597d59a354a9
This commit is contained in:
Ingo Schommer 2007-09-14 01:45:06 +00:00
parent f912a33b63
commit 817f279cf1
1 changed files with 42 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
core/model/PDODatabase.php
View File

@ -35,6 +35,12 @@ class PDODatabase extends Database {
*/
private $stmt;
/**
* Parameters used for creating a connection
* @var array
*/
private $param;
/**
* Connect to a database (MySQL, PostgreSQL, or MS SQL).
* @param parameters An map of parameters, which should include:
@ -47,6 +53,7 @@ class PDODatabase extends Database {
* <li>database: The database to connect to</li></ul>
*/
public function __construct($parameters) {
$this->param = $parameters;
$connect = self::getConnect($parameters);
$connectWithDB = $connect . ';dbname=' . $parameters['database'];
try { // Try connect to the database, if it does not exist, create it
@ -235,6 +242,41 @@ class PDODatabase extends Database {
}
return true;
}
/**
* Returns true if the named database exists.
*/
public function databaseExists($name) {
$SQL_name = Convert::raw2sql($name);
$connect = self::getConnect($this->param);
$connectWithDB = $connect . ';dbname=' . $SQL_name;
try { // Try connect to the database
$testConn = new PDO($connectWithDB, $this->param['username'], $this->param['password']);
} catch (PDOException $e) {
return false;
}
return true;
}
/**
* Switches to the given database.
* Simply switching database in PDO is not possible, you need to create a new PDO object
*/
public function selectDatabase($dbname) {
$this->dbConn = null; // Remove the old connection
$connect = self::getConnect($param);
$connectWithDB = $connect . ';dbname=' . $dbname;
try { // Try connect to the database, if it does not exist, create it
$this->dbConn = new PDO($connectWithDB, $param['username'], $param['password']);
} catch (PDOException $e) {
if (!self::createDatabase($connect, $param['username'], $param['password'], $dbname)) {
$this->databaseError("Could not connect to the database, make sure the server is available and user credentials are correct");
} else {
$this->dbConn = new PDO($connectWithDB, $param['username'], $param['password']); // After creating the database, connect to it
}
}
}
/**
* Create a new table with an integer primary key called ID.
* @var string $tableName The name of the table.