Completed
Pull Request — 4.0 (#48)
by Marc
05:40
created
src/Mouf/Database/TDBM/Controllers/TdbmController.php 2 patches
Indentation   +153 added lines, -153 removed lines patch added patch discarded remove patch
@@ -16,158 +16,158 @@
 block discarded – undo
16 16
  */
17 17
 class TdbmController extends AbstractMoufInstanceController
18 18
 {
19
-    /**
20
-     * @var HtmlBlock
21
-     */
22
-    public $content;
23
-
24
-    protected $daoNamespace;
25
-    protected $beanNamespace;
26
-    protected $daoFactoryName;
27
-    protected $daoFactoryInstanceName;
28
-    protected $autoloadDetected;
29
-    protected $storeInUtc;
30
-
31
-    /**
32
-     * Admin page used to display the DAO generation form.
33
-     *
34
-     * @Action
35
-     * //@Admin
36
-     */
37
-    public function defaultAction($name, $selfedit = 'false')
38
-    {
39
-        $this->initController($name, $selfedit);
40
-
41
-        // Fill variables
42
-        if ($this->moufManager->getVariable('tdbmDefaultSourceDirectory_'.$name) != null) {
43
-            $this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace_'.$name);
44
-            $this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace_'.$name);
45
-            $this->daoFactoryName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryName_'.$name);
46
-            $this->daoFactoryInstanceName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryInstanceName_'.$name);
47
-            $this->storeInUtc = $this->moufManager->getVariable('tdbmDefaultStoreInUtc_'.$name);
48
-            $this->defaultPath = $this->moufManager->getVariable('tdbmDefaultDefaultPath_'.$name);
49
-            $this->storePath = $this->moufManager->getVariable('tdbmDefaultStorePath_'.$name);
50
-        } else {
51
-            $this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace');
52
-            $this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace');
53
-            $this->daoFactoryName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryName');
54
-            $this->daoFactoryInstanceName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryInstanceName');
55
-            $this->storeInUtc = $this->moufManager->getVariable('tdbmDefaultStoreInUtc');
56
-            $this->defaultPath = $this->moufManager->getVariable('tdbmDefaultDefaultPath');
57
-            $this->storePath = $this->moufManager->getVariable('tdbmDefaultStorePath');
58
-        }
59
-
60
-        if ($this->daoNamespace == null && $this->beanNamespace == null) {
61
-            $classNameMapper = ClassNameMapper::createFromComposerFile(__DIR__.'/../../../../../../../../composer.json');
62
-
63
-            $autoloadNamespaces = $classNameMapper->getManagedNamespaces();
64
-            if ($autoloadNamespaces) {
65
-                $this->autoloadDetected = true;
66
-                $rootNamespace = $autoloadNamespaces[0];
67
-                $this->daoNamespace = $rootNamespace.'Dao';
68
-                $this->beanNamespace = $rootNamespace.'Dao\\Bean';
69
-            } else {
70
-                $this->autoloadDetected = false;
71
-                $this->daoNamespace = 'YourApplication\\Dao';
72
-                $this->beanNamespace = 'YourApplication\\Dao\\Bean';
73
-            }
74
-        } else {
75
-            $this->autoloadDetected = true;
76
-        }
77
-
78
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/tdbmGenerate.php', $this);
79
-        $this->template->toHtml();
80
-    }
81
-
82
-    /**
83
-     * This action generates the DAOs and Beans for the TDBM service passed in parameter.
84
-     *
85
-     * @Action
86
-     *
87
-     * @param string $name
88
-     * @param bool   $selfedit
89
-     */
90
-    public function generate($name, $daonamespace, $beannamespace, $daofactoryclassname, $daofactoryinstancename, $storeInUtc = 0, $selfedit = 'false', $defaultPath = false, $storePath = '')
91
-    {
92
-        $this->initController($name, $selfedit);
93
-
94
-        self::generateDaos($this->moufManager, $name, $daonamespace, $beannamespace, $daofactoryclassname, $daofactoryinstancename, $selfedit, $storeInUtc, $defaultPath, $storePath);
95
-
96
-        // TODO: better: we should redirect to a screen that list the number of DAOs generated, etc...
97
-        header('Location: '.ROOT_URL.'ajaxinstance/?name='.urlencode($name).'&selfedit='.$selfedit);
98
-    }
99
-
100
-    /**
101
-     * This function generates the DAOs and Beans for the TDBM service passed in parameter.
102
-     *
103
-     * @param MoufManager $moufManager
104
-     * @param string      $name
105
-     * @param string      $daonamespace
106
-     * @param string      $beannamespace
107
-     * @param string      $daofactoryclassname
108
-     * @param string      $daofactoryinstancename
109
-     * @param string      $selfedit
110
-     * @param bool        $storeInUtc
111
-     *
112
-     * @throws \Mouf\MoufException
113
-     */
114
-    public static function generateDaos(MoufManager $moufManager, $name, $daonamespace, $beannamespace, $daofactoryclassname, $daofactoryinstancename, $selfedit = 'false', $storeInUtc = null, $defaultPath = null, $storePath = null)
115
-    {
116
-        $moufManager->setVariable('tdbmDefaultDaoNamespace_'.$name, $daonamespace);
117
-        $moufManager->setVariable('tdbmDefaultBeanNamespace_'.$name, $beannamespace);
118
-        $moufManager->setVariable('tdbmDefaultDaoFactoryName_'.$name, $daofactoryclassname);
119
-        $moufManager->setVariable('tdbmDefaultDaoFactoryInstanceName_'.$name, $daofactoryinstancename);
120
-        $moufManager->setVariable('tdbmDefaultStoreInUtc_'.$name, $storeInUtc);
121
-        $moufManager->setVariable('tdbmDefaultDefaultPath_'.$name, $defaultPath);
122
-        $moufManager->setVariable('tdbmDefaultStorePath_'.$name, $storePath);
19
+	/**
20
+	 * @var HtmlBlock
21
+	 */
22
+	public $content;
23
+
24
+	protected $daoNamespace;
25
+	protected $beanNamespace;
26
+	protected $daoFactoryName;
27
+	protected $daoFactoryInstanceName;
28
+	protected $autoloadDetected;
29
+	protected $storeInUtc;
30
+
31
+	/**
32
+	 * Admin page used to display the DAO generation form.
33
+	 *
34
+	 * @Action
35
+	 * //@Admin
36
+	 */
37
+	public function defaultAction($name, $selfedit = 'false')
38
+	{
39
+		$this->initController($name, $selfedit);
40
+
41
+		// Fill variables
42
+		if ($this->moufManager->getVariable('tdbmDefaultSourceDirectory_'.$name) != null) {
43
+			$this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace_'.$name);
44
+			$this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace_'.$name);
45
+			$this->daoFactoryName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryName_'.$name);
46
+			$this->daoFactoryInstanceName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryInstanceName_'.$name);
47
+			$this->storeInUtc = $this->moufManager->getVariable('tdbmDefaultStoreInUtc_'.$name);
48
+			$this->defaultPath = $this->moufManager->getVariable('tdbmDefaultDefaultPath_'.$name);
49
+			$this->storePath = $this->moufManager->getVariable('tdbmDefaultStorePath_'.$name);
50
+		} else {
51
+			$this->daoNamespace = $this->moufManager->getVariable('tdbmDefaultDaoNamespace');
52
+			$this->beanNamespace = $this->moufManager->getVariable('tdbmDefaultBeanNamespace');
53
+			$this->daoFactoryName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryName');
54
+			$this->daoFactoryInstanceName = $this->moufManager->getVariable('tdbmDefaultDaoFactoryInstanceName');
55
+			$this->storeInUtc = $this->moufManager->getVariable('tdbmDefaultStoreInUtc');
56
+			$this->defaultPath = $this->moufManager->getVariable('tdbmDefaultDefaultPath');
57
+			$this->storePath = $this->moufManager->getVariable('tdbmDefaultStorePath');
58
+		}
59
+
60
+		if ($this->daoNamespace == null && $this->beanNamespace == null) {
61
+			$classNameMapper = ClassNameMapper::createFromComposerFile(__DIR__.'/../../../../../../../../composer.json');
62
+
63
+			$autoloadNamespaces = $classNameMapper->getManagedNamespaces();
64
+			if ($autoloadNamespaces) {
65
+				$this->autoloadDetected = true;
66
+				$rootNamespace = $autoloadNamespaces[0];
67
+				$this->daoNamespace = $rootNamespace.'Dao';
68
+				$this->beanNamespace = $rootNamespace.'Dao\\Bean';
69
+			} else {
70
+				$this->autoloadDetected = false;
71
+				$this->daoNamespace = 'YourApplication\\Dao';
72
+				$this->beanNamespace = 'YourApplication\\Dao\\Bean';
73
+			}
74
+		} else {
75
+			$this->autoloadDetected = true;
76
+		}
77
+
78
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/tdbmGenerate.php', $this);
79
+		$this->template->toHtml();
80
+	}
81
+
82
+	/**
83
+	 * This action generates the DAOs and Beans for the TDBM service passed in parameter.
84
+	 *
85
+	 * @Action
86
+	 *
87
+	 * @param string $name
88
+	 * @param bool   $selfedit
89
+	 */
90
+	public function generate($name, $daonamespace, $beannamespace, $daofactoryclassname, $daofactoryinstancename, $storeInUtc = 0, $selfedit = 'false', $defaultPath = false, $storePath = '')
91
+	{
92
+		$this->initController($name, $selfedit);
93
+
94
+		self::generateDaos($this->moufManager, $name, $daonamespace, $beannamespace, $daofactoryclassname, $daofactoryinstancename, $selfedit, $storeInUtc, $defaultPath, $storePath);
95
+
96
+		// TODO: better: we should redirect to a screen that list the number of DAOs generated, etc...
97
+		header('Location: '.ROOT_URL.'ajaxinstance/?name='.urlencode($name).'&selfedit='.$selfedit);
98
+	}
99
+
100
+	/**
101
+	 * This function generates the DAOs and Beans for the TDBM service passed in parameter.
102
+	 *
103
+	 * @param MoufManager $moufManager
104
+	 * @param string      $name
105
+	 * @param string      $daonamespace
106
+	 * @param string      $beannamespace
107
+	 * @param string      $daofactoryclassname
108
+	 * @param string      $daofactoryinstancename
109
+	 * @param string      $selfedit
110
+	 * @param bool        $storeInUtc
111
+	 *
112
+	 * @throws \Mouf\MoufException
113
+	 */
114
+	public static function generateDaos(MoufManager $moufManager, $name, $daonamespace, $beannamespace, $daofactoryclassname, $daofactoryinstancename, $selfedit = 'false', $storeInUtc = null, $defaultPath = null, $storePath = null)
115
+	{
116
+		$moufManager->setVariable('tdbmDefaultDaoNamespace_'.$name, $daonamespace);
117
+		$moufManager->setVariable('tdbmDefaultBeanNamespace_'.$name, $beannamespace);
118
+		$moufManager->setVariable('tdbmDefaultDaoFactoryName_'.$name, $daofactoryclassname);
119
+		$moufManager->setVariable('tdbmDefaultDaoFactoryInstanceName_'.$name, $daofactoryinstancename);
120
+		$moufManager->setVariable('tdbmDefaultStoreInUtc_'.$name, $storeInUtc);
121
+		$moufManager->setVariable('tdbmDefaultDefaultPath_'.$name, $defaultPath);
122
+		$moufManager->setVariable('tdbmDefaultStorePath_'.$name, $storePath);
123 123
         
124
-        // In case of instance renaming, let's use the last used settings
125
-        $moufManager->setVariable('tdbmDefaultDaoNamespace', $daonamespace);
126
-        $moufManager->setVariable('tdbmDefaultBeanNamespace', $beannamespace);
127
-        $moufManager->setVariable('tdbmDefaultDaoFactoryName', $daofactoryclassname);
128
-        $moufManager->setVariable('tdbmDefaultDaoFactoryInstanceName', $daofactoryinstancename);
129
-        $moufManager->setVariable('tdbmDefaultStoreInUtc', $storeInUtc);
130
-        $moufManager->setVariable('tdbmDefaultDefaultPath', $defaultPath);
131
-        $moufManager->setVariable('tdbmDefaultStorePath', $storePath);
132
-
133
-        // Remove first and last slash in namespace.
134
-        if (strpos($daonamespace, '\\') === 0) {
135
-            $daonamespace = substr($daonamespace, 1);
136
-        }
137
-        if (strpos($daonamespace, '\\') === strlen($daonamespace) - 1) {
138
-            $daonamespace = substr($daonamespace, 0, strlen($daonamespace) - 1);
139
-        }
140
-        if (strpos($beannamespace, '\\') === 0) {
141
-            $beannamespace = substr($beannamespace, 1);
142
-        }
143
-        if (strpos($beannamespace, '\\') === strlen($beannamespace) - 1) {
144
-            $beannamespace = substr($beannamespace, 0, strlen($beannamespace) - 1);
145
-        }
146
-
147
-        $tdbmService = new InstanceProxy($name);
148
-        /* @var $tdbmService TDBMService */
149
-        $tables = $tdbmService->generateAllDaosAndBeans($daofactoryclassname, $daonamespace, $beannamespace, $storeInUtc, (!$defaultPath?$storePath:null));
150
-
151
-        $moufManager->declareComponent($daofactoryinstancename, $daonamespace.'\\'.$daofactoryclassname, false, MoufManager::DECLARE_ON_EXIST_KEEP_INCOMING_LINKS);
152
-
153
-        $tableToBeanMap = [];
154
-
155
-        //$tdbmServiceDescriptor = $moufManager->getInstanceDescriptor('tdbmService');
156
-
157
-        foreach ($tables as $table) {
158
-            $daoName = TDBMDaoGenerator::getDaoNameFromTableName($table);
159
-
160
-            $instanceName = TDBMDaoGenerator::toVariableName($daoName);
161
-            if (!$moufManager->instanceExists($instanceName)) {
162
-                $moufManager->declareComponent($instanceName, $daonamespace.'\\'.$daoName);
163
-            }
164
-            $moufManager->setParameterViaConstructor($instanceName, 0, $name, 'object');
165
-            $moufManager->bindComponentViaSetter($daofactoryinstancename, 'set'.$daoName, $instanceName);
166
-
167
-            $tableToBeanMap[$table] = $beannamespace.'\\'.TDBMDaoGenerator::getBeanNameFromTableName($table);
168
-        }
169
-        $tdbmServiceDescriptor = $moufManager->getInstanceDescriptor($name);
170
-        $tdbmServiceDescriptor->getSetterProperty('setTableToBeanMap')->setValue($tableToBeanMap);
171
-        $moufManager->rewriteMouf();
172
-    }
124
+		// In case of instance renaming, let's use the last used settings
125
+		$moufManager->setVariable('tdbmDefaultDaoNamespace', $daonamespace);
126
+		$moufManager->setVariable('tdbmDefaultBeanNamespace', $beannamespace);
127
+		$moufManager->setVariable('tdbmDefaultDaoFactoryName', $daofactoryclassname);
128
+		$moufManager->setVariable('tdbmDefaultDaoFactoryInstanceName', $daofactoryinstancename);
129
+		$moufManager->setVariable('tdbmDefaultStoreInUtc', $storeInUtc);
130
+		$moufManager->setVariable('tdbmDefaultDefaultPath', $defaultPath);
131
+		$moufManager->setVariable('tdbmDefaultStorePath', $storePath);
132
+
133
+		// Remove first and last slash in namespace.
134
+		if (strpos($daonamespace, '\\') === 0) {
135
+			$daonamespace = substr($daonamespace, 1);
136
+		}
137
+		if (strpos($daonamespace, '\\') === strlen($daonamespace) - 1) {
138
+			$daonamespace = substr($daonamespace, 0, strlen($daonamespace) - 1);
139
+		}
140
+		if (strpos($beannamespace, '\\') === 0) {
141
+			$beannamespace = substr($beannamespace, 1);
142
+		}
143
+		if (strpos($beannamespace, '\\') === strlen($beannamespace) - 1) {
144
+			$beannamespace = substr($beannamespace, 0, strlen($beannamespace) - 1);
145
+		}
146
+
147
+		$tdbmService = new InstanceProxy($name);
148
+		/* @var $tdbmService TDBMService */
149
+		$tables = $tdbmService->generateAllDaosAndBeans($daofactoryclassname, $daonamespace, $beannamespace, $storeInUtc, (!$defaultPath?$storePath:null));
150
+
151
+		$moufManager->declareComponent($daofactoryinstancename, $daonamespace.'\\'.$daofactoryclassname, false, MoufManager::DECLARE_ON_EXIST_KEEP_INCOMING_LINKS);
152
+
153
+		$tableToBeanMap = [];
154
+
155
+		//$tdbmServiceDescriptor = $moufManager->getInstanceDescriptor('tdbmService');
156
+
157
+		foreach ($tables as $table) {
158
+			$daoName = TDBMDaoGenerator::getDaoNameFromTableName($table);
159
+
160
+			$instanceName = TDBMDaoGenerator::toVariableName($daoName);
161
+			if (!$moufManager->instanceExists($instanceName)) {
162
+				$moufManager->declareComponent($instanceName, $daonamespace.'\\'.$daoName);
163
+			}
164
+			$moufManager->setParameterViaConstructor($instanceName, 0, $name, 'object');
165
+			$moufManager->bindComponentViaSetter($daofactoryinstancename, 'set'.$daoName, $instanceName);
166
+
167
+			$tableToBeanMap[$table] = $beannamespace.'\\'.TDBMDaoGenerator::getBeanNameFromTableName($table);
168
+		}
169
+		$tdbmServiceDescriptor = $moufManager->getInstanceDescriptor($name);
170
+		$tdbmServiceDescriptor->getSetterProperty('setTableToBeanMap')->setValue($tableToBeanMap);
171
+		$moufManager->rewriteMouf();
172
+	}
173 173
 }
Please login to merge, or discard this patch.
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -134,19 +134,19 @@
 block discarded – undo
134 134
         if (strpos($daonamespace, '\\') === 0) {
135 135
             $daonamespace = substr($daonamespace, 1);
136 136
         }
137
-        if (strpos($daonamespace, '\\') === strlen($daonamespace) - 1) {
138
-            $daonamespace = substr($daonamespace, 0, strlen($daonamespace) - 1);
137
+        if (strpos($daonamespace, '\\') === strlen($daonamespace)-1) {
138
+            $daonamespace = substr($daonamespace, 0, strlen($daonamespace)-1);
139 139
         }
140 140
         if (strpos($beannamespace, '\\') === 0) {
141 141
             $beannamespace = substr($beannamespace, 1);
142 142
         }
143
-        if (strpos($beannamespace, '\\') === strlen($beannamespace) - 1) {
144
-            $beannamespace = substr($beannamespace, 0, strlen($beannamespace) - 1);
143
+        if (strpos($beannamespace, '\\') === strlen($beannamespace)-1) {
144
+            $beannamespace = substr($beannamespace, 0, strlen($beannamespace)-1);
145 145
         }
146 146
 
147 147
         $tdbmService = new InstanceProxy($name);
148 148
         /* @var $tdbmService TDBMService */
149
-        $tables = $tdbmService->generateAllDaosAndBeans($daofactoryclassname, $daonamespace, $beannamespace, $storeInUtc, (!$defaultPath?$storePath:null));
149
+        $tables = $tdbmService->generateAllDaosAndBeans($daofactoryclassname, $daonamespace, $beannamespace, $storeInUtc, (!$defaultPath ? $storePath : null));
150 150
 
151 151
         $moufManager->declareComponent($daofactoryinstancename, $daonamespace.'\\'.$daofactoryclassname, false, MoufManager::DECLARE_ON_EXIST_KEEP_INCOMING_LINKS);
152 152
 
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Controllers/TdbmInstallController.php 1 patch
Indentation   +174 added lines, -174 removed lines patch added patch discarded remove patch
@@ -15,178 +15,178 @@
 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
-        $this->defaultPath = true;
134
-        $this->storePath = '';
135
-
136
-        $this->castDatesToDateTime = true;
137
-
138
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installStep2.php', $this);
139
-        $this->template->toHtml();
140
-    }
141
-
142
-    /**
143
-     * This action generates the TDBM instance, then the DAOs and Beans.
144
-     *
145
-     * @Action
146
-     *
147
-     * @param string $daonamespace
148
-     * @param string $beannamespace
149
-     * @param int    $storeInUtc
150
-     * @param string $selfedit
151
-     *
152
-     * @throws \Mouf\MoufException
153
-     */
154
-    public function generate($daonamespace, $beannamespace, $storeInUtc = 0, $selfedit = 'false', $defaultPath = false, $storePath = '')
155
-    {
156
-        $this->selfedit = $selfedit;
157
-
158
-        if ($selfedit == 'true') {
159
-            $this->moufManager = MoufManager::getMoufManager();
160
-        } else {
161
-            $this->moufManager = MoufManager::getMoufManagerHiddenInstance();
162
-        }
163
-
164
-        if (!$this->moufManager->instanceExists('doctrineApcCache')) {
165
-            $doctrineApcCache = $this->moufManager->createInstance('Doctrine\\Common\\Cache\\ApcCache')->setName('doctrineApcCache');
166
-            // TODO: set namespace
167
-        } else {
168
-            $doctrineApcCache = $this->moufManager->getInstanceDescriptor('doctrineApcCache');
169
-        }
170
-
171
-        if (!$this->moufManager->instanceExists('tdbmService')) {
172
-            $tdbmService = $this->moufManager->createInstance('Mouf\\Database\\TDBM\\TDBMService')->setName('tdbmService');
173
-            $tdbmService->getConstructorArgumentProperty('connection')->setValue($this->moufManager->getInstanceDescriptor('dbalConnection'));
174
-            $tdbmService->getConstructorArgumentProperty('cache')->setValue($doctrineApcCache);
175
-        }
176
-
177
-        $this->moufManager->rewriteMouf();
178
-
179
-        TdbmController::generateDaos($this->moufManager, 'tdbmService', $daonamespace, $beannamespace, 'DaoFactory', 'daoFactory', $selfedit, $storeInUtc, $defaultPath, $storePath);
180
-
181
-        InstallUtils::continueInstall($selfedit == 'true');
182
-    }
183
-
184
-    protected $errorMsg;
185
-
186
-    private function displayErrorMsg($msg)
187
-    {
188
-        $this->errorMsg = $msg;
189
-        $this->content->addFile(dirname(__FILE__).'/../../../../views/installError.php', $this);
190
-        $this->template->toHtml();
191
-    }
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
+		$this->defaultPath = true;
134
+		$this->storePath = '';
135
+
136
+		$this->castDatesToDateTime = true;
137
+
138
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installStep2.php', $this);
139
+		$this->template->toHtml();
140
+	}
141
+
142
+	/**
143
+	 * This action generates the TDBM instance, then the DAOs and Beans.
144
+	 *
145
+	 * @Action
146
+	 *
147
+	 * @param string $daonamespace
148
+	 * @param string $beannamespace
149
+	 * @param int    $storeInUtc
150
+	 * @param string $selfedit
151
+	 *
152
+	 * @throws \Mouf\MoufException
153
+	 */
154
+	public function generate($daonamespace, $beannamespace, $storeInUtc = 0, $selfedit = 'false', $defaultPath = false, $storePath = '')
155
+	{
156
+		$this->selfedit = $selfedit;
157
+
158
+		if ($selfedit == 'true') {
159
+			$this->moufManager = MoufManager::getMoufManager();
160
+		} else {
161
+			$this->moufManager = MoufManager::getMoufManagerHiddenInstance();
162
+		}
163
+
164
+		if (!$this->moufManager->instanceExists('doctrineApcCache')) {
165
+			$doctrineApcCache = $this->moufManager->createInstance('Doctrine\\Common\\Cache\\ApcCache')->setName('doctrineApcCache');
166
+			// TODO: set namespace
167
+		} else {
168
+			$doctrineApcCache = $this->moufManager->getInstanceDescriptor('doctrineApcCache');
169
+		}
170
+
171
+		if (!$this->moufManager->instanceExists('tdbmService')) {
172
+			$tdbmService = $this->moufManager->createInstance('Mouf\\Database\\TDBM\\TDBMService')->setName('tdbmService');
173
+			$tdbmService->getConstructorArgumentProperty('connection')->setValue($this->moufManager->getInstanceDescriptor('dbalConnection'));
174
+			$tdbmService->getConstructorArgumentProperty('cache')->setValue($doctrineApcCache);
175
+		}
176
+
177
+		$this->moufManager->rewriteMouf();
178
+
179
+		TdbmController::generateDaos($this->moufManager, 'tdbmService', $daonamespace, $beannamespace, 'DaoFactory', 'daoFactory', $selfedit, $storeInUtc, $defaultPath, $storePath);
180
+
181
+		InstallUtils::continueInstall($selfedit == 'true');
182
+	}
183
+
184
+	protected $errorMsg;
185
+
186
+	private function displayErrorMsg($msg)
187
+	{
188
+		$this->errorMsg = $msg;
189
+		$this->content->addFile(dirname(__FILE__).'/../../../../views/installError.php', $this);
190
+		$this->template->toHtml();
191
+	}
192 192
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/TDBMService.php 1 patch
Indentation   +1321 added lines, -1321 removed lines patch added patch discarded remove patch
@@ -41,213 +41,213 @@  discard block
 block discarded – undo
41 41
  */
42 42
 class TDBMService
43 43
 {
44
-    const MODE_CURSOR = 1;
45
-    const MODE_ARRAY = 2;
46
-
47
-    /**
48
-     * The database connection.
49
-     *
50
-     * @var Connection
51
-     */
52
-    private $connection;
53
-
54
-    /**
55
-     * @var SchemaAnalyzer
56
-     */
57
-    private $schemaAnalyzer;
58
-
59
-    /**
60
-     * @var MagicQuery
61
-     */
62
-    private $magicQuery;
63
-
64
-    /**
65
-     * @var TDBMSchemaAnalyzer
66
-     */
67
-    private $tdbmSchemaAnalyzer;
68
-
69
-    /**
70
-     * @var string
71
-     */
72
-    private $cachePrefix;
73
-
74
-    /**
75
-     * Cache of table of primary keys.
76
-     * Primary keys are stored by tables, as an array of column.
77
-     * For instance $primary_key['my_table'][0] will return the first column of the primary key of table 'my_table'.
78
-     *
79
-     * @var string[]
80
-     */
81
-    private $primaryKeysColumns;
82
-
83
-    /**
84
-     * Service storing objects in memory.
85
-     * Access is done by table name and then by primary key.
86
-     * If the primary key is split on several columns, access is done by an array of columns, serialized.
87
-     *
88
-     * @var StandardObjectStorage|WeakrefObjectStorage
89
-     */
90
-    private $objectStorage;
91
-
92
-    /**
93
-     * The fetch mode of the result sets returned by `getObjects`.
94
-     * Can be one of: TDBMObjectArray::MODE_CURSOR or TDBMObjectArray::MODE_ARRAY or TDBMObjectArray::MODE_COMPATIBLE_ARRAY.
95
-     *
96
-     * In 'MODE_ARRAY' mode (default), the result is an array. Use this mode by default (unless the list returned is very big).
97
-     * In 'MODE_CURSOR' mode, the result is a Generator which is an iterable collection that can be scanned only once (only one "foreach") on it,
98
-     * and it cannot be accessed via key. Use this mode for large datasets processed by batch.
99
-     * In 'MODE_COMPATIBLE_ARRAY' mode, the result is an old TDBMObjectArray (used up to TDBM 3.2).
100
-     * You can access the array by key, or using foreach, several times.
101
-     *
102
-     * @var int
103
-     */
104
-    private $mode = self::MODE_ARRAY;
105
-
106
-    /**
107
-     * Table of new objects not yet inserted in database or objects modified that must be saved.
108
-     *
109
-     * @var \SplObjectStorage of DbRow objects
110
-     */
111
-    private $toSaveObjects;
112
-
113
-    /**
114
-     * The content of the cache variable.
115
-     *
116
-     * @var array<string, mixed>
117
-     */
118
-    private $cache;
119
-
120
-    /**
121
-     * Map associating a table name to a fully qualified Bean class name.
122
-     *
123
-     * @var array
124
-     */
125
-    private $tableToBeanMap = [];
126
-
127
-    /**
128
-     * @var \ReflectionClass[]
129
-     */
130
-    private $reflectionClassCache = array();
131
-
132
-    /**
133
-     * @param Connection     $connection     The DBAL DB connection to use
134
-     * @param Cache|null     $cache          A cache service to be used
135
-     * @param SchemaAnalyzer $schemaAnalyzer The schema analyzer that will be used to find shortest paths...
136
-     *                                       Will be automatically created if not passed.
137
-     */
138
-    public function __construct(Connection $connection, Cache $cache = null, SchemaAnalyzer $schemaAnalyzer = null)
139
-    {
140
-        if (extension_loaded('weakref')) {
141
-            $this->objectStorage = new WeakrefObjectStorage();
142
-        } else {
143
-            $this->objectStorage = new StandardObjectStorage();
144
-        }
145
-        $this->connection = $connection;
146
-        if ($cache !== null) {
147
-            $this->cache = $cache;
148
-        } else {
149
-            $this->cache = new VoidCache();
150
-        }
151
-        if ($schemaAnalyzer) {
152
-            $this->schemaAnalyzer = $schemaAnalyzer;
153
-        } else {
154
-            $this->schemaAnalyzer = new SchemaAnalyzer($this->connection->getSchemaManager(), $this->cache, $this->getConnectionUniqueId());
155
-        }
156
-
157
-        $this->magicQuery = new MagicQuery($this->connection, $this->cache, $this->schemaAnalyzer);
158
-
159
-        $this->tdbmSchemaAnalyzer = new TDBMSchemaAnalyzer($connection, $this->cache, $this->schemaAnalyzer);
160
-        $this->cachePrefix = $this->tdbmSchemaAnalyzer->getCachePrefix();
161
-
162
-        $this->toSaveObjects = new \SplObjectStorage();
163
-    }
164
-
165
-    /**
166
-     * Returns the object used to connect to the database.
167
-     *
168
-     * @return Connection
169
-     */
170
-    public function getConnection()
171
-    {
172
-        return $this->connection;
173
-    }
174
-
175
-    /**
176
-     * Creates a unique cache key for the current connection.
177
-     *
178
-     * @return string
179
-     */
180
-    private function getConnectionUniqueId()
181
-    {
182
-        return hash('md4', $this->connection->getHost().'-'.$this->connection->getPort().'-'.$this->connection->getDatabase().'-'.$this->connection->getDriver()->getName());
183
-    }
184
-
185
-    /**
186
-     * Sets the default fetch mode of the result sets returned by `findObjects`.
187
-     * Can be one of: TDBMObjectArray::MODE_CURSOR or TDBMObjectArray::MODE_ARRAY.
188
-     *
189
-     * In 'MODE_ARRAY' mode (default), the result is a ResultIterator object that behaves like an array. Use this mode by default (unless the list returned is very big).
190
-     * In 'MODE_CURSOR' mode, the result is a ResultIterator object. If you scan it many times (by calling several time a foreach loop), the query will be run
191
-     * several times. In cursor mode, you cannot access the result set by key. Use this mode for large datasets processed by batch.
192
-     *
193
-     * @param int $mode
194
-     *
195
-     * @return $this
196
-     *
197
-     * @throws TDBMException
198
-     */
199
-    public function setFetchMode($mode)
200
-    {
201
-        if ($mode !== self::MODE_CURSOR && $mode !== self::MODE_ARRAY) {
202
-            throw new TDBMException("Unknown fetch mode: '".$this->mode."'");
203
-        }
204
-        $this->mode = $mode;
205
-
206
-        return $this;
207
-    }
208
-
209
-    /**
210
-     * Returns a TDBMObject associated from table "$table_name".
211
-     * If the $filters parameter is an int/string, the object returned will be the object whose primary key = $filters.
212
-     * $filters can also be a set of TDBM_Filters (see the findObjects method for more details).
213
-     *
214
-     * For instance, if there is a table 'users', with a primary key on column 'user_id' and a column 'user_name', then
215
-     * 			$user = $tdbmService->getObject('users',1);
216
-     * 			echo $user->name;
217
-     * will return the name of the user whose user_id is one.
218
-     *
219
-     * If a table has a primary key over several columns, you should pass to $id an array containing the the value of the various columns.
220
-     * For instance:
221
-     * 			$group = $tdbmService->getObject('groups',array(1,2));
222
-     *
223
-     * Note that TDBMObject performs caching for you. If you get twice the same object, the reference of the object you will get
224
-     * will be the same.
225
-     *
226
-     * For instance:
227
-     * 			$user1 = $tdbmService->getObject('users',1);
228
-     * 			$user2 = $tdbmService->getObject('users',1);
229
-     * 			$user1->name = 'John Doe';
230
-     * 			echo $user2->name;
231
-     * will return 'John Doe'.
232
-     *
233
-     * You can use filters instead of passing the primary key. For instance:
234
-     * 			$user = $tdbmService->getObject('users',new EqualFilter('users', 'login', 'jdoe'));
235
-     * This will return the user whose login is 'jdoe'.
236
-     * Please note that if 2 users have the jdoe login in database, the method will throw a TDBM_DuplicateRowException.
237
-     *
238
-     * Also, you can specify the return class for the object (provided the return class extends TDBMObject).
239
-     * For instance:
240
-     *  	$user = $tdbmService->getObject('users',1,'User');
241
-     * will return an object from the "User" class. The "User" class must extend the "TDBMObject" class.
242
-     * Please be sure not to override any method or any property unless you perfectly know what you are doing!
243
-     *
244
-     * @param string $table_name   The name of the table we retrieve an object from.
245
-     * @param mixed  $filters      If the filter is a string/integer, it will be considered as the id of the object (the value of the primary key). Otherwise, it can be a filter bag (see the filterbag parameter of the findObjects method for more details about filter bags)
246
-     * @param string $className    Optional: The name of the class to instanciate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
247
-     * @param bool   $lazy_loading If set to true, and if the primary key is passed in parameter of getObject, the object will not be queried in database. It will be queried when you first try to access a column. If at that time the object cannot be found in database, an exception will be thrown.
248
-     *
249
-     * @return TDBMObject
250
-     */
44
+	const MODE_CURSOR = 1;
45
+	const MODE_ARRAY = 2;
46
+
47
+	/**
48
+	 * The database connection.
49
+	 *
50
+	 * @var Connection
51
+	 */
52
+	private $connection;
53
+
54
+	/**
55
+	 * @var SchemaAnalyzer
56
+	 */
57
+	private $schemaAnalyzer;
58
+
59
+	/**
60
+	 * @var MagicQuery
61
+	 */
62
+	private $magicQuery;
63
+
64
+	/**
65
+	 * @var TDBMSchemaAnalyzer
66
+	 */
67
+	private $tdbmSchemaAnalyzer;
68
+
69
+	/**
70
+	 * @var string
71
+	 */
72
+	private $cachePrefix;
73
+
74
+	/**
75
+	 * Cache of table of primary keys.
76
+	 * Primary keys are stored by tables, as an array of column.
77
+	 * For instance $primary_key['my_table'][0] will return the first column of the primary key of table 'my_table'.
78
+	 *
79
+	 * @var string[]
80
+	 */
81
+	private $primaryKeysColumns;
82
+
83
+	/**
84
+	 * Service storing objects in memory.
85
+	 * Access is done by table name and then by primary key.
86
+	 * If the primary key is split on several columns, access is done by an array of columns, serialized.
87
+	 *
88
+	 * @var StandardObjectStorage|WeakrefObjectStorage
89
+	 */
90
+	private $objectStorage;
91
+
92
+	/**
93
+	 * The fetch mode of the result sets returned by `getObjects`.
94
+	 * Can be one of: TDBMObjectArray::MODE_CURSOR or TDBMObjectArray::MODE_ARRAY or TDBMObjectArray::MODE_COMPATIBLE_ARRAY.
95
+	 *
96
+	 * In 'MODE_ARRAY' mode (default), the result is an array. Use this mode by default (unless the list returned is very big).
97
+	 * In 'MODE_CURSOR' mode, the result is a Generator which is an iterable collection that can be scanned only once (only one "foreach") on it,
98
+	 * and it cannot be accessed via key. Use this mode for large datasets processed by batch.
99
+	 * In 'MODE_COMPATIBLE_ARRAY' mode, the result is an old TDBMObjectArray (used up to TDBM 3.2).
100
+	 * You can access the array by key, or using foreach, several times.
101
+	 *
102
+	 * @var int
103
+	 */
104
+	private $mode = self::MODE_ARRAY;
105
+
106
+	/**
107
+	 * Table of new objects not yet inserted in database or objects modified that must be saved.
108
+	 *
109
+	 * @var \SplObjectStorage of DbRow objects
110
+	 */
111
+	private $toSaveObjects;
112
+
113
+	/**
114
+	 * The content of the cache variable.
115
+	 *
116
+	 * @var array<string, mixed>
117
+	 */
118
+	private $cache;
119
+
120
+	/**
121
+	 * Map associating a table name to a fully qualified Bean class name.
122
+	 *
123
+	 * @var array
124
+	 */
125
+	private $tableToBeanMap = [];
126
+
127
+	/**
128
+	 * @var \ReflectionClass[]
129
+	 */
130
+	private $reflectionClassCache = array();
131
+
132
+	/**
133
+	 * @param Connection     $connection     The DBAL DB connection to use
134
+	 * @param Cache|null     $cache          A cache service to be used
135
+	 * @param SchemaAnalyzer $schemaAnalyzer The schema analyzer that will be used to find shortest paths...
136
+	 *                                       Will be automatically created if not passed.
137
+	 */
138
+	public function __construct(Connection $connection, Cache $cache = null, SchemaAnalyzer $schemaAnalyzer = null)
139
+	{
140
+		if (extension_loaded('weakref')) {
141
+			$this->objectStorage = new WeakrefObjectStorage();
142
+		} else {
143
+			$this->objectStorage = new StandardObjectStorage();
144
+		}
145
+		$this->connection = $connection;
146
+		if ($cache !== null) {
147
+			$this->cache = $cache;
148
+		} else {
149
+			$this->cache = new VoidCache();
150
+		}
151
+		if ($schemaAnalyzer) {
152
+			$this->schemaAnalyzer = $schemaAnalyzer;
153
+		} else {
154
+			$this->schemaAnalyzer = new SchemaAnalyzer($this->connection->getSchemaManager(), $this->cache, $this->getConnectionUniqueId());
155
+		}
156
+
157
+		$this->magicQuery = new MagicQuery($this->connection, $this->cache, $this->schemaAnalyzer);
158
+
159
+		$this->tdbmSchemaAnalyzer = new TDBMSchemaAnalyzer($connection, $this->cache, $this->schemaAnalyzer);
160
+		$this->cachePrefix = $this->tdbmSchemaAnalyzer->getCachePrefix();
161
+
162
+		$this->toSaveObjects = new \SplObjectStorage();
163
+	}
164
+
165
+	/**
166
+	 * Returns the object used to connect to the database.
167
+	 *
168
+	 * @return Connection
169
+	 */
170
+	public function getConnection()
171
+	{
172
+		return $this->connection;
173
+	}
174
+
175
+	/**
176
+	 * Creates a unique cache key for the current connection.
177
+	 *
178
+	 * @return string
179
+	 */
180
+	private function getConnectionUniqueId()
181
+	{
182
+		return hash('md4', $this->connection->getHost().'-'.$this->connection->getPort().'-'.$this->connection->getDatabase().'-'.$this->connection->getDriver()->getName());
183
+	}
184
+
185
+	/**
186
+	 * Sets the default fetch mode of the result sets returned by `findObjects`.
187
+	 * Can be one of: TDBMObjectArray::MODE_CURSOR or TDBMObjectArray::MODE_ARRAY.
188
+	 *
189
+	 * In 'MODE_ARRAY' mode (default), the result is a ResultIterator object that behaves like an array. Use this mode by default (unless the list returned is very big).
190
+	 * In 'MODE_CURSOR' mode, the result is a ResultIterator object. If you scan it many times (by calling several time a foreach loop), the query will be run
191
+	 * several times. In cursor mode, you cannot access the result set by key. Use this mode for large datasets processed by batch.
192
+	 *
193
+	 * @param int $mode
194
+	 *
195
+	 * @return $this
196
+	 *
197
+	 * @throws TDBMException
198
+	 */
199
+	public function setFetchMode($mode)
200
+	{
201
+		if ($mode !== self::MODE_CURSOR && $mode !== self::MODE_ARRAY) {
202
+			throw new TDBMException("Unknown fetch mode: '".$this->mode."'");
203
+		}
204
+		$this->mode = $mode;
205
+
206
+		return $this;
207
+	}
208
+
209
+	/**
210
+	 * Returns a TDBMObject associated from table "$table_name".
211
+	 * If the $filters parameter is an int/string, the object returned will be the object whose primary key = $filters.
212
+	 * $filters can also be a set of TDBM_Filters (see the findObjects method for more details).
213
+	 *
214
+	 * For instance, if there is a table 'users', with a primary key on column 'user_id' and a column 'user_name', then
215
+	 * 			$user = $tdbmService->getObject('users',1);
216
+	 * 			echo $user->name;
217
+	 * will return the name of the user whose user_id is one.
218
+	 *
219
+	 * If a table has a primary key over several columns, you should pass to $id an array containing the the value of the various columns.
220
+	 * For instance:
221
+	 * 			$group = $tdbmService->getObject('groups',array(1,2));
222
+	 *
223
+	 * Note that TDBMObject performs caching for you. If you get twice the same object, the reference of the object you will get
224
+	 * will be the same.
225
+	 *
226
+	 * For instance:
227
+	 * 			$user1 = $tdbmService->getObject('users',1);
228
+	 * 			$user2 = $tdbmService->getObject('users',1);
229
+	 * 			$user1->name = 'John Doe';
230
+	 * 			echo $user2->name;
231
+	 * will return 'John Doe'.
232
+	 *
233
+	 * You can use filters instead of passing the primary key. For instance:
234
+	 * 			$user = $tdbmService->getObject('users',new EqualFilter('users', 'login', 'jdoe'));
235
+	 * This will return the user whose login is 'jdoe'.
236
+	 * Please note that if 2 users have the jdoe login in database, the method will throw a TDBM_DuplicateRowException.
237
+	 *
238
+	 * Also, you can specify the return class for the object (provided the return class extends TDBMObject).
239
+	 * For instance:
240
+	 *  	$user = $tdbmService->getObject('users',1,'User');
241
+	 * will return an object from the "User" class. The "User" class must extend the "TDBMObject" class.
242
+	 * Please be sure not to override any method or any property unless you perfectly know what you are doing!
243
+	 *
244
+	 * @param string $table_name   The name of the table we retrieve an object from.
245
+	 * @param mixed  $filters      If the filter is a string/integer, it will be considered as the id of the object (the value of the primary key). Otherwise, it can be a filter bag (see the filterbag parameter of the findObjects method for more details about filter bags)
246
+	 * @param string $className    Optional: The name of the class to instanciate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
247
+	 * @param bool   $lazy_loading If set to true, and if the primary key is passed in parameter of getObject, the object will not be queried in database. It will be queried when you first try to access a column. If at that time the object cannot be found in database, an exception will be thrown.
248
+	 *
249
+	 * @return TDBMObject
250
+	 */
251 251
 /*	public function getObject($table_name, $filters, $className = null, $lazy_loading = false) {
252 252
 
253 253
         if (is_array($filters) || $filters instanceof FilterInterface) {
@@ -333,233 +333,233 @@  discard block
 block discarded – undo
333 333
         return $obj;
334 334
     }*/
335 335
 
336
-    /**
337
-     * Removes the given object from database.
338
-     * This cannot be called on an object that is not attached to this TDBMService
339
-     * (will throw a TDBMInvalidOperationException).
340
-     *
341
-     * @param AbstractTDBMObject $object the object to delete.
342
-     *
343
-     * @throws TDBMException
344
-     * @throws TDBMInvalidOperationException
345
-     */
346
-    public function delete(AbstractTDBMObject $object)
347
-    {
348
-        switch ($object->_getStatus()) {
349
-            case TDBMObjectStateEnum::STATE_DELETED:
350
-                // Nothing to do, object already deleted.
351
-                return;
352
-            case TDBMObjectStateEnum::STATE_DETACHED:
353
-                throw new TDBMInvalidOperationException('Cannot delete a detached object');
354
-            case TDBMObjectStateEnum::STATE_NEW:
355
-                $this->deleteManyToManyRelationships($object);
356
-                foreach ($object->_getDbRows() as $dbRow) {
357
-                    $this->removeFromToSaveObjectList($dbRow);
358
-                }
359
-                break;
360
-            case TDBMObjectStateEnum::STATE_DIRTY:
361
-                foreach ($object->_getDbRows() as $dbRow) {
362
-                    $this->removeFromToSaveObjectList($dbRow);
363
-                }
364
-                // And continue deleting...
365
-            case TDBMObjectStateEnum::STATE_NOT_LOADED:
366
-            case TDBMObjectStateEnum::STATE_LOADED:
367
-                $this->deleteManyToManyRelationships($object);
368
-                // Let's delete db rows, in reverse order.
369
-                foreach (array_reverse($object->_getDbRows()) as $dbRow) {
370
-                    $tableName = $dbRow->_getDbTableName();
371
-                    $primaryKeys = $dbRow->_getPrimaryKeys();
372
-                    $this->connection->delete($tableName, $primaryKeys);
373
-                    $this->objectStorage->remove($dbRow->_getDbTableName(), $this->getObjectHash($primaryKeys));
374
-                }
375
-                break;
376
-            // @codeCoverageIgnoreStart
377
-            default:
378
-                throw new TDBMInvalidOperationException('Unexpected status for bean');
379
-            // @codeCoverageIgnoreEnd
380
-        }
381
-
382
-        $object->_setStatus(TDBMObjectStateEnum::STATE_DELETED);
383
-    }
384
-
385
-    /**
386
-     * Removes all many to many relationships for this object.
387
-     *
388
-     * @param AbstractTDBMObject $object
389
-     */
390
-    private function deleteManyToManyRelationships(AbstractTDBMObject $object)
391
-    {
392
-        foreach ($object->_getDbRows() as $tableName => $dbRow) {
393
-            $pivotTables = $this->tdbmSchemaAnalyzer->getPivotTableLinkedToTable($tableName);
394
-            foreach ($pivotTables as $pivotTable) {
395
-                $remoteBeans = $object->_getRelationships($pivotTable);
396
-                foreach ($remoteBeans as $remoteBean) {
397
-                    $object->_removeRelationship($pivotTable, $remoteBean);
398
-                }
399
-            }
400
-        }
401
-        $this->persistManyToManyRelationships($object);
402
-    }
403
-
404
-    /**
405
-     * This function removes the given object from the database. It will also remove all objects relied to the one given
406
-     * by parameter before all.
407
-     *
408
-     * Notice: if the object has a multiple primary key, the function will not work.
409
-     *
410
-     * @param AbstractTDBMObject $objToDelete
411
-     */
412
-    public function deleteCascade(AbstractTDBMObject $objToDelete)
413
-    {
414
-        $this->deleteAllConstraintWithThisObject($objToDelete);
415
-        $this->delete($objToDelete);
416
-    }
417
-
418
-    /**
419
-     * This function is used only in TDBMService (private function)
420
-     * It will call deleteCascade function foreach object relied with a foreign key to the object given by parameter.
421
-     *
422
-     * @param AbstractTDBMObject $obj
423
-     */
424
-    private function deleteAllConstraintWithThisObject(AbstractTDBMObject $obj)
425
-    {
426
-        $dbRows = $obj->_getDbRows();
427
-        foreach ($dbRows as $dbRow) {
428
-            $tableName = $dbRow->_getDbTableName();
429
-            $pks = array_values($dbRow->_getPrimaryKeys());
430
-            if (!empty($pks)) {
431
-                $incomingFks = $this->tdbmSchemaAnalyzer->getIncomingForeignKeys($tableName);
432
-
433
-                foreach ($incomingFks as $incomingFk) {
434
-                    $filter = array_combine($incomingFk->getLocalColumns(), $pks);
435
-
436
-                    $results = $this->findObjects($incomingFk->getLocalTableName(), $filter);
437
-
438
-                    foreach ($results as $bean) {
439
-                        $this->deleteCascade($bean);
440
-                    }
441
-                }
442
-            }
443
-        }
444
-    }
445
-
446
-    /**
447
-     * This function performs a save() of all the objects that have been modified.
448
-     */
449
-    public function completeSave()
450
-    {
451
-        foreach ($this->toSaveObjects as $dbRow) {
452
-            $this->save($dbRow->getTDBMObject());
453
-        }
454
-    }
455
-
456
-    /**
457
-     * Takes in input a filter_bag (which can be about anything from a string to an array of TDBMObjects... see above from documentation),
458
-     * and gives back a proper Filter object.
459
-     *
460
-     * @param mixed $filter_bag
461
-     * @param int   $counter
462
-     *
463
-     * @return array First item: filter string, second item: parameters.
464
-     *
465
-     * @throws TDBMException
466
-     */
467
-    public function buildFilterFromFilterBag($filter_bag, $counter = 1)
468
-    {
469
-        if ($filter_bag === null) {
470
-            return ['', []];
471
-        } elseif (is_string($filter_bag)) {
472
-            return [$filter_bag, []];
473
-        } elseif (is_array($filter_bag)) {
474
-            $sqlParts = [];
475
-            $parameters = [];
476
-            foreach ($filter_bag as $column => $value) {
477
-                if (is_int($column)) {
478
-                    list($subSqlPart, $subParameters) = $this->buildFilterFromFilterBag($value, $counter);
479
-                    $sqlParts[] = $subSqlPart;
480
-                    $parameters += $subParameters;
481
-                } else {
482
-                    $paramName = 'tdbmparam'.$counter;
483
-                    if (is_array($value)) {
484
-                        $sqlParts[] = $this->connection->quoteIdentifier($column).' IN :'.$paramName;
485
-                    } else {
486
-                        $sqlParts[] = $this->connection->quoteIdentifier($column).' = :'.$paramName;
487
-                    }
488
-                    $parameters[$paramName] = $value;
489
-                    ++$counter;
490
-                }
491
-            }
492
-
493
-            return [implode(' AND ', $sqlParts), $parameters];
494
-        } elseif ($filter_bag instanceof AbstractTDBMObject) {
495
-            $sqlParts = [];
496
-            $parameters = [];
497
-            $dbRows = $filter_bag->_getDbRows();
498
-            $dbRow = reset($dbRows);
499
-            $primaryKeys = $dbRow->_getPrimaryKeys();
500
-
501
-            foreach ($primaryKeys as $column => $value) {
502
-                $paramName = 'tdbmparam'.$counter;
503
-                $sqlParts[] = $this->connection->quoteIdentifier($dbRow->_getDbTableName()).'.'.$this->connection->quoteIdentifier($column).' = :'.$paramName;
504
-                $parameters[$paramName] = $value;
505
-                ++$counter;
506
-            }
507
-
508
-            return [implode(' AND ', $sqlParts), $parameters];
509
-        } elseif ($filter_bag instanceof \Iterator) {
510
-            return $this->buildFilterFromFilterBag(iterator_to_array($filter_bag), $counter);
511
-        } else {
512
-            throw new TDBMException('Error in filter. An object has been passed that is neither a SQL string, nor an array, nor a bean, nor null.');
513
-        }
514
-    }
515
-
516
-    /**
517
-     * Takes in input an order_bag (which can be about anything from a string to an array of OrderByColumn objects... see above from documentation),
518
-     * and gives back an array of OrderByColumn / OrderBySQLString objects.
519
-     *
520
-     * @param unknown_type $orderby_bag
521
-     *
522
-     * @return array
523
-     */
524
-    public function buildOrderArrayFromOrderBag($orderby_bag)
525
-    {
526
-        // Fourth, let's apply the same steps to the orderby_bag
527
-        // 4-1 orderby_bag should be an array, if it is a singleton, let's put it in an array.
528
-
529
-        if (!is_array($orderby_bag)) {
530
-            $orderby_bag = array($orderby_bag);
531
-        }
532
-
533
-        // 4-2, let's take all the objects out of the orderby bag, and let's make objects from them
534
-        $orderby_bag2 = array();
535
-        foreach ($orderby_bag as $thing) {
536
-            if (is_a($thing, 'Mouf\\Database\\TDBM\\Filters\\OrderBySQLString')) {
537
-                $orderby_bag2[] = $thing;
538
-            } elseif (is_a($thing, 'Mouf\\Database\\TDBM\\Filters\\OrderByColumn')) {
539
-                $orderby_bag2[] = $thing;
540
-            } elseif (is_string($thing)) {
541
-                $orderby_bag2[] = new OrderBySQLString($thing);
542
-            } elseif ($thing !== null) {
543
-                throw new TDBMException('Error in orderby bag in getObjectsByFilter. An object has been passed that is neither a OrderBySQLString, nor a OrderByColumn, nor a string, nor null.');
544
-            }
545
-        }
546
-
547
-        return $orderby_bag2;
548
-    }
549
-
550
-    /**
551
-     * @param string $table
552
-     *
553
-     * @return string[]
554
-     */
555
-    public function getPrimaryKeyColumns($table)
556
-    {
557
-        if (!isset($this->primaryKeysColumns[$table])) {
558
-            $this->primaryKeysColumns[$table] = $this->tdbmSchemaAnalyzer->getSchema()->getTable($table)->getPrimaryKeyColumns();
559
-
560
-            // TODO TDBM4: See if we need to improve error reporting if table name does not exist.
561
-
562
-            /*$arr = array();
336
+	/**
337
+	 * Removes the given object from database.
338
+	 * This cannot be called on an object that is not attached to this TDBMService
339
+	 * (will throw a TDBMInvalidOperationException).
340
+	 *
341
+	 * @param AbstractTDBMObject $object the object to delete.
342
+	 *
343
+	 * @throws TDBMException
344
+	 * @throws TDBMInvalidOperationException
345
+	 */
346
+	public function delete(AbstractTDBMObject $object)
347
+	{
348
+		switch ($object->_getStatus()) {
349
+			case TDBMObjectStateEnum::STATE_DELETED:
350
+				// Nothing to do, object already deleted.
351
+				return;
352
+			case TDBMObjectStateEnum::STATE_DETACHED:
353
+				throw new TDBMInvalidOperationException('Cannot delete a detached object');
354
+			case TDBMObjectStateEnum::STATE_NEW:
355
+				$this->deleteManyToManyRelationships($object);
356
+				foreach ($object->_getDbRows() as $dbRow) {
357
+					$this->removeFromToSaveObjectList($dbRow);
358
+				}
359
+				break;
360
+			case TDBMObjectStateEnum::STATE_DIRTY:
361
+				foreach ($object->_getDbRows() as $dbRow) {
362
+					$this->removeFromToSaveObjectList($dbRow);
363
+				}
364
+				// And continue deleting...
365
+			case TDBMObjectStateEnum::STATE_NOT_LOADED:
366
+			case TDBMObjectStateEnum::STATE_LOADED:
367
+				$this->deleteManyToManyRelationships($object);
368
+				// Let's delete db rows, in reverse order.
369
+				foreach (array_reverse($object->_getDbRows()) as $dbRow) {
370
+					$tableName = $dbRow->_getDbTableName();
371
+					$primaryKeys = $dbRow->_getPrimaryKeys();
372
+					$this->connection->delete($tableName, $primaryKeys);
373
+					$this->objectStorage->remove($dbRow->_getDbTableName(), $this->getObjectHash($primaryKeys));
374
+				}
375
+				break;
376
+			// @codeCoverageIgnoreStart
377
+			default:
378
+				throw new TDBMInvalidOperationException('Unexpected status for bean');
379
+			// @codeCoverageIgnoreEnd
380
+		}
381
+
382
+		$object->_setStatus(TDBMObjectStateEnum::STATE_DELETED);
383
+	}
384
+
385
+	/**
386
+	 * Removes all many to many relationships for this object.
387
+	 *
388
+	 * @param AbstractTDBMObject $object
389
+	 */
390
+	private function deleteManyToManyRelationships(AbstractTDBMObject $object)
391
+	{
392
+		foreach ($object->_getDbRows() as $tableName => $dbRow) {
393
+			$pivotTables = $this->tdbmSchemaAnalyzer->getPivotTableLinkedToTable($tableName);
394
+			foreach ($pivotTables as $pivotTable) {
395
+				$remoteBeans = $object->_getRelationships($pivotTable);
396
+				foreach ($remoteBeans as $remoteBean) {
397
+					$object->_removeRelationship($pivotTable, $remoteBean);
398
+				}
399
+			}
400
+		}
401
+		$this->persistManyToManyRelationships($object);
402
+	}
403
+
404
+	/**
405
+	 * This function removes the given object from the database. It will also remove all objects relied to the one given
406
+	 * by parameter before all.
407
+	 *
408
+	 * Notice: if the object has a multiple primary key, the function will not work.
409
+	 *
410
+	 * @param AbstractTDBMObject $objToDelete
411
+	 */
412
+	public function deleteCascade(AbstractTDBMObject $objToDelete)
413
+	{
414
+		$this->deleteAllConstraintWithThisObject($objToDelete);
415
+		$this->delete($objToDelete);
416
+	}
417
+
418
+	/**
419
+	 * This function is used only in TDBMService (private function)
420
+	 * It will call deleteCascade function foreach object relied with a foreign key to the object given by parameter.
421
+	 *
422
+	 * @param AbstractTDBMObject $obj
423
+	 */
424
+	private function deleteAllConstraintWithThisObject(AbstractTDBMObject $obj)
425
+	{
426
+		$dbRows = $obj->_getDbRows();
427
+		foreach ($dbRows as $dbRow) {
428
+			$tableName = $dbRow->_getDbTableName();
429
+			$pks = array_values($dbRow->_getPrimaryKeys());
430
+			if (!empty($pks)) {
431
+				$incomingFks = $this->tdbmSchemaAnalyzer->getIncomingForeignKeys($tableName);
432
+
433
+				foreach ($incomingFks as $incomingFk) {
434
+					$filter = array_combine($incomingFk->getLocalColumns(), $pks);
435
+
436
+					$results = $this->findObjects($incomingFk->getLocalTableName(), $filter);
437
+
438
+					foreach ($results as $bean) {
439
+						$this->deleteCascade($bean);
440
+					}
441
+				}
442
+			}
443
+		}
444
+	}
445
+
446
+	/**
447
+	 * This function performs a save() of all the objects that have been modified.
448
+	 */
449
+	public function completeSave()
450
+	{
451
+		foreach ($this->toSaveObjects as $dbRow) {
452
+			$this->save($dbRow->getTDBMObject());
453
+		}
454
+	}
455
+
456
+	/**
457
+	 * Takes in input a filter_bag (which can be about anything from a string to an array of TDBMObjects... see above from documentation),
458
+	 * and gives back a proper Filter object.
459
+	 *
460
+	 * @param mixed $filter_bag
461
+	 * @param int   $counter
462
+	 *
463
+	 * @return array First item: filter string, second item: parameters.
464
+	 *
465
+	 * @throws TDBMException
466
+	 */
467
+	public function buildFilterFromFilterBag($filter_bag, $counter = 1)
468
+	{
469
+		if ($filter_bag === null) {
470
+			return ['', []];
471
+		} elseif (is_string($filter_bag)) {
472
+			return [$filter_bag, []];
473
+		} elseif (is_array($filter_bag)) {
474
+			$sqlParts = [];
475
+			$parameters = [];
476
+			foreach ($filter_bag as $column => $value) {
477
+				if (is_int($column)) {
478
+					list($subSqlPart, $subParameters) = $this->buildFilterFromFilterBag($value, $counter);
479
+					$sqlParts[] = $subSqlPart;
480
+					$parameters += $subParameters;
481
+				} else {
482
+					$paramName = 'tdbmparam'.$counter;
483
+					if (is_array($value)) {
484
+						$sqlParts[] = $this->connection->quoteIdentifier($column).' IN :'.$paramName;
485
+					} else {
486
+						$sqlParts[] = $this->connection->quoteIdentifier($column).' = :'.$paramName;
487
+					}
488
+					$parameters[$paramName] = $value;
489
+					++$counter;
490
+				}
491
+			}
492
+
493
+			return [implode(' AND ', $sqlParts), $parameters];
494
+		} elseif ($filter_bag instanceof AbstractTDBMObject) {
495
+			$sqlParts = [];
496
+			$parameters = [];
497
+			$dbRows = $filter_bag->_getDbRows();
498
+			$dbRow = reset($dbRows);
499
+			$primaryKeys = $dbRow->_getPrimaryKeys();
500
+
501
+			foreach ($primaryKeys as $column => $value) {
502
+				$paramName = 'tdbmparam'.$counter;
503
+				$sqlParts[] = $this->connection->quoteIdentifier($dbRow->_getDbTableName()).'.'.$this->connection->quoteIdentifier($column).' = :'.$paramName;
504
+				$parameters[$paramName] = $value;
505
+				++$counter;
506
+			}
507
+
508
+			return [implode(' AND ', $sqlParts), $parameters];
509
+		} elseif ($filter_bag instanceof \Iterator) {
510
+			return $this->buildFilterFromFilterBag(iterator_to_array($filter_bag), $counter);
511
+		} else {
512
+			throw new TDBMException('Error in filter. An object has been passed that is neither a SQL string, nor an array, nor a bean, nor null.');
513
+		}
514
+	}
515
+
516
+	/**
517
+	 * Takes in input an order_bag (which can be about anything from a string to an array of OrderByColumn objects... see above from documentation),
518
+	 * and gives back an array of OrderByColumn / OrderBySQLString objects.
519
+	 *
520
+	 * @param unknown_type $orderby_bag
521
+	 *
522
+	 * @return array
523
+	 */
524
+	public function buildOrderArrayFromOrderBag($orderby_bag)
525
+	{
526
+		// Fourth, let's apply the same steps to the orderby_bag
527
+		// 4-1 orderby_bag should be an array, if it is a singleton, let's put it in an array.
528
+
529
+		if (!is_array($orderby_bag)) {
530
+			$orderby_bag = array($orderby_bag);
531
+		}
532
+
533
+		// 4-2, let's take all the objects out of the orderby bag, and let's make objects from them
534
+		$orderby_bag2 = array();
535
+		foreach ($orderby_bag as $thing) {
536
+			if (is_a($thing, 'Mouf\\Database\\TDBM\\Filters\\OrderBySQLString')) {
537
+				$orderby_bag2[] = $thing;
538
+			} elseif (is_a($thing, 'Mouf\\Database\\TDBM\\Filters\\OrderByColumn')) {
539
+				$orderby_bag2[] = $thing;
540
+			} elseif (is_string($thing)) {
541
+				$orderby_bag2[] = new OrderBySQLString($thing);
542
+			} elseif ($thing !== null) {
543
+				throw new TDBMException('Error in orderby bag in getObjectsByFilter. An object has been passed that is neither a OrderBySQLString, nor a OrderByColumn, nor a string, nor null.');
544
+			}
545
+		}
546
+
547
+		return $orderby_bag2;
548
+	}
549
+
550
+	/**
551
+	 * @param string $table
552
+	 *
553
+	 * @return string[]
554
+	 */
555
+	public function getPrimaryKeyColumns($table)
556
+	{
557
+		if (!isset($this->primaryKeysColumns[$table])) {
558
+			$this->primaryKeysColumns[$table] = $this->tdbmSchemaAnalyzer->getSchema()->getTable($table)->getPrimaryKeyColumns();
559
+
560
+			// TODO TDBM4: See if we need to improve error reporting if table name does not exist.
561
+
562
+			/*$arr = array();
563 563
             foreach ($this->connection->getPrimaryKey($table) as $col) {
564 564
                 $arr[] = $col->name;
565 565
             }
@@ -580,129 +580,129 @@  discard block
 block discarded – undo
580 580
                     throw new TDBMException($str);
581 581
                 }
582 582
             }*/
583
-        }
584
-
585
-        return $this->primaryKeysColumns[$table];
586
-    }
587
-
588
-    /**
589
-     * This is an internal function, you should not use it in your application.
590
-     * This is used internally by TDBM to add an object to the object cache.
591
-     *
592
-     * @param DbRow $dbRow
593
-     */
594
-    public function _addToCache(DbRow $dbRow)
595
-    {
596
-        $primaryKey = $this->getPrimaryKeysForObjectFromDbRow($dbRow);
597
-        $hash = $this->getObjectHash($primaryKey);
598
-        $this->objectStorage->set($dbRow->_getDbTableName(), $hash, $dbRow);
599
-    }
600
-
601
-    /**
602
-     * This is an internal function, you should not use it in your application.
603
-     * This is used internally by TDBM to remove the object from the list of objects that have been
604
-     * created/updated but not saved yet.
605
-     *
606
-     * @param DbRow $myObject
607
-     */
608
-    private function removeFromToSaveObjectList(DbRow $myObject)
609
-    {
610
-        unset($this->toSaveObjects[$myObject]);
611
-    }
612
-
613
-    /**
614
-     * This is an internal function, you should not use it in your application.
615
-     * This is used internally by TDBM to add an object to the list of objects that have been
616
-     * created/updated but not saved yet.
617
-     *
618
-     * @param AbstractTDBMObject $myObject
619
-     */
620
-    public function _addToToSaveObjectList(DbRow $myObject)
621
-    {
622
-        $this->toSaveObjects[$myObject] = true;
623
-    }
624
-
625
-    /**
626
-     * Generates all the daos and beans.
627
-     *
628
-     * @param string $daoFactoryClassName The classe name of the DAO factory
629
-     * @param string $daonamespace        The namespace for the DAOs, without trailing \
630
-     * @param string $beannamespace       The Namespace for the beans, without trailing \
631
-     * @param bool   $storeInUtc          If the generated daos should store the date in UTC timezone instead of user's timezone.
632
-     * @param string $storePath           If it's set, the path to generate daos and beans. By default it's locate with rootPath.
633
-     *
634
-     * @return \string[] the list of tables
635
-     */
636
-    public function generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc, $storePath = null)
637
-    {
638
-        $tdbmDaoGenerator = new TDBMDaoGenerator($this->schemaAnalyzer, $this->tdbmSchemaAnalyzer->getSchema(), $this->tdbmSchemaAnalyzer);
639
-        $tdbmDaoGenerator->setRootPath($tdbmDaoGenerator->getRootPath().$storePath);
640
-        return $tdbmDaoGenerator->generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc, $storePath);
641
-    }
642
-
643
-    /**
644
-     * @param array<string, string> $tableToBeanMap
645
-     */
646
-    public function setTableToBeanMap(array $tableToBeanMap)
647
-    {
648
-        $this->tableToBeanMap = $tableToBeanMap;
649
-    }
650
-
651
-    /**
652
-     * Saves $object by INSERTing or UPDAT(E)ing it in the database.
653
-     *
654
-     * @param AbstractTDBMObject $object
655
-     *
656
-     * @throws TDBMException
657
-     */
658
-    public function save(AbstractTDBMObject $object)
659
-    {
660
-        $status = $object->_getStatus();
661
-
662
-        // Let's attach this object if it is in detached state.
663
-        if ($status === TDBMObjectStateEnum::STATE_DETACHED) {
664
-            $object->_attach($this);
665
-            $status = $object->_getStatus();
666
-        }
667
-
668
-        if ($status === TDBMObjectStateEnum::STATE_NEW) {
669
-            $dbRows = $object->_getDbRows();
670
-
671
-            $unindexedPrimaryKeys = array();
672
-
673
-            foreach ($dbRows as $dbRow) {
674
-                $tableName = $dbRow->_getDbTableName();
675
-
676
-                $schema = $this->tdbmSchemaAnalyzer->getSchema();
677
-                $tableDescriptor = $schema->getTable($tableName);
678
-
679
-                $primaryKeyColumns = $this->getPrimaryKeyColumns($tableName);
680
-
681
-                if (empty($unindexedPrimaryKeys)) {
682
-                    $primaryKeys = $this->getPrimaryKeysForObjectFromDbRow($dbRow);
683
-                } else {
684
-                    // First insert, the children must have the same primary key as the parent.
685
-                    $primaryKeys = $this->_getPrimaryKeysFromIndexedPrimaryKeys($tableName, $unindexedPrimaryKeys);
686
-                    $dbRow->_setPrimaryKeys($primaryKeys);
687
-                }
688
-
689
-                $references = $dbRow->_getReferences();
690
-
691
-                // Let's save all references in NEW or DETACHED state (we need their primary key)
692
-                foreach ($references as $fkName => $reference) {
693
-                    $refStatus = $reference->_getStatus();
694
-                    if ($refStatus === TDBMObjectStateEnum::STATE_NEW || $refStatus === TDBMObjectStateEnum::STATE_DETACHED) {
695
-                        $this->save($reference);
696
-                    }
697
-                }
698
-
699
-                $dbRowData = $dbRow->_getDbRow();
700
-
701
-                // Let's see if the columns for primary key have been set before inserting.
702
-                // We assume that if one of the value of the PK has been set, the PK is set.
703
-                $isPkSet = !empty($primaryKeys);
704
-
705
-                /*if (!$isPkSet) {
583
+		}
584
+
585
+		return $this->primaryKeysColumns[$table];
586
+	}
587
+
588
+	/**
589
+	 * This is an internal function, you should not use it in your application.
590
+	 * This is used internally by TDBM to add an object to the object cache.
591
+	 *
592
+	 * @param DbRow $dbRow
593
+	 */
594
+	public function _addToCache(DbRow $dbRow)
595
+	{
596
+		$primaryKey = $this->getPrimaryKeysForObjectFromDbRow($dbRow);
597
+		$hash = $this->getObjectHash($primaryKey);
598
+		$this->objectStorage->set($dbRow->_getDbTableName(), $hash, $dbRow);
599
+	}
600
+
601
+	/**
602
+	 * This is an internal function, you should not use it in your application.
603
+	 * This is used internally by TDBM to remove the object from the list of objects that have been
604
+	 * created/updated but not saved yet.
605
+	 *
606
+	 * @param DbRow $myObject
607
+	 */
608
+	private function removeFromToSaveObjectList(DbRow $myObject)
609
+	{
610
+		unset($this->toSaveObjects[$myObject]);
611
+	}
612
+
613
+	/**
614
+	 * This is an internal function, you should not use it in your application.
615
+	 * This is used internally by TDBM to add an object to the list of objects that have been
616
+	 * created/updated but not saved yet.
617
+	 *
618
+	 * @param AbstractTDBMObject $myObject
619
+	 */
620
+	public function _addToToSaveObjectList(DbRow $myObject)
621
+	{
622
+		$this->toSaveObjects[$myObject] = true;
623
+	}
624
+
625
+	/**
626
+	 * Generates all the daos and beans.
627
+	 *
628
+	 * @param string $daoFactoryClassName The classe name of the DAO factory
629
+	 * @param string $daonamespace        The namespace for the DAOs, without trailing \
630
+	 * @param string $beannamespace       The Namespace for the beans, without trailing \
631
+	 * @param bool   $storeInUtc          If the generated daos should store the date in UTC timezone instead of user's timezone.
632
+	 * @param string $storePath           If it's set, the path to generate daos and beans. By default it's locate with rootPath.
633
+	 *
634
+	 * @return \string[] the list of tables
635
+	 */
636
+	public function generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc, $storePath = null)
637
+	{
638
+		$tdbmDaoGenerator = new TDBMDaoGenerator($this->schemaAnalyzer, $this->tdbmSchemaAnalyzer->getSchema(), $this->tdbmSchemaAnalyzer);
639
+		$tdbmDaoGenerator->setRootPath($tdbmDaoGenerator->getRootPath().$storePath);
640
+		return $tdbmDaoGenerator->generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc, $storePath);
641
+	}
642
+
643
+	/**
644
+	 * @param array<string, string> $tableToBeanMap
645
+	 */
646
+	public function setTableToBeanMap(array $tableToBeanMap)
647
+	{
648
+		$this->tableToBeanMap = $tableToBeanMap;
649
+	}
650
+
651
+	/**
652
+	 * Saves $object by INSERTing or UPDAT(E)ing it in the database.
653
+	 *
654
+	 * @param AbstractTDBMObject $object
655
+	 *
656
+	 * @throws TDBMException
657
+	 */
658
+	public function save(AbstractTDBMObject $object)
659
+	{
660
+		$status = $object->_getStatus();
661
+
662
+		// Let's attach this object if it is in detached state.
663
+		if ($status === TDBMObjectStateEnum::STATE_DETACHED) {
664
+			$object->_attach($this);
665
+			$status = $object->_getStatus();
666
+		}
667
+
668
+		if ($status === TDBMObjectStateEnum::STATE_NEW) {
669
+			$dbRows = $object->_getDbRows();
670
+
671
+			$unindexedPrimaryKeys = array();
672
+
673
+			foreach ($dbRows as $dbRow) {
674
+				$tableName = $dbRow->_getDbTableName();
675
+
676
+				$schema = $this->tdbmSchemaAnalyzer->getSchema();
677
+				$tableDescriptor = $schema->getTable($tableName);
678
+
679
+				$primaryKeyColumns = $this->getPrimaryKeyColumns($tableName);
680
+
681
+				if (empty($unindexedPrimaryKeys)) {
682
+					$primaryKeys = $this->getPrimaryKeysForObjectFromDbRow($dbRow);
683
+				} else {
684
+					// First insert, the children must have the same primary key as the parent.
685
+					$primaryKeys = $this->_getPrimaryKeysFromIndexedPrimaryKeys($tableName, $unindexedPrimaryKeys);
686
+					$dbRow->_setPrimaryKeys($primaryKeys);
687
+				}
688
+
689
+				$references = $dbRow->_getReferences();
690
+
691
+				// Let's save all references in NEW or DETACHED state (we need their primary key)
692
+				foreach ($references as $fkName => $reference) {
693
+					$refStatus = $reference->_getStatus();
694
+					if ($refStatus === TDBMObjectStateEnum::STATE_NEW || $refStatus === TDBMObjectStateEnum::STATE_DETACHED) {
695
+						$this->save($reference);
696
+					}
697
+				}
698
+
699
+				$dbRowData = $dbRow->_getDbRow();
700
+
701
+				// Let's see if the columns for primary key have been set before inserting.
702
+				// We assume that if one of the value of the PK has been set, the PK is set.
703
+				$isPkSet = !empty($primaryKeys);
704
+
705
+				/*if (!$isPkSet) {
706 706
                     // if there is no autoincrement and no pk set, let's go in error.
707 707
                     $isAutoIncrement = true;
708 708
 
@@ -720,25 +720,25 @@  discard block
 block discarded – undo
720 720
 
721 721
                 }*/
722 722
 
723
-                $types = [];
723
+				$types = [];
724 724
 
725
-                foreach ($dbRowData as $columnName => $value) {
726
-                    $columnDescriptor = $tableDescriptor->getColumn($columnName);
727
-                    $types[] = $columnDescriptor->getType();
728
-                }
725
+				foreach ($dbRowData as $columnName => $value) {
726
+					$columnDescriptor = $tableDescriptor->getColumn($columnName);
727
+					$types[] = $columnDescriptor->getType();
728
+				}
729 729
 
730
-                $this->connection->insert($tableName, $dbRowData, $types);
730
+				$this->connection->insert($tableName, $dbRowData, $types);
731 731
 
732
-                if (!$isPkSet && count($primaryKeyColumns) == 1) {
733
-                    $id = $this->connection->lastInsertId();
734
-                    $primaryKeys[$primaryKeyColumns[0]] = $id;
735
-                }
732
+				if (!$isPkSet && count($primaryKeyColumns) == 1) {
733
+					$id = $this->connection->lastInsertId();
734
+					$primaryKeys[$primaryKeyColumns[0]] = $id;
735
+				}
736 736
 
737
-                // TODO: change this to some private magic accessor in future
738
-                $dbRow->_setPrimaryKeys($primaryKeys);
739
-                $unindexedPrimaryKeys = array_values($primaryKeys);
737
+				// TODO: change this to some private magic accessor in future
738
+				$dbRow->_setPrimaryKeys($primaryKeys);
739
+				$unindexedPrimaryKeys = array_values($primaryKeys);
740 740
 
741
-                /*
741
+				/*
742 742
                  * When attached, on "save", we check if the column updated is part of a primary key
743 743
                  * If this is part of a primary key, we call the _update_id method that updates the id in the list of known objects.
744 744
                  * This method should first verify that the id is not already used (and is not auto-incremented)
@@ -748,7 +748,7 @@  discard block
 block discarded – undo
748 748
                  *
749 749
                  */
750 750
 
751
-                /*try {
751
+				/*try {
752 752
                     $this->db_connection->exec($sql);
753 753
                 } catch (TDBMException $e) {
754 754
                     $this->db_onerror = true;
@@ -767,390 +767,390 @@  discard block
 block discarded – undo
767 767
                     }
768 768
                 }*/
769 769
 
770
-                // Let's remove this object from the $new_objects static table.
771
-                $this->removeFromToSaveObjectList($dbRow);
772
-
773
-                // TODO: change this behaviour to something more sensible performance-wise
774
-                // Maybe a setting to trigger this globally?
775
-                //$this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
776
-                //$this->db_modified_state = false;
777
-                //$dbRow = array();
778
-
779
-                // Let's add this object to the list of objects in cache.
780
-                $this->_addToCache($dbRow);
781
-            }
782
-
783
-            $object->_setStatus(TDBMObjectStateEnum::STATE_LOADED);
784
-        } elseif ($status === TDBMObjectStateEnum::STATE_DIRTY) {
785
-            $dbRows = $object->_getDbRows();
786
-
787
-            foreach ($dbRows as $dbRow) {
788
-                $references = $dbRow->_getReferences();
789
-
790
-                // Let's save all references in NEW state (we need their primary key)
791
-                foreach ($references as $fkName => $reference) {
792
-                    if ($reference->_getStatus() === TDBMObjectStateEnum::STATE_NEW) {
793
-                        $this->save($reference);
794
-                    }
795
-                }
796
-
797
-                // Let's first get the primary keys
798
-                $tableName = $dbRow->_getDbTableName();
799
-                $dbRowData = $dbRow->_getDbRow();
800
-
801
-                $schema = $this->tdbmSchemaAnalyzer->getSchema();
802
-                $tableDescriptor = $schema->getTable($tableName);
803
-
804
-                $primaryKeys = $dbRow->_getPrimaryKeys();
805
-
806
-                $types = [];
807
-
808
-                foreach ($dbRowData as $columnName => $value) {
809
-                    $columnDescriptor = $tableDescriptor->getColumn($columnName);
810
-                    $types[] = $columnDescriptor->getType();
811
-                }
812
-                foreach ($primaryKeys as $columnName => $value) {
813
-                    $columnDescriptor = $tableDescriptor->getColumn($columnName);
814
-                    $types[] = $columnDescriptor->getType();
815
-                }
816
-
817
-                $this->connection->update($tableName, $dbRowData, $primaryKeys, $types);
818
-
819
-                // Let's check if the primary key has been updated...
820
-                $needsUpdatePk = false;
821
-                foreach ($primaryKeys as $column => $value) {
822
-                    if (!isset($dbRowData[$column]) || $dbRowData[$column] != $value) {
823
-                        $needsUpdatePk = true;
824
-                        break;
825
-                    }
826
-                }
827
-                if ($needsUpdatePk) {
828
-                    $this->objectStorage->remove($tableName, $this->getObjectHash($primaryKeys));
829
-                    $newPrimaryKeys = $this->getPrimaryKeysForObjectFromDbRow($dbRow);
830
-                    $dbRow->_setPrimaryKeys($newPrimaryKeys);
831
-                    $this->objectStorage->set($tableName, $this->getObjectHash($primaryKeys), $dbRow);
832
-                }
833
-
834
-                // Let's remove this object from the list of objects to save.
835
-                $this->removeFromToSaveObjectList($dbRow);
836
-            }
837
-
838
-            $object->_setStatus(TDBMObjectStateEnum::STATE_LOADED);
839
-        } elseif ($status === TDBMObjectStateEnum::STATE_DELETED) {
840
-            throw new TDBMInvalidOperationException('This object has been deleted. It cannot be saved.');
841
-        }
842
-
843
-        // Finally, let's save all the many to many relationships to this bean.
844
-        $this->persistManyToManyRelationships($object);
845
-    }
846
-
847
-    private function persistManyToManyRelationships(AbstractTDBMObject $object)
848
-    {
849
-        foreach ($object->_getCachedRelationships() as $pivotTableName => $storage) {
850
-            $tableDescriptor = $this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName);
851
-            list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $object);
852
-
853
-            foreach ($storage as $remoteBean) {
854
-                /* @var $remoteBean AbstractTDBMObject */
855
-                $statusArr = $storage[$remoteBean];
856
-                $status = $statusArr['status'];
857
-                $reverse = $statusArr['reverse'];
858
-                if ($reverse) {
859
-                    continue;
860
-                }
861
-
862
-                if ($status === 'new') {
863
-                    $remoteBeanStatus = $remoteBean->_getStatus();
864
-                    if ($remoteBeanStatus === TDBMObjectStateEnum::STATE_NEW || $remoteBeanStatus === TDBMObjectStateEnum::STATE_DETACHED) {
865
-                        // Let's save remote bean if needed.
866
-                        $this->save($remoteBean);
867
-                    }
868
-
869
-                    $filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
870
-
871
-                    $types = [];
872
-
873
-                    foreach ($filters as $columnName => $value) {
874
-                        $columnDescriptor = $tableDescriptor->getColumn($columnName);
875
-                        $types[] = $columnDescriptor->getType();
876
-                    }
877
-
878
-                    $this->connection->insert($pivotTableName, $filters, $types);
879
-
880
-                    // Finally, let's mark relationships as saved.
881
-                    $statusArr['status'] = 'loaded';
882
-                    $storage[$remoteBean] = $statusArr;
883
-                    $remoteStorage = $remoteBean->_getCachedRelationships()[$pivotTableName];
884
-                    $remoteStatusArr = $remoteStorage[$object];
885
-                    $remoteStatusArr['status'] = 'loaded';
886
-                    $remoteStorage[$object] = $remoteStatusArr;
887
-                } elseif ($status === 'delete') {
888
-                    $filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
889
-
890
-                    $types = [];
891
-
892
-                    foreach ($filters as $columnName => $value) {
893
-                        $columnDescriptor = $tableDescriptor->getColumn($columnName);
894
-                        $types[] = $columnDescriptor->getType();
895
-                    }
896
-
897
-                    $this->connection->delete($pivotTableName, $filters, $types);
898
-
899
-                    // Finally, let's remove relationships completely from bean.
900
-                    $storage->detach($remoteBean);
901
-                    $remoteBean->_getCachedRelationships()[$pivotTableName]->detach($object);
902
-                }
903
-            }
904
-        }
905
-    }
906
-
907
-    private function getPivotFilters(AbstractTDBMObject $localBean, AbstractTDBMObject $remoteBean, ForeignKeyConstraint $localFk, ForeignKeyConstraint $remoteFk)
908
-    {
909
-        $localBeanPk = $this->getPrimaryKeyValues($localBean);
910
-        $remoteBeanPk = $this->getPrimaryKeyValues($remoteBean);
911
-        $localColumns = $localFk->getLocalColumns();
912
-        $remoteColumns = $remoteFk->getLocalColumns();
913
-
914
-        $localFilters = array_combine($localColumns, $localBeanPk);
915
-        $remoteFilters = array_combine($remoteColumns, $remoteBeanPk);
916
-
917
-        return array_merge($localFilters, $remoteFilters);
918
-    }
919
-
920
-    /**
921
-     * Returns the "values" of the primary key.
922
-     * This returns the primary key from the $primaryKey attribute, not the one stored in the columns.
923
-     *
924
-     * @param AbstractTDBMObject $bean
925
-     *
926
-     * @return array numerically indexed array of values.
927
-     */
928
-    private function getPrimaryKeyValues(AbstractTDBMObject $bean)
929
-    {
930
-        $dbRows = $bean->_getDbRows();
931
-        $dbRow = reset($dbRows);
932
-
933
-        return array_values($dbRow->_getPrimaryKeys());
934
-    }
935
-
936
-    /**
937
-     * Returns a unique hash used to store the object based on its primary key.
938
-     * If the array contains only one value, then the value is returned.
939
-     * Otherwise, a hash representing the array is returned.
940
-     *
941
-     * @param array $primaryKeys An array of columns => values forming the primary key
942
-     *
943
-     * @return string
944
-     */
945
-    public function getObjectHash(array $primaryKeys)
946
-    {
947
-        if (count($primaryKeys) === 1) {
948
-            return reset($primaryKeys);
949
-        } else {
950
-            ksort($primaryKeys);
951
-
952
-            return md5(json_encode($primaryKeys));
953
-        }
954
-    }
955
-
956
-    /**
957
-     * Returns an array of primary keys from the object.
958
-     * The primary keys are extracted from the object columns and not from the primary keys stored in the
959
-     * $primaryKeys variable of the object.
960
-     *
961
-     * @param DbRow $dbRow
962
-     *
963
-     * @return array Returns an array of column => value
964
-     */
965
-    public function getPrimaryKeysForObjectFromDbRow(DbRow $dbRow)
966
-    {
967
-        $table = $dbRow->_getDbTableName();
968
-        $dbRowData = $dbRow->_getDbRow();
969
-
970
-        return $this->_getPrimaryKeysFromObjectData($table, $dbRowData);
971
-    }
972
-
973
-    /**
974
-     * Returns an array of primary keys for the given row.
975
-     * The primary keys are extracted from the object columns.
976
-     *
977
-     * @param $table
978
-     * @param array $columns
979
-     *
980
-     * @return array
981
-     */
982
-    public function _getPrimaryKeysFromObjectData($table, array $columns)
983
-    {
984
-        $primaryKeyColumns = $this->getPrimaryKeyColumns($table);
985
-        $values = array();
986
-        foreach ($primaryKeyColumns as $column) {
987
-            if (isset($columns[$column])) {
988
-                $values[$column] = $columns[$column];
989
-            }
990
-        }
991
-
992
-        return $values;
993
-    }
994
-
995
-    /**
996
-     * Attaches $object to this TDBMService.
997
-     * The $object must be in DETACHED state and will pass in NEW state.
998
-     *
999
-     * @param AbstractTDBMObject $object
1000
-     *
1001
-     * @throws TDBMInvalidOperationException
1002
-     */
1003
-    public function attach(AbstractTDBMObject $object)
1004
-    {
1005
-        $object->_attach($this);
1006
-    }
1007
-
1008
-    /**
1009
-     * Returns an associative array (column => value) for the primary keys from the table name and an
1010
-     * indexed array of primary key values.
1011
-     *
1012
-     * @param string $tableName
1013
-     * @param array  $indexedPrimaryKeys
1014
-     */
1015
-    public function _getPrimaryKeysFromIndexedPrimaryKeys($tableName, array $indexedPrimaryKeys)
1016
-    {
1017
-        $primaryKeyColumns = $this->tdbmSchemaAnalyzer->getSchema()->getTable($tableName)->getPrimaryKeyColumns();
1018
-
1019
-        if (count($primaryKeyColumns) !== count($indexedPrimaryKeys)) {
1020
-            throw new TDBMException(sprintf('Wrong number of columns passed for primary key. Expected %s columns for table "%s",
770
+				// Let's remove this object from the $new_objects static table.
771
+				$this->removeFromToSaveObjectList($dbRow);
772
+
773
+				// TODO: change this behaviour to something more sensible performance-wise
774
+				// Maybe a setting to trigger this globally?
775
+				//$this->status = TDBMObjectStateEnum::STATE_NOT_LOADED;
776
+				//$this->db_modified_state = false;
777
+				//$dbRow = array();
778
+
779
+				// Let's add this object to the list of objects in cache.
780
+				$this->_addToCache($dbRow);
781
+			}
782
+
783
+			$object->_setStatus(TDBMObjectStateEnum::STATE_LOADED);
784
+		} elseif ($status === TDBMObjectStateEnum::STATE_DIRTY) {
785
+			$dbRows = $object->_getDbRows();
786
+
787
+			foreach ($dbRows as $dbRow) {
788
+				$references = $dbRow->_getReferences();
789
+
790
+				// Let's save all references in NEW state (we need their primary key)
791
+				foreach ($references as $fkName => $reference) {
792
+					if ($reference->_getStatus() === TDBMObjectStateEnum::STATE_NEW) {
793
+						$this->save($reference);
794
+					}
795
+				}
796
+
797
+				// Let's first get the primary keys
798
+				$tableName = $dbRow->_getDbTableName();
799
+				$dbRowData = $dbRow->_getDbRow();
800
+
801
+				$schema = $this->tdbmSchemaAnalyzer->getSchema();
802
+				$tableDescriptor = $schema->getTable($tableName);
803
+
804
+				$primaryKeys = $dbRow->_getPrimaryKeys();
805
+
806
+				$types = [];
807
+
808
+				foreach ($dbRowData as $columnName => $value) {
809
+					$columnDescriptor = $tableDescriptor->getColumn($columnName);
810
+					$types[] = $columnDescriptor->getType();
811
+				}
812
+				foreach ($primaryKeys as $columnName => $value) {
813
+					$columnDescriptor = $tableDescriptor->getColumn($columnName);
814
+					$types[] = $columnDescriptor->getType();
815
+				}
816
+
817
+				$this->connection->update($tableName, $dbRowData, $primaryKeys, $types);
818
+
819
+				// Let's check if the primary key has been updated...
820
+				$needsUpdatePk = false;
821
+				foreach ($primaryKeys as $column => $value) {
822
+					if (!isset($dbRowData[$column]) || $dbRowData[$column] != $value) {
823
+						$needsUpdatePk = true;
824
+						break;
825
+					}
826
+				}
827
+				if ($needsUpdatePk) {
828
+					$this->objectStorage->remove($tableName, $this->getObjectHash($primaryKeys));
829
+					$newPrimaryKeys = $this->getPrimaryKeysForObjectFromDbRow($dbRow);
830
+					$dbRow->_setPrimaryKeys($newPrimaryKeys);
831
+					$this->objectStorage->set($tableName, $this->getObjectHash($primaryKeys), $dbRow);
832
+				}
833
+
834
+				// Let's remove this object from the list of objects to save.
835
+				$this->removeFromToSaveObjectList($dbRow);
836
+			}
837
+
838
+			$object->_setStatus(TDBMObjectStateEnum::STATE_LOADED);
839
+		} elseif ($status === TDBMObjectStateEnum::STATE_DELETED) {
840
+			throw new TDBMInvalidOperationException('This object has been deleted. It cannot be saved.');
841
+		}
842
+
843
+		// Finally, let's save all the many to many relationships to this bean.
844
+		$this->persistManyToManyRelationships($object);
845
+	}
846
+
847
+	private function persistManyToManyRelationships(AbstractTDBMObject $object)
848
+	{
849
+		foreach ($object->_getCachedRelationships() as $pivotTableName => $storage) {
850
+			$tableDescriptor = $this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName);
851
+			list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $object);
852
+
853
+			foreach ($storage as $remoteBean) {
854
+				/* @var $remoteBean AbstractTDBMObject */
855
+				$statusArr = $storage[$remoteBean];
856
+				$status = $statusArr['status'];
857
+				$reverse = $statusArr['reverse'];
858
+				if ($reverse) {
859
+					continue;
860
+				}
861
+
862
+				if ($status === 'new') {
863
+					$remoteBeanStatus = $remoteBean->_getStatus();
864
+					if ($remoteBeanStatus === TDBMObjectStateEnum::STATE_NEW || $remoteBeanStatus === TDBMObjectStateEnum::STATE_DETACHED) {
865
+						// Let's save remote bean if needed.
866
+						$this->save($remoteBean);
867
+					}
868
+
869
+					$filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
870
+
871
+					$types = [];
872
+
873
+					foreach ($filters as $columnName => $value) {
874
+						$columnDescriptor = $tableDescriptor->getColumn($columnName);
875
+						$types[] = $columnDescriptor->getType();
876
+					}
877
+
878
+					$this->connection->insert($pivotTableName, $filters, $types);
879
+
880
+					// Finally, let's mark relationships as saved.
881
+					$statusArr['status'] = 'loaded';
882
+					$storage[$remoteBean] = $statusArr;
883
+					$remoteStorage = $remoteBean->_getCachedRelationships()[$pivotTableName];
884
+					$remoteStatusArr = $remoteStorage[$object];
885
+					$remoteStatusArr['status'] = 'loaded';
886
+					$remoteStorage[$object] = $remoteStatusArr;
887
+				} elseif ($status === 'delete') {
888
+					$filters = $this->getPivotFilters($object, $remoteBean, $localFk, $remoteFk);
889
+
890
+					$types = [];
891
+
892
+					foreach ($filters as $columnName => $value) {
893
+						$columnDescriptor = $tableDescriptor->getColumn($columnName);
894
+						$types[] = $columnDescriptor->getType();
895
+					}
896
+
897
+					$this->connection->delete($pivotTableName, $filters, $types);
898
+
899
+					// Finally, let's remove relationships completely from bean.
900
+					$storage->detach($remoteBean);
901
+					$remoteBean->_getCachedRelationships()[$pivotTableName]->detach($object);
902
+				}
903
+			}
904
+		}
905
+	}
906
+
907
+	private function getPivotFilters(AbstractTDBMObject $localBean, AbstractTDBMObject $remoteBean, ForeignKeyConstraint $localFk, ForeignKeyConstraint $remoteFk)
908
+	{
909
+		$localBeanPk = $this->getPrimaryKeyValues($localBean);
910
+		$remoteBeanPk = $this->getPrimaryKeyValues($remoteBean);
911
+		$localColumns = $localFk->getLocalColumns();
912
+		$remoteColumns = $remoteFk->getLocalColumns();
913
+
914
+		$localFilters = array_combine($localColumns, $localBeanPk);
915
+		$remoteFilters = array_combine($remoteColumns, $remoteBeanPk);
916
+
917
+		return array_merge($localFilters, $remoteFilters);
918
+	}
919
+
920
+	/**
921
+	 * Returns the "values" of the primary key.
922
+	 * This returns the primary key from the $primaryKey attribute, not the one stored in the columns.
923
+	 *
924
+	 * @param AbstractTDBMObject $bean
925
+	 *
926
+	 * @return array numerically indexed array of values.
927
+	 */
928
+	private function getPrimaryKeyValues(AbstractTDBMObject $bean)
929
+	{
930
+		$dbRows = $bean->_getDbRows();
931
+		$dbRow = reset($dbRows);
932
+
933
+		return array_values($dbRow->_getPrimaryKeys());
934
+	}
935
+
936
+	/**
937
+	 * Returns a unique hash used to store the object based on its primary key.
938
+	 * If the array contains only one value, then the value is returned.
939
+	 * Otherwise, a hash representing the array is returned.
940
+	 *
941
+	 * @param array $primaryKeys An array of columns => values forming the primary key
942
+	 *
943
+	 * @return string
944
+	 */
945
+	public function getObjectHash(array $primaryKeys)
946
+	{
947
+		if (count($primaryKeys) === 1) {
948
+			return reset($primaryKeys);
949
+		} else {
950
+			ksort($primaryKeys);
951
+
952
+			return md5(json_encode($primaryKeys));
953
+		}
954
+	}
955
+
956
+	/**
957
+	 * Returns an array of primary keys from the object.
958
+	 * The primary keys are extracted from the object columns and not from the primary keys stored in the
959
+	 * $primaryKeys variable of the object.
960
+	 *
961
+	 * @param DbRow $dbRow
962
+	 *
963
+	 * @return array Returns an array of column => value
964
+	 */
965
+	public function getPrimaryKeysForObjectFromDbRow(DbRow $dbRow)
966
+	{
967
+		$table = $dbRow->_getDbTableName();
968
+		$dbRowData = $dbRow->_getDbRow();
969
+
970
+		return $this->_getPrimaryKeysFromObjectData($table, $dbRowData);
971
+	}
972
+
973
+	/**
974
+	 * Returns an array of primary keys for the given row.
975
+	 * The primary keys are extracted from the object columns.
976
+	 *
977
+	 * @param $table
978
+	 * @param array $columns
979
+	 *
980
+	 * @return array
981
+	 */
982
+	public function _getPrimaryKeysFromObjectData($table, array $columns)
983
+	{
984
+		$primaryKeyColumns = $this->getPrimaryKeyColumns($table);
985
+		$values = array();
986
+		foreach ($primaryKeyColumns as $column) {
987
+			if (isset($columns[$column])) {
988
+				$values[$column] = $columns[$column];
989
+			}
990
+		}
991
+
992
+		return $values;
993
+	}
994
+
995
+	/**
996
+	 * Attaches $object to this TDBMService.
997
+	 * The $object must be in DETACHED state and will pass in NEW state.
998
+	 *
999
+	 * @param AbstractTDBMObject $object
1000
+	 *
1001
+	 * @throws TDBMInvalidOperationException
1002
+	 */
1003
+	public function attach(AbstractTDBMObject $object)
1004
+	{
1005
+		$object->_attach($this);
1006
+	}
1007
+
1008
+	/**
1009
+	 * Returns an associative array (column => value) for the primary keys from the table name and an
1010
+	 * indexed array of primary key values.
1011
+	 *
1012
+	 * @param string $tableName
1013
+	 * @param array  $indexedPrimaryKeys
1014
+	 */
1015
+	public function _getPrimaryKeysFromIndexedPrimaryKeys($tableName, array $indexedPrimaryKeys)
1016
+	{
1017
+		$primaryKeyColumns = $this->tdbmSchemaAnalyzer->getSchema()->getTable($tableName)->getPrimaryKeyColumns();
1018
+
1019
+		if (count($primaryKeyColumns) !== count($indexedPrimaryKeys)) {
1020
+			throw new TDBMException(sprintf('Wrong number of columns passed for primary key. Expected %s columns for table "%s",
1021 1021
 			got %s instead.', count($primaryKeyColumns), $tableName, count($indexedPrimaryKeys)));
1022
-        }
1023
-
1024
-        return array_combine($primaryKeyColumns, $indexedPrimaryKeys);
1025
-    }
1026
-
1027
-    /**
1028
-     * Return the list of tables (from child to parent) joining the tables passed in parameter.
1029
-     * Tables must be in a single line of inheritance. The method will find missing tables.
1030
-     *
1031
-     * Algorithm: one of those tables is the ultimate child. From this child, by recursively getting the parent,
1032
-     * we must be able to find all other tables.
1033
-     *
1034
-     * @param string[] $tables
1035
-     *
1036
-     * @return string[]
1037
-     */
1038
-    public function _getLinkBetweenInheritedTables(array $tables)
1039
-    {
1040
-        sort($tables);
1041
-
1042
-        return $this->fromCache($this->cachePrefix.'_linkbetweeninheritedtables_'.implode('__split__', $tables),
1043
-            function () use ($tables) {
1044
-                return $this->_getLinkBetweenInheritedTablesWithoutCache($tables);
1045
-            });
1046
-    }
1047
-
1048
-    /**
1049
-     * Return the list of tables (from child to parent) joining the tables passed in parameter.
1050
-     * Tables must be in a single line of inheritance. The method will find missing tables.
1051
-     *
1052
-     * Algorithm: one of those tables is the ultimate child. From this child, by recursively getting the parent,
1053
-     * we must be able to find all other tables.
1054
-     *
1055
-     * @param string[] $tables
1056
-     *
1057
-     * @return string[]
1058
-     */
1059
-    private function _getLinkBetweenInheritedTablesWithoutCache(array $tables)
1060
-    {
1061
-        $schemaAnalyzer = $this->schemaAnalyzer;
1062
-
1063
-        foreach ($tables as $currentTable) {
1064
-            $allParents = [$currentTable];
1065
-            while ($currentFk = $schemaAnalyzer->getParentRelationship($currentTable)) {
1066
-                $currentTable = $currentFk->getForeignTableName();
1067
-                $allParents[] = $currentTable;
1068
-            };
1069
-
1070
-            // Now, does the $allParents contain all the tables we want?
1071
-            $notFoundTables = array_diff($tables, $allParents);
1072
-            if (empty($notFoundTables)) {
1073
-                // We have a winner!
1074
-                return $allParents;
1075
-            }
1076
-        }
1077
-
1078
-        throw new TDBMException(sprintf('The tables (%s) cannot be linked by an inheritance relationship.', implode(', ', $tables)));
1079
-    }
1080
-
1081
-    /**
1082
-     * Returns the list of tables related to this table (via a parent or child inheritance relationship).
1083
-     *
1084
-     * @param string $table
1085
-     *
1086
-     * @return string[]
1087
-     */
1088
-    public function _getRelatedTablesByInheritance($table)
1089
-    {
1090
-        return $this->fromCache($this->cachePrefix.'_relatedtables_'.$table, function () use ($table) {
1091
-            return $this->_getRelatedTablesByInheritanceWithoutCache($table);
1092
-        });
1093
-    }
1094
-
1095
-    /**
1096
-     * Returns the list of tables related to this table (via a parent or child inheritance relationship).
1097
-     *
1098
-     * @param string $table
1099
-     *
1100
-     * @return string[]
1101
-     */
1102
-    private function _getRelatedTablesByInheritanceWithoutCache($table)
1103
-    {
1104
-        $schemaAnalyzer = $this->schemaAnalyzer;
1105
-
1106
-        // Let's scan the parent tables
1107
-        $currentTable = $table;
1108
-
1109
-        $parentTables = [];
1110
-
1111
-        // Get parent relationship
1112
-        while ($currentFk = $schemaAnalyzer->getParentRelationship($currentTable)) {
1113
-            $currentTable = $currentFk->getForeignTableName();
1114
-            $parentTables[] = $currentTable;
1115
-        };
1116
-
1117
-        // Let's recurse in children
1118
-        $childrenTables = $this->exploreChildrenTablesRelationships($schemaAnalyzer, $table);
1119
-
1120
-        return array_merge(array_reverse($parentTables), $childrenTables);
1121
-    }
1122
-
1123
-    /**
1124
-     * Explore all the children and descendant of $table and returns ForeignKeyConstraints on those.
1125
-     *
1126
-     * @param string $table
1127
-     *
1128
-     * @return string[]
1129
-     */
1130
-    private function exploreChildrenTablesRelationships(SchemaAnalyzer $schemaAnalyzer, $table)
1131
-    {
1132
-        $tables = [$table];
1133
-        $keys = $schemaAnalyzer->getChildrenRelationships($table);
1134
-
1135
-        foreach ($keys as $key) {
1136
-            $tables = array_merge($tables, $this->exploreChildrenTablesRelationships($schemaAnalyzer, $key->getLocalTableName()));
1137
-        }
1138
-
1139
-        return $tables;
1140
-    }
1141
-
1142
-    /**
1143
-     * Casts a foreign key into SQL, assuming table name is used with no alias.
1144
-     * The returned value does contain only one table. For instance:.
1145
-     *
1146
-     * " LEFT JOIN table2 ON table1.id = table2.table1_id"
1147
-     *
1148
-     * @param ForeignKeyConstraint $fk
1149
-     * @param bool                 $leftTableIsLocal
1150
-     *
1151
-     * @return string
1152
-     */
1153
-    /*private function foreignKeyToSql(ForeignKeyConstraint $fk, $leftTableIsLocal) {
1022
+		}
1023
+
1024
+		return array_combine($primaryKeyColumns, $indexedPrimaryKeys);
1025
+	}
1026
+
1027
+	/**
1028
+	 * Return the list of tables (from child to parent) joining the tables passed in parameter.
1029
+	 * Tables must be in a single line of inheritance. The method will find missing tables.
1030
+	 *
1031
+	 * Algorithm: one of those tables is the ultimate child. From this child, by recursively getting the parent,
1032
+	 * we must be able to find all other tables.
1033
+	 *
1034
+	 * @param string[] $tables
1035
+	 *
1036
+	 * @return string[]
1037
+	 */
1038
+	public function _getLinkBetweenInheritedTables(array $tables)
1039
+	{
1040
+		sort($tables);
1041
+
1042
+		return $this->fromCache($this->cachePrefix.'_linkbetweeninheritedtables_'.implode('__split__', $tables),
1043
+			function () use ($tables) {
1044
+				return $this->_getLinkBetweenInheritedTablesWithoutCache($tables);
1045
+			});
1046
+	}
1047
+
1048
+	/**
1049
+	 * Return the list of tables (from child to parent) joining the tables passed in parameter.
1050
+	 * Tables must be in a single line of inheritance. The method will find missing tables.
1051
+	 *
1052
+	 * Algorithm: one of those tables is the ultimate child. From this child, by recursively getting the parent,
1053
+	 * we must be able to find all other tables.
1054
+	 *
1055
+	 * @param string[] $tables
1056
+	 *
1057
+	 * @return string[]
1058
+	 */
1059
+	private function _getLinkBetweenInheritedTablesWithoutCache(array $tables)
1060
+	{
1061
+		$schemaAnalyzer = $this->schemaAnalyzer;
1062
+
1063
+		foreach ($tables as $currentTable) {
1064
+			$allParents = [$currentTable];
1065
+			while ($currentFk = $schemaAnalyzer->getParentRelationship($currentTable)) {
1066
+				$currentTable = $currentFk->getForeignTableName();
1067
+				$allParents[] = $currentTable;
1068
+			};
1069
+
1070
+			// Now, does the $allParents contain all the tables we want?
1071
+			$notFoundTables = array_diff($tables, $allParents);
1072
+			if (empty($notFoundTables)) {
1073
+				// We have a winner!
1074
+				return $allParents;
1075
+			}
1076
+		}
1077
+
1078
+		throw new TDBMException(sprintf('The tables (%s) cannot be linked by an inheritance relationship.', implode(', ', $tables)));
1079
+	}
1080
+
1081
+	/**
1082
+	 * Returns the list of tables related to this table (via a parent or child inheritance relationship).
1083
+	 *
1084
+	 * @param string $table
1085
+	 *
1086
+	 * @return string[]
1087
+	 */
1088
+	public function _getRelatedTablesByInheritance($table)
1089
+	{
1090
+		return $this->fromCache($this->cachePrefix.'_relatedtables_'.$table, function () use ($table) {
1091
+			return $this->_getRelatedTablesByInheritanceWithoutCache($table);
1092
+		});
1093
+	}
1094
+
1095
+	/**
1096
+	 * Returns the list of tables related to this table (via a parent or child inheritance relationship).
1097
+	 *
1098
+	 * @param string $table
1099
+	 *
1100
+	 * @return string[]
1101
+	 */
1102
+	private function _getRelatedTablesByInheritanceWithoutCache($table)
1103
+	{
1104
+		$schemaAnalyzer = $this->schemaAnalyzer;
1105
+
1106
+		// Let's scan the parent tables
1107
+		$currentTable = $table;
1108
+
1109
+		$parentTables = [];
1110
+
1111
+		// Get parent relationship
1112
+		while ($currentFk = $schemaAnalyzer->getParentRelationship($currentTable)) {
1113
+			$currentTable = $currentFk->getForeignTableName();
1114
+			$parentTables[] = $currentTable;
1115
+		};
1116
+
1117
+		// Let's recurse in children
1118
+		$childrenTables = $this->exploreChildrenTablesRelationships($schemaAnalyzer, $table);
1119
+
1120
+		return array_merge(array_reverse($parentTables), $childrenTables);
1121
+	}
1122
+
1123
+	/**
1124
+	 * Explore all the children and descendant of $table and returns ForeignKeyConstraints on those.
1125
+	 *
1126
+	 * @param string $table
1127
+	 *
1128
+	 * @return string[]
1129
+	 */
1130
+	private function exploreChildrenTablesRelationships(SchemaAnalyzer $schemaAnalyzer, $table)
1131
+	{
1132
+		$tables = [$table];
1133
+		$keys = $schemaAnalyzer->getChildrenRelationships($table);
1134
+
1135
+		foreach ($keys as $key) {
1136
+			$tables = array_merge($tables, $this->exploreChildrenTablesRelationships($schemaAnalyzer, $key->getLocalTableName()));
1137
+		}
1138
+
1139
+		return $tables;
1140
+	}
1141
+
1142
+	/**
1143
+	 * Casts a foreign key into SQL, assuming table name is used with no alias.
1144
+	 * The returned value does contain only one table. For instance:.
1145
+	 *
1146
+	 * " LEFT JOIN table2 ON table1.id = table2.table1_id"
1147
+	 *
1148
+	 * @param ForeignKeyConstraint $fk
1149
+	 * @param bool                 $leftTableIsLocal
1150
+	 *
1151
+	 * @return string
1152
+	 */
1153
+	/*private function foreignKeyToSql(ForeignKeyConstraint $fk, $leftTableIsLocal) {
1154 1154
         $onClauses = [];
1155 1155
         $foreignTableName = $this->connection->quoteIdentifier($fk->getForeignTableName());
1156 1156
         $foreignColumns = $fk->getForeignColumns();
@@ -1176,370 +1176,370 @@  discard block
 block discarded – undo
1176 1176
         }
1177 1177
     }*/
1178 1178
 
1179
-    /**
1180
-     * Returns an identifier for the group of tables passed in parameter.
1181
-     *
1182
-     * @param string[] $relatedTables
1183
-     *
1184
-     * @return string
1185
-     */
1186
-    private function getTableGroupName(array $relatedTables)
1187
-    {
1188
-        sort($relatedTables);
1189
-
1190
-        return implode('_``_', $relatedTables);
1191
-    }
1192
-
1193
-    /**
1194
-     * Returns a `ResultIterator` object representing filtered records of "$mainTable" .
1195
-     *
1196
-     * The findObjects method should be the most used query method in TDBM if you want to query the database for objects.
1197
-     * (Note: if you want to query the database for an object by its primary key, use the findObjectByPk method).
1198
-     *
1199
-     * The findObjects method takes in parameter:
1200
-     * 	- mainTable: the kind of bean you want to retrieve. In TDBM, a bean matches a database row, so the
1201
-     * 			`$mainTable` parameter should be the name of an existing table in database.
1202
-     *  - filter: The filter is a filter bag. It is what you use to filter your request (the WHERE part in SQL).
1203
-     *          It can be a string (SQL Where clause), or even a bean or an associative array (key = column to filter, value = value to find)
1204
-     *  - parameters: The parameters used in the filter. If you pass a SQL string as a filter, be sure to avoid
1205
-     *          concatenating parameters in the string (this leads to SQL injection and also to poor caching performance).
1206
-     *          Instead, please consider passing parameters (see documentation for more details).
1207
-     *  - additionalTablesFetch: An array of SQL tables names. The beans related to those tables will be fetched along
1208
-     *          the main table. This is useful to avoid hitting the database with numerous subqueries.
1209
-     *  - mode: The fetch mode of the result. See `setFetchMode()` method for more details.
1210
-     *
1211
-     * The `findObjects` method will return a `ResultIterator`. A `ResultIterator` is an object that behaves as an array
1212
-     * (in ARRAY mode) at least. It can be iterated using a `foreach` loop.
1213
-     *
1214
-     * Finally, if filter_bag is null, the whole table is returned.
1215
-     *
1216
-     * @param string            $mainTable             The name of the table queried
1217
-     * @param string|array|null $filter                The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column)
1218
-     * @param array             $parameters
1219
-     * @param string|null       $orderString           The ORDER BY part of the query. All columns must be prefixed by the table name (in the form: table.column)
1220
-     * @param array             $additionalTablesFetch
1221
-     * @param int               $mode
1222
-     * @param string            $className             Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
1223
-     *
1224
-     * @return ResultIterator An object representing an array of results.
1225
-     *
1226
-     * @throws TDBMException
1227
-     */
1228
-    public function findObjects($mainTable, $filter = null, array $parameters = array(), $orderString = null, array $additionalTablesFetch = array(), $mode = null, $className = null)
1229
-    {
1230
-        // $mainTable is not secured in MagicJoin, let's add a bit of security to avoid SQL injection.
1231
-        if (!preg_match('/^[a-zA-Z_][a-zA-Z0-9_]*$/', $mainTable)) {
1232
-            throw new TDBMException(sprintf("Invalid table name: '%s'", $mainTable));
1233
-        }
1234
-
1235
-        list($filterString, $additionalParameters) = $this->buildFilterFromFilterBag($filter);
1236
-
1237
-        $parameters = array_merge($parameters, $additionalParameters);
1238
-
1239
-        // From the table name and the additional tables we want to fetch, let's build a list of all tables
1240
-        // that must be part of the select columns.
1241
-
1242
-        $tableGroups = [];
1243
-        $allFetchedTables = $this->_getRelatedTablesByInheritance($mainTable);
1244
-        $tableGroupName = $this->getTableGroupName($allFetchedTables);
1245
-        foreach ($allFetchedTables as $table) {
1246
-            $tableGroups[$table] = $tableGroupName;
1247
-        }
1248
-
1249
-        foreach ($additionalTablesFetch as $additionalTable) {
1250
-            $relatedTables = $this->_getRelatedTablesByInheritance($additionalTable);
1251
-            $tableGroupName = $this->getTableGroupName($relatedTables);
1252
-            foreach ($relatedTables as $table) {
1253
-                $tableGroups[$table] = $tableGroupName;
1254
-            }
1255
-            $allFetchedTables = array_merge($allFetchedTables, $relatedTables);
1256
-        }
1257
-
1258
-        // Let's remove any duplicate
1259
-        $allFetchedTables = array_flip(array_flip($allFetchedTables));
1260
-
1261
-        $columnsList = [];
1262
-        $columnDescList = [];
1263
-        $schema = $this->tdbmSchemaAnalyzer->getSchema();
1264
-
1265
-        // Now, let's build the column list
1266
-        foreach ($allFetchedTables as $table) {
1267
-            foreach ($schema->getTable($table)->getColumns() as $column) {
1268
-                $columnName = $column->getName();
1269
-                $columnDescList[] = [
1270
-                    'as' => $table.'____'.$columnName,
1271
-                    'table' => $table,
1272
-                    'column' => $columnName,
1273
-                    'type' => $column->getType(),
1274
-                    'tableGroup' => $tableGroups[$table],
1275
-                ];
1276
-                $columnsList[] = $this->connection->quoteIdentifier($table).'.'.$this->connection->quoteIdentifier($columnName).' as '.
1277
-                    $this->connection->quoteIdentifier($table.'____'.$columnName);
1278
-            }
1279
-        }
1280
-
1281
-        $sql = 'SELECT DISTINCT '.implode(', ', $columnsList).' FROM MAGICJOIN('.$mainTable.')';
1282
-        $countSql = 'SELECT COUNT(1) FROM MAGICJOIN('.$mainTable.')';
1283
-
1284
-        if (!empty($filterString)) {
1285
-            $sql .= ' WHERE '.$filterString;
1286
-            $countSql .= ' WHERE '.$filterString;
1287
-        }
1288
-
1289
-        if (!empty($orderString)) {
1290
-            $sql .= ' ORDER BY '.$orderString;
1291
-            $countSql .= ' ORDER BY '.$orderString;
1292
-        }
1293
-
1294
-        if ($mode !== null && $mode !== self::MODE_CURSOR && $mode !== self::MODE_ARRAY) {
1295
-            throw new TDBMException("Unknown fetch mode: '".$this->mode."'");
1296
-        }
1297
-
1298
-        $mode = $mode ?: $this->mode;
1299
-
1300
-        return new ResultIterator($sql, $countSql, $parameters, $columnDescList, $this->objectStorage, $className, $this, $this->magicQuery, $mode);
1301
-    }
1302
-
1303
-    /**
1304
-     * @param $table
1305
-     * @param array  $primaryKeys
1306
-     * @param array  $additionalTablesFetch
1307
-     * @param bool   $lazy                  Whether to perform lazy loading on this object or not.
1308
-     * @param string $className
1309
-     *
1310
-     * @return AbstractTDBMObject
1311
-     *
1312
-     * @throws TDBMException
1313
-     */
1314
-    public function findObjectByPk($table, array $primaryKeys, array $additionalTablesFetch = array(), $lazy = false, $className = null)
1315
-    {
1316
-        $primaryKeys = $this->_getPrimaryKeysFromObjectData($table, $primaryKeys);
1317
-        $hash = $this->getObjectHash($primaryKeys);
1318
-
1319
-        if ($this->objectStorage->has($table, $hash)) {
1320
-            $dbRow = $this->objectStorage->get($table, $hash);
1321
-            $bean = $dbRow->getTDBMObject();
1322
-            if ($className !== null && !is_a($bean, $className)) {
1323
-                throw new TDBMException("TDBM cannot create a bean of class '".$className."'. The requested object was already loaded and its class is '".get_class($bean)."'");
1324
-            }
1325
-
1326
-            return $bean;
1327
-        }
1328
-
1329
-        // Are we performing lazy fetching?
1330
-        if ($lazy === true) {
1331
-            // Can we perform lazy fetching?
1332
-            $tables = $this->_getRelatedTablesByInheritance($table);
1333
-            // Only allowed if no inheritance.
1334
-            if (count($tables) === 1) {
1335
-                if ($className === null) {
1336
-                    $className = isset($this->tableToBeanMap[$table]) ? $this->tableToBeanMap[$table] : 'Mouf\\Database\\TDBM\\TDBMObject';
1337
-                }
1338
-
1339
-                // Let's construct the bean
1340
-                if (!isset($this->reflectionClassCache[$className])) {
1341
-                    $this->reflectionClassCache[$className] = new \ReflectionClass($className);
1342
-                }
1343
-                // Let's bypass the constructor when creating the bean!
1344
-                $bean = $this->reflectionClassCache[$className]->newInstanceWithoutConstructor();
1345
-                /* @var $bean AbstractTDBMObject */
1346
-                $bean->_constructLazy($table, $primaryKeys, $this);
1347
-            }
1348
-        }
1349
-
1350
-        // Did not find the object in cache? Let's query it!
1351
-        return $this->findObjectOrFail($table, $primaryKeys, [], $additionalTablesFetch, $className);
1352
-    }
1353
-
1354
-    /**
1355
-     * Returns a unique bean (or null) according to the filters passed in parameter.
1356
-     *
1357
-     * @param string            $mainTable             The name of the table queried
1358
-     * @param string|array|null $filter                The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column)
1359
-     * @param array             $parameters
1360
-     * @param array             $additionalTablesFetch
1361
-     * @param string            $className             Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
1362
-     *
1363
-     * @return AbstractTDBMObject|null The object we want, or null if no object matches the filters.
1364
-     *
1365
-     * @throws TDBMException
1366
-     */
1367
-    public function findObject($mainTable, $filter = null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null)
1368
-    {
1369
-        $objects = $this->findObjects($mainTable, $filter, $parameters, null, $additionalTablesFetch, self::MODE_ARRAY, $className);
1370
-        $page = $objects->take(0, 2);
1371
-        $count = $page->count();
1372
-        if ($count > 1) {
1373
-            throw new DuplicateRowException("Error while querying an object for table '$mainTable': More than 1 row have been returned, but we should have received at most one.");
1374
-        } elseif ($count === 0) {
1375
-            return;
1376
-        }
1377
-
1378
-        return $objects[0];
1379
-    }
1380
-
1381
-    /**
1382
-     * Returns a unique bean according to the filters passed in parameter.
1383
-     * Throws a NoBeanFoundException if no bean was found for the filter passed in parameter.
1384
-     *
1385
-     * @param string            $mainTable             The name of the table queried
1386
-     * @param string|array|null $filter                The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column)
1387
-     * @param array             $parameters
1388
-     * @param array             $additionalTablesFetch
1389
-     * @param string            $className             Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
1390
-     *
1391
-     * @return AbstractTDBMObject The object we want
1392
-     *
1393
-     * @throws TDBMException
1394
-     */
1395
-    public function findObjectOrFail($mainTable, $filter = null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null)
1396
-    {
1397
-        $bean = $this->findObject($mainTable, $filter, $parameters, $additionalTablesFetch, $className);
1398
-        if ($bean === null) {
1399
-            throw new NoBeanFoundException("No result found for query on table '".$mainTable."'");
1400
-        }
1401
-
1402
-        return $bean;
1403
-    }
1404
-
1405
-    /**
1406
-     * @param array $beanData An array of data: array<table, array<column, value>>
1407
-     *
1408
-     * @return array an array with first item = class name and second item = table name
1409
-     */
1410
-    public function _getClassNameFromBeanData(array $beanData)
1411
-    {
1412
-        if (count($beanData) === 1) {
1413
-            $tableName = array_keys($beanData)[0];
1414
-        } else {
1415
-            $tables = [];
1416
-            foreach ($beanData as $table => $row) {
1417
-                $primaryKeyColumns = $this->getPrimaryKeyColumns($table);
1418
-                $pkSet = false;
1419
-                foreach ($primaryKeyColumns as $columnName) {
1420
-                    if ($row[$columnName] !== null) {
1421
-                        $pkSet = true;
1422
-                        break;
1423
-                    }
1424
-                }
1425
-                if ($pkSet) {
1426
-                    $tables[] = $table;
1427
-                }
1428
-            }
1429
-
1430
-            // $tables contains the tables for this bean. Let's view the top most part of the hierarchy
1431
-            $allTables = $this->_getLinkBetweenInheritedTables($tables);
1432
-            $tableName = $allTables[0];
1433
-        }
1434
-
1435
-        // Only one table in this bean. Life is sweat, let's look at its type:
1436
-        if (isset($this->tableToBeanMap[$tableName])) {
1437
-            return [$this->tableToBeanMap[$tableName], $tableName];
1438
-        } else {
1439
-            return ['Mouf\\Database\\TDBM\\TDBMObject', $tableName];
1440
-        }
1441
-    }
1442
-
1443
-    /**
1444
-     * Returns an item from cache or computes it using $closure and puts it in cache.
1445
-     *
1446
-     * @param string   $key
1447
-     * @param callable $closure
1448
-     *
1449
-     * @return mixed
1450
-     */
1451
-    private function fromCache($key, callable $closure)
1452
-    {
1453
-        $item = $this->cache->fetch($key);
1454
-        if ($item === false) {
1455
-            $item = $closure();
1456
-            $this->cache->save($key, $item);
1457
-        }
1458
-
1459
-        return $item;
1460
-    }
1461
-
1462
-    /**
1463
-     * Returns the foreign key object.
1464
-     *
1465
-     * @param string $table
1466
-     * @param string $fkName
1467
-     *
1468
-     * @return ForeignKeyConstraint
1469
-     */
1470
-    public function _getForeignKeyByName($table, $fkName)
1471
-    {
1472
-        return $this->tdbmSchemaAnalyzer->getSchema()->getTable($table)->getForeignKey($fkName);
1473
-    }
1474
-
1475
-    /**
1476
-     * @param $pivotTableName
1477
-     * @param AbstractTDBMObject $bean
1478
-     *
1479
-     * @return AbstractTDBMObject[]
1480
-     */
1481
-    public function _getRelatedBeans($pivotTableName, AbstractTDBMObject $bean)
1482
-    {
1483
-        list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $bean);
1484
-        /* @var $localFk ForeignKeyConstraint */
1485
-        /* @var $remoteFk ForeignKeyConstraint */
1486
-        $remoteTable = $remoteFk->getForeignTableName();
1487
-
1488
-        $primaryKeys = $this->getPrimaryKeyValues($bean);
1489
-        $columnNames = array_map(function ($name) use ($pivotTableName) { return $pivotTableName.'.'.$name; }, $localFk->getLocalColumns());
1490
-
1491
-        $filter = array_combine($columnNames, $primaryKeys);
1492
-
1493
-        return $this->findObjects($remoteTable, $filter);
1494
-    }
1495
-
1496
-    /**
1497
-     * @param $pivotTableName
1498
-     * @param AbstractTDBMObject $bean The LOCAL bean
1499
-     *
1500
-     * @return ForeignKeyConstraint[] First item: the LOCAL bean, second item: the REMOTE bean.
1501
-     *
1502
-     * @throws TDBMException
1503
-     */
1504
-    private function getPivotTableForeignKeys($pivotTableName, AbstractTDBMObject $bean)
1505
-    {
1506
-        $fks = array_values($this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName)->getForeignKeys());
1507
-        $table1 = $fks[0]->getForeignTableName();
1508
-        $table2 = $fks[1]->getForeignTableName();
1509
-
1510
-        $beanTables = array_map(function (DbRow $dbRow) { return $dbRow->_getDbTableName(); }, $bean->_getDbRows());
1511
-
1512
-        if (in_array($table1, $beanTables)) {
1513
-            return [$fks[0], $fks[1]];
1514
-        } elseif (in_array($table2, $beanTables)) {
1515
-            return [$fks[1], $fks[0]];
1516
-        } else {
1517
-            throw new TDBMException("Unexpected bean type in getPivotTableForeignKeys. Awaiting beans from table {$table1} and {$table2} for pivot table {$pivotTableName}");
1518
-        }
1519
-    }
1520
-
1521
-    /**
1522
-     * Returns a list of pivot tables linked to $bean.
1523
-     *
1524
-     * @param AbstractTDBMObject $bean
1525
-     *
1526
-     * @return string[]
1527
-     */
1528
-    public function _getPivotTablesLinkedToBean(AbstractTDBMObject $bean)
1529
-    {
1530
-        $junctionTables = [];
1531
-        $allJunctionTables = $this->schemaAnalyzer->detectJunctionTables();
1532
-        foreach ($bean->_getDbRows() as $dbRow) {
1533
-            foreach ($allJunctionTables as $table) {
1534
-                // There are exactly 2 FKs since this is a pivot table.
1535
-                $fks = array_values($table->getForeignKeys());
1536
-
1537
-                if ($fks[0]->getForeignTableName() === $dbRow->_getDbTableName() || $fks[1]->getForeignTableName() === $dbRow->_getDbTableName()) {
1538
-                    $junctionTables[] = $table->getName();
1539
-                }
1540
-            }
1541
-        }
1542
-
1543
-        return $junctionTables;
1544
-    }
1179
+	/**
1180
+	 * Returns an identifier for the group of tables passed in parameter.
1181
+	 *
1182
+	 * @param string[] $relatedTables
1183
+	 *
1184
+	 * @return string
1185
+	 */
1186
+	private function getTableGroupName(array $relatedTables)
1187
+	{
1188
+		sort($relatedTables);
1189
+
1190
+		return implode('_``_', $relatedTables);
1191
+	}
1192
+
1193
+	/**
1194
+	 * Returns a `ResultIterator` object representing filtered records of "$mainTable" .
1195
+	 *
1196
+	 * The findObjects method should be the most used query method in TDBM if you want to query the database for objects.
1197
+	 * (Note: if you want to query the database for an object by its primary key, use the findObjectByPk method).
1198
+	 *
1199
+	 * The findObjects method takes in parameter:
1200
+	 * 	- mainTable: the kind of bean you want to retrieve. In TDBM, a bean matches a database row, so the
1201
+	 * 			`$mainTable` parameter should be the name of an existing table in database.
1202
+	 *  - filter: The filter is a filter bag. It is what you use to filter your request (the WHERE part in SQL).
1203
+	 *          It can be a string (SQL Where clause), or even a bean or an associative array (key = column to filter, value = value to find)
1204
+	 *  - parameters: The parameters used in the filter. If you pass a SQL string as a filter, be sure to avoid
1205
+	 *          concatenating parameters in the string (this leads to SQL injection and also to poor caching performance).
1206
+	 *          Instead, please consider passing parameters (see documentation for more details).
1207
+	 *  - additionalTablesFetch: An array of SQL tables names. The beans related to those tables will be fetched along
1208
+	 *          the main table. This is useful to avoid hitting the database with numerous subqueries.
1209
+	 *  - mode: The fetch mode of the result. See `setFetchMode()` method for more details.
1210
+	 *
1211
+	 * The `findObjects` method will return a `ResultIterator`. A `ResultIterator` is an object that behaves as an array
1212
+	 * (in ARRAY mode) at least. It can be iterated using a `foreach` loop.
1213
+	 *
1214
+	 * Finally, if filter_bag is null, the whole table is returned.
1215
+	 *
1216
+	 * @param string            $mainTable             The name of the table queried
1217
+	 * @param string|array|null $filter                The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column)
1218
+	 * @param array             $parameters
1219
+	 * @param string|null       $orderString           The ORDER BY part of the query. All columns must be prefixed by the table name (in the form: table.column)
1220
+	 * @param array             $additionalTablesFetch
1221
+	 * @param int               $mode
1222
+	 * @param string            $className             Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
1223
+	 *
1224
+	 * @return ResultIterator An object representing an array of results.
1225
+	 *
1226
+	 * @throws TDBMException
1227
+	 */
1228
+	public function findObjects($mainTable, $filter = null, array $parameters = array(), $orderString = null, array $additionalTablesFetch = array(), $mode = null, $className = null)
1229
+	{
1230
+		// $mainTable is not secured in MagicJoin, let's add a bit of security to avoid SQL injection.
1231
+		if (!preg_match('/^[a-zA-Z_][a-zA-Z0-9_]*$/', $mainTable)) {
1232
+			throw new TDBMException(sprintf("Invalid table name: '%s'", $mainTable));
1233
+		}
1234
+
1235
+		list($filterString, $additionalParameters) = $this->buildFilterFromFilterBag($filter);
1236
+
1237
+		$parameters = array_merge($parameters, $additionalParameters);
1238
+
1239
+		// From the table name and the additional tables we want to fetch, let's build a list of all tables
1240
+		// that must be part of the select columns.
1241
+
1242
+		$tableGroups = [];
1243
+		$allFetchedTables = $this->_getRelatedTablesByInheritance($mainTable);
1244
+		$tableGroupName = $this->getTableGroupName($allFetchedTables);
1245
+		foreach ($allFetchedTables as $table) {
1246
+			$tableGroups[$table] = $tableGroupName;
1247
+		}
1248
+
1249
+		foreach ($additionalTablesFetch as $additionalTable) {
1250
+			$relatedTables = $this->_getRelatedTablesByInheritance($additionalTable);
1251
+			$tableGroupName = $this->getTableGroupName($relatedTables);
1252
+			foreach ($relatedTables as $table) {
1253
+				$tableGroups[$table] = $tableGroupName;
1254
+			}
1255
+			$allFetchedTables = array_merge($allFetchedTables, $relatedTables);
1256
+		}
1257
+
1258
+		// Let's remove any duplicate
1259
+		$allFetchedTables = array_flip(array_flip($allFetchedTables));
1260
+
1261
+		$columnsList = [];
1262
+		$columnDescList = [];
1263
+		$schema = $this->tdbmSchemaAnalyzer->getSchema();
1264
+
1265
+		// Now, let's build the column list
1266
+		foreach ($allFetchedTables as $table) {
1267
+			foreach ($schema->getTable($table)->getColumns() as $column) {
1268
+				$columnName = $column->getName();
1269
+				$columnDescList[] = [
1270
+					'as' => $table.'____'.$columnName,
1271
+					'table' => $table,
1272
+					'column' => $columnName,
1273
+					'type' => $column->getType(),
1274
+					'tableGroup' => $tableGroups[$table],
1275
+				];
1276
+				$columnsList[] = $this->connection->quoteIdentifier($table).'.'.$this->connection->quoteIdentifier($columnName).' as '.
1277
+					$this->connection->quoteIdentifier($table.'____'.$columnName);
1278
+			}
1279
+		}
1280
+
1281
+		$sql = 'SELECT DISTINCT '.implode(', ', $columnsList).' FROM MAGICJOIN('.$mainTable.')';
1282
+		$countSql = 'SELECT COUNT(1) FROM MAGICJOIN('.$mainTable.')';
1283
+
1284
+		if (!empty($filterString)) {
1285
+			$sql .= ' WHERE '.$filterString;
1286
+			$countSql .= ' WHERE '.$filterString;
1287
+		}
1288
+
1289
+		if (!empty($orderString)) {
1290
+			$sql .= ' ORDER BY '.$orderString;
1291
+			$countSql .= ' ORDER BY '.$orderString;
1292
+		}
1293
+
1294
+		if ($mode !== null && $mode !== self::MODE_CURSOR && $mode !== self::MODE_ARRAY) {
1295
+			throw new TDBMException("Unknown fetch mode: '".$this->mode."'");
1296
+		}
1297
+
1298
+		$mode = $mode ?: $this->mode;
1299
+
1300
+		return new ResultIterator($sql, $countSql, $parameters, $columnDescList, $this->objectStorage, $className, $this, $this->magicQuery, $mode);
1301
+	}
1302
+
1303
+	/**
1304
+	 * @param $table
1305
+	 * @param array  $primaryKeys
1306
+	 * @param array  $additionalTablesFetch
1307
+	 * @param bool   $lazy                  Whether to perform lazy loading on this object or not.
1308
+	 * @param string $className
1309
+	 *
1310
+	 * @return AbstractTDBMObject
1311
+	 *
1312
+	 * @throws TDBMException
1313
+	 */
1314
+	public function findObjectByPk($table, array $primaryKeys, array $additionalTablesFetch = array(), $lazy = false, $className = null)
1315
+	{
1316
+		$primaryKeys = $this->_getPrimaryKeysFromObjectData($table, $primaryKeys);
1317
+		$hash = $this->getObjectHash($primaryKeys);
1318
+
1319
+		if ($this->objectStorage->has($table, $hash)) {
1320
+			$dbRow = $this->objectStorage->get($table, $hash);
1321
+			$bean = $dbRow->getTDBMObject();
1322
+			if ($className !== null && !is_a($bean, $className)) {
1323
+				throw new TDBMException("TDBM cannot create a bean of class '".$className."'. The requested object was already loaded and its class is '".get_class($bean)."'");
1324
+			}
1325
+
1326
+			return $bean;
1327
+		}
1328
+
1329
+		// Are we performing lazy fetching?
1330
+		if ($lazy === true) {
1331
+			// Can we perform lazy fetching?
1332
+			$tables = $this->_getRelatedTablesByInheritance($table);
1333
+			// Only allowed if no inheritance.
1334
+			if (count($tables) === 1) {
1335
+				if ($className === null) {
1336
+					$className = isset($this->tableToBeanMap[$table]) ? $this->tableToBeanMap[$table] : 'Mouf\\Database\\TDBM\\TDBMObject';
1337
+				}
1338
+
1339
+				// Let's construct the bean
1340
+				if (!isset($this->reflectionClassCache[$className])) {
1341
+					$this->reflectionClassCache[$className] = new \ReflectionClass($className);
1342
+				}
1343
+				// Let's bypass the constructor when creating the bean!
1344
+				$bean = $this->reflectionClassCache[$className]->newInstanceWithoutConstructor();
1345
+				/* @var $bean AbstractTDBMObject */
1346
+				$bean->_constructLazy($table, $primaryKeys, $this);
1347
+			}
1348
+		}
1349
+
1350
+		// Did not find the object in cache? Let's query it!
1351
+		return $this->findObjectOrFail($table, $primaryKeys, [], $additionalTablesFetch, $className);
1352
+	}
1353
+
1354
+	/**
1355
+	 * Returns a unique bean (or null) according to the filters passed in parameter.
1356
+	 *
1357
+	 * @param string            $mainTable             The name of the table queried
1358
+	 * @param string|array|null $filter                The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column)
1359
+	 * @param array             $parameters
1360
+	 * @param array             $additionalTablesFetch
1361
+	 * @param string            $className             Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
1362
+	 *
1363
+	 * @return AbstractTDBMObject|null The object we want, or null if no object matches the filters.
1364
+	 *
1365
+	 * @throws TDBMException
1366
+	 */
1367
+	public function findObject($mainTable, $filter = null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null)
1368
+	{
1369
+		$objects = $this->findObjects($mainTable, $filter, $parameters, null, $additionalTablesFetch, self::MODE_ARRAY, $className);
1370
+		$page = $objects->take(0, 2);
1371
+		$count = $page->count();
1372
+		if ($count > 1) {
1373
+			throw new DuplicateRowException("Error while querying an object for table '$mainTable': More than 1 row have been returned, but we should have received at most one.");
1374
+		} elseif ($count === 0) {
1375
+			return;
1376
+		}
1377
+
1378
+		return $objects[0];
1379
+	}
1380
+
1381
+	/**
1382
+	 * Returns a unique bean according to the filters passed in parameter.
1383
+	 * Throws a NoBeanFoundException if no bean was found for the filter passed in parameter.
1384
+	 *
1385
+	 * @param string            $mainTable             The name of the table queried
1386
+	 * @param string|array|null $filter                The SQL filters to apply to the query (the WHERE part). All columns must be prefixed by the table name (in the form: table.column)
1387
+	 * @param array             $parameters
1388
+	 * @param array             $additionalTablesFetch
1389
+	 * @param string            $className             Optional: The name of the class to instantiate. This class must extend the TDBMObject class. If none is specified, a TDBMObject instance will be returned.
1390
+	 *
1391
+	 * @return AbstractTDBMObject The object we want
1392
+	 *
1393
+	 * @throws TDBMException
1394
+	 */
1395
+	public function findObjectOrFail($mainTable, $filter = null, array $parameters = array(), array $additionalTablesFetch = array(), $className = null)
1396
+	{
1397
+		$bean = $this->findObject($mainTable, $filter, $parameters, $additionalTablesFetch, $className);
1398
+		if ($bean === null) {
1399
+			throw new NoBeanFoundException("No result found for query on table '".$mainTable."'");
1400
+		}
1401
+
1402
+		return $bean;
1403
+	}
1404
+
1405
+	/**
1406
+	 * @param array $beanData An array of data: array<table, array<column, value>>
1407
+	 *
1408
+	 * @return array an array with first item = class name and second item = table name
1409
+	 */
1410
+	public function _getClassNameFromBeanData(array $beanData)
1411
+	{
1412
+		if (count($beanData) === 1) {
1413
+			$tableName = array_keys($beanData)[0];
1414
+		} else {
1415
+			$tables = [];
1416
+			foreach ($beanData as $table => $row) {
1417
+				$primaryKeyColumns = $this->getPrimaryKeyColumns($table);
1418
+				$pkSet = false;
1419
+				foreach ($primaryKeyColumns as $columnName) {
1420
+					if ($row[$columnName] !== null) {
1421
+						$pkSet = true;
1422
+						break;
1423
+					}
1424
+				}
1425
+				if ($pkSet) {
1426
+					$tables[] = $table;
1427
+				}
1428
+			}
1429
+
1430
+			// $tables contains the tables for this bean. Let's view the top most part of the hierarchy
1431
+			$allTables = $this->_getLinkBetweenInheritedTables($tables);
1432
+			$tableName = $allTables[0];
1433
+		}
1434
+
1435
+		// Only one table in this bean. Life is sweat, let's look at its type:
1436
+		if (isset($this->tableToBeanMap[$tableName])) {
1437
+			return [$this->tableToBeanMap[$tableName], $tableName];
1438
+		} else {
1439
+			return ['Mouf\\Database\\TDBM\\TDBMObject', $tableName];
1440
+		}
1441
+	}
1442
+
1443
+	/**
1444
+	 * Returns an item from cache or computes it using $closure and puts it in cache.
1445
+	 *
1446
+	 * @param string   $key
1447
+	 * @param callable $closure
1448
+	 *
1449
+	 * @return mixed
1450
+	 */
1451
+	private function fromCache($key, callable $closure)
1452
+	{
1453
+		$item = $this->cache->fetch($key);
1454
+		if ($item === false) {
1455
+			$item = $closure();
1456
+			$this->cache->save($key, $item);
1457
+		}
1458
+
1459
+		return $item;
1460
+	}
1461
+
1462
+	/**
1463
+	 * Returns the foreign key object.
1464
+	 *
1465
+	 * @param string $table
1466
+	 * @param string $fkName
1467
+	 *
1468
+	 * @return ForeignKeyConstraint
1469
+	 */
1470
+	public function _getForeignKeyByName($table, $fkName)
1471
+	{
1472
+		return $this->tdbmSchemaAnalyzer->getSchema()->getTable($table)->getForeignKey($fkName);
1473
+	}
1474
+
1475
+	/**
1476
+	 * @param $pivotTableName
1477
+	 * @param AbstractTDBMObject $bean
1478
+	 *
1479
+	 * @return AbstractTDBMObject[]
1480
+	 */
1481
+	public function _getRelatedBeans($pivotTableName, AbstractTDBMObject $bean)
1482
+	{
1483
+		list($localFk, $remoteFk) = $this->getPivotTableForeignKeys($pivotTableName, $bean);
1484
+		/* @var $localFk ForeignKeyConstraint */
1485
+		/* @var $remoteFk ForeignKeyConstraint */
1486
+		$remoteTable = $remoteFk->getForeignTableName();
1487
+
1488
+		$primaryKeys = $this->getPrimaryKeyValues($bean);
1489
+		$columnNames = array_map(function ($name) use ($pivotTableName) { return $pivotTableName.'.'.$name; }, $localFk->getLocalColumns());
1490
+
1491
+		$filter = array_combine($columnNames, $primaryKeys);
1492
+
1493
+		return $this->findObjects($remoteTable, $filter);
1494
+	}
1495
+
1496
+	/**
1497
+	 * @param $pivotTableName
1498
+	 * @param AbstractTDBMObject $bean The LOCAL bean
1499
+	 *
1500
+	 * @return ForeignKeyConstraint[] First item: the LOCAL bean, second item: the REMOTE bean.
1501
+	 *
1502
+	 * @throws TDBMException
1503
+	 */
1504
+	private function getPivotTableForeignKeys($pivotTableName, AbstractTDBMObject $bean)
1505
+	{
1506
+		$fks = array_values($this->tdbmSchemaAnalyzer->getSchema()->getTable($pivotTableName)->getForeignKeys());
1507
+		$table1 = $fks[0]->getForeignTableName();
1508
+		$table2 = $fks[1]->getForeignTableName();
1509
+
1510
+		$beanTables = array_map(function (DbRow $dbRow) { return $dbRow->_getDbTableName(); }, $bean->_getDbRows());
1511
+
1512
+		if (in_array($table1, $beanTables)) {
1513
+			return [$fks[0], $fks[1]];
1514
+		} elseif (in_array($table2, $beanTables)) {
1515
+			return [$fks[1], $fks[0]];
1516
+		} else {
1517
+			throw new TDBMException("Unexpected bean type in getPivotTableForeignKeys. Awaiting beans from table {$table1} and {$table2} for pivot table {$pivotTableName}");
1518
+		}
1519
+	}
1520
+
1521
+	/**
1522
+	 * Returns a list of pivot tables linked to $bean.
1523
+	 *
1524
+	 * @param AbstractTDBMObject $bean
1525
+	 *
1526
+	 * @return string[]
1527
+	 */
1528
+	public function _getPivotTablesLinkedToBean(AbstractTDBMObject $bean)
1529
+	{
1530
+		$junctionTables = [];
1531
+		$allJunctionTables = $this->schemaAnalyzer->detectJunctionTables();
1532
+		foreach ($bean->_getDbRows() as $dbRow) {
1533
+			foreach ($allJunctionTables as $table) {
1534
+				// There are exactly 2 FKs since this is a pivot table.
1535
+				$fks = array_values($table->getForeignKeys());
1536
+
1537
+				if ($fks[0]->getForeignTableName() === $dbRow->_getDbTableName() || $fks[1]->getForeignTableName() === $dbRow->_getDbTableName()) {
1538
+					$junctionTables[] = $table->getName();
1539
+				}
1540
+			}
1541
+		}
1542
+
1543
+		return $junctionTables;
1544
+	}
1545 1545
 }
Please login to merge, or discard this patch.
src/Mouf/Database/TDBM/Utils/TDBMDaoGenerator.php 1 patch
Indentation   +466 added lines, -466 removed lines patch added patch discarded remove patch
@@ -17,197 +17,197 @@  discard block
 block discarded – undo
17 17
  */
18 18
 class TDBMDaoGenerator
19 19
 {
20
-    /**
21
-     * @var SchemaAnalyzer
22
-     */
23
-    private $schemaAnalyzer;
24
-
25
-    /**
26
-     * @var Schema
27
-     */
28
-    private $schema;
29
-
30
-    /**
31
-     * The root directory of the project.
32
-     *
33
-     * @var string
34
-     */
35
-    private $rootPath;
36
-
37
-    /**
38
-     * @var TDBMSchemaAnalyzer
39
-     */
40
-    private $tdbmSchemaAnalyzer;
41
-
42
-    /**
43
-     * Constructor.
44
-     *
45
-     * @param SchemaAnalyzer     $schemaAnalyzer
46
-     * @param Schema             $schema
47
-     * @param TDBMSchemaAnalyzer $tdbmSchemaAnalyzer
48
-     */
49
-    public function __construct(SchemaAnalyzer $schemaAnalyzer, Schema $schema, TDBMSchemaAnalyzer $tdbmSchemaAnalyzer)
50
-    {
51
-        $this->schemaAnalyzer = $schemaAnalyzer;
52
-        $this->schema = $schema;
53
-        $this->tdbmSchemaAnalyzer = $tdbmSchemaAnalyzer;
54
-        $this->rootPath = __DIR__.'/../../../../../../../../';
55
-    }
56
-
57
-    /**
58
-     * Generates all the daos and beans.
59
-     *
60
-     * @param string $daoFactoryClassName The classe name of the DAO factory
61
-     * @param string $daonamespace        The namespace for the DAOs, without trailing \
62
-     * @param string $beannamespace       The Namespace for the beans, without trailing \
63
-     * @param bool   $storeInUtc          If the generated daos should store the date in UTC timezone instead of user's timezone.
64
-     *
65
-     * @return \string[] the list of tables
66
-     *
67
-     * @throws TDBMException
68
-     */
69
-    public function generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc)
70
-    {
71
-        // TODO: extract ClassNameMapper in its own package!
72
-        $classNameMapper = ClassNameMapper::createFromComposerFile($this->rootPath.'composer.json');
73
-
74
-        // TODO: check that no class name ends with "Base". Otherwise, there will be name clash.
75
-
76
-        $tableList = $this->schema->getTables();
77
-
78
-        // Remove all beans and daos from junction tables
79
-        $junctionTables = $this->schemaAnalyzer->detectJunctionTables();
80
-        $junctionTableNames = array_map(function (Table $table) {
81
-            return $table->getName();
82
-        }, $junctionTables);
83
-
84
-        $tableList = array_filter($tableList, function (Table $table) use ($junctionTableNames) {
85
-            return !in_array($table->getName(), $junctionTableNames);
86
-        });
87
-
88
-        foreach ($tableList as $table) {
89
-            $this->generateDaoAndBean($table, $daonamespace, $beannamespace, $classNameMapper, $storeInUtc);
90
-        }
91
-
92
-        $this->generateFactory($tableList, $daoFactoryClassName, $daonamespace, $classNameMapper);
93
-
94
-        // Ok, let's return the list of all tables.
95
-        // These will be used by the calling script to create Mouf instances.
96
-
97
-        return array_map(function (Table $table) { return $table->getName(); }, $tableList);
98
-    }
99
-
100
-    /**
101
-     * Generates in one method call the daos and the beans for one table.
102
-     *
103
-     * @param Table           $table
104
-     * @param string          $daonamespace
105
-     * @param string          $beannamespace
106
-     * @param ClassNameMapper $classNameMapper
107
-     * @param bool            $storeInUtc
108
-     *
109
-     * @throws TDBMException
110
-     */
111
-    public function generateDaoAndBean(Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc)
112
-    {
113
-        $tableName = $table->getName();
114
-        $daoName = $this->getDaoNameFromTableName($tableName);
115
-        $beanName = $this->getBeanNameFromTableName($tableName);
116
-        $baseBeanName = $this->getBaseBeanNameFromTableName($tableName);
117
-        $baseDaoName = $this->getBaseDaoNameFromTableName($tableName);
118
-
119
-        $beanDescriptor = new BeanDescriptor($table, $this->schemaAnalyzer, $this->schema, $this->tdbmSchemaAnalyzer);
120
-
121
-        $this->generateBean($beanDescriptor, $beanName, $baseBeanName, $table, $beannamespace, $classNameMapper, $storeInUtc);
122
-        $this->generateDao($beanDescriptor, $daoName, $baseDaoName, $beanName, $table, $daonamespace, $beannamespace, $classNameMapper);
123
-    }
124
-
125
-    /**
126
-     * Returns the name of the bean class from the table name.
127
-     *
128
-     * @param $tableName
129
-     *
130
-     * @return string
131
-     */
132
-    public static function getBeanNameFromTableName($tableName)
133
-    {
134
-        return self::toSingular(self::toCamelCase($tableName)).'Bean';
135
-    }
136
-
137
-    /**
138
-     * Returns the name of the DAO class from the table name.
139
-     *
140
-     * @param $tableName
141
-     *
142
-     * @return string
143
-     */
144
-    public static function getDaoNameFromTableName($tableName)
145
-    {
146
-        return self::toSingular(self::toCamelCase($tableName)).'Dao';
147
-    }
148
-
149
-    /**
150
-     * Returns the name of the base bean class from the table name.
151
-     *
152
-     * @param $tableName
153
-     *
154
-     * @return string
155
-     */
156
-    public static function getBaseBeanNameFromTableName($tableName)
157
-    {
158
-        return self::toSingular(self::toCamelCase($tableName)).'BaseBean';
159
-    }
160
-
161
-    /**
162
-     * Returns the name of the base DAO class from the table name.
163
-     *
164
-     * @param $tableName
165
-     *
166
-     * @return string
167
-     */
168
-    public static function getBaseDaoNameFromTableName($tableName)
169
-    {
170
-        return self::toSingular(self::toCamelCase($tableName)).'BaseDao';
171
-    }
172
-
173
-    /**
174
-     * Writes the PHP bean file with all getters and setters from the table passed in parameter.
175
-     *
176
-     * @param BeanDescriptor  $beanDescriptor
177
-     * @param string          $className       The name of the class
178
-     * @param string          $baseClassName   The name of the base class which will be extended (name only, no directory)
179
-     * @param Table           $table           The table
180
-     * @param string          $beannamespace   The namespace of the bean
181
-     * @param ClassNameMapper $classNameMapper
182
-     *
183
-     * @throws TDBMException
184
-     */
185
-    public function generateBean(BeanDescriptor $beanDescriptor, $className, $baseClassName, Table $table, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc)
186
-    {
187
-        $str = $beanDescriptor->generatePhpCode($beannamespace);
188
-
189
-        $possibleBaseFileNames = $classNameMapper->getPossibleFileNames($beannamespace.'\\'.$baseClassName);
190
-        if (empty($possibleBaseFileNames)) {
191
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace.'\\'.$baseClassName.'" is not autoloadable.');
192
-        }
193
-        $possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
194
-
195
-        $this->ensureDirectoryExist($possibleBaseFileName);
196
-        file_put_contents($possibleBaseFileName, $str);
197
-        @chmod($possibleBaseFileName, 0664);
198
-
199
-        $possibleFileNames = $classNameMapper->getPossibleFileNames($beannamespace.'\\'.$className);
200
-        if (empty($possibleFileNames)) {
201
-            // @codeCoverageIgnoreStart
202
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace.'\\'.$className.'" is not autoloadable.');
203
-            // @codeCoverageIgnoreEnd
204
-        }
205
-        $possibleFileName = $this->rootPath.$possibleFileNames[0];
206
-
207
-        if (!file_exists($possibleFileName)) {
208
-            $tableName = $table->getName();
209
-
210
-            $str = "<?php
20
+	/**
21
+	 * @var SchemaAnalyzer
22
+	 */
23
+	private $schemaAnalyzer;
24
+
25
+	/**
26
+	 * @var Schema
27
+	 */
28
+	private $schema;
29
+
30
+	/**
31
+	 * The root directory of the project.
32
+	 *
33
+	 * @var string
34
+	 */
35
+	private $rootPath;
36
+
37
+	/**
38
+	 * @var TDBMSchemaAnalyzer
39
+	 */
40
+	private $tdbmSchemaAnalyzer;
41
+
42
+	/**
43
+	 * Constructor.
44
+	 *
45
+	 * @param SchemaAnalyzer     $schemaAnalyzer
46
+	 * @param Schema             $schema
47
+	 * @param TDBMSchemaAnalyzer $tdbmSchemaAnalyzer
48
+	 */
49
+	public function __construct(SchemaAnalyzer $schemaAnalyzer, Schema $schema, TDBMSchemaAnalyzer $tdbmSchemaAnalyzer)
50
+	{
51
+		$this->schemaAnalyzer = $schemaAnalyzer;
52
+		$this->schema = $schema;
53
+		$this->tdbmSchemaAnalyzer = $tdbmSchemaAnalyzer;
54
+		$this->rootPath = __DIR__.'/../../../../../../../../';
55
+	}
56
+
57
+	/**
58
+	 * Generates all the daos and beans.
59
+	 *
60
+	 * @param string $daoFactoryClassName The classe name of the DAO factory
61
+	 * @param string $daonamespace        The namespace for the DAOs, without trailing \
62
+	 * @param string $beannamespace       The Namespace for the beans, without trailing \
63
+	 * @param bool   $storeInUtc          If the generated daos should store the date in UTC timezone instead of user's timezone.
64
+	 *
65
+	 * @return \string[] the list of tables
66
+	 *
67
+	 * @throws TDBMException
68
+	 */
69
+	public function generateAllDaosAndBeans($daoFactoryClassName, $daonamespace, $beannamespace, $storeInUtc)
70
+	{
71
+		// TODO: extract ClassNameMapper in its own package!
72
+		$classNameMapper = ClassNameMapper::createFromComposerFile($this->rootPath.'composer.json');
73
+
74
+		// TODO: check that no class name ends with "Base". Otherwise, there will be name clash.
75
+
76
+		$tableList = $this->schema->getTables();
77
+
78
+		// Remove all beans and daos from junction tables
79
+		$junctionTables = $this->schemaAnalyzer->detectJunctionTables();
80
+		$junctionTableNames = array_map(function (Table $table) {
81
+			return $table->getName();
82
+		}, $junctionTables);
83
+
84
+		$tableList = array_filter($tableList, function (Table $table) use ($junctionTableNames) {
85
+			return !in_array($table->getName(), $junctionTableNames);
86
+		});
87
+
88
+		foreach ($tableList as $table) {
89
+			$this->generateDaoAndBean($table, $daonamespace, $beannamespace, $classNameMapper, $storeInUtc);
90
+		}
91
+
92
+		$this->generateFactory($tableList, $daoFactoryClassName, $daonamespace, $classNameMapper);
93
+
94
+		// Ok, let's return the list of all tables.
95
+		// These will be used by the calling script to create Mouf instances.
96
+
97
+		return array_map(function (Table $table) { return $table->getName(); }, $tableList);
98
+	}
99
+
100
+	/**
101
+	 * Generates in one method call the daos and the beans for one table.
102
+	 *
103
+	 * @param Table           $table
104
+	 * @param string          $daonamespace
105
+	 * @param string          $beannamespace
106
+	 * @param ClassNameMapper $classNameMapper
107
+	 * @param bool            $storeInUtc
108
+	 *
109
+	 * @throws TDBMException
110
+	 */
111
+	public function generateDaoAndBean(Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc)
112
+	{
113
+		$tableName = $table->getName();
114
+		$daoName = $this->getDaoNameFromTableName($tableName);
115
+		$beanName = $this->getBeanNameFromTableName($tableName);
116
+		$baseBeanName = $this->getBaseBeanNameFromTableName($tableName);
117
+		$baseDaoName = $this->getBaseDaoNameFromTableName($tableName);
118
+
119
+		$beanDescriptor = new BeanDescriptor($table, $this->schemaAnalyzer, $this->schema, $this->tdbmSchemaAnalyzer);
120
+
121
+		$this->generateBean($beanDescriptor, $beanName, $baseBeanName, $table, $beannamespace, $classNameMapper, $storeInUtc);
122
+		$this->generateDao($beanDescriptor, $daoName, $baseDaoName, $beanName, $table, $daonamespace, $beannamespace, $classNameMapper);
123
+	}
124
+
125
+	/**
126
+	 * Returns the name of the bean class from the table name.
127
+	 *
128
+	 * @param $tableName
129
+	 *
130
+	 * @return string
131
+	 */
132
+	public static function getBeanNameFromTableName($tableName)
133
+	{
134
+		return self::toSingular(self::toCamelCase($tableName)).'Bean';
135
+	}
136
+
137
+	/**
138
+	 * Returns the name of the DAO class from the table name.
139
+	 *
140
+	 * @param $tableName
141
+	 *
142
+	 * @return string
143
+	 */
144
+	public static function getDaoNameFromTableName($tableName)
145
+	{
146
+		return self::toSingular(self::toCamelCase($tableName)).'Dao';
147
+	}
148
+
149
+	/**
150
+	 * Returns the name of the base bean class from the table name.
151
+	 *
152
+	 * @param $tableName
153
+	 *
154
+	 * @return string
155
+	 */
156
+	public static function getBaseBeanNameFromTableName($tableName)
157
+	{
158
+		return self::toSingular(self::toCamelCase($tableName)).'BaseBean';
159
+	}
160
+
161
+	/**
162
+	 * Returns the name of the base DAO class from the table name.
163
+	 *
164
+	 * @param $tableName
165
+	 *
166
+	 * @return string
167
+	 */
168
+	public static function getBaseDaoNameFromTableName($tableName)
169
+	{
170
+		return self::toSingular(self::toCamelCase($tableName)).'BaseDao';
171
+	}
172
+
173
+	/**
174
+	 * Writes the PHP bean file with all getters and setters from the table passed in parameter.
175
+	 *
176
+	 * @param BeanDescriptor  $beanDescriptor
177
+	 * @param string          $className       The name of the class
178
+	 * @param string          $baseClassName   The name of the base class which will be extended (name only, no directory)
179
+	 * @param Table           $table           The table
180
+	 * @param string          $beannamespace   The namespace of the bean
181
+	 * @param ClassNameMapper $classNameMapper
182
+	 *
183
+	 * @throws TDBMException
184
+	 */
185
+	public function generateBean(BeanDescriptor $beanDescriptor, $className, $baseClassName, Table $table, $beannamespace, ClassNameMapper $classNameMapper, $storeInUtc)
186
+	{
187
+		$str = $beanDescriptor->generatePhpCode($beannamespace);
188
+
189
+		$possibleBaseFileNames = $classNameMapper->getPossibleFileNames($beannamespace.'\\'.$baseClassName);
190
+		if (empty($possibleBaseFileNames)) {
191
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace.'\\'.$baseClassName.'" is not autoloadable.');
192
+		}
193
+		$possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
194
+
195
+		$this->ensureDirectoryExist($possibleBaseFileName);
196
+		file_put_contents($possibleBaseFileName, $str);
197
+		@chmod($possibleBaseFileName, 0664);
198
+
199
+		$possibleFileNames = $classNameMapper->getPossibleFileNames($beannamespace.'\\'.$className);
200
+		if (empty($possibleFileNames)) {
201
+			// @codeCoverageIgnoreStart
202
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$beannamespace.'\\'.$className.'" is not autoloadable.');
203
+			// @codeCoverageIgnoreEnd
204
+		}
205
+		$possibleFileName = $this->rootPath.$possibleFileNames[0];
206
+
207
+		if (!file_exists($possibleFileName)) {
208
+			$tableName = $table->getName();
209
+
210
+			$str = "<?php
211 211
 /*
212 212
  * This file has been automatically generated by TDBM.
213 213
  * You can edit this file as it will not be overwritten.
@@ -222,76 +222,76 @@  discard block
 block discarded – undo
222 222
 {
223 223
 
224 224
 }";
225
-            $this->ensureDirectoryExist($possibleFileName);
226
-            file_put_contents($possibleFileName, $str);
227
-            @chmod($possibleFileName, 0664);
228
-        }
229
-    }
230
-
231
-    /**
232
-     * Tries to find a @defaultSort annotation in one of the columns.
233
-     *
234
-     * @param Table $table
235
-     *
236
-     * @return array First item: column name, Second item: column order (asc/desc)
237
-     */
238
-    private function getDefaultSortColumnFromAnnotation(Table $table)
239
-    {
240
-        $defaultSort = null;
241
-        $defaultSortDirection = null;
242
-        foreach ($table->getColumns() as $column) {
243
-            $comments = $column->getComment();
244
-            $matches = [];
245
-            if (preg_match('/@defaultSort(\((desc|asc)\))*/', $comments, $matches) != 0) {
246
-                $defaultSort = $column->getName();
247
-                if (count($matches) === 3) {
248
-                    $defaultSortDirection = $matches[2];
249
-                } else {
250
-                    $defaultSortDirection = 'ASC';
251
-                }
252
-            }
253
-        }
254
-
255
-        return [$defaultSort, $defaultSortDirection];
256
-    }
257
-
258
-    /**
259
-     * Writes the PHP bean DAO with simple functions to create/get/save objects.
260
-     *
261
-     * @param BeanDescriptor  $beanDescriptor
262
-     * @param string          $className       The name of the class
263
-     * @param string          $baseClassName
264
-     * @param string          $beanClassName
265
-     * @param Table           $table
266
-     * @param string          $daonamespace
267
-     * @param string          $beannamespace
268
-     * @param ClassNameMapper $classNameMapper
269
-     *
270
-     * @throws TDBMException
271
-     */
272
-    public function generateDao(BeanDescriptor $beanDescriptor, $className, $baseClassName, $beanClassName, Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper)
273
-    {
274
-        $tableName = $table->getName();
275
-        $primaryKeyColumns = $table->getPrimaryKeyColumns();
276
-
277
-        list($defaultSort, $defaultSortDirection) = $this->getDefaultSortColumnFromAnnotation($table);
278
-
279
-        // FIXME: lowercase tables with _ in the name should work!
280
-        $tableCamel = self::toSingular(self::toCamelCase($tableName));
281
-
282
-        $beanClassWithoutNameSpace = $beanClassName;
283
-        $beanClassName = $beannamespace.'\\'.$beanClassName;
284
-
285
-        list($usedBeans, $findByDaoCode) = $beanDescriptor->generateFindByDaoCode($beannamespace, $beanClassWithoutNameSpace);
286
-
287
-        $usedBeans[] = $beanClassName;
288
-        // Let's suppress duplicates in used beans (if any)
289
-        $usedBeans = array_flip(array_flip($usedBeans));
290
-        $useStatements = array_map(function ($usedBean) {
291
-            return "use $usedBean;\n";
292
-        }, $usedBeans);
293
-
294
-        $str = "<?php
225
+			$this->ensureDirectoryExist($possibleFileName);
226
+			file_put_contents($possibleFileName, $str);
227
+			@chmod($possibleFileName, 0664);
228
+		}
229
+	}
230
+
231
+	/**
232
+	 * Tries to find a @defaultSort annotation in one of the columns.
233
+	 *
234
+	 * @param Table $table
235
+	 *
236
+	 * @return array First item: column name, Second item: column order (asc/desc)
237
+	 */
238
+	private function getDefaultSortColumnFromAnnotation(Table $table)
239
+	{
240
+		$defaultSort = null;
241
+		$defaultSortDirection = null;
242
+		foreach ($table->getColumns() as $column) {
243
+			$comments = $column->getComment();
244
+			$matches = [];
245
+			if (preg_match('/@defaultSort(\((desc|asc)\))*/', $comments, $matches) != 0) {
246
+				$defaultSort = $column->getName();
247
+				if (count($matches) === 3) {
248
+					$defaultSortDirection = $matches[2];
249
+				} else {
250
+					$defaultSortDirection = 'ASC';
251
+				}
252
+			}
253
+		}
254
+
255
+		return [$defaultSort, $defaultSortDirection];
256
+	}
257
+
258
+	/**
259
+	 * Writes the PHP bean DAO with simple functions to create/get/save objects.
260
+	 *
261
+	 * @param BeanDescriptor  $beanDescriptor
262
+	 * @param string          $className       The name of the class
263
+	 * @param string          $baseClassName
264
+	 * @param string          $beanClassName
265
+	 * @param Table           $table
266
+	 * @param string          $daonamespace
267
+	 * @param string          $beannamespace
268
+	 * @param ClassNameMapper $classNameMapper
269
+	 *
270
+	 * @throws TDBMException
271
+	 */
272
+	public function generateDao(BeanDescriptor $beanDescriptor, $className, $baseClassName, $beanClassName, Table $table, $daonamespace, $beannamespace, ClassNameMapper $classNameMapper)
273
+	{
274
+		$tableName = $table->getName();
275
+		$primaryKeyColumns = $table->getPrimaryKeyColumns();
276
+
277
+		list($defaultSort, $defaultSortDirection) = $this->getDefaultSortColumnFromAnnotation($table);
278
+
279
+		// FIXME: lowercase tables with _ in the name should work!
280
+		$tableCamel = self::toSingular(self::toCamelCase($tableName));
281
+
282
+		$beanClassWithoutNameSpace = $beanClassName;
283
+		$beanClassName = $beannamespace.'\\'.$beanClassName;
284
+
285
+		list($usedBeans, $findByDaoCode) = $beanDescriptor->generateFindByDaoCode($beannamespace, $beanClassWithoutNameSpace);
286
+
287
+		$usedBeans[] = $beanClassName;
288
+		// Let's suppress duplicates in used beans (if any)
289
+		$usedBeans = array_flip(array_flip($usedBeans));
290
+		$useStatements = array_map(function ($usedBean) {
291
+			return "use $usedBean;\n";
292
+		}, $usedBeans);
293
+
294
+		$str = "<?php
295 295
 
296 296
 /*
297 297
  * This file has been automatically generated by TDBM.
@@ -368,9 +368,9 @@  discard block
 block discarded – undo
368 368
     }
369 369
     ";
370 370
 
371
-        if (count($primaryKeyColumns) === 1) {
372
-            $primaryKeyColumn = $primaryKeyColumns[0];
373
-            $str .= "
371
+		if (count($primaryKeyColumns) === 1) {
372
+			$primaryKeyColumn = $primaryKeyColumns[0];
373
+			$str .= "
374 374
     /**
375 375
      * Get $beanClassWithoutNameSpace specified by its ID (its primary key)
376 376
      * If the primary key does not exist, an exception is thrown.
@@ -385,8 +385,8 @@  discard block
 block discarded – undo
385 385
         return \$this->tdbmService->findObjectByPk('$tableName', ['$primaryKeyColumn' => \$id], [], \$lazyLoading);
386 386
     }
387 387
     ";
388
-        }
389
-        $str .= "
388
+		}
389
+		$str .= "
390 390
     /**
391 391
      * Deletes the $beanClassWithoutNameSpace passed in parameter.
392 392
      *
@@ -444,33 +444,33 @@  discard block
 block discarded – undo
444 444
     }
445 445
 ";
446 446
 
447
-        $str .= $findByDaoCode;
448
-        $str .= '}
447
+		$str .= $findByDaoCode;
448
+		$str .= '}
449 449
 ';
450 450
 
451
-        $possibleBaseFileNames = $classNameMapper->getPossibleFileNames($daonamespace.'\\'.$baseClassName);
452
-        if (empty($possibleBaseFileNames)) {
453
-            // @codeCoverageIgnoreStart
454
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$baseClassName.'" is not autoloadable.');
455
-            // @codeCoverageIgnoreEnd
456
-        }
457
-        $possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
458
-
459
-        $this->ensureDirectoryExist($possibleBaseFileName);
460
-        file_put_contents($possibleBaseFileName, $str);
461
-        @chmod($possibleBaseFileName, 0664);
462
-
463
-        $possibleFileNames = $classNameMapper->getPossibleFileNames($daonamespace.'\\'.$className);
464
-        if (empty($possibleFileNames)) {
465
-            // @codeCoverageIgnoreStart
466
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$className.'" is not autoloadable.');
467
-            // @codeCoverageIgnoreEnd
468
-        }
469
-        $possibleFileName = $this->rootPath.$possibleFileNames[0];
470
-
471
-        // Now, let's generate the "editable" class
472
-        if (!file_exists($possibleFileName)) {
473
-            $str = "<?php
451
+		$possibleBaseFileNames = $classNameMapper->getPossibleFileNames($daonamespace.'\\'.$baseClassName);
452
+		if (empty($possibleBaseFileNames)) {
453
+			// @codeCoverageIgnoreStart
454
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$baseClassName.'" is not autoloadable.');
455
+			// @codeCoverageIgnoreEnd
456
+		}
457
+		$possibleBaseFileName = $this->rootPath.$possibleBaseFileNames[0];
458
+
459
+		$this->ensureDirectoryExist($possibleBaseFileName);
460
+		file_put_contents($possibleBaseFileName, $str);
461
+		@chmod($possibleBaseFileName, 0664);
462
+
463
+		$possibleFileNames = $classNameMapper->getPossibleFileNames($daonamespace.'\\'.$className);
464
+		if (empty($possibleFileNames)) {
465
+			// @codeCoverageIgnoreStart
466
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$className.'" is not autoloadable.');
467
+			// @codeCoverageIgnoreEnd
468
+		}
469
+		$possibleFileName = $this->rootPath.$possibleFileNames[0];
470
+
471
+		// Now, let's generate the "editable" class
472
+		if (!file_exists($possibleFileName)) {
473
+			$str = "<?php
474 474
 
475 475
 /*
476 476
  * This file has been automatically generated by TDBM.
@@ -487,22 +487,22 @@  discard block
 block discarded – undo
487 487
 
488 488
 }
489 489
 ";
490
-            $this->ensureDirectoryExist($possibleFileName);
491
-            file_put_contents($possibleFileName, $str);
492
-            @chmod($possibleFileName, 0664);
493
-        }
494
-    }
495
-
496
-    /**
497
-     * Generates the factory bean.
498
-     *
499
-     * @param Table[] $tableList
500
-     */
501
-    private function generateFactory(array $tableList, $daoFactoryClassName, $daoNamespace, ClassNameMapper $classNameMapper)
502
-    {
503
-        // For each table, let's write a property.
504
-
505
-        $str = "<?php
490
+			$this->ensureDirectoryExist($possibleFileName);
491
+			file_put_contents($possibleFileName, $str);
492
+			@chmod($possibleFileName, 0664);
493
+		}
494
+	}
495
+
496
+	/**
497
+	 * Generates the factory bean.
498
+	 *
499
+	 * @param Table[] $tableList
500
+	 */
501
+	private function generateFactory(array $tableList, $daoFactoryClassName, $daoNamespace, ClassNameMapper $classNameMapper)
502
+	{
503
+		// For each table, let's write a property.
504
+
505
+		$str = "<?php
506 506
 
507 507
 /*
508 508
  * This file has been automatically generated by TDBM.
@@ -519,12 +519,12 @@  discard block
 block discarded – undo
519 519
 {
520 520
 ";
521 521
 
522
-        foreach ($tableList as $table) {
523
-            $tableName = $table->getName();
524
-            $daoClassName = $this->getDaoNameFromTableName($tableName);
525
-            $daoInstanceName = self::toVariableName($daoClassName);
522
+		foreach ($tableList as $table) {
523
+			$tableName = $table->getName();
524
+			$daoClassName = $this->getDaoNameFromTableName($tableName);
525
+			$daoInstanceName = self::toVariableName($daoClassName);
526 526
 
527
-            $str .= '    /**
527
+			$str .= '    /**
528 528
      * @var '.$daoClassName.'
529 529
      */
530 530
     private $'.$daoInstanceName.';
@@ -549,163 +549,163 @@  discard block
 block discarded – undo
549 549
     }
550 550
 
551 551
 ';
552
-        }
552
+		}
553 553
 
554
-        $str .= '
554
+		$str .= '
555 555
 }
556 556
 ';
557 557
 
558
-        $possibleFileNames = $classNameMapper->getPossibleFileNames($daoNamespace.'\\'.$daoFactoryClassName);
559
-        if (empty($possibleFileNames)) {
560
-            throw new TDBMException('Sorry, autoload namespace issue. The class "'.$daoNamespace.'\\'.$daoFactoryClassName.'" is not autoloadable.');
561
-        }
562
-        $possibleFileName = $this->rootPath.$possibleFileNames[0];
563
-
564
-        $this->ensureDirectoryExist($possibleFileName);
565
-        file_put_contents($possibleFileName, $str);
566
-        @chmod($possibleFileName, 0664);
567
-    }
568
-
569
-    /**
570
-     * Transforms a string to camelCase (except the first letter will be uppercase too).
571
-     * Underscores and spaces are removed and the first letter after the underscore is uppercased.
572
-     *
573
-     * @param $str string
574
-     *
575
-     * @return string
576
-     */
577
-    public static function toCamelCase($str)
578
-    {
579
-        $str = strtoupper(substr($str, 0, 1)).substr($str, 1);
580
-        while (true) {
581
-            if (strpos($str, '_') === false && strpos($str, ' ') === false) {
582
-                break;
583
-            }
584
-
585
-            $pos = strpos($str, '_');
586
-            if ($pos === false) {
587
-                $pos = strpos($str, ' ');
588
-            }
589
-            $before = substr($str, 0, $pos);
590
-            $after = substr($str, $pos + 1);
591
-            $str = $before.strtoupper(substr($after, 0, 1)).substr($after, 1);
592
-        }
593
-
594
-        return $str;
595
-    }
596
-
597
-    /**
598
-     * Tries to put string to the singular form (if it is plural).
599
-     * We assume the table names are in english.
600
-     *
601
-     * @param $str string
602
-     *
603
-     * @return string
604
-     */
605
-    public static function toSingular($str)
606
-    {
607
-        return Inflector::singularize($str);
608
-    }
609
-
610
-    /**
611
-     * Put the first letter of the string in lower case.
612
-     * Very useful to transform a class name into a variable name.
613
-     *
614
-     * @param $str string
615
-     *
616
-     * @return string
617
-     */
618
-    public static function toVariableName($str)
619
-    {
620
-        return strtolower(substr($str, 0, 1)).substr($str, 1);
621
-    }
622
-
623
-    /**
624
-     * Ensures the file passed in parameter can be written in its directory.
625
-     *
626
-     * @param string $fileName
627
-     *
628
-     * @throws TDBMException
629
-     */
630
-    private function ensureDirectoryExist($fileName)
631
-    {
632
-        $dirName = dirname($fileName);
633
-        if (!file_exists($dirName)) {
634
-            $old = umask(0);
635
-            $result = mkdir($dirName, 0775, true);
636
-            umask($old);
637
-            if ($result === false) {
638
-                throw new TDBMException("Unable to create directory: '".$dirName."'.");
639
-            }
640
-        }
641
-    }
642
-
643
-    /**
644
-     * @param string $rootPath
645
-     */
646
-    public function setRootPath($rootPath)
647
-    {
648
-        $this->rootPath = $rootPath;
649
-    }
650
-
651
-    /**
652
-     * @return string
653
-     */
654
-    public function getRootPath()
655
-    {
656
-        return $this->rootPath;
657
-    }
558
+		$possibleFileNames = $classNameMapper->getPossibleFileNames($daoNamespace.'\\'.$daoFactoryClassName);
559
+		if (empty($possibleFileNames)) {
560
+			throw new TDBMException('Sorry, autoload namespace issue. The class "'.$daoNamespace.'\\'.$daoFactoryClassName.'" is not autoloadable.');
561
+		}
562
+		$possibleFileName = $this->rootPath.$possibleFileNames[0];
563
+
564
+		$this->ensureDirectoryExist($possibleFileName);
565
+		file_put_contents($possibleFileName, $str);
566
+		@chmod($possibleFileName, 0664);
567
+	}
568
+
569
+	/**
570
+	 * Transforms a string to camelCase (except the first letter will be uppercase too).
571
+	 * Underscores and spaces are removed and the first letter after the underscore is uppercased.
572
+	 *
573
+	 * @param $str string
574
+	 *
575
+	 * @return string
576
+	 */
577
+	public static function toCamelCase($str)
578
+	{
579
+		$str = strtoupper(substr($str, 0, 1)).substr($str, 1);
580
+		while (true) {
581
+			if (strpos($str, '_') === false && strpos($str, ' ') === false) {
582
+				break;
583
+			}
584
+
585
+			$pos = strpos($str, '_');
586
+			if ($pos === false) {
587
+				$pos = strpos($str, ' ');
588
+			}
589
+			$before = substr($str, 0, $pos);
590
+			$after = substr($str, $pos + 1);
591
+			$str = $before.strtoupper(substr($after, 0, 1)).substr($after, 1);
592
+		}
593
+
594
+		return $str;
595
+	}
596
+
597
+	/**
598
+	 * Tries to put string to the singular form (if it is plural).
599
+	 * We assume the table names are in english.
600
+	 *
601
+	 * @param $str string
602
+	 *
603
+	 * @return string
604
+	 */
605
+	public static function toSingular($str)
606
+	{
607
+		return Inflector::singularize($str);
608
+	}
609
+
610
+	/**
611
+	 * Put the first letter of the string in lower case.
612
+	 * Very useful to transform a class name into a variable name.
613
+	 *
614
+	 * @param $str string
615
+	 *
616
+	 * @return string
617
+	 */
618
+	public static function toVariableName($str)
619
+	{
620
+		return strtolower(substr($str, 0, 1)).substr($str, 1);
621
+	}
622
+
623
+	/**
624
+	 * Ensures the file passed in parameter can be written in its directory.
625
+	 *
626
+	 * @param string $fileName
627
+	 *
628
+	 * @throws TDBMException
629
+	 */
630
+	private function ensureDirectoryExist($fileName)
631
+	{
632
+		$dirName = dirname($fileName);
633
+		if (!file_exists($dirName)) {
634
+			$old = umask(0);
635
+			$result = mkdir($dirName, 0775, true);
636
+			umask($old);
637
+			if ($result === false) {
638
+				throw new TDBMException("Unable to create directory: '".$dirName."'.");
639
+			}
640
+		}
641
+	}
642
+
643
+	/**
644
+	 * @param string $rootPath
645
+	 */
646
+	public function setRootPath($rootPath)
647
+	{
648
+		$this->rootPath = $rootPath;
649
+	}
650
+
651
+	/**
652
+	 * @return string
653
+	 */
654
+	public function getRootPath()
655
+	{
656
+		return $this->rootPath;
657
+	}
658 658
     
659
-    /**
660
-     * Transforms a DBAL type into a PHP type (for PHPDoc purpose).
661
-     *
662
-     * @param Type $type The DBAL type
663
-     *
664
-     * @return string The PHP type
665
-     */
666
-    public static function dbalTypeToPhpType(Type $type)
667
-    {
668
-        $map = [
669
-            Type::TARRAY => 'array',
670
-            Type::SIMPLE_ARRAY => 'array',
671
-            Type::JSON_ARRAY => 'array',
672
-            Type::BIGINT => 'string',
673
-            Type::BOOLEAN => 'bool',
674
-            Type::DATETIME => '\DateTimeInterface',
675
-            Type::DATETIMETZ => '\DateTimeInterface',
676
-            Type::DATE => '\DateTimeInterface',
677
-            Type::TIME => '\DateTimeInterface',
678
-            Type::DECIMAL => 'float',
679
-            Type::INTEGER => 'int',
680
-            Type::OBJECT => 'string',
681
-            Type::SMALLINT => 'int',
682
-            Type::STRING => 'string',
683
-            Type::TEXT => 'string',
684
-            Type::BINARY => 'string',
685
-            Type::BLOB => 'string',
686
-            Type::FLOAT => 'float',
687
-            Type::GUID => 'string',
688
-        ];
689
-
690
-        return isset($map[$type->getName()]) ? $map[$type->getName()] : $type->getName();
691
-    }
692
-
693
-    /**
694
-     * @param string $beanNamespace
695
-     *
696
-     * @return \string[] Returns a map mapping table name to beans name
697
-     */
698
-    public function buildTableToBeanMap($beanNamespace)
699
-    {
700
-        $tableToBeanMap = [];
701
-
702
-        $tables = $this->schema->getTables();
703
-
704
-        foreach ($tables as $table) {
705
-            $tableName = $table->getName();
706
-            $tableToBeanMap[$tableName] = $beanNamespace.'\\'.self::getBeanNameFromTableName($tableName);
707
-        }
708
-
709
-        return $tableToBeanMap;
710
-    }
659
+	/**
660
+	 * Transforms a DBAL type into a PHP type (for PHPDoc purpose).
661
+	 *
662
+	 * @param Type $type The DBAL type
663
+	 *
664
+	 * @return string The PHP type
665
+	 */
666
+	public static function dbalTypeToPhpType(Type $type)
667
+	{
668
+		$map = [
669
+			Type::TARRAY => 'array',
670
+			Type::SIMPLE_ARRAY => 'array',
671
+			Type::JSON_ARRAY => 'array',
672
+			Type::BIGINT => 'string',
673
+			Type::BOOLEAN => 'bool',
674
+			Type::DATETIME => '\DateTimeInterface',
675
+			Type::DATETIMETZ => '\DateTimeInterface',
676
+			Type::DATE => '\DateTimeInterface',
677
+			Type::TIME => '\DateTimeInterface',
678
+			Type::DECIMAL => 'float',
679
+			Type::INTEGER => 'int',
680
+			Type::OBJECT => 'string',
681
+			Type::SMALLINT => 'int',
682
+			Type::STRING => 'string',
683
+			Type::TEXT => 'string',
684
+			Type::BINARY => 'string',
685
+			Type::BLOB => 'string',
686
+			Type::FLOAT => 'float',
687
+			Type::GUID => 'string',
688
+		];
689
+
690
+		return isset($map[$type->getName()]) ? $map[$type->getName()] : $type->getName();
691
+	}
692
+
693
+	/**
694
+	 * @param string $beanNamespace
695
+	 *
696
+	 * @return \string[] Returns a map mapping table name to beans name
697
+	 */
698
+	public function buildTableToBeanMap($beanNamespace)
699
+	{
700
+		$tableToBeanMap = [];
701
+
702
+		$tables = $this->schema->getTables();
703
+
704
+		foreach ($tables as $table) {
705
+			$tableName = $table->getName();
706
+			$tableToBeanMap[$tableName] = $beanNamespace.'\\'.self::getBeanNameFromTableName($tableName);
707
+		}
708
+
709
+		return $tableToBeanMap;
710
+	}
711 711
 }
Please login to merge, or discard this patch.