2 if(!defined('sugarEntry') || !sugarEntry) die('Not A Valid Entry Point');
3 /*********************************************************************************
4 * SugarCRM Community Edition is a customer relationship management program developed by
5 * SugarCRM, Inc. Copyright (C) 2004-2011 SugarCRM Inc.
7 * This program is free software; you can redistribute it and/or modify it under
8 * the terms of the GNU Affero General Public License version 3 as published by the
9 * Free Software Foundation with the addition of the following permission added
10 * to Section 15 as permitted in Section 7(a): FOR ANY PART OF THE COVERED WORK
11 * IN WHICH THE COPYRIGHT IS OWNED BY SUGARCRM, SUGARCRM DISCLAIMS THE WARRANTY
12 * OF NON INFRINGEMENT OF THIRD PARTY RIGHTS.
14 * This program is distributed in the hope that it will be useful, but WITHOUT
15 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
16 * FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more
19 * You should have received a copy of the GNU Affero General Public License along with
20 * this program; if not, see http://www.gnu.org/licenses or write to the Free
21 * Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
24 * You can contact SugarCRM, Inc. headquarters at 10050 North Wolfe Road,
25 * SW2-130, Cupertino, CA 95014, USA. or at email address contact@sugarcrm.com.
27 * The interactive user interfaces in modified source and object code versions
28 * of this program must display Appropriate Legal Notices, as required under
29 * Section 5 of the GNU Affero General Public License version 3.
31 * In accordance with Section 7(b) of the GNU Affero General Public License version 3,
32 * these Appropriate Legal Notices must retain the display of the "Powered by
33 * SugarCRM" logo. If the display of the logo is not reasonably feasible for
34 * technical reasons, the Appropriate Legal Notices must display the words
35 * "Powered by SugarCRM".
36 ********************************************************************************/
39 require_once("data/Relationships/One2MRelationship.php");
42 * Represents a one to many relationship that is table based.
44 class One2MBeanRelationship extends One2MRelationship
46 //Type is read in sugarbean to determine query construction
47 var $type = "one-to-many";
49 public function __construct($def)
51 parent::__construct($def);
55 * @param $lhs SugarBean left side bean to add to the relationship.
56 * @param $rhs SugarBean right side bean to add to the relationship.
57 * @param $additionalFields key=>value pairs of fields to save on the relationship
58 * @return boolean true if successful
60 public function add($lhs, $rhs, $additionalFields = array())
62 $lhsLinkName = $this->lhsLink;
63 $rhsLinkName = $this->rhsLink;
65 //Since this is bean based, we know updating the RHS's field will overwrite any old value,
66 //But we need to use delete to make sure custom logic is called correctly
67 if ($rhs->load_relationship($rhsLinkName))
69 $oldLink = $rhs->$rhsLinkName;
70 $prevRelated = $oldLink->getBeans(null);
71 foreach($prevRelated as $oldLHS)
73 $this->remove($oldLHS, $rhs, false);
77 //Make sure we load the current relationship state to the LHS link
78 if ((isset($lhs->$lhsLinkName) && is_a($lhs->$lhsLinkName, "Link2")) || $lhs->load_relationship($lhsLinkName)) {
79 $lhs->$lhsLinkName->getBeans();
82 $this->updateFields($lhs, $rhs, $additionalFields);
85 if (empty($_SESSION['disable_workflow']) || $_SESSION['disable_workflow'] != "Yes")
87 //Need to call save to update the bean as the relationship is saved on the main table
88 //We don't want to create a save loop though, so make sure we aren't already in the middle of saving this bean
89 SugarRelationship::addToResaveList($rhs);
91 $this->updateLinks($lhs, $lhsLinkName, $rhs, $rhsLinkName);
93 $this->callAfterAdd($lhs, $rhs);
94 $this->callAfterAdd($rhs, $lhs);
98 protected function updateLinks($lhs, $lhsLinkName, $rhs, $rhsLinkName)
100 if (isset($lhs->$lhsLinkName))
101 $lhs->$lhsLinkName->addBean($rhs);
102 //RHS only has one bean ever, so we don't need to preload the relationship
103 if (isset($rhs->$rhsLinkName))
104 $rhs->$rhsLinkName->beans = array($lhs->id => $lhs);
107 protected function updateFields($lhs, $rhs, $additionalFields)
109 //Now update the RHS bean's ID field
110 $rhsID = $this->def['rhs_key'];
111 $rhs->$rhsID = $lhs->id;
112 foreach($additionalFields as $field => $val)
117 if(!empty($this->def["relationship_role_column"]) && !empty($this->def["relationship_role_column_value"]))
119 $roleField = $this->def["relationship_role_column"];
120 $rhs->$roleField = $this->def["relationship_role_column_value"];
124 public function remove($lhs, $rhs, $save = true)
126 $rhsID = $this->def['rhs_key'];
131 $rhs->in_relationship_update = TRUE;
134 $rhsID = $this->def['rhs_key'];
137 if (empty($_SESSION['disable_workflow']) || $_SESSION['disable_workflow'] != "Yes")
139 $this->callAfterDelete($lhs, $rhs);
140 $this->callAfterDelete($rhs, $lhs);
145 * @param $link Link2 loads the relationship for this link.
148 public function load($link)
150 $relatedModule = $link->getSide() == REL_LHS ? $this->def['rhs_module'] : $this->def['lhs_module'];
152 //The related bean ID is stored on the RHS table.
153 //If the link is RHS, just grab it from the focus.
154 if ($link->getSide() == REL_RHS)
156 $rhsID = $this->def['rhs_key'];
157 $id = $link->getFocus()->$rhsID;
160 $rows[$id] = array('id' => $id);
163 else //If the link is LHS, we need to query to get the full list and load all the beans.
165 $db = DBManagerFactory::getInstance();
166 $query = $this->getQuery($link);
169 echo ("query for {$this->name} was empty when loading from {$this->lhsLink}\n");
171 $result = $db->query($query);
172 while ($row = $db->fetchByAssoc($result))
179 return array("rows" => $rows);
182 public function getQuery($link, $return_as_array = false)
185 if ($link->getSide() == REL_RHS) {
190 $lhsKey = $this->def['lhs_key'];
191 $rhsTable = $this->def['rhs_table'];
192 $rhsTableKey = "{$rhsTable}.{$this->def['rhs_key']}";
193 $where = "WHERE $rhsTableKey = '{$link->getFocus()->$lhsKey}' AND {$rhsTable}.deleted=0";
194 //Check for role column
195 if(!empty($this->def["relationship_role_column"]) && !empty($this->def["relationship_role_column_value"]))
197 $roleField = $this->def["relationship_role_column"];
198 $roleValue = $this->def["relationship_role_column_value"];
199 $where .= " AND $rhsTable.$roleField = '$roleValue'";
201 if (!$return_as_array) {
202 return "SELECT id FROM {$this->def['rhs_table']} $where";
207 'select' => "SELECT id",
208 'from' => "FROM {$this->def['rhs_table']}",
215 public function getJoin($link, $params = array(), $return_array = false)
217 $linkIsLHS = $link->getSide() == REL_LHS;
218 $startingTable = (empty($params['left_join_table_alias']) ? $this->def['lhs_table'] : $params['left_join_table_alias']);
220 $startingTable = (empty($params['right_join_table_alias']) ? $this->def['rhs_table'] : $params['right_join_table_alias']);
221 $startingKey = $linkIsLHS ? $this->def['lhs_key'] : $this->def['rhs_key'];
222 $targetTable = $linkIsLHS ? $this->def['rhs_table'] : $this->def['lhs_table'];
223 $targetTableWithAlias = $targetTable;
224 $targetKey = $linkIsLHS ? $this->def['rhs_key'] : $this->def['lhs_key'];
225 $join_type= isset($params['join_type']) ? $params['join_type'] : ' INNER JOIN ';
228 //Set up any table aliases required
229 if ( ! empty($params['join_table_alias']))
231 $targetTableWithAlias = $targetTable. " ".$params['join_table_alias'];
232 $targetTable = $params['join_table_alias'];
235 //First join the relationship table
236 $join .= "$join_type $targetTableWithAlias ON $startingTable.$startingKey=$targetTable.$targetKey AND $targetTable.deleted=0\n"
237 //Next add any role filters
238 . $this->getRoleFilterForJoin() . "\n";
243 'type' => $this->type,
244 'rel_key' => $targetKey,
245 'join_tables' => array($targetTable),
247 'select' => "$targetTable.id",
253 public function getSubpanelQuery($link, $params = array(), $return_array = false)
256 $linkIsLHS = $link->getSide() == REL_RHS;
257 $startingTable = (empty($params['left_join_table_alias']) ? $this->def['lhs_table'] : $params['left_join_table_alias']);
259 $startingTable = (empty($params['right_join_table_alias']) ? $this->def['rhs_table'] : $params['right_join_table_alias']);
260 $startingKey = $linkIsLHS ? $this->def['lhs_key'] : $this->def['rhs_key'];
261 $targetTable = $linkIsLHS ? $this->def['rhs_table'] : $this->def['lhs_table'];
262 $targetKey = $linkIsLHS ? $this->def['rhs_key'] : $this->def['lhs_key'];
263 $join_type= isset($params['join_type']) ? $params['join_type'] : ' INNER JOIN ';
266 $alias = empty($params['join_table_alias']) ? "{$link->name}_rel": $params['join_table_alias'];
267 //Set up any table aliases required
268 $targetTableWithAlias = "$targetTable $alias";
269 $targetTable = $alias;
271 $query .= "$join_type $targetTableWithAlias ON $startingTable.$startingKey=$targetTable.$targetKey AND $targetTable.deleted=0\n"
272 //Next add any role filters
273 . $this->getRoleFilterForJoin() . "\n";
278 'type' => $this->type,
279 'rel_key' => $targetKey,
280 'join_tables' => array($targetTable),
281 'where' => "WHERE $startingTable.$startingKey='{$link->focus->id}'",
294 public function relationship_exists($lhs, $rhs)
300 public function getRelationshipTable()
302 return $this->def['table'];