Completed
Push — 4.0 ( 984e8a...f02fa4 )
by David
08:59 queued 18s
created
src/Mouf/Database/TDBM/Controllers/TdbmInstallController.php 2 patches
Doc Comments   +3 added lines patch added patch discarded remove patch
@@ -181,6 +181,9 @@
 block discarded – undo
181 181
 
182 182
     protected $errorMsg;
183 183
 
184
+    /**
185
+     * @param string $msg
186
+     */
184 187
     private function displayErrorMsg($msg)
185 188
     {
186 189
         $this->errorMsg = $msg;
Please login to merge, or discard this patch.
Indentation   +172 added lines, -172 removed lines patch added patch discarded remove patch
@@ -15,176 +15,176 @@
 block discarded – undo
15 15
  */
16 16
 class TdbmInstallController extends Controller
17 17
 {
18
-    /**
19
-     * @var HtmlBlock
20
-     */
21
-    public $content;
22
-
23
-    public $selfedit;
24
-
25
-    /**
26
-     * The active MoufManager to be edited/viewed.
27
-     *
28
-     * @var MoufManager
29
-     */
30
-    public $moufManager;
31
-
32
-    /**
33
-     * The template used by the main page for mouf.
34
-     *
35
-     * @Property
36
-     * @Compulsory
37
-     *
38
-     * @var TemplateInterface
39
-     */
40
-    public $template;
41
-
42
-    /**
43
-     * Displays the first install screen.
44
-     *
45
-     * @Action
46
-     * @Logged
47
-     *
48
-     * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
49
-     */
50
-    public function defaultAction($selfedit = 'false')
51
-    {
52
-        $this->selfedit = $selfedit;
53
-
54
-        if ($selfedit == 'true') {
55
-            $this->moufManager = MoufManager::getMoufManager();
56
-        } else {
57
-            $this->moufManager = MoufManager::getMoufManagerHiddenInstance();
58
-        }
59
-
60
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installStep1.php', $this);
61
-        $this->template->toHtml();
62
-    }
63
-
64
-    /**
65
-     * Skips the install process.
66
-     *
67
-     * @Action
68
-     * @Logged
69
-     *
70
-     * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
71
-     */
72
-    public function skip($selfedit = 'false')
73
-    {
74
-        InstallUtils::continueInstall($selfedit == 'true');
75
-    }
76
-
77
-    protected $daoNamespace;
78
-    protected $beanNamespace;
79
-    protected $autoloadDetected;
80
-    protected $storeInUtc;
81
-
82
-    /**
83
-     * Displays the second install screen.
84
-     *
85
-     * @Action
86
-     * @Logged
87
-     *
88
-     * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
89
-     */
90
-    public function configure($selfedit = 'false')
91
-    {
92
-        $this->selfedit = $selfedit;
93
-
94
-        if ($selfedit == 'true') {
95
-            $this->moufManager = MoufManager::getMoufManager();
96
-        } else {
97
-            $this->moufManager = MoufManager::getMoufManagerHiddenInstance();
98
-        }
99
-
100
-        // Let's start by performing basic checks about the instances we assume to exist.
101
-        if (!$this->moufManager->instanceExists('dbalConnection')) {
102
-            $this->displayErrorMsg("The TDBM install process assumes your database connection instance is already created, and that the name of this instance is 'dbalConnection'. Could not find the 'dbalConnection' instance.");
103
-
104
-            return;
105
-        }
106
-
107
-        if (!$this->moufManager->instanceExists('noCacheService')) {
108
-            $this->displayErrorMsg("The TDBM install process assumes that a cache instance named 'noCacheService' exists. Could not find the 'noCacheService' instance.");
109
-
110
-            return;
111
-        }
112
-
113
-        $this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace_tdbmService');
114
-        $this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace_tdbmService');
115
-
116
-        if ($this->daoNamespace == null && $this->beanNamespace == null) {
117
-            $classNameMapper = ClassNameMapper::createFromComposerFile(__DIR__.'/../../../../../../../../composer.json');
118
-
119
-            $autoloadNamespaces = $classNameMapper->getManagedNamespaces();
120
-            if ($autoloadNamespaces) {
121
-                $this->autoloadDetected = true;
122
-                $rootNamespace = $autoloadNamespaces[0];
123
-                $this->daoNamespace = $rootNamespace.'Dao';
124
-                $this->beanNamespace = $rootNamespace.'Dao\\Bean';
125
-            } else {
126
-                $this->autoloadDetected = false;
127
-                $this->daoNamespace = 'YourApplication\\Dao';
128
-                $this->beanNamespace = 'YourApplication\\Dao\\Bean';
129
-            }
130
-        } else {
131
-            $this->autoloadDetected = true;
132
-        }
133
-
134
-        $this->castDatesToDateTime = true;
135
-
136
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installStep2.php', $this);
137
-        $this->template->toHtml();
138
-    }
139
-
140
-    /**
141
-     * This action generates the TDBM instance, then the DAOs and Beans.
142
-     *
143
-     * @Action
144
-     *
145
-     * @param string $daonamespace
146
-     * @param string $beannamespace
147
-     * @param int    $storeInUtc
148
-     * @param string $selfedit
149
-     *
150
-     * @throws \Mouf\MoufException
151
-     */
152
-    public function generate($daonamespace, $beannamespace, $storeInUtc = 0, $selfedit = 'false')
153
-    {
154
-        $this->selfedit = $selfedit;
155
-
156
-        if ($selfedit == 'true') {
157
-            $this->moufManager = MoufManager::getMoufManager();
158
-        } else {
159
-            $this->moufManager = MoufManager::getMoufManagerHiddenInstance();
160
-        }
161
-
162
-        if (!$this->moufManager->instanceExists('doctrineApcCache')) {
163
-            $doctrineApcCache = $this->moufManager->createInstance('Doctrine\\Common\\Cache\\ApcCache')->setName('doctrineApcCache');
164
-            // TODO: set namespace
165
-        } else {
166
-            $doctrineApcCache = $this->moufManager->getInstanceDescriptor('doctrineApcCache');
167
-        }
168
-
169
-        if (!$this->moufManager->instanceExists('tdbmService')) {
170
-            $tdbmService = $this->moufManager->createInstance('Mouf\\Database\\TDBM\\TDBMService')->setName('tdbmService');
171
-            $tdbmService->getConstructorArgumentProperty('connection')->setValue($this->moufManager->getInstanceDescriptor('dbalConnection'));
172
-            $tdbmService->getConstructorArgumentProperty('cache')->setValue($doctrineApcCache);
173
-        }
174
-
175
-        $this->moufManager->rewriteMouf();
176
-
177
-        TdbmController::generateDaos($this->moufManager, 'tdbmService', $daonamespace, $beannamespace, 'DaoFactory', 'daoFactory', $selfedit, $storeInUtc);
178
-
179
-        InstallUtils::continueInstall($selfedit == 'true');
180
-    }
181
-
182
-    protected $errorMsg;
183
-
184
-    private function displayErrorMsg($msg)
185
-    {
186
-        $this->errorMsg = $msg;
187
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installError.php', $this);
188
-        $this->template->toHtml();
189
-    }
18
+	/**
19
+	 * @var HtmlBlock
20
+	 */
21
+	public $content;
22
+
23
+	public $selfedit;
24
+
25
+	/**
26
+	 * The active MoufManager to be edited/viewed.
27
+	 *
28
+	 * @var MoufManager
29
+	 */
30
+	public $moufManager;
31
+
32
+	/**
33
+	 * The template used by the main page for mouf.
34
+	 *
35
+	 * @Property
36
+	 * @Compulsory
37
+	 *
38
+	 * @var TemplateInterface
39
+	 */
40
+	public $template;
41
+
42
+	/**
43
+	 * Displays the first install screen.
44
+	 *
45
+	 * @Action
46
+	 * @Logged
47
+	 *
48
+	 * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
49
+	 */
50
+	public function defaultAction($selfedit = 'false')
51
+	{
52
+		$this->selfedit = $selfedit;
53
+
54
+		if ($selfedit == 'true') {
55
+			$this->moufManager = MoufManager::getMoufManager();
56
+		} else {
57
+			$this->moufManager = MoufManager::getMoufManagerHiddenInstance();
58
+		}
59
+
60
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installStep1.php', $this);
61
+		$this->template->toHtml();
62
+	}
63
+
64
+	/**
65
+	 * Skips the install process.
66
+	 *
67
+	 * @Action
68
+	 * @Logged
69
+	 *
70
+	 * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
71
+	 */
72
+	public function skip($selfedit = 'false')
73
+	{
74
+		InstallUtils::continueInstall($selfedit == 'true');
75
+	}
76
+
77
+	protected $daoNamespace;
78
+	protected $beanNamespace;
79
+	protected $autoloadDetected;
80
+	protected $storeInUtc;
81
+
82
+	/**
83
+	 * Displays the second install screen.
84
+	 *
85
+	 * @Action
86
+	 * @Logged
87
+	 *
88
+	 * @param string $selfedit If true, the name of the component must be a component from the Mouf framework itself (internal use only)
89
+	 */
90
+	public function configure($selfedit = 'false')
91
+	{
92
+		$this->selfedit = $selfedit;
93
+
94
+		if ($selfedit == 'true') {
95
+			$this->moufManager = MoufManager::getMoufManager();
96
+		} else {
97
+			$this->moufManager = MoufManager::getMoufManagerHiddenInstance();
98
+		}
99
+
100
+		// Let's start by performing basic checks about the instances we assume to exist.
101
+		if (!$this->moufManager->instanceExists('dbalConnection')) {
102
+			$this->displayErrorMsg("The TDBM install process assumes your database connection instance is already created, and that the name of this instance is 'dbalConnection'. Could not find the 'dbalConnection' instance.");
103
+
104
+			return;
105
+		}
106
+
107
+		if (!$this->moufManager->instanceExists('noCacheService')) {
108
+			$this->displayErrorMsg("The TDBM install process assumes that a cache instance named 'noCacheService' exists. Could not find the 'noCacheService' instance.");
109
+
110
+			return;
111
+		}
112
+
113
+		$this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace_tdbmService');
114
+		$this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace_tdbmService');
115
+
116
+		if ($this->daoNamespace == null && $this->beanNamespace == null) {
117
+			$classNameMapper = ClassNameMapper::createFromComposerFile(__DIR__.'/../../../../../../../../composer.json');
118
+
119
+			$autoloadNamespaces = $classNameMapper->getManagedNamespaces();
120
+			if ($autoloadNamespaces) {
121
+				$this->autoloadDetected = true;
122
+				$rootNamespace = $autoloadNamespaces[0];
123
+				$this->daoNamespace = $rootNamespace.'Dao';
124
+				$this->beanNamespace = $rootNamespace.'Dao\\Bean';
125
+			} else {
126
+				$this->autoloadDetected = false;
127
+				$this->daoNamespace = 'YourApplication\\Dao';
128
+				$this->beanNamespace = 'YourApplication\\Dao\\Bean';
129
+			}
130
+		} else {
131
+			$this->autoloadDetected = true;
132
+		}
133
+
134
+		$this->castDatesToDateTime = true;
135
+
136
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installStep2.php', $this);
137
+		$this->template->toHtml();
138
+	}
139
+
140
+	/**
141
+	 * This action generates the TDBM instance, then the DAOs and Beans.
142
+	 *
143
+	 * @Action
144
+	 *
145
+	 * @param string $daonamespace
146
+	 * @param string $beannamespace
147
+	 * @param int    $storeInUtc
148
+	 * @param string $selfedit
149
+	 *
150
+	 * @throws \Mouf\MoufException
151
+	 */
152
+	public function generate($daonamespace, $beannamespace, $storeInUtc = 0, $selfedit = 'false')
153
+	{
154
+		$this->selfedit = $selfedit;
155
+
156
+		if ($selfedit == 'true') {
157
+			$this->moufManager = MoufManager::getMoufManager();
158
+		} else {
159
+			$this->moufManager = MoufManager::getMoufManagerHiddenInstance();
160
+		}
161
+
162
+		if (!$this->moufManager->instanceExists('doctrineApcCache')) {
163
+			$doctrineApcCache = $this->moufManager->createInstance('Doctrine\\Common\\Cache\\ApcCache')->setName('doctrineApcCache');
164
+			// TODO: set namespace
165
+		} else {
166
+			$doctrineApcCache = $this->moufManager->getInstanceDescriptor('doctrineApcCache');
167
+		}
168
+
169
+		if (!$this->moufManager->instanceExists('tdbmService')) {
170
+			$tdbmService = $this->moufManager->createInstance('Mouf\\Database\\TDBM\\TDBMService')->setName('tdbmService');
171
+			$tdbmService->getConstructorArgumentProperty('connection')->setValue($this->moufManager->getInstanceDescriptor('dbalConnection'));
172
+			$tdbmService->getConstructorArgumentProperty('cache')->setValue($doctrineApcCache);
173
+		}
174
+
175
+		$this->moufManager->rewriteMouf();
176
+
177
+		TdbmController::generateDaos($this->moufManager, 'tdbmService', $daonamespace, $beannamespace, 'DaoFactory', 'daoFactory', $selfedit, $storeInUtc);
178
+
179
+		InstallUtils::continueInstall($selfedit == 'true');
180
+	}
181
+
182
+	protected $errorMsg;
183
+
184
+	private function displayErrorMsg($msg)
185
+	{
186
+		$this->errorMsg = $msg;
187
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installError.php', $this);
188
+		$this->template->toHtml();
189
+	}
190 190
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/TDBMObject.php 1 patch
Indentation   +21 added lines, -21 removed lines patch added patch discarded remove patch
@@ -33,25 +33,25 @@
 block discarded – undo
33 33
  */
34 34
 class TDBMObject extends AbstractTDBMObject
35 35
 {
36
-    public function getProperty($var, $tableName = null)
37
-    {
38
-        return $this->get($var, $tableName);
39
-    }
40
-
41
-    public function setProperty($var, $value, $tableName = null)
42
-    {
43
-        $this->set($var, $value, $tableName);
44
-    }
45
-
46
-    /**
47
-     * Specify data which should be serialized to JSON
48
-     * @link http://php.net/manual/en/jsonserializable.jsonserialize.php
49
-     * @return mixed data which can be serialized by <b>json_encode</b>,
50
-     * which is a value of any type other than a resource.
51
-     * @since 5.4.0
52
-     */
53
-    public function jsonSerialize()
54
-    {
55
-        throw new TDBMException('Json serialization is only implemented for generated beans.');
56
-    }
36
+	public function getProperty($var, $tableName = null)
37
+	{
38
+		return $this->get($var, $tableName);
39
+	}
40
+
41
+	public function setProperty($var, $value, $tableName = null)
42
+	{
43
+		$this->set($var, $value, $tableName);
44
+	}
45
+
46
+	/**
47
+	 * Specify data which should be serialized to JSON
48
+	 * @link http://php.net/manual/en/jsonserializable.jsonserialize.php
49
+	 * @return mixed data which can be serialized by <b>json_encode</b>,
50
+	 * which is a value of any type other than a resource.
51
+	 * @since 5.4.0
52
+	 */
53
+	public function jsonSerialize()
54
+	{
55
+		throw new TDBMException('Json serialization is only implemented for generated beans.');
56
+	}
57 57
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/AbstractTDBMObject.php 2 patches
Indentation   +489 added lines, -489 removed lines patch added patch discarded remove patch
@@ -31,493 +31,493 @@
 block discarded – undo
31 31
  */
32 32
 abstract class AbstractTDBMObject implements JsonSerializable
33 33
 {
34
-    /**
35
-     * The service this object is bound to.
36
-     *
37
-     * @var TDBMService
38
-     */
39
-    protected $tdbmService;
40
-
41
-    /**
42
-     * An array of DbRow, indexed by table name.
43
-     *
44
-     * @var DbRow[]
45
-     */
46
-    protected $dbRows = array();
47
-
48
-    /**
49
-     * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
50
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
51
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
52
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
53
-     *
54
-     * @var string
55
-     */
56
-    private $status;
57
-
58
-    /**
59
-     * Array storing beans related via many to many relationships (pivot tables).
60
-     *
61
-     * @var \SplObjectStorage[] Key: pivot table name, value: SplObjectStorage
62
-     */
63
-    private $relationships = [];
64
-
65
-    /**
66
-     * @var bool[] Key: pivot table name, value: whether a query was performed to load the data.
67
-     */
68
-    private $loadedRelationships = [];
69
-
70
-    /**
71
-     * Used with $primaryKeys when we want to retrieve an existing object
72
-     * and $primaryKeys=[] if we want a new object.
73
-     *
74
-     * @param string      $tableName
75
-     * @param array       $primaryKeys
76
-     * @param TDBMService $tdbmService
77
-     *
78
-     * @throws TDBMException
79
-     * @throws TDBMInvalidOperationException
80
-     */
81
-    public function __construct($tableName = null, array $primaryKeys = array(), TDBMService $tdbmService = null)
82
-    {
83
-        // FIXME: lazy loading should be forbidden on tables with inheritance and dynamic type assignation...
84
-        if (!empty($tableName)) {
85
-            $this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
86
-        }
87
-
88
-        if ($tdbmService === null) {
89
-            $this->_setStatus(TDBMObjectStateEnum::STATE_DETACHED);
90
-        } else {
91
-            $this->_attach($tdbmService);
92
-            if (!empty($primaryKeys)) {
93
-                $this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
94
-            } else {
95
-                $this->_setStatus(TDBMObjectStateEnum::STATE_NEW);
96
-            }
97
-        }
98
-    }
99
-
100
-    /**
101
-     * Alternative constructor called when data is fetched from database via a SELECT.
102
-     *
103
-     * @param array       $beanData    array<table, array<column, value>>
104
-     * @param TDBMService $tdbmService
105
-     */
106
-    public function _constructFromData(array $beanData, TDBMService $tdbmService)
107
-    {
108
-        $this->tdbmService = $tdbmService;
109
-
110
-        foreach ($beanData as $table => $columns) {
111
-            $this->dbRows[$table] = new DbRow($this, $table, $tdbmService->_getPrimaryKeysFromObjectData($table, $columns), $tdbmService, $columns);
112
-        }
113
-
114
-        $this->status = TDBMObjectStateEnum::STATE_LOADED;
115
-    }
116
-
117
-    /**
118
-     * Alternative constructor called when bean is lazily loaded.
119
-     *
120
-     * @param string      $tableName
121
-     * @param array       $primaryKeys
122
-     * @param TDBMService $tdbmService
123
-     */
124
-    public function _constructLazy($tableName, array $primaryKeys, TDBMService $tdbmService)
125
-    {
126
-        $this->tdbmService = $tdbmService;
127
-
128
-        $this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
129
-
130
-        $this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
131
-    }
132
-
133
-    public function _attach(TDBMService $tdbmService)
134
-    {
135
-        if ($this->status !== TDBMObjectStateEnum::STATE_DETACHED) {
136
-            throw new TDBMInvalidOperationException('Cannot attach an object that is already attached to TDBM.');
137
-        }
138
-        $this->tdbmService = $tdbmService;
139
-
140
-        // If we attach this object, we must work to make sure the tables are in ascending order (from low level to top level)
141
-        $tableNames = array_keys($this->dbRows);
142
-        $tableNames = $this->tdbmService->_getLinkBetweenInheritedTables($tableNames);
143
-        $tableNames = array_reverse($tableNames);
144
-
145
-        $newDbRows = [];
146
-
147
-        foreach ($tableNames as $table) {
148
-            if (!isset($this->dbRows[$table])) {
149
-                $this->registerTable($table);
150
-            }
151
-            $newDbRows[$table] = $this->dbRows[$table];
152
-        }
153
-        $this->dbRows = $newDbRows;
154
-
155
-        $this->status = TDBMObjectStateEnum::STATE_NEW;
156
-        foreach ($this->dbRows as $dbRow) {
157
-            $dbRow->_attach($tdbmService);
158
-        }
159
-    }
160
-
161
-    /**
162
-     * Sets the state of the TDBM Object
163
-     * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
164
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
165
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
166
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
167
-     *
168
-     * @param string $state
169
-     */
170
-    public function _setStatus($state)
171
-    {
172
-        $this->status = $state;
173
-
174
-        // TODO: we might ignore the loaded => dirty state here! dirty status comes from the db_row itself.
175
-        foreach ($this->dbRows as $dbRow) {
176
-            $dbRow->_setStatus($state);
177
-        }
178
-    }
179
-
180
-    protected function get($var, $tableName = null)
181
-    {
182
-        if ($tableName === null) {
183
-            if (count($this->dbRows) > 1) {
184
-                throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
185
-            } elseif (count($this->dbRows) === 1) {
186
-                $tableName = array_keys($this->dbRows)[0];
187
-            }
188
-        }
189
-
190
-        if (!isset($this->dbRows[$tableName])) {
191
-            if (count($this->dbRows[$tableName] === 0)) {
192
-                throw new TDBMException('Object is not yet bound to any table.');
193
-            } else {
194
-                throw new TDBMException('Unknown table "'.$tableName.'"" in object.');
195
-            }
196
-        }
197
-
198
-        return $this->dbRows[$tableName]->get($var);
199
-    }
200
-
201
-    protected function set($var, $value, $tableName = null)
202
-    {
203
-        if ($tableName === null) {
204
-            if (count($this->dbRows) > 1) {
205
-                throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
206
-            } elseif (count($this->dbRows) === 1) {
207
-                $tableName = array_keys($this->dbRows)[0];
208
-            } else {
209
-                throw new TDBMException('Please specify a table for this object.');
210
-            }
211
-        }
212
-
213
-        if (!isset($this->dbRows[$tableName])) {
214
-            $this->registerTable($tableName);
215
-        }
216
-
217
-        $this->dbRows[$tableName]->set($var, $value);
218
-        if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
219
-            $this->status = TDBMObjectStateEnum::STATE_DIRTY;
220
-        }
221
-    }
222
-
223
-    /**
224
-     * @param string             $foreignKeyName
225
-     * @param AbstractTDBMObject $bean
226
-     */
227
-    protected function setRef($foreignKeyName, AbstractTDBMObject $bean, $tableName = null)
228
-    {
229
-        if ($tableName === null) {
230
-            if (count($this->dbRows) > 1) {
231
-                throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
232
-            } elseif (count($this->dbRows) === 1) {
233
-                $tableName = array_keys($this->dbRows)[0];
234
-            } else {
235
-                throw new TDBMException('Please specify a table for this object.');
236
-            }
237
-        }
238
-
239
-        if (!isset($this->dbRows[$tableName])) {
240
-            $this->registerTable($tableName);
241
-        }
242
-
243
-        $this->dbRows[$tableName]->setRef($foreignKeyName, $bean);
244
-        if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
245
-            $this->status = TDBMObjectStateEnum::STATE_DIRTY;
246
-        }
247
-    }
248
-
249
-    /**
250
-     * @param string $foreignKeyName A unique name for this reference
251
-     *
252
-     * @return AbstractTDBMObject|null
253
-     */
254
-    protected function getRef($foreignKeyName, $tableName = null)
255
-    {
256
-        if ($tableName === null) {
257
-            if (count($this->dbRows) > 1) {
258
-                throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
259
-            } elseif (count($this->dbRows) === 1) {
260
-                $tableName = array_keys($this->dbRows)[0];
261
-            }
262
-        }
263
-
264
-        if (!isset($this->dbRows[$tableName])) {
265
-            if (count($this->dbRows[$tableName] === 0)) {
266
-                throw new TDBMException('Object is not yet bound to any table.');
267
-            } else {
268
-                throw new TDBMException('Unknown table "'.$tableName.'"" in object.');
269
-            }
270
-        }
271
-
272
-        return $this->dbRows[$tableName]->getRef($foreignKeyName);
273
-    }
274
-
275
-    /**
276
-     * Adds a many to many relationship to this bean.
277
-     *
278
-     * @param string             $pivotTableName
279
-     * @param AbstractTDBMObject $remoteBean
280
-     */
281
-    protected function addRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
282
-    {
283
-        $this->setRelationship($pivotTableName, $remoteBean, 'new');
284
-    }
285
-
286
-    /**
287
-     * Returns true if there is a relationship to this bean.
288
-     *
289
-     * @param string             $pivotTableName
290
-     * @param AbstractTDBMObject $remoteBean
291
-     *
292
-     * @return bool
293
-     */
294
-    protected function hasRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
295
-    {
296
-        $storage = $this->retrieveRelationshipsStorage($pivotTableName);
297
-
298
-        if ($storage->contains($remoteBean)) {
299
-            if ($storage[$remoteBean]['status'] !== 'delete') {
300
-                return true;
301
-            }
302
-        }
303
-
304
-        return false;
305
-    }
306
-
307
-    /**
308
-     * Internal TDBM method. Removes a many to many relationship from this bean.
309
-     *
310
-     * @param string             $pivotTableName
311
-     * @param AbstractTDBMObject $remoteBean
312
-     */
313
-    public function _removeRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
314
-    {
315
-        if (isset($this->relationships[$pivotTableName][$remoteBean]) && $this->relationships[$pivotTableName][$remoteBean]['status'] === 'new') {
316
-            unset($this->relationships[$pivotTableName][$remoteBean]);
317
-            unset($remoteBean->relationships[$pivotTableName][$this]);
318
-        } else {
319
-            $this->setRelationship($pivotTableName, $remoteBean, 'delete');
320
-        }
321
-    }
322
-
323
-    /**
324
-     * Returns the list of objects linked to this bean via $pivotTableName.
325
-     *
326
-     * @param $pivotTableName
327
-     *
328
-     * @return \SplObjectStorage
329
-     */
330
-    private function retrieveRelationshipsStorage($pivotTableName)
331
-    {
332
-        $storage = $this->getRelationshipStorage($pivotTableName);
333
-        if ($this->status === TDBMObjectStateEnum::STATE_DETACHED || $this->status === TDBMObjectStateEnum::STATE_NEW || isset($this->loadedRelationships[$pivotTableName]) && $this->loadedRelationships[$pivotTableName]) {
334
-            return $storage;
335
-        }
336
-
337
-        $beans = $this->tdbmService->_getRelatedBeans($pivotTableName, $this);
338
-        $this->loadedRelationships[$pivotTableName] = true;
339
-
340
-        foreach ($beans as $bean) {
341
-            if (isset($storage[$bean])) {
342
-                $oldStatus = $storage[$bean]['status'];
343
-                if ($oldStatus === 'delete') {
344
-                    // Keep deleted things deleted
345
-                    continue;
346
-                }
347
-            }
348
-            $this->setRelationship($pivotTableName, $bean, 'loaded');
349
-        }
350
-
351
-        return $storage;
352
-    }
353
-
354
-    /**
355
-     * Internal TDBM method. Returns the list of objects linked to this bean via $pivotTableName.
356
-     *
357
-     * @param $pivotTableName
358
-     *
359
-     * @return AbstractTDBMObject[]
360
-     */
361
-    public function _getRelationships($pivotTableName)
362
-    {
363
-        return $this->relationshipStorageToArray($this->retrieveRelationshipsStorage($pivotTableName));
364
-    }
365
-
366
-    private function relationshipStorageToArray(\SplObjectStorage $storage)
367
-    {
368
-        $beans = [];
369
-        foreach ($storage as $bean) {
370
-            $statusArr = $storage[$bean];
371
-            if ($statusArr['status'] !== 'delete') {
372
-                $beans[] = $bean;
373
-            }
374
-        }
375
-
376
-        return $beans;
377
-    }
378
-
379
-    /**
380
-     * Declares a relationship between.
381
-     *
382
-     * @param string             $pivotTableName
383
-     * @param AbstractTDBMObject $remoteBean
384
-     * @param string             $status
385
-     */
386
-    private function setRelationship($pivotTableName, AbstractTDBMObject $remoteBean, $status)
387
-    {
388
-        $storage = $this->getRelationshipStorage($pivotTableName);
389
-        $storage->attach($remoteBean, ['status' => $status, 'reverse' => false]);
390
-        if ($this->status === TDBMObjectStateEnum::STATE_LOADED) {
391
-            $this->_setStatus(TDBMObjectStateEnum::STATE_DIRTY);
392
-        }
393
-
394
-        $remoteStorage = $remoteBean->getRelationshipStorage($pivotTableName);
395
-        $remoteStorage->attach($this, ['status' => $status, 'reverse' => true]);
396
-    }
397
-
398
-    /**
399
-     * Returns the SplObjectStorage associated to this relationship (creates it if it does not exists).
400
-     *
401
-     * @param $pivotTableName
402
-     *
403
-     * @return \SplObjectStorage
404
-     */
405
-    private function getRelationshipStorage($pivotTableName)
406
-    {
407
-        if (isset($this->relationships[$pivotTableName])) {
408
-            $storage = $this->relationships[$pivotTableName];
409
-        } else {
410
-            $storage = new \SplObjectStorage();
411
-            $this->relationships[$pivotTableName] = $storage;
412
-        }
413
-
414
-        return $storage;
415
-    }
416
-
417
-    /**
418
-     * Reverts any changes made to the object and resumes it to its DB state.
419
-     * This can only be called on objects that come from database and that have not been deleted.
420
-     * Otherwise, this will throw an exception.
421
-     *
422
-     * @throws TDBMException
423
-     */
424
-    public function discardChanges()
425
-    {
426
-        if ($this->status === TDBMObjectStateEnum::STATE_NEW || $this->status === TDBMObjectStateEnum::STATE_DETACHED) {
427
-            throw new TDBMException("You cannot call discardChanges() on an object that has been created with the 'new' keyword and that has not yet been saved.");
428
-        }
429
-
430
-        if ($this->status === TDBMObjectStateEnum::STATE_DELETED) {
431
-            throw new TDBMException('You cannot call discardChanges() on an object that has been deleted.');
432
-        }
433
-
434
-        $this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
435
-    }
436
-
437
-    /**
438
-     * Method used internally by TDBM. You should not use it directly.
439
-     * This method returns the status of the TDBMObject.
440
-     * This is one of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
441
-     * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
442
-     * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
443
-     * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
444
-     *
445
-     * @return string
446
-     */
447
-    public function _getStatus()
448
-    {
449
-        return $this->status;
450
-    }
451
-
452
-    /**
453
-     * Override the native php clone function for TDBMObjects.
454
-     */
455
-    public function __clone()
456
-    {
457
-        // Let's clone the many to many relationships
458
-        if ($this->status === TDBMObjectStateEnum::STATE_DETACHED) {
459
-            $pivotTableList = array_keys($this->relationships);
460
-        } else {
461
-            $pivotTableList = $this->tdbmService->_getPivotTablesLinkedToBean($this);
462
-        }
463
-
464
-        foreach ($pivotTableList as $pivotTable) {
465
-            $storage = $this->retrieveRelationshipsStorage($pivotTable);
466
-
467
-            // Let's duplicate the reverse side of the relationship
468
-            foreach ($storage as $remoteBean) {
469
-                $metadata = $storage[$remoteBean];
470
-
471
-                $remoteStorage = $remoteBean->getRelationshipStorage($pivotTable);
472
-                $remoteStorage->attach($this, ['status' => $metadata['status'], 'reverse' => !$metadata['reverse']]);
473
-            }
474
-        }
475
-
476
-        // Let's clone each row
477
-        foreach ($this->dbRows as $key => $dbRow) {
478
-            $this->dbRows[$key] = clone $dbRow;
479
-        }
480
-
481
-        // Let's set the status to new (to enter the save function)
482
-        $this->status = TDBMObjectStateEnum::STATE_DETACHED;
483
-    }
484
-
485
-    /**
486
-     * Returns raw database rows.
487
-     *
488
-     * @return DbRow[] Key: table name, Value: DbRow object
489
-     */
490
-    public function _getDbRows()
491
-    {
492
-        return $this->dbRows;
493
-    }
494
-
495
-    private function registerTable($tableName)
496
-    {
497
-        $dbRow = new DbRow($this, $tableName);
498
-
499
-        if (in_array($this->status, [TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DIRTY])) {
500
-            // Let's get the primary key for the new table
501
-            $anotherDbRow = array_values($this->dbRows)[0];
502
-            /* @var $anotherDbRow DbRow */
503
-            $indexedPrimaryKeys = array_values($anotherDbRow->_getPrimaryKeys());
504
-            $primaryKeys = $this->tdbmService->_getPrimaryKeysFromIndexedPrimaryKeys($tableName, $indexedPrimaryKeys);
505
-            $dbRow->_setPrimaryKeys($primaryKeys);
506
-        }
507
-
508
-        $dbRow->_setStatus($this->status);
509
-
510
-        $this->dbRows[$tableName] = $dbRow;
511
-        // TODO: look at status (if not new)=> get primary key from tdbmservice
512
-    }
513
-
514
-    /**
515
-     * Internal function: return the list of relationships.
516
-     *
517
-     * @return \SplObjectStorage[]
518
-     */
519
-    public function _getCachedRelationships()
520
-    {
521
-        return $this->relationships;
522
-    }
34
+	/**
35
+	 * The service this object is bound to.
36
+	 *
37
+	 * @var TDBMService
38
+	 */
39
+	protected $tdbmService;
40
+
41
+	/**
42
+	 * An array of DbRow, indexed by table name.
43
+	 *
44
+	 * @var DbRow[]
45
+	 */
46
+	protected $dbRows = array();
47
+
48
+	/**
49
+	 * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
50
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
51
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
52
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
53
+	 *
54
+	 * @var string
55
+	 */
56
+	private $status;
57
+
58
+	/**
59
+	 * Array storing beans related via many to many relationships (pivot tables).
60
+	 *
61
+	 * @var \SplObjectStorage[] Key: pivot table name, value: SplObjectStorage
62
+	 */
63
+	private $relationships = [];
64
+
65
+	/**
66
+	 * @var bool[] Key: pivot table name, value: whether a query was performed to load the data.
67
+	 */
68
+	private $loadedRelationships = [];
69
+
70
+	/**
71
+	 * Used with $primaryKeys when we want to retrieve an existing object
72
+	 * and $primaryKeys=[] if we want a new object.
73
+	 *
74
+	 * @param string      $tableName
75
+	 * @param array       $primaryKeys
76
+	 * @param TDBMService $tdbmService
77
+	 *
78
+	 * @throws TDBMException
79
+	 * @throws TDBMInvalidOperationException
80
+	 */
81
+	public function __construct($tableName = null, array $primaryKeys = array(), TDBMService $tdbmService = null)
82
+	{
83
+		// FIXME: lazy loading should be forbidden on tables with inheritance and dynamic type assignation...
84
+		if (!empty($tableName)) {
85
+			$this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
86
+		}
87
+
88
+		if ($tdbmService === null) {
89
+			$this->_setStatus(TDBMObjectStateEnum::STATE_DETACHED);
90
+		} else {
91
+			$this->_attach($tdbmService);
92
+			if (!empty($primaryKeys)) {
93
+				$this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
94
+			} else {
95
+				$this->_setStatus(TDBMObjectStateEnum::STATE_NEW);
96
+			}
97
+		}
98
+	}
99
+
100
+	/**
101
+	 * Alternative constructor called when data is fetched from database via a SELECT.
102
+	 *
103
+	 * @param array       $beanData    array<table, array<column, value>>
104
+	 * @param TDBMService $tdbmService
105
+	 */
106
+	public function _constructFromData(array $beanData, TDBMService $tdbmService)
107
+	{
108
+		$this->tdbmService = $tdbmService;
109
+
110
+		foreach ($beanData as $table => $columns) {
111
+			$this->dbRows[$table] = new DbRow($this, $table, $tdbmService->_getPrimaryKeysFromObjectData($table, $columns), $tdbmService, $columns);
112
+		}
113
+
114
+		$this->status = TDBMObjectStateEnum::STATE_LOADED;
115
+	}
116
+
117
+	/**
118
+	 * Alternative constructor called when bean is lazily loaded.
119
+	 *
120
+	 * @param string      $tableName
121
+	 * @param array       $primaryKeys
122
+	 * @param TDBMService $tdbmService
123
+	 */
124
+	public function _constructLazy($tableName, array $primaryKeys, TDBMService $tdbmService)
125
+	{
126
+		$this->tdbmService = $tdbmService;
127
+
128
+		$this->dbRows[$tableName] = new DbRow($this, $tableName, $primaryKeys, $tdbmService);
129
+
130
+		$this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
131
+	}
132
+
133
+	public function _attach(TDBMService $tdbmService)
134
+	{
135
+		if ($this->status !== TDBMObjectStateEnum::STATE_DETACHED) {
136
+			throw new TDBMInvalidOperationException('Cannot attach an object that is already attached to TDBM.');
137
+		}
138
+		$this->tdbmService = $tdbmService;
139
+
140
+		// If we attach this object, we must work to make sure the tables are in ascending order (from low level to top level)
141
+		$tableNames = array_keys($this->dbRows);
142
+		$tableNames = $this->tdbmService->_getLinkBetweenInheritedTables($tableNames);
143
+		$tableNames = array_reverse($tableNames);
144
+
145
+		$newDbRows = [];
146
+
147
+		foreach ($tableNames as $table) {
148
+			if (!isset($this->dbRows[$table])) {
149
+				$this->registerTable($table);
150
+			}
151
+			$newDbRows[$table] = $this->dbRows[$table];
152
+		}
153
+		$this->dbRows = $newDbRows;
154
+
155
+		$this->status = TDBMObjectStateEnum::STATE_NEW;
156
+		foreach ($this->dbRows as $dbRow) {
157
+			$dbRow->_attach($tdbmService);
158
+		}
159
+	}
160
+
161
+	/**
162
+	 * Sets the state of the TDBM Object
163
+	 * One of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
164
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
165
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
166
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
167
+	 *
168
+	 * @param string $state
169
+	 */
170
+	public function _setStatus($state)
171
+	{
172
+		$this->status = $state;
173
+
174
+		// TODO: we might ignore the loaded => dirty state here! dirty status comes from the db_row itself.
175
+		foreach ($this->dbRows as $dbRow) {
176
+			$dbRow->_setStatus($state);
177
+		}
178
+	}
179
+
180
+	protected function get($var, $tableName = null)
181
+	{
182
+		if ($tableName === null) {
183
+			if (count($this->dbRows) > 1) {
184
+				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
185
+			} elseif (count($this->dbRows) === 1) {
186
+				$tableName = array_keys($this->dbRows)[0];
187
+			}
188
+		}
189
+
190
+		if (!isset($this->dbRows[$tableName])) {
191
+			if (count($this->dbRows[$tableName] === 0)) {
192
+				throw new TDBMException('Object is not yet bound to any table.');
193
+			} else {
194
+				throw new TDBMException('Unknown table "'.$tableName.'"" in object.');
195
+			}
196
+		}
197
+
198
+		return $this->dbRows[$tableName]->get($var);
199
+	}
200
+
201
+	protected function set($var, $value, $tableName = null)
202
+	{
203
+		if ($tableName === null) {
204
+			if (count($this->dbRows) > 1) {
205
+				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
206
+			} elseif (count($this->dbRows) === 1) {
207
+				$tableName = array_keys($this->dbRows)[0];
208
+			} else {
209
+				throw new TDBMException('Please specify a table for this object.');
210
+			}
211
+		}
212
+
213
+		if (!isset($this->dbRows[$tableName])) {
214
+			$this->registerTable($tableName);
215
+		}
216
+
217
+		$this->dbRows[$tableName]->set($var, $value);
218
+		if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
219
+			$this->status = TDBMObjectStateEnum::STATE_DIRTY;
220
+		}
221
+	}
222
+
223
+	/**
224
+	 * @param string             $foreignKeyName
225
+	 * @param AbstractTDBMObject $bean
226
+	 */
227
+	protected function setRef($foreignKeyName, AbstractTDBMObject $bean, $tableName = null)
228
+	{
229
+		if ($tableName === null) {
230
+			if (count($this->dbRows) > 1) {
231
+				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
232
+			} elseif (count($this->dbRows) === 1) {
233
+				$tableName = array_keys($this->dbRows)[0];
234
+			} else {
235
+				throw new TDBMException('Please specify a table for this object.');
236
+			}
237
+		}
238
+
239
+		if (!isset($this->dbRows[$tableName])) {
240
+			$this->registerTable($tableName);
241
+		}
242
+
243
+		$this->dbRows[$tableName]->setRef($foreignKeyName, $bean);
244
+		if ($this->dbRows[$tableName]->_getStatus() === TDBMObjectStateEnum::STATE_DIRTY) {
245
+			$this->status = TDBMObjectStateEnum::STATE_DIRTY;
246
+		}
247
+	}
248
+
249
+	/**
250
+	 * @param string $foreignKeyName A unique name for this reference
251
+	 *
252
+	 * @return AbstractTDBMObject|null
253
+	 */
254
+	protected function getRef($foreignKeyName, $tableName = null)
255
+	{
256
+		if ($tableName === null) {
257
+			if (count($this->dbRows) > 1) {
258
+				throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
259
+			} elseif (count($this->dbRows) === 1) {
260
+				$tableName = array_keys($this->dbRows)[0];
261
+			}
262
+		}
263
+
264
+		if (!isset($this->dbRows[$tableName])) {
265
+			if (count($this->dbRows[$tableName] === 0)) {
266
+				throw new TDBMException('Object is not yet bound to any table.');
267
+			} else {
268
+				throw new TDBMException('Unknown table "'.$tableName.'"" in object.');
269
+			}
270
+		}
271
+
272
+		return $this->dbRows[$tableName]->getRef($foreignKeyName);
273
+	}
274
+
275
+	/**
276
+	 * Adds a many to many relationship to this bean.
277
+	 *
278
+	 * @param string             $pivotTableName
279
+	 * @param AbstractTDBMObject $remoteBean
280
+	 */
281
+	protected function addRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
282
+	{
283
+		$this->setRelationship($pivotTableName, $remoteBean, 'new');
284
+	}
285
+
286
+	/**
287
+	 * Returns true if there is a relationship to this bean.
288
+	 *
289
+	 * @param string             $pivotTableName
290
+	 * @param AbstractTDBMObject $remoteBean
291
+	 *
292
+	 * @return bool
293
+	 */
294
+	protected function hasRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
295
+	{
296
+		$storage = $this->retrieveRelationshipsStorage($pivotTableName);
297
+
298
+		if ($storage->contains($remoteBean)) {
299
+			if ($storage[$remoteBean]['status'] !== 'delete') {
300
+				return true;
301
+			}
302
+		}
303
+
304
+		return false;
305
+	}
306
+
307
+	/**
308
+	 * Internal TDBM method. Removes a many to many relationship from this bean.
309
+	 *
310
+	 * @param string             $pivotTableName
311
+	 * @param AbstractTDBMObject $remoteBean
312
+	 */
313
+	public function _removeRelationship($pivotTableName, AbstractTDBMObject $remoteBean)
314
+	{
315
+		if (isset($this->relationships[$pivotTableName][$remoteBean]) && $this->relationships[$pivotTableName][$remoteBean]['status'] === 'new') {
316
+			unset($this->relationships[$pivotTableName][$remoteBean]);
317
+			unset($remoteBean->relationships[$pivotTableName][$this]);
318
+		} else {
319
+			$this->setRelationship($pivotTableName, $remoteBean, 'delete');
320
+		}
321
+	}
322
+
323
+	/**
324
+	 * Returns the list of objects linked to this bean via $pivotTableName.
325
+	 *
326
+	 * @param $pivotTableName
327
+	 *
328
+	 * @return \SplObjectStorage
329
+	 */
330
+	private function retrieveRelationshipsStorage($pivotTableName)
331
+	{
332
+		$storage = $this->getRelationshipStorage($pivotTableName);
333
+		if ($this->status === TDBMObjectStateEnum::STATE_DETACHED || $this->status === TDBMObjectStateEnum::STATE_NEW || isset($this->loadedRelationships[$pivotTableName]) && $this->loadedRelationships[$pivotTableName]) {
334
+			return $storage;
335
+		}
336
+
337
+		$beans = $this->tdbmService->_getRelatedBeans($pivotTableName, $this);
338
+		$this->loadedRelationships[$pivotTableName] = true;
339
+
340
+		foreach ($beans as $bean) {
341
+			if (isset($storage[$bean])) {
342
+				$oldStatus = $storage[$bean]['status'];
343
+				if ($oldStatus === 'delete') {
344
+					// Keep deleted things deleted
345
+					continue;
346
+				}
347
+			}
348
+			$this->setRelationship($pivotTableName, $bean, 'loaded');
349
+		}
350
+
351
+		return $storage;
352
+	}
353
+
354
+	/**
355
+	 * Internal TDBM method. Returns the list of objects linked to this bean via $pivotTableName.
356
+	 *
357
+	 * @param $pivotTableName
358
+	 *
359
+	 * @return AbstractTDBMObject[]
360
+	 */
361
+	public function _getRelationships($pivotTableName)
362
+	{
363
+		return $this->relationshipStorageToArray($this->retrieveRelationshipsStorage($pivotTableName));
364
+	}
365
+
366
+	private function relationshipStorageToArray(\SplObjectStorage $storage)
367
+	{
368
+		$beans = [];
369
+		foreach ($storage as $bean) {
370
+			$statusArr = $storage[$bean];
371
+			if ($statusArr['status'] !== 'delete') {
372
+				$beans[] = $bean;
373
+			}
374
+		}
375
+
376
+		return $beans;
377
+	}
378
+
379
+	/**
380
+	 * Declares a relationship between.
381
+	 *
382
+	 * @param string             $pivotTableName
383
+	 * @param AbstractTDBMObject $remoteBean
384
+	 * @param string             $status
385
+	 */
386
+	private function setRelationship($pivotTableName, AbstractTDBMObject $remoteBean, $status)
387
+	{
388
+		$storage = $this->getRelationshipStorage($pivotTableName);
389
+		$storage->attach($remoteBean, ['status' => $status, 'reverse' => false]);
390
+		if ($this->status === TDBMObjectStateEnum::STATE_LOADED) {
391
+			$this->_setStatus(TDBMObjectStateEnum::STATE_DIRTY);
392
+		}
393
+
394
+		$remoteStorage = $remoteBean->getRelationshipStorage($pivotTableName);
395
+		$remoteStorage->attach($this, ['status' => $status, 'reverse' => true]);
396
+	}
397
+
398
+	/**
399
+	 * Returns the SplObjectStorage associated to this relationship (creates it if it does not exists).
400
+	 *
401
+	 * @param $pivotTableName
402
+	 *
403
+	 * @return \SplObjectStorage
404
+	 */
405
+	private function getRelationshipStorage($pivotTableName)
406
+	{
407
+		if (isset($this->relationships[$pivotTableName])) {
408
+			$storage = $this->relationships[$pivotTableName];
409
+		} else {
410
+			$storage = new \SplObjectStorage();
411
+			$this->relationships[$pivotTableName] = $storage;
412
+		}
413
+
414
+		return $storage;
415
+	}
416
+
417
+	/**
418
+	 * Reverts any changes made to the object and resumes it to its DB state.
419
+	 * This can only be called on objects that come from database and that have not been deleted.
420
+	 * Otherwise, this will throw an exception.
421
+	 *
422
+	 * @throws TDBMException
423
+	 */
424
+	public function discardChanges()
425
+	{
426
+		if ($this->status === TDBMObjectStateEnum::STATE_NEW || $this->status === TDBMObjectStateEnum::STATE_DETACHED) {
427
+			throw new TDBMException("You cannot call discardChanges() on an object that has been created with the 'new' keyword and that has not yet been saved.");
428
+		}
429
+
430
+		if ($this->status === TDBMObjectStateEnum::STATE_DELETED) {
431
+			throw new TDBMException('You cannot call discardChanges() on an object that has been deleted.');
432
+		}
433
+
434
+		$this->_setStatus(TDBMObjectStateEnum::STATE_NOT_LOADED);
435
+	}
436
+
437
+	/**
438
+	 * Method used internally by TDBM. You should not use it directly.
439
+	 * This method returns the status of the TDBMObject.
440
+	 * This is one of TDBMObjectStateEnum::STATE_NEW, TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DELETED.
441
+	 * $status = TDBMObjectStateEnum::STATE_NEW when a new object is created with DBMObject:getNewObject.
442
+	 * $status = TDBMObjectStateEnum::STATE_NOT_LOADED when the object has been retrieved with getObject but when no data has been accessed in it yet.
443
+	 * $status = TDBMObjectStateEnum::STATE_LOADED when the object is cached in memory.
444
+	 *
445
+	 * @return string
446
+	 */
447
+	public function _getStatus()
448
+	{
449
+		return $this->status;
450
+	}
451
+
452
+	/**
453
+	 * Override the native php clone function for TDBMObjects.
454
+	 */
455
+	public function __clone()
456
+	{
457
+		// Let's clone the many to many relationships
458
+		if ($this->status === TDBMObjectStateEnum::STATE_DETACHED) {
459
+			$pivotTableList = array_keys($this->relationships);
460
+		} else {
461
+			$pivotTableList = $this->tdbmService->_getPivotTablesLinkedToBean($this);
462
+		}
463
+
464
+		foreach ($pivotTableList as $pivotTable) {
465
+			$storage = $this->retrieveRelationshipsStorage($pivotTable);
466
+
467
+			// Let's duplicate the reverse side of the relationship
468
+			foreach ($storage as $remoteBean) {
469
+				$metadata = $storage[$remoteBean];
470
+
471
+				$remoteStorage = $remoteBean->getRelationshipStorage($pivotTable);
472
+				$remoteStorage->attach($this, ['status' => $metadata['status'], 'reverse' => !$metadata['reverse']]);
473
+			}
474
+		}
475
+
476
+		// Let's clone each row
477
+		foreach ($this->dbRows as $key => $dbRow) {
478
+			$this->dbRows[$key] = clone $dbRow;
479
+		}
480
+
481
+		// Let's set the status to new (to enter the save function)
482
+		$this->status = TDBMObjectStateEnum::STATE_DETACHED;
483
+	}
484
+
485
+	/**
486
+	 * Returns raw database rows.
487
+	 *
488
+	 * @return DbRow[] Key: table name, Value: DbRow object
489
+	 */
490
+	public function _getDbRows()
491
+	{
492
+		return $this->dbRows;
493
+	}
494
+
495
+	private function registerTable($tableName)
496
+	{
497
+		$dbRow = new DbRow($this, $tableName);
498
+
499
+		if (in_array($this->status, [TDBMObjectStateEnum::STATE_NOT_LOADED, TDBMObjectStateEnum::STATE_LOADED, TDBMObjectStateEnum::STATE_DIRTY])) {
500
+			// Let's get the primary key for the new table
501
+			$anotherDbRow = array_values($this->dbRows)[0];
502
+			/* @var $anotherDbRow DbRow */
503
+			$indexedPrimaryKeys = array_values($anotherDbRow->_getPrimaryKeys());
504
+			$primaryKeys = $this->tdbmService->_getPrimaryKeysFromIndexedPrimaryKeys($tableName, $indexedPrimaryKeys);
505
+			$dbRow->_setPrimaryKeys($primaryKeys);
506
+		}
507
+
508
+		$dbRow->_setStatus($this->status);
509
+
510
+		$this->dbRows[$tableName] = $dbRow;
511
+		// TODO: look at status (if not new)=> get primary key from tdbmservice
512
+	}
513
+
514
+	/**
515
+	 * Internal function: return the list of relationships.
516
+	 *
517
+	 * @return \SplObjectStorage[]
518
+	 */
519
+	public function _getCachedRelationships()
520
+	{
521
+		return $this->relationships;
522
+	}
523 523
 }
Please login to merge, or discard this patch.
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -180,7 +180,7 @@  discard block
 block discarded – undo
180 180
     protected function get($var, $tableName = null)
181 181
     {
182 182
         if ($tableName === null) {
183
-            if (count($this->dbRows) > 1) {
183
+            if (count($this->dbRows)>1) {
184 184
                 throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
185 185
             } elseif (count($this->dbRows) === 1) {
186 186
                 $tableName = array_keys($this->dbRows)[0];
@@ -201,7 +201,7 @@  discard block
 block discarded – undo
201 201
     protected function set($var, $value, $tableName = null)
202 202
     {
203 203
         if ($tableName === null) {
204
-            if (count($this->dbRows) > 1) {
204
+            if (count($this->dbRows)>1) {
205 205
                 throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
206 206
             } elseif (count($this->dbRows) === 1) {
207 207
                 $tableName = array_keys($this->dbRows)[0];
@@ -227,7 +227,7 @@  discard block
 block discarded – undo
227 227
     protected function setRef($foreignKeyName, AbstractTDBMObject $bean, $tableName = null)
228 228
     {
229 229
         if ($tableName === null) {
230
-            if (count($this->dbRows) > 1) {
230
+            if (count($this->dbRows)>1) {
231 231
                 throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
232 232
             } elseif (count($this->dbRows) === 1) {
233 233
                 $tableName = array_keys($this->dbRows)[0];
@@ -254,7 +254,7 @@  discard block
 block discarded – undo
254 254
     protected function getRef($foreignKeyName, $tableName = null)
255 255
     {
256 256
         if ($tableName === null) {
257
-            if (count($this->dbRows) > 1) {
257
+            if (count($this->dbRows)>1) {
258 258
                 throw new TDBMException('This object is based on several tables. You must specify which table you are retrieving data from.');
259 259
             } elseif (count($this->dbRows) === 1) {
260 260
                 $tableName = array_keys($this->dbRows)[0];
Please login to merge, or discard this patch.