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',
                        ),
                );
        }
}