122 lines
4.2 KiB
PHP
122 lines
4.2 KiB
PHP
<?php
|
|
|
|
class Application_Model_Datatables
|
|
{
|
|
/*
|
|
* query used to return data for a paginated/searchable datatable.
|
|
*/
|
|
public static function findEntries($con, $displayColumns, $fromTable, $data, $dataProp = "aaData")
|
|
{
|
|
$where = array();
|
|
|
|
if ($data["sSearch"] !== "") {
|
|
$searchTerms = explode(" ", $data["sSearch"]);
|
|
}
|
|
|
|
$selectorCount = "SELECT COUNT(*) ";
|
|
$selectorRows = "SELECT ".join(",", $displayColumns)." ";
|
|
|
|
$sql = $selectorCount." FROM ".$fromTable;
|
|
$sqlTotalRows = $sql;
|
|
|
|
if (isset($searchTerms)) {
|
|
$searchCols = array();
|
|
for ($i = 0; $i < $data["iColumns"]; $i++) {
|
|
if ($data["bSearchable_".$i] == "true") {
|
|
$searchCols[] = $data["mDataProp_{$i}"];
|
|
}
|
|
}
|
|
|
|
$outerCond = array();
|
|
|
|
foreach ($searchTerms as $term) {
|
|
$innerCond = array();
|
|
|
|
foreach ($searchCols as $col) {
|
|
$escapedTerm = pg_escape_string($term);
|
|
$innerCond[] = "{$col}::text ILIKE '%{$escapedTerm}%'";
|
|
}
|
|
$outerCond[] = "(".join(" OR ", $innerCond).")";
|
|
}
|
|
$where[] = "(".join(" AND ", $outerCond).")";
|
|
}
|
|
// End Where clause
|
|
|
|
// Order By clause
|
|
$orderby = array();
|
|
for ($i = 0; $i < $data["iSortingCols"]; $i++) {
|
|
$num = $data["iSortCol_".$i];
|
|
$orderby[] = $data["mDataProp_{$num}"]." ".$data["sSortDir_".$i];
|
|
}
|
|
$orderby[] = "id";
|
|
$orderby = join("," , $orderby);
|
|
// End Order By clause
|
|
|
|
$displayLength = intval($data["iDisplayLength"]);
|
|
if (count($where) > 0) {
|
|
$where = join(" AND ", $where);
|
|
$sql = $selectorCount." FROM ".$fromTable." WHERE ".$where;
|
|
$sqlTotalDisplayRows = $sql;
|
|
|
|
$sql = $selectorRows." FROM ".$fromTable." WHERE ".$where." ORDER BY ".$orderby;
|
|
|
|
//limit the results returned.
|
|
if ($displayLength !== -1) {
|
|
$sql .= " OFFSET ".$data["iDisplayStart"]." LIMIT ".$displayLength;
|
|
}
|
|
} else {
|
|
$sql = $selectorRows." FROM ".$fromTable." ORDER BY ".$orderby;
|
|
|
|
//limit the results returned.
|
|
if ($displayLength !== -1) {
|
|
$sql .= " OFFSET ".$data["iDisplayStart"]." LIMIT ".$displayLength;
|
|
}
|
|
}
|
|
|
|
try {
|
|
$r = $con->query($sqlTotalRows);
|
|
$totalRows = $r->fetchColumn(0);
|
|
|
|
if (isset($sqlTotalDisplayRows)) {
|
|
$r = $con->query($sqlTotalDisplayRows);
|
|
$totalDisplayRows = $r->fetchColumn(0);
|
|
} else {
|
|
$totalDisplayRows = $totalRows;
|
|
}
|
|
|
|
$r = $con->query($sql);
|
|
$r->setFetchMode(PDO::FETCH_ASSOC);
|
|
$results = $r->fetchAll();
|
|
// we need to go over all items and fix length for playlist
|
|
// in case the playlist contains dynamic block
|
|
foreach ($results as &$r) {
|
|
//this function is also called for Manage Users so in
|
|
//this case there will be no 'ftype'
|
|
if (isset($r['ftype'])) {
|
|
if ($r['ftype'] == 'playlist') {
|
|
$pl = new Application_Model_Playlist($r['id']);
|
|
$r['length'] = $pl->getLength();
|
|
} else if ($r['ftype'] == "block") {
|
|
$bl = new Application_Model_Block($r['id']);
|
|
if ($bl->isStatic()) {
|
|
$r['bl_type'] = 'static';
|
|
} else {
|
|
$r['bl_type'] = 'dynamic';
|
|
}
|
|
$r['length'] = $bl->getLength();
|
|
}
|
|
}
|
|
}
|
|
} catch (Exception $e) {
|
|
Logging::debug($e->getMessage());
|
|
}
|
|
|
|
return array(
|
|
"sEcho" => intval($data["sEcho"]),
|
|
"iTotalDisplayRecords" => intval($totalDisplayRows),
|
|
"iTotalRecords" => intval($totalRows),
|
|
$dataProp => $results
|
|
);
|
|
}
|
|
}
|