ilDatabaseAtomRunTest.php

Go to the documentation of this file.

<?php
/*
    +-----------------------------------------------------------------------------+
    | ILIAS open source                                                           |
    +-----------------------------------------------------------------------------+
    | Copyright (c) 1998-2009 ILIAS open source, University of Cologne            |
    |                                                                             |
    | 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. |
    +-----------------------------------------------------------------------------+
*/
 
class ilDatabaseAtomRunTest extends PHPUnit_Framework_TestCase
{
 
    protected $backupGlobals = false;
    protected $ilDBInterfaceGalera;
    protected $ilDBInterfaceGaleraSecond;
    protected $ilDBInterfaceInnoDB;
    protected $ilDBInterfaceInnoDBSecond;
 
 
    protected function setUp()
    {
        require_once("./Services/PHPUnit/classes/class.ilUnitUtil.php");
        ilUnitUtil::performInitialisation();
 
        global $ilClientIniFile;
        $this->ilDBInterfaceGalera = ilDBWrapperFactory::getWrapper(ilDBConstants::TYPE_GALERA);
        $this->ilDBInterfaceGalera->initFromIniFile($ilClientIniFile);
        $this->ilDBInterfaceGalera->connect();
 
        $this->ilDBInterfaceGaleraSecond = ilDBWrapperFactory::getWrapper(ilDBConstants::TYPE_GALERA);
        $this->ilDBInterfaceGaleraSecond->initFromIniFile($ilClientIniFile);
        $this->ilDBInterfaceGaleraSecond->connect();
 
        $this->ilDBInterfaceInnoDB = ilDBWrapperFactory::getWrapper(ilDBConstants::TYPE_PDO_MYSQL_INNODB);
        $this->ilDBInterfaceInnoDB->initFromIniFile($ilClientIniFile);
        $this->ilDBInterfaceInnoDB->connect();
 
        $this->ilDBInterfaceInnoDBSecond = ilDBWrapperFactory::getWrapper(ilDBConstants::TYPE_PDO_MYSQL_INNODB);
        $this->ilDBInterfaceInnoDBSecond->initFromIniFile($ilClientIniFile);
        $this->ilDBInterfaceInnoDBSecond->connect();
 
        $this->setupTable();
    }
 
 
    public function tearDown()
    {
        $this->ilDBInterfaceGalera->dropSequence('il_db_tests_atom');
        $this->ilDBInterfaceGalera->dropTable('il_db_tests_atom');
    }
 
 
    public function testConnection()
    {
        $this->assertTrue($this->ilDBInterfaceGalera->connect(true));
        $this->assertTrue($this->ilDBInterfaceGaleraSecond->connect(true));
        $this->assertTrue($this->ilDBInterfaceInnoDB->connect(true));
    }
 
 
    public function setupTable()
    {
        if ($this->ilDBInterfaceGalera->sequenceExists('il_db_tests_atom')) {
            $this->ilDBInterfaceGalera->dropSequence('il_db_tests_atom');
        }
        $this->ilDBInterfaceGalera->createTable('il_db_tests_atom', $fields = array(
            'id'        => array(
                'type'    => 'integer',
                'length'  => 4,
                'notnull' => true,
            ),
            'is_online' => array(
                'type'    => 'integer',
                'length'  => 1,
                'notnull' => false,
            ),
        ), true);
        $this->ilDBInterfaceGalera->addPrimaryKey('il_db_tests_atom', array( 'id' ));
        $this->ilDBInterfaceGalera->createSequence('il_db_tests_atom');
    }
 
 
    public function testTableExists()
    {
        $this->assertTrue($this->ilDBInterfaceGalera->tableExists('il_db_tests_atom'));
    }
 
 
    public function testWriteWithTransactions()
    {
        $ilAtomQuery = $this->ilDBInterfaceGalera->buildAtomQuery();
        $ilAtomQuery->addTableLock('il_db_tests_atom')->lockSequence(true);
        $ilAtomQuery->addQueryCallable($this->getInsertQueryCallable());
 
        $ilAtomQuery->run();
 
        $this->assertEquals($this->getExpectedResult(), $this->getResultFromDB());
    }
 
 
    public function testWriteWithLocks()
    {
        $ilAtomQuery = $this->ilDBInterfaceInnoDB->buildAtomQuery();
        $ilAtomQuery->addTableLock('il_db_tests_atom')->lockSequence(true);
        $ilAtomQuery->addQueryCallable($this->getInsertQueryCallable());
 
        $ilAtomQuery->run();
 
        $this->assertEquals($this->getExpectedResult(), $this->getResultFromDB());
    }
 
 
    public function testWriteWithLocksAndAlias()
    {
        $ilAtomQuery = $this->ilDBInterfaceInnoDB->buildAtomQuery();
        $ilAtomQuery->addTableLock('il_db_tests_atom')->lockSequence(true)->aliasName('my_alias');
        $ilAtomQuery->addQueryCallable($this->getInsertQueryCallable());
 
        $ilAtomQuery->run();
 
        $this->assertEquals($this->getExpectedResult(), $this->getResultFromDB());
    }
 
 
    public function testWriteWithMultipleLocksAndAlias()
    {
        $ilAtomQuery = $this->ilDBInterfaceInnoDB->buildAtomQuery();
        $ilAtomQuery->addTableLock('il_db_tests_atom')->lockSequence(true)->aliasName('my_alias');
        $ilAtomQuery->addTableLock('il_db_tests_atom')->lockSequence(true)->aliasName('my_second_alias');
        $ilAtomQuery->addQueryCallable($this->getInsertQueryCallable());
 
        $ilAtomQuery->run();
 
        $this->assertEquals($this->getExpectedResult(), $this->getResultFromDB());
    }
 
 
    public function testWriteWithMultipleLocksWithAndWithoutAlias()
    {
        $ilAtomQuery = $this->ilDBInterfaceInnoDB->buildAtomQuery();
        $ilAtomQuery->addTableLock('il_db_tests_atom')->lockSequence(true);
        $ilAtomQuery->addTableLock('il_db_tests_atom')->lockSequence(true)->aliasName('my_alias');
        $ilAtomQuery->addQueryCallable($this->getInsertQueryCallable());
 
        $ilAtomQuery->run();
 
        $this->assertEquals($this->getExpectedResult(), $this->getResultFromDB());
    }
 
 
    public function testNoTables()
    {
        $this->setExpectedException('ilDatabaseException');
        $ilAtomQuery = $this->ilDBInterfaceInnoDB->buildAtomQuery();
        $ilAtomQuery->addQueryCallable($this->getInsertQueryCallable());
 
        $ilAtomQuery->run();
    }
 
 
    public function testNoQueries()
    {
        $this->setExpectedException('ilDatabaseException');
        $ilAtomQuery = $this->ilDBInterfaceInnoDB->buildAtomQuery();
        $ilAtomQuery->addTableLock('il_db_tests_atom');
 
        $ilAtomQuery->run();
    }
 
 
    public function testUpdateDuringTransaction()
    {
        $this->ilDBInterfaceGalera->insert('il_db_tests_atom', array(
            'id'        => array( 'integer', $this->ilDBInterfaceGalera->nextId('il_db_tests_atom') ),
            'is_online' => array( 'integer', 1 ),
        ));
 
        // Start a Transaction with one instance and update the same entry as another instance
        $this->ilDBInterfaceGalera->beginTransaction();
        $this->ilDBInterfaceGalera->update('il_db_tests_atom', array(
            'is_online' => array( 'integer', 5 ),
        ), array( 'id' => array( 'integer', 1 ) ));
 
        // Update the same entry with another instance (which currently fails due to missing multi-thread in PHP)
        //              $this->ilDBInterfaceGaleraSecond->update('il_db_tests_atom', array(
        //                      'is_online' => array( 'integer', 6 ),
        //              ), array( 'id' => array( 'integer', 1 ) ), true);
 
        // Commit the other
        $this->ilDBInterfaceGalera->commit();
 
        // Check
        $query = 'SELECT is_online FROM il_db_tests_atom WHERE id = ' . $this->ilDBInterfaceGalera->quote(1, 'integer');
        $res = $this->ilDBInterfaceGalera->query($query);
        $d = $this->ilDBInterfaceGalera->fetchAssoc($res);
 
        $this->assertEquals(5, $d['is_online']);
    }
 
 
    public function testUpdateDuringLock()
    {
        $this->ilDBInterfaceInnoDB->insert('il_db_tests_atom', array(
            'id'        => array( 'integer', $this->ilDBInterfaceInnoDB->nextId('il_db_tests_atom') ),
            'is_online' => array( 'integer', 1 ),
        ));
        // Start a Transaction with one instance and update the same entry as another instance
        $this->ilDBInterfaceInnoDB->lockTables(array( array( 'name' => 'il_db_tests_atom', 'type' => ilAtomQuery::LOCK_WRITE ) ));
        $this->ilDBInterfaceInnoDB->update('il_db_tests_atom', array(
            'is_online' => array( 'integer', 5 ),
        ), array( 'id' => array( 'integer', 1 ) ));
 
        // Update the same entry with another instance (which currently fails due to missing multi-thread in PHP)
        //              $this->ilDBInterfaceInnoDBSecond->update('il_db_tests_atom', array(
        //                      'is_online' => array( 'integer', 6 ),
        //              ), array( 'id' => array( 'integer', 1 ) ), true);
 
        // Unlock Tables
        $this->ilDBInterfaceInnoDB->unlockTables();
 
        // Check
        $query = 'SELECT is_online FROM il_db_tests_atom WHERE id = ' . $this->ilDBInterfaceInnoDB->quote(1, 'integer');
        $res = $this->ilDBInterfaceInnoDB->query($query);
        $d = $this->ilDBInterfaceInnoDB->fetchAssoc($res);
 
        $this->assertEquals(5, $d['is_online']);
    }
 
 
 
    //
    // HELPERS
    //
 
    protected function getInsertQueryCallable()
    {
        $query = function (ilDBInterface $ilDB) {
            $ilDB->insert('il_db_tests_atom', array(
                'id'        => array( 'integer', $ilDB->nextId('il_db_tests_atom') ),
                'is_online' => array( 'integer', 1 ),
            ));
            $ilDB->insert('il_db_tests_atom', array(
                'id'        => array( 'integer', $ilDB->nextId('il_db_tests_atom') ),
                'is_online' => array( 'integer', 0 ),
            ));
        };
 
        return $query;
    }
 
 
    protected function getTableLocksForDbInterface()
    {
        $tables = array(
            array(
                'name'     => 'il_db_tests_atom',
                'type'     => ilAtomQuery::LOCK_WRITE,
                'sequence' => true,
            ),
        );
 
        return $tables;
    }
 
 
    protected function getResultFromDB()
    {
        $res = $this->ilDBInterfaceGalera->query('SELECT * FROM il_db_tests_atom');
        $results = array();
        while ($d = $this->ilDBInterfaceGalera->fetchAssoc($res)) {
            $results[] = $d;
        }
 
        return $results;
    }
 
 
    protected function getExpectedResult()
    {
        return array(
            0 => array(
                'id'        => '1',
                'is_online' => '1',
            ),
            1 => array(
                'id'        => '2',
                'is_online' => '0',
            ),
        );
    }
}