|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
/** |
|
4
|
|
|
* TechDivision\Import\Actions\Processors\ProductPersistProcessor |
|
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 Tim Wagner <[email protected]> |
|
15
|
|
|
* @copyright 2016 TechDivision GmbH <[email protected]> |
|
16
|
|
|
* @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) |
|
17
|
|
|
* @link https://github.com/techdivision/import |
|
18
|
|
|
* @link http://www.techdivision.com |
|
19
|
|
|
*/ |
|
20
|
|
|
|
|
21
|
|
|
namespace TechDivision\Import\Actions\Processors; |
|
22
|
|
|
|
|
23
|
|
|
use TechDivision\Import\Connection\ConnectionInterface; |
|
24
|
|
|
use TechDivision\Import\Repositories\SqlStatementRepositoryInterface; |
|
25
|
|
|
|
|
26
|
|
|
/** |
|
27
|
|
|
* An abstract CRUD processor implementation. |
|
28
|
|
|
* |
|
29
|
|
|
* @author Tim Wagner <[email protected]> |
|
30
|
|
|
* @copyright 2016 TechDivision GmbH <[email protected]> |
|
31
|
|
|
* @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) |
|
32
|
|
|
* @link https://github.com/techdivision/import |
|
33
|
|
|
* @link http://www.techdivision.com |
|
34
|
|
|
*/ |
|
35
|
|
View Code Duplication |
abstract class AbstractProcessor implements ProcessorInterface |
|
|
|
|
|
|
36
|
|
|
{ |
|
37
|
|
|
|
|
38
|
|
|
/** |
|
39
|
|
|
* The connection instance. |
|
40
|
|
|
* . |
|
41
|
|
|
* @var \TechDivision\Import\Connection\ConnectionInterface; |
|
42
|
|
|
*/ |
|
43
|
|
|
protected $connection; |
|
44
|
|
|
|
|
45
|
|
|
/** |
|
46
|
|
|
* The respository instance with the SQL statements to use. |
|
47
|
|
|
* |
|
48
|
|
|
* @var \TechDivision\Import\Repositories\SqlStatementRepositoryInterface |
|
49
|
|
|
*/ |
|
50
|
|
|
protected $sqlStatementRepository; |
|
51
|
|
|
|
|
52
|
|
|
/** |
|
53
|
|
|
* Initialize the processor with the passed connection and utility class name. |
|
54
|
|
|
* . |
|
55
|
|
|
* @param \TechDivision\Import\Connection\ConnectionInterface $connection The connection instance |
|
56
|
|
|
* @param \TechDivision\Import\Repositories\SqlStatementRepositoryInterface $sqlStatementRepository The repository instance |
|
57
|
|
|
*/ |
|
58
|
|
|
public function __construct( |
|
59
|
|
|
ConnectionInterface $connection, |
|
60
|
|
|
SqlStatementRepositoryInterface $sqlStatementRepository |
|
61
|
|
|
) { |
|
62
|
|
|
|
|
63
|
|
|
// set the passed instances |
|
64
|
|
|
$this->setConnection($connection); |
|
65
|
|
|
$this->setSqlStatementRepository($sqlStatementRepository); |
|
66
|
|
|
|
|
67
|
|
|
// initialize the instance |
|
68
|
|
|
$this->init(); |
|
69
|
|
|
} |
|
70
|
|
|
|
|
71
|
|
|
/** |
|
72
|
|
|
* Set's the connection to use. |
|
73
|
|
|
* . |
|
74
|
|
|
* @param \TechDivision\Import\Connection\ConnectionInterface $connection The connection instance |
|
75
|
|
|
* |
|
76
|
|
|
* @return void |
|
77
|
|
|
*/ |
|
78
|
|
|
public function setConnection(ConnectionInterface $connection) |
|
79
|
|
|
{ |
|
80
|
|
|
$this->connection = $connection; |
|
81
|
|
|
} |
|
82
|
|
|
|
|
83
|
|
|
/** |
|
84
|
|
|
* Return's the connection to use. |
|
85
|
|
|
* |
|
86
|
|
|
* @return \TechDivision\Import\Connection\ConnectionInterface The connection instance |
|
87
|
|
|
*/ |
|
88
|
|
|
public function getConnection() |
|
89
|
|
|
{ |
|
90
|
|
|
return $this->connection; |
|
91
|
|
|
} |
|
92
|
|
|
|
|
93
|
|
|
/** |
|
94
|
|
|
* Set's the repository instance with the SQL statements to use. |
|
95
|
|
|
* |
|
96
|
|
|
* @param \TechDivision\Import\Repositories\SqlStatementRepositoryInterface $sqlStatementRepository The repository instance |
|
97
|
|
|
* |
|
98
|
|
|
* @return void |
|
99
|
|
|
*/ |
|
100
|
|
|
public function setSqlStatementRepository(SqlStatementRepositoryInterface $sqlStatementRepository) |
|
101
|
|
|
{ |
|
102
|
|
|
$this->sqlStatementRepository = $sqlStatementRepository; |
|
103
|
|
|
} |
|
104
|
|
|
|
|
105
|
|
|
/** |
|
106
|
|
|
* Return's the repository instance with the SQL statements to use. |
|
107
|
|
|
* |
|
108
|
|
|
* @return \TechDivision\Import\Repositories\SqlStatementRepositoryInterface The repository instance |
|
109
|
|
|
*/ |
|
110
|
|
|
public function getSqlStatementRepository() |
|
111
|
|
|
{ |
|
112
|
|
|
return $this->sqlStatementRepository; |
|
113
|
|
|
} |
|
114
|
|
|
|
|
115
|
|
|
/** |
|
116
|
|
|
* Return's the class name of the SQL repository instance with the SQL statements to use. |
|
117
|
|
|
* |
|
118
|
|
|
* @return string The SQL repository instance class name |
|
119
|
|
|
*/ |
|
120
|
|
|
public function getSqlStatementRepositoryClassName() |
|
121
|
|
|
{ |
|
122
|
|
|
return get_class($this->getSqlStatementRepository()); |
|
123
|
|
|
} |
|
124
|
|
|
|
|
125
|
|
|
/** |
|
126
|
|
|
* Load's the SQL statement with the passed ID from the SQL repository. |
|
127
|
|
|
* |
|
128
|
|
|
* @param string $id The ID of the SQL statement to load |
|
129
|
|
|
* |
|
130
|
|
|
* @return string The SQL statement with the passed ID |
|
131
|
|
|
*/ |
|
132
|
|
|
public function loadStatement($id) |
|
133
|
|
|
{ |
|
134
|
|
|
return $this->getSqlStatementRepository()->load($id); |
|
135
|
|
|
} |
|
136
|
|
|
} |
|
137
|
|
|
|
techdivision /
import
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.