DAOBulkUpdatesTrait.php

Go to the documentation of this file.

<?php
 
namespace Ubiquity\orm\traits;
 
class DAOBulkUpdatesTrait {
    protected static $bulks = [ 'insert' => [ ],'update' => [ ],'delete' => [ ] ];
 
    protected static function getBulk($class, $operation = 'update') {
        if (! isset ( self::$bulks [$operation] [$class] )) {
            $bulkClass = '\\Ubiquity\\orm\\bulk\\Bulk' . \ucfirst ( $operation ) . 's';
            self::$bulks [$operation] [$class] = new $bulkClass ( $class );
        }
        return self::$bulks [$operation] [$class];
    }
 
    protected static function toOperation($instance, string $operation): void {
        $class = \get_class ( $instance );
        self::getBulk ( $class, $operation )->addInstance ( $instance );
    }
 
    protected static function toOperations(array $instances, string $operation): void {
        $instance = \current ( $instances );
        if (isset ( $instance )) {
            $class = \get_class ( $instance );
            self::getBulk ( $class, $operation )->addInstances ( $instances );
        }
    }
 
    public static function toInsert($instance): void {
        self::toOperation ( $instance, 'insert' );
    }
 
    public static function toInserts(array $instances): void {
        self::toOperations ( $instances, 'insert' );
    }
 
    public static function flushInserts(): void {
        $bulks = self::$bulks ['insert'];
        foreach ( $bulks as $bulk ) {
            $bulk->flush ();
        }
    }
 
    public static function toUpdate($instance): void {
        self::toOperation ( $instance, 'update' );
    }
 
    public static function toUpdates(array $instances): void {
        self::toOperations ( $instances, 'update' );
    }
 
    public static function updateGroups($count = 5) {
        $bulks = self::$bulks ['update'];
        foreach ( $bulks as $bulk ) {
            $bulk->groupOp ( $count );
        }
    }
 
    public static function insertGroups($count = 5) {
        $bulks = self::$bulks ['insert'];
        foreach ( $bulks as $bulk ) {
            $bulk->groupOp ( $count );
        }
    }
 
    public static function deleteGroups($count = 5) {
        $bulks = self::$bulks ['delete'];
        foreach ( $bulks as $bulk ) {
            $bulk->groupOp ( $count );
        }
    }
 
    public static function flushUpdates(): void {
        $bulks = self::$bulks ['update'];
        foreach ( $bulks as $bulk ) {
            $bulk->flush ();
        }
    }
 
    public static function toDelete($instance): void {
        self::toOperation ( $instance, 'delete' );
    }
 
    public static function toDeletes(array $instances): void {
        self::toOperations ( $instances, 'delete' );
    }
 
    public static function flushDeletes(): void {
        $bulks = self::$bulks ['delete'];
        foreach ( $bulks as $bulk ) {
            $bulk->flush ();
        }
    }
 
    public static function flush(): void {
        foreach ( self::$bulks as $bulks ) {
            foreach ( $bulks as $bulk ) {
                $bulk->flush ();
            }
        }
    }
 
    public static function clearBulks(?array $operations = null, ?array $classes = null): void {
        $operations ??= \array_keys ( self::$bulks );
        foreach ( $operations as $op ) {
            $thisClasses = $classes ?? \array_keys ( self::$bulks [$op] );
            foreach ( $thisClasses as $class ) {
                if (isset ( self::$bulks [$op] [$class] )) {
                    self::$bulks [$op] [$class]->clear ();
                }
            }
        }
    }
 
    public static function countInstancesBulk(string $class, string $operation = 'update'): int {
        $bulk = self::$bulks [$operation] [$class] ?? null;
        if (isset ( $bulk )) {
            return $bulk->count ();
        }
        return 0;
    }
}