Ivory\StdCoreFactory

Complexity

Total Complexity

9

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	19

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	createGlobalTypeRegister()	0	70	2
A	createSqlPatternParser()	0	8	2
A	createStatementExceptionFactory()	0	4	1
A	createConnection()	0	4	1
A	createCacheControl()	0	18	2
A	createTransactionHandle()	0	6	1

<?php
namespace Ivory;

use Ivory\Cache\CacheControl;
use Ivory\Cache\ICacheControl;
use Ivory\Connection\Connection;
use Ivory\Connection\ConnectionParameters;
use Ivory\Connection\IConnection;
use Ivory\Connection\IObservableTransactionControl;
use Ivory\Connection\IStatementExecution;
use Ivory\Connection\ITxHandle;
use Ivory\Connection\TxHandle;
use Ivory\Exception\StatementExceptionFactory;
use Ivory\Lang;
use Ivory\Lang\SqlPattern\CachingSqlPatternParser;
use Ivory\Lang\SqlPattern\ISqlPatternParser;
use Ivory\Lang\SqlPattern\SqlPatternParser;
use Ivory\Type\Ivory\CommandSerializer;
use Ivory\Type\Ivory\IdentifierSerializer;
use Ivory\Type\Ivory\LikeExpressionSerializer;
use Ivory\Type\Ivory\QuotedIdentifierSerializer;
use Ivory\Type\Ivory\RelationSerializer;
use Ivory\Type\Ivory\SqlSerializer;
use Ivory\Type\Std\StdRangeCanonicalFuncProvider;
use Ivory\Type\Std\StdTypeLoader;
use Ivory\Type\TypeRegister;

/**
 * The standard factory for the core Ivory objects.
 *
 * The factory may either be inherited or replaced altogether to change any default behaviour of Ivory. The user
 * supplied factory may be activated with {@link Ivory::setCoreFactory()}. Note, however, that {@link Ivory} caches the
 * objects so setting another core factory is only effective at the very beginning of working with Ivory.
 */
class StdCoreFactory implements ICoreFactory
{
    public function createGlobalTypeRegister(): TypeRegister
    {
        $reg = new TypeRegister();
        $reg->registerTypeLoader(new StdTypeLoader());
        $reg->registerRangeCanonicalFuncProvider(new StdRangeCanonicalFuncProvider());

        $reservedTypes = Lang\Sql\Types::getReservedTypes();
        foreach ($reservedTypes as $alias => list($implSchema, $implName)) {
            $reg->registerTypeAbbreviation($alias, $implSchema, $implName);
        }

        // standard value serializers
        $reg->registerValueSerializer('sql', new SqlSerializer());
        $reg->registerValueSerializer('ident', new IdentifierSerializer());
        $reg->registerValueSerializer('qident', new QuotedIdentifierSerializer());
        $reg->registerValueSerializer('rel', new RelationSerializer());
        $reg->registerValueSerializer('cmd', new CommandSerializer());
        $reg->registerValueSerializer('like', new LikeExpressionSerializer(LikeExpressionSerializer::WILDCARD_NONE));
        $reg->registerValueSerializer('like_', new LikeExpressionSerializer(LikeExpressionSerializer::WILDCARD_APPEND));
        $reg->registerValueSerializer('_like', new LikeExpressionSerializer(LikeExpressionSerializer::WILDCARD_PREPEND));
        $reg->registerValueSerializer('_like_', new LikeExpressionSerializer(LikeExpressionSerializer::WILDCARD_BOTH));

        // standard type abbreviations
        $reg->registerTypeAbbreviation('s', 'pg_catalog', 'text');
        $reg->registerTypeAbbreviation('i', 'pg_catalog', 'bigint');
        $reg->registerTypeAbbreviation('num', 'pg_catalog', 'numeric');
        $reg->registerTypeAbbreviation('f', 'pg_catalog', 'float8');
        $reg->registerTypeAbbreviation('ts', 'pg_catalog', 'timestamp');
        $reg->registerTypeAbbreviation('tstz', 'pg_catalog', 'timestamptz');

        // standard type recognition rules
        $reg->addTypeRecognitionRule('int', 'pg_catalog', 'int8');
        $reg->addTypeRecognitionRule('string', 'pg_catalog', 'text');
        $reg->addTypeRecognitionRule('bool', 'pg_catalog', 'bool');
        $reg->addTypeRecognitionRule('float', 'pg_catalog', 'float8');
        $reg->addTypeRecognitionRule('null', 'pg_catalog', 'text');
        $reg->addTypeRecognitionRule('array', 'pg_catalog', 'text[]');
        $reg->addTypeRecognitionRule(\Ivory\Value\Decimal::class, 'pg_catalog', 'numeric');
        $reg->addTypeRecognitionRule(\Ivory\Value\Date::class, 'pg_catalog', 'date');
        $reg->addTypeRecognitionRule(\Ivory\Value\Time::class, 'pg_catalog', 'time');
        $reg->addTypeRecognitionRule(\Ivory\Value\TimeTz::class, 'pg_catalog', 'timetz');
        $reg->addTypeRecognitionRule(\Ivory\Value\Timestamp::class, 'pg_catalog', 'timestamp');
        $reg->addTypeRecognitionRule(\Ivory\Value\TimestampTz::class, 'pg_catalog', 'timestamptz');
        $reg->addTypeRecognitionRule(\Ivory\Value\TimeInterval::class, 'pg_catalog', 'interval');
        $reg->addTypeRecognitionRule(\Ivory\Value\FixedBitString::class, 'pg_catalog', 'bit');
        $reg->addTypeRecognitionRule(\Ivory\Value\VarBitString::class, 'pg_catalog', 'varbit');
        $reg->addTypeRecognitionRule(\Ivory\Value\Json::class, 'pg_catalog', 'json');
        $reg->addTypeRecognitionRule(\Ivory\Value\XmlContent::class, 'pg_catalog', 'xml');
        $reg->addTypeRecognitionRule(\Ivory\Value\XmlDocument::class, 'pg_catalog', 'xml');
        $reg->addTypeRecognitionRule(\DOMDocument::class, 'pg_catalog', 'xml');
        $reg->addTypeRecognitionRule(\DOMNode::class, 'pg_catalog', 'xml');
        $reg->addTypeRecognitionRule(\DOMNodeList::class, 'pg_catalog', 'xml');
        $reg->addTypeRecognitionRule(\SimpleXMLElement::class, 'pg_catalog', 'xml');
        $reg->addTypeRecognitionRule(\Ivory\Value\Point::class, 'pg_catalog', 'point');
        $reg->addTypeRecognitionRule(\Ivory\Value\Line::class, 'pg_catalog', 'line');
        $reg->addTypeRecognitionRule(\Ivory\Value\LineSegment::class, 'pg_catalog', 'lseg');
        $reg->addTypeRecognitionRule(\Ivory\Value\Box::class, 'pg_catalog', 'box');
        $reg->addTypeRecognitionRule(\Ivory\Value\Path::class, 'pg_catalog', 'path');
        $reg->addTypeRecognitionRule(\Ivory\Value\Polygon::class, 'pg_catalog', 'polygon');
        $reg->addTypeRecognitionRule(\Ivory\Value\Circle::class, 'pg_catalog', 'circle');
        $reg->addTypeRecognitionRule(\Ivory\Value\NetAddress::class, 'pg_catalog', 'inet');
        $reg->addTypeRecognitionRule(\Ivory\Value\MacAddr::class, 'pg_catalog', 'macaddr');
        $reg->addTypeRecognitionRule(\Ivory\Value\Money::class, 'pg_catalog', 'money');
        $reg->addTypeRecognitionRule(\Ivory\Value\PgLogSequenceNumber::class, 'pg_catalog', 'pg_lsn');
        $reg->addTypeRecognitionRule(\Ivory\Value\TxIdSnapshot::class, 'pg_catalog', 'txid_snapshot');
        $reg->addTypeRecognitionRule(\Ivory\Value\TextSearchVector::class, 'pg_catalog', 'tsvector');
        $reg->addTypeRecognitionRule(\Ivory\Value\TextSearchQuery::class, 'pg_catalog', 'tsquery');

        return $reg;
    }

    public function createSqlPatternParser(ICacheControl $cacheControl = null): ISqlPatternParser
    {
        if ($cacheControl === null) {
            return new SqlPatternParser();
        } else {
            return new CachingSqlPatternParser($cacheControl);
        }
    }

    public function createStatementExceptionFactory(): StatementExceptionFactory
    {
        return new StatementExceptionFactory();
    }

    public function createConnection(string $connName, ConnectionParameters $params): IConnection
    {
        return new Connection($connName, $params);
    }

    public function createCacheControl(IConnection $connection = null): ICacheControl
    {
        $prefix = 'Ivory' . Ivory::VERSION . '.';

        if ($connection === null) {
            $postfix = '';
        } else {
            $params = $connection->getParameters();
            $postfix = sprintf(
                '.%s.%d.%s',
                $params->getHost(),
                $params->getPort(),
                $params->getDbName()
            );
        }

        return new CacheControl(Ivory::getDefaultCacheImpl(), $prefix, $postfix);
    }

    public function createTransactionHandle(
        IStatementExecution $stmtExec,
        IObservableTransactionControl $observableTxCtl
    ): ITxHandle {
        return new TxHandle($stmtExec, $observableTxCtl);
    }
}