Changeset View
Changeset View
Standalone View
Standalone View
src/infrastructure/storage/lisk/LiskDAOSet.php
| Show First 20 Lines • Show All 71 Lines • ▼ Show 20 Lines | if ($relatives === null) { | ||||
| $ids[$id] = $id; | $ids[$id] = $id; | ||||
| } | } | ||||
| } | } | ||||
| if (!$ids) { | if (!$ids) { | ||||
| $relatives = array(); | $relatives = array(); | ||||
| } else { | } else { | ||||
| $set = new LiskDAOSet(); | $set = new LiskDAOSet(); | ||||
| $this->subsets[] = $set; | $this->subsets[] = $set; | ||||
| $conn = $object->establishConnection('r'); | |||||
| if (strlen($where)) { | |||||
| $where_clause = qsprintf($conn, 'AND %Q', $where); | |||||
| } else { | |||||
| $where_clause = qsprintf($conn, ''); | |||||
| } | |||||
| $relatives = $object->putInSet($set)->loadAllWhere( | $relatives = $object->putInSet($set)->loadAllWhere( | ||||
| '%C IN (%Ls) %Q', | '%C IN (%Ls) %Q', | ||||
| $foreign_column, | $foreign_column, | ||||
| $ids, | $ids, | ||||
| ($where != '' ? 'AND '.$where : '')); | $where_clause); | ||||
| $relatives = mgroup($relatives, 'get'.$foreign_column); | $relatives = mgroup($relatives, 'get'.$foreign_column); | ||||
| } | } | ||||
| } | } | ||||
| return $relatives; | return $relatives; | ||||
| } | } | ||||
| } | } | ||||