Completed
Push — 11.x ( 365b0c )
by Tim
08:17
created

SqlStatementRepository::getPrimaryKeyUtil()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 3
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
eloc 1
dl 0
loc 3
ccs 0
cts 3
cp 0
rs 10
c 0
b 0
f 0
cc 1
nc 1
nop 0
crap 2
1
<?php
2
3
/**
4
 * TechDivision\Import\Product\TierPrice\Repositories\SqlStatementRepository
5
 *
6
 * NOTICE OF LICENSE
7
 *
8
 * This source file is subject to the Open Software License (OSL 3.0)
9
 * that is available through the world-wide-web at this URL:
10
 * http://opensource.org/licenses/osl-3.0.php
11
 *
12
 * PHP version 5
13
 *
14
 * @author    Klaas-Tido Rühl <[email protected]>
15
 * @author    Tim Wagner <[email protected]>
16
 * @copyright 2019 REFUSiON GmbH <[email protected]>
17
 * @license   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
18
 * @link      https://github.com/techdivision/import-product-tier-price
19
 * @link      https://www.techdivision.com
20
 * @link      https://www.refusion.com
21
 */
22
23
namespace TechDivision\Import\Product\TierPrice\Repositories;
24
25
use TechDivision\Import\Product\TierPrice\Utils\SqlStatementKeys;
26
27
/**
28
 * Adds statements specifically required for tier price CRUD operations.
29
 *
30
 * @author    Klaas-Tido Rühl <[email protected]>
31
 * @author    Tim Wagner <[email protected]>
32
 * @copyright 2019 REFUSiON GmbH <[email protected]>
33
 * @license   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
34
 * @link      https://github.com/techdivision/import-product-tier-price
35
 * @link      https://www.techdivision.com
36
 * @link      https://www.refusion.com
37
 */
38
class SqlStatementRepository extends \TechDivision\Import\Repositories\SqlStatementRepository
39
{
40
41
    /**
42
     * The SQL statements.
43
     *
44
     * @var array
45
     */
46
    private $statements = array(
47
        SqlStatementKeys::TIER_PRICES =>
48
            'SELECT *
49
               FROM ${table:catalog_product_entity_tier_price}',
50
        SqlStatementKeys::TIER_PRICE_BY_PK_AND_ALL_GROUPS_AND_CUSTOMER_GROUP_ID_AND_QTY_AND_WEBSITE_ID =>
51
            'SELECT *
52
               FROM ${table:catalog_product_entity_tier_price}
53
              WHERE ${pk:entity_id} = :${pk:entity_id}
54
                AND all_groups = :all_groups
55
                AND customer_group_id = :customer_group_id
56
                AND qty = :qty
57
                AND website_id = :website_id',
58
        SqlStatementKeys::DELETE_TIER_PRICE =>
59
            'DELETE
60
               FROM ${table:catalog_product_entity_tier_price}
61
              WHERE value_id = :value_id',
62
        SqlStatementKeys::CREATE_TIER_PRICE =>
63
            'INSERT
64
               INTO ${table:catalog_product_entity_tier_price}
65
                    (all_groups,
66
                     customer_group_id,
67
                     qty,
68
                     value,
69
                     website_id,
70
                     percentage_value,
71
                     ${pk:entity_id})
72
             VALUES (:all_groups,
73
                     :customer_group_id,
74
                     :qty,
75
                     :value,
76
                     :website_id,
77
                     :percentage_value,
78
                     :${pk:entity_id})',
79
        SqlStatementKeys::UPDATE_TIER_PRICE =>
80
            'UPDATE ${table:catalog_product_entity_tier_price}
81
                SET all_groups = :all_groups,
82
                    customer_group_id = :customer_group_id,
83
                    qty = :qty,
84
                    value = :value,
85
                    website_id = :website_id,
86
                    percentage_value = :percentage_value,
87
                    ${pk:entity_id} = :${pk:entity_id}
88
              WHERE value_id = :value_id'
89
    );
90
91
    /**
92
     * Initializes the SQL statement repository with the primary key and table prefix utility.
93
     *
94
     * @param \IteratorAggregate<\TechDivision\Import\Utils\SqlCompilerInterface> $compilers The array with the compiler instances
95
     */
96
    public function __construct(\IteratorAggregate $compilers)
97
    {
98
99
        // pass primary key + table prefix utility to parent instance
100
        parent::__construct($compilers);
101
102
        // compile the SQL statements
103
        $this->compile($this->statements);
104
    }
105
}
106