SqlExpectedSchemaService.php

Go to the documentation of this file.

<?php
namespace TYPO3\CMS\Install\Service;

use TYPO3\CMS\Core\Utility\GeneralUtility;

class SqlExpectedSchemaService {

    protected $objectManager = NULL;

    protected $signalSlotDispatcher;

    public function getExpectedDatabaseSchema() {
        $schemaMigrationService = $this->objectManager->get('TYPO3\\CMS\\Install\\Service\\SqlSchemaMigrationService');
        // Raw concatenated ext_tables.sql and friends string
        $expectedSchemaString = $this->getTablesDefinitionString();
        // Remove comments
        $cleanedExpectedSchemaString = implode(LF, $schemaMigrationService->getStatementArray($expectedSchemaString, TRUE, '^CREATE TABLE '));
        $expectedSchema = $schemaMigrationService->getFieldDefinitions_fileContent($cleanedExpectedSchemaString);
        return $expectedSchema;
    }

    public function getTablesDefinitionString($withStatic = FALSE) {
        $sqlString = array();

        // Find all ext_tables.sql of loaded extensions
        $loadedExtensionInformation = $GLOBALS['TYPO3_LOADED_EXT'];
        foreach ($loadedExtensionInformation as $extensionConfiguration) {
            if ((is_array($extensionConfiguration) || $extensionConfiguration instanceof \ArrayAccess) && $extensionConfiguration['ext_tables.sql']) {
                $sqlString[] = GeneralUtility::getUrl($extensionConfiguration['ext_tables.sql']);
            }
            if ($withStatic
                && (is_array($extensionConfiguration) || $extensionConfiguration instanceof \ArrayAccess)
                && $extensionConfiguration['ext_tables_static+adt.sql']
            ) {
                $sqlString[] = GeneralUtility::getUrl($extensionConfiguration['ext_tables_static+adt.sql']);
            }
        }

        $sqlString = $this->emitTablesDefinitionIsBeingBuiltSignal($sqlString);

        return implode(LF . LF . LF . LF, $sqlString);
    }

    protected function emitTablesDefinitionIsBeingBuiltSignal(array $sqlString) {
        $signalReturn = $this->signalSlotDispatcher->dispatch(__CLASS__, 'tablesDefinitionIsBeingBuilt', array($sqlString));
        // This is important to support old associated returns
        $signalReturn = array_values($signalReturn);
        $sqlString = $signalReturn[0];
        if (!is_array($sqlString)) {
            throw new Exception\UnexpectedSignalReturnValueTypeException(
                sprintf(
                    'The signal %s of class %s returned a value of type %s, but array was expected.',
                    'tablesDefinitionIsBeingBuilt',
                    __CLASS__,
                    gettype($sqlString)
                ),
                1382351456
            );
        }
        return $sqlString;
    }
}