File Source for PMO_Dbms_Pdo

<?php
/**
* This file contains the PMO_Dbms_Pdo driver class.
*
* This file is part of the PhpMyObject project,
* an Object-Relational Mapping (ORM) system.
*
* For questions, help, comments, discussion, etc., please join our
* forum at {@link http://www.developpez.net/forums/forumdisplay.php?f=770}
* or our mailing list at {@link http://groups.google.com/group/pmo-dev}.
*
* PhpMyObject 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 3 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, see {@link http://www.gnu.org/licenses/}.
*
* @package PhpMyObject
* @subpackage PMO_Tests
* @author Nicolas Boiteux <nicolas_boiteux@yahoo.fr>
* @author Louis Lapointe <laplix@gmail.com>
* @link http://pmo.developpez.com/
* @since PhpMyObject v0.15
* @version $Revision: 400 $
* @copyright Copyright (c) 2007-2008 Nicolas Boiteux
* @copyright Copyright (c) 2008 Louis Lapointe
* @license GPLv3 {@link http://www.gnu.org/licenses/gpl}
* @filesource
*/
/**
* setup the test cases if called individually
*/
if (!defined('PMO_TEST_SUITE')) {
require_once(dirname(dirname(__FILE__)).DIRECTORY_SEPARATOR.'config.php');
require_once(SIMPLETEST.DS.'autorun.php');
}
/**
* requires the classes to be tested
*/
require_once(PMO_CORE . DS . 'PMO_MyDbms.php');
require_once(PMO_CORE . DS . 'PMO_dbms_pdo.php');
require_once(PMO_CORE . DS . 'PMO_dbms_mysql.php');
require_once(PMO_CORE . DS . 'PMO_dbms_sqlite.php');
/**
* this tests the PMO_Dbms_Pdo connections.
*
* This is just a sanity check. Real testing is going to be
* done with de PMO_MyDbms class.
*/
class PMO_Dbms_Pdo_Connection_Test extends UnitTestCase
{
/** constructor calls parent contructor. */
function PMO_Dbms_Pdo_Connection_Test()
{
$this->UnitTestCase();
$this->sqliteDatabase = dirname(__FILE__).DS.'test.db';
}
function setUp()
{
$this->authdb = array(
'driver' => 'pdo',
'pdodriver' => '',
'dsn' => 'sqlite:'.$this->sqliteDatabase,
'host' => 'localhost',
'user' => 'pmo',
'pass' => 'pmo',
'base' => 'test'
);
}
function tearDown() {
if ($this->authdb['pdodriver'] == 'sqlite') {
@unlink($this->sqliteDatabase);
}
}
function test_pdo_mysql_connect_with_bad_host()
{
$db = new PMO_Dbms_Pdo();
$this->authdb['pdodriver'] = 'mysql';
$this->authdb['host'] = 'qwerty';
try {
$db->connect($this->authdb);
$this->fail('Should have catched the exception.');
}
catch(Exception $e) {
$this->assertWantedPattern('/Unknown MySQL server host/', $e->getMessage(), $e->getMessage());
}
}
function test_pdo_mysql_connect_with_bad_user()
{
$db = new PMO_Dbms_Pdo();
$this->authdb['pdodriver'] = 'mysql';
$this->authdb['user'] = 'qwerty';
try {
$db->connect($this->authdb);
$this->fail('Should have catched the exception.');
}
catch(PDOException $e) {
$this->assertWantedPattern('/Access denied for user \'qwerty\'/', $e->getMessage(), $e->getMessage());
}
}
function test_pdo_mysql_connect_with_bad_pass()
{
$db = new PMO_Dbms_Pdo();
$this->authdb['pdodriver'] = 'mysql';
$this->authdb['pass'] = 'qwerty';
try {
$db->connect($this->authdb);
$this->fail('Should have catched the exception.');
}
catch(PDOException $e) {
$this->assertWantedPattern('/Access denied for user \'pmo\'/', $e->getMessage(), $e->getMessage());
}
}
function test_pdo_mysql_connect_with_bad_base()
{
$db = new PMO_Dbms_Pdo();
$this->authdb['pdodriver'] = 'mysql';
$this->authdb['base'] = 'qwerty';
try {
$db->connect($this->authdb);
$this->fail('Should have catched the exception.');
}
catch(Exception $e) {
$this->assertWantedPattern('/database \'qwerty\'/', $e->getMessage(), $e->getMessage());
}
}
function test_pdo_mysql_connect_good_connection()
{
$db = new PMO_Dbms_Pdo();
$this->authdb['pdodriver'] = 'mysql';
try {
$db->connect($this->authdb);
$this->pass('Connected');
}
catch (Exception $e) {
$this->fail($e->getMessage());
}
}
}
/**
* This tests the PMO_dbms_pdo class.
*
* This is just a sanity check. Real testing is going to be
* done with de PMO_MyDbms class.
*/
class PMO_Dbms_Pdo_Test extends UnitTestCase
{
/** constructor calls parent contructor. */
function PMO_Dbms_Pdo_Test()
{
$this->UnitTestCase();
$this->sqliteDatabase = dirname(__FILE__).'/test.db';
$this->setSql();
}
/**
* setup is called before each test is performed
*/
function setUp()
{
$this->authdb = array(
'driver' => 'pdo',
'pdodriver' => 'mysql',
'host' => 'localhost',
'user' => 'pmo',
'pass' => 'pmo',
'base' => 'test',
'dsn' => 'sqlite:',$this->sqliteDatabase
);
$this->db = new PMO_Dbms_Pdo();
$this->db->connect($this->authdb);
$this->db->query($this->drop);
$this->db->query($this->create);
foreach ($this->inserts as $insert) {
$sql = 'INSERT INTO `t1` VALUES ' . $insert;
$this->db->query($sql);
}
}
/**
* tearDown is called after each test has been performed
*/
function tearDown()
{
$this->db->query($this->drop);
unset($this->db);
}
// helpers
function setSql()
{
// we need to drop instead of truncate because we need to know
// the last inserted id.
$this->drop = 'DROP TABLE IF EXISTS `t1`';
$this->create = 'CREATE TABLE `t1` ('
. '`id` INT(11) NOT NULL AUTO_INCREMENT,'
. '`name` VARCHAR(50) NOT NULL DEFAULT \'\','
. '`group_id` INT(11) NOT NULL DEFAULT \'0\','
. '`description` VARCHAR(255) DEFAULT NULL,'
. '`start_date` DATE DEFAULT NULL,'
. 'PRIMARY KEY (`id`)'
. ') ENGINE=InnoDB DEFAULT CHARSET=latin1;' ;
$this->inserts = array(
'(1, "one", 1, null, null)'
,'(2, "two", 1, null, null)'
,'(3, "three", 1, "description of four", "2008-02-29")'
,'(4, "four", 10, null, null)'
,'(5, "five", 10, null, null)'
,'(6, "six", 10, null, null)'
,'(7, "seven", 10, null, null)'
,'(8, "eight", 20, null, null)'
,'(9, "nine", 20, null, null)'
);
}
function test_query()
{
$sql = 'select * from t1';
$this->assertTrue($this->db->query($sql), 'select data that exists');
try {
$sql2 = $sql . ' where groups = "40"';
$this->db->query($sql2);
$this->fail('should have caught the exception since the column "groups" does not exist');
}
catch (Exception $e) {
$this->assertWantedPattern('/Unknown column \'groups\'/', $e->getMessage()); //, $e->getMessage());
}
$sql2 = $sql . ' where group_id = 40';
$this->assertTrue($this->db->query($sql2), 'a select with nonexistent group_id');
}
function test_fetchArray()
{
$sql = 'select * from t1 where group_id = 1';
$this->assertTrue($this->db->query($sql), "query [$sql] succeeded");
$row = $this->db->fetchArray();
$this->assertEqual(count($row), 5, 'the row does contain 5 columns');
$this->assertEqual($row['name'], 'one', 'the first row[name] does equal "one"');
$row = $this->db->fetchArray();
$this->assertEqual($row['name'], 'two', 'the second row[name] does equal "two"');
$row = $this->db->fetchArray();
$this->assertEqual($row['id'], 3, 'the third row[id] does equal 3');
$this->assertEqual($row['name'], 'three', 'the third row[name] does equal "three"');
$this->assertEqual($row['group_id'], 1, 'the third row[group_id] does equal 1');
$this->assertEqual($row['description'], 'description of four', 'the third row[description] does equal "description of four"');
$this->assertEqual($row['start_date'], '2008-02-29', 'the third row[start_date] does equal "2008-02-29"');
$row = $this->db->fetchArray();
$this->assertFalse($row, 'there are no more rows');
}
function test_getTableDesc()
{
$arr = $this->db->getTableDesc('t1');
$this->assertTrue(is_array($arr), 'getTableDesc(t1) return an array');
$this->assertEqual(count($arr), 5, 'and returned 5 columns as expected');
$this->assertEqual($arr[0]['Field'], 'id', 'Field value is "id" as expected');
$this->assertEqual($arr[0]['Null'], 'NO', 'Null equals NO as expected');
$this->assertEqual($arr[0]['Key'], 'PRI', 'Key contains "PRI" as expected');
$this->assertEqual($arr[0]['Default'], '', 'Default is empty as expected');
$this->assertEqual($arr[0]['Extra'], 'auto_increment', 'Extra contains "auto_increment" as expected');
$this->assertEqual($arr[0]['Perm'], 'rw', 'Perm contains "rw" as expected');
}
function test_getLastId()
{
$sql = "insert into `t1` values (0, 'last one', 99, 'a short description', now())";
$this->db->query($sql);
$this->assertEqual($this->db->getLastId(), 10, 'New id equals 10 as expected');
}
function test_transaction_commit_and_rollback() {
$insert98 = 'INSERT INTO `t1` VALUES (98, "quatre-vingt dix-huit", 1,null,null)';
$select98 = 'SELECT * FROM `t1` WHERE id = 98';
$insert99 = 'INSERT INTO `t1` VALUES (99, "quatre-vingt dix-neuf", 1,null,null)';
$select99 = 'SELECT * FROM `t1` WHERE id = 99';
$this->db->beginTransaction();
$this->db->query($insert98);
$this->db->commit();
$this->db->query($select98);
$res = $this->db->fetchArray();
$this->assertEqual($res['id'], 98);
$this->db->beginTransaction();
$this->db->query($insert99);
$this->db->rollback();
$this->db->query($select99);
$res = $this->db->fetchArray();
$this->assertEqual($res['id'],NULL);
}
}
// run the tests if called individually
if (!defined('PMO_TEST_SUITE')) {
$level = '';
if (isset($_GET['level'])) {
$level = $_GET['level'];
}
$test = new TestSuite('PMO_Dbms_Pdo Tests');
$test->add(new PMO_Dbms_Pdo_Connection_Test);
$test->add(new PMO_Dbms_Pdo_Test);
$test->run(new PMO_HTMLReporter($level));
}

Source for file PMO_Dbms_Pdo_Test.php