_dbInstance = Database::getInstance(); $this->_dbHandle = $this->_dbInstance->getDbConnection(); } /** * @param $data * @return bool */ public function addFacility($data): bool { $sqlQuery = " INSERT INTO ecoFacilities (title, category, description, houseNumber, streetName, county, town, postcode, lng, lat, contributor) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ;"; $stmt = $this->_dbHandle->prepare($sqlQuery); // Ensures only one value is returned per column name $stmt->setFetchMode(\PDO::FETCH_ASSOC); // Initialize index for binding $bindIndex = 1; // Bind other filters for ($i = 1; $i <= 8; $i++) { // Assuming 8 other filters $value = !empty($data[$i]) ? "%" . $data[$i] . "%" : "%"; $stmt->bindValue($bindIndex++, $value, \PDO::PARAM_STR); } return !($stmt->rowCount()); } public function deleteFacility($id): bool { $sqlQuery = "DELETE FROM ecoFacilities WHERE id = ?"; $stmt = $this->_dbHandle->prepare($sqlQuery); $stmt->setFetchMode(\PDO::FETCH_ASSOC); $stmt->bindValue(1, $id, \PDO::PARAM_INT); $stmt->execute(); return !($stmt->rowCount() == 0); } public function fetchAll($filterArray, $sortArray): array { // Define columns for filtering and sorting $filterColumns = [ 0 => 'ecoFacilityStatus.statusComment', 1 => 'ecoFacilities.title', 2 => 'ecoCategories.name', 3 => 'ecoFacilities.description', 4 => 'ecoFacilities.streetName', 5 => 'ecoFacilities.county', 6 => 'ecoFacilities.town', 7 => 'ecoFacilities.postcode', 8 => 'ecoUser.username' ]; $sortColumns = [ 0 => 'ecoFacilityStatus.statusComment', 1 => 'ecoFacilities.title', 2 => 'ecoCategories.name', 3 => 'ecoFacilities.description', 4 => 'ecoFacilities.streetName', 5 => 'ecoFacilities.county', 6 => 'ecoFacilities.town', 7 => 'ecoFacilities.postcode', 8 => 'ecoUser.username' ]; // Validate and select the filter column $selectedFilterColumn = $filterColumns[$filterArray['category']] ?? 'ecoFacilities.title'; // Validate and select the sort column $selectedSortColumn = $sortColumns[$sortArray['sort']] ?? 'ecoFacilities.title'; // Validate sort direction $direction = strtolower($sortArray['dir']) === 'desc' ? 'DESC' : 'ASC'; // Base query for filtering and sorting $baseQuery = " FROM ecoFacilities LEFT JOIN ecoCategories ON ecoCategories.id = ecoFacilities.category LEFT JOIN ecoUser ON ecoUser.id = ecoFacilities.contributor LEFT JOIN ecoFacilityStatus ON ecoFacilityStatus.facilityid = ecoFacilities.id WHERE {$selectedFilterColumn} LIKE :term "; // Query to count total results $countQuery = "SELECT COUNT(DISTINCT ecoFacilities.id) AS total {$baseQuery}"; // Query to fetch filtered and sorted results $dataQuery = " SELECT DISTINCT ecoFacilities.id, ecoFacilities.title, GROUP_CONCAT(ecoFacilityStatus.statusComment, ', ') AS status, ecoCategories.name AS category, ecoFacilities.description, ecoFacilities.houseNumber, ecoFacilities.streetName, ecoFacilities.county, ecoFacilities.town, ecoFacilities.postcode, ecoFacilities.lng, ecoFacilities.lat, ecoUser.username AS contributor {$baseQuery} GROUP BY ecoFacilities.id, ecoFacilities.title, ecoCategories.name, ecoFacilities.description, ecoFacilities.streetName, ecoFacilities.county, ecoFacilities.town, ecoFacilities.postcode, ecoUser.username ORDER BY {$selectedSortColumn} {$direction}; "; $filterArray['term'] = '%' . $filterArray['term'] . '%' ?? '%'; var_dump($filterArray); // Prepare and execute the count query $countStmt = $this->_dbHandle->prepare($countQuery); $countStmt->bindValue(':term', $filterArray['term'], PDO::PARAM_STR); $countStmt->execute(); $totalResults = (int)$countStmt->fetchColumn(); // Prepare and execute the data query $dataStmt = $this->_dbHandle->prepare($dataQuery); $dataStmt->bindValue(':term', $filterArray['term'], PDO::PARAM_STR); $dataStmt->execute(); // Fetch results into FacilityData objects $dataSet = []; while ($row = $dataStmt->fetch()) { $dataSet[] = new FacilityData($row); } return [ 'dataset' => $dataSet, 'count' => $totalResults ]; } /** * @param $sqlQuery * @param $filterArray * @return false|PDOStatement * Function for fetchAll() to de-dupe code. Performs binding on PDO statements to facilitate * filtering of facilities. Returns a bound PDO statement. */ // private function populateFields($sqlQuery, $filterArray, $sortBy, $direction) // { // $stmt = $this->_dbHandle->prepare($sqlQuery); // $stmt->setFetchMode(\PDO::FETCH_ASSOC); // // // Initialize index for binding // $bindIndex = 1; // // // Bind statusComment filter, required due to comments not being so. // $statusComment = !empty($filterArray[0]) ? "%" . $filterArray[0] . "%" : null; // $stmt->bindValue($bindIndex++, $statusComment ?? "%", \PDO::PARAM_STR); // First ? // $stmt->bindValue($bindIndex++, $statusComment, $statusComment === null ? \PDO::PARAM_NULL : \PDO::PARAM_STR); // Second ? // // // Bind other filters // for ($i = 1; $i <= 8; $i++) { // Assuming 8 other filters // $value = !empty($filterArray[$i]) ? "%" . $filterArray[$i] . "%" : "%"; // $stmt->bindValue($bindIndex++, $value, \PDO::PARAM_STR); // } // return $stmt; // } // So i worked on trying to get this to work for 30 minutes and it turns out you // can never bind column name values to placeholders, and must use column orders // as integers..... what // if(isset($sortBy) && isset($direction)) { // $stmt->bindValue(':sortBy', $sortBy, \PDO::PARAM_STR); // $stmt->bindValue(':direction', $direction, \PDO::PARAM_STR); // } private function populateFields($sqlQuery, $filterArray) { $stmt = $this->_dbHandle->prepare($sqlQuery); $stmt->setFetchMode(\PDO::FETCH_ASSOC); $bindIndex = 1; // Bind statusComment (two placeholders required) $statusComment = $filterArray[0] ?? '%'; $stmt->bindValue($bindIndex++, $statusComment, \PDO::PARAM_STR); $stmt->bindValue($bindIndex++, $statusComment, \PDO::PARAM_STR); // Bind other filters for ($i = 1; $i < count($filterArray); $i++) { $value = $filterArray[$i] ?? '%'; print_r($i . ":" . $value . "||\n"); $stmt->bindValue($bindIndex++, $value, \PDO::PARAM_STR); } // Debugging //$stmt->debugDumpParams(); return $stmt; } }