AutoTransactionBatchIterator::valid() - Code Metrics - SuRaMoN/itertools - Measure and Improve Code Quality continuously with Scrutinizer

AutoTransactionBatchIterator::valid() A
last analyzed 2020-05-28 15:38 UTC

↳ Parent: AutoTransactionBatchIterator

Complexity

Conditions	4
Paths	5

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	18
rs	9.6666
c	0
b	0
f	0
cc	4
nc	5
nop	0

<?php

namespace itertools;

use Exception;
use IteratorIterator;
use itertools\IterUtil;
use PDO;


class AutoTransactionBatchIterator extends IteratorIterator
{
	const START_TRANSACTION = -1;

	protected $batchSize;
	protected $pdo;
	protected $currentStep = self::START_TRANSACTION;
	protected $inTransaction = false;

	public function __construct($iterator, PDO $pdo, $batchSize = 100)
	{
		$this->batchSize = $batchSize;
		$this->pdo = $pdo;
		parent::__construct(IterUtil::asTraversable($iterator));
	}

	public function valid()
	{
		$valid = parent::valid();
		if(! $valid) {
			$this->commitIfInTransaction();
			return false;
		}
		if($this->currentStep >= $this->batchSize) {
			$this->currentStep = self::START_TRANSACTION;
			$this->commitIfInTransaction();
		}
		if(self::START_TRANSACTION == $this->currentStep) {
			$this->pdo->beginTransaction();
			$this->inTransaction = true;
			$this->currentStep = 0;
		}
		return true;
	}

	public function commitIfInTransaction()
	{
		if(! $this->inTransaction) {
			return;
		}
		try {
			$this->pdo->commit();
			$this->inTransaction = false;
		} catch(Exception $e) {
			$this->pdo->rollBack();
			$this->inTransaction = false;
			throw $e;
		}
	}

	public function next()
	{
		$this->currentStep += 1;
		parent::next();
	}

	public function __destruct()
	{
		if(! $this->inTransaction) {
			return;
		}
		// this can only be destructed in transaction if exception occured
		$this->pdo->rollBack();
	}
}



1			<?php
2
3			namespace itertools;
4
5			use Exception;
6			use IteratorIterator;
7			use itertools\IterUtil;
8			use PDO;
9
10
11			class AutoTransactionBatchIterator extends IteratorIterator
12			{
13			const START_TRANSACTION = -1;
14
15			protected $batchSize;
16			protected $pdo;
17			protected $currentStep = self::START_TRANSACTION;
18			protected $inTransaction = false;
19
20			public function __construct($iterator, PDO $pdo, $batchSize = 100)
21			{
22			$this->batchSize = $batchSize;
23			$this->pdo = $pdo;
24			parent::__construct(IterUtil::asTraversable($iterator));
25			}
26
27			public function valid()
28			{
29			$valid = parent::valid();
30			if(! $valid) {
31			$this->commitIfInTransaction();
32			return false;
33			}
34			if($this->currentStep >= $this->batchSize) {
35			$this->currentStep = self::START_TRANSACTION;
36			$this->commitIfInTransaction();
37			}
38			if(self::START_TRANSACTION == $this->currentStep) {
39			$this->pdo->beginTransaction();
40			$this->inTransaction = true;
41			$this->currentStep = 0;
42			}
43			return true;
44			}
45
46			public function commitIfInTransaction()
47			{
48			if(! $this->inTransaction) {
49			return;
50			}
51			try {
52			$this->pdo->commit();
53			$this->inTransaction = false;
54			} catch(Exception $e) {
55			$this->pdo->rollBack();
56			$this->inTransaction = false;
57			throw $e;
58			}
59			}
60
61			public function next()
62			{
63			$this->currentStep += 1;
64			parent::next();
65			}
66
67			public function __destruct()
68			{
69			if(! $this->inTransaction) {
70			return;
71			}
72			// this can only be destructed in transaction if exception occured
73			$this->pdo->rollBack();
74			}
75			}
76
77

SuRaMoN / itertools

AutoTransactionBatchIterator::valid() A last analyzed 2020-05-28 15:38 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

AutoTransactionBatchIterator::valid() A
last analyzed 2020-05-28 15:38 UTC