bs3.php

<?php
require_once("connect.inc");
class bs3s
{
	private $operations = array(
		'eq' => "= '[val]'",
		'ne' => "!= '[val]'",
		'lt' => "< '[val]'",
		'le' => "<= '[val]'",
		'gt' => "'> '[val]'",
		'ge' => ">= '[val]'",
		'bw' => "like '[val]%'",
		'ew' => "like '%[val]'",
		'cn' => "like '%[val]%'"
	);
	private $query = array(
		'limit' => '',
		'where' => '',
		'order' => ''
	);
	private $result = array(
		'total' => 0,
		'page' => 1,
		'records' => 0,
		'rows' => array()
	);
	private $db;
	private $level;
	private $page=1;
	private $id_parent;
	private $limit;
	
	public function __construct() 
	{
		// Connect to database 
		$con=new Connect_mysql();
		try { 
		$this->db = new PDO("mysql:host=$con->host;dbname=$con->databaseName", $con->user, $con->password);
		}  
		catch(PDOException $e) {  
			echo $e->getMessage(); 
			die ("\nYou don't have connection to database\n");
		}
	}
	
	function execute()
	{
		//Получаем информацию о том, нужно ли выполнять фильтрацию данных
		$this->buildjqGridWhere();
		//Подсчитываем число строк, которые будут выбраны (с учетом фильтрации)
		//А так же добавляем ограничение выборки (если таковое есть в запросе)
		$this->calculateLimit();
		//Добавляем к рещультирующему запросу порядок сортировки (order by)
		$this->setupOrder();
		//Выбираем записи с учетом фильтрации и ограничения
		$this->fetchRecords();
		//Выводим результат
		$this->printResult();
	}
	/**
	 * Теперь подряд опишем функции
	 */
	
	private function calculateLimit()
	{
		//Подсчитываем число записей
		$count = $this->countRecords();
		
		//Получаем номер страницы, которую нужно вывести 
		//и число записей на странице
		$page = $this->page;
		$limit = $this->get('rows',-1);
		$limit=100;
		$this->limit=$limit;
		//Если число записей в выборке и число записей на странице выдачи больше 0
		//То посчитаем количество страниц в выборке
		//Иначе количество страниц в выборке равно 1
		$totalPages=1;
		//Если страница, которую запросил пользователь не существует,
		//то установим в качестве страницы выдачи последнюю страницу
		//Запись в выборке, с которой начинается выдача
		$start = $limit*$page - $limit;
		
		//Проверим номер первой записи и скорректируем если необходимо
		if($start < 0)
			$start = 0;
		
		//Если количество записей на страницу указано, 
		//то установим лимит выдачи
		if($limit > 1)	
			$this->query['limit'] = "limit {$limit} offset {$start} ";
		//Заполним необходимые поля для вывода последующего вывода данных
		$this->result['total'] = $totalPages;
		$this->result['page'] = $page;
		$this->result['records'] = $count;
	}
	
	/**
	 * Выборка записей из базы данных
	 */
	private function fetchRecords()
	{
		$nlevel      =  $this->get('nlevel',0); //get id folder
			$se=" SELECT id, title, id_parent,size FROM s3objects WHERE ".$this->buildQuery().$this->query['limit'];
			//echo $se;
			$result = $this->db->query(" SELECT id, title, id_parent,size,folder FROM s3objects WHERE ".$this->buildQuery().$this->query['limit']);
			
			$i =0;
			foreach($result as $row) {
				if(!$row['id_parent']) $parent = 'NULL';
				else $parent = $row['id_parent'];
				$this->result['rows'][$i]['id']=$row['id']."_1";//.$this->page;
				$id = $row['id'];
				$selr = $this->db->query(" SELECT count(*) as count_c FROM s3objects WHERE id_parent=$id ");
				$cou = 0;
				foreach($selr as $row1) {
					$cou = $row1['count_c'];
				}
				if ($cou) {
					$is_leaf =false;
				} else {
					$is_leaf =true;
				}
				if ($row['folder']==1){
				    $is_leaf =false;
				}
				$title=$row['title'];
				$is_bucket =false;
				if ($row['id_parent']==0){
					$is_bucket =true;
					$title="<font color='vodka'>".$title."</font>";
				} else {
					$id_pp=$row['id_parent'];
					$selr = $this->db->query(" SELECT * FROM s3objects WHERE id=$id_pp ");
					$p_r = 0;
					foreach($selr as $row1) {
						$p_r = $row1['id_parent'];
					}
					if ($p_r==0) {
						$title="<b><font color='blue'>".$title."</font></b>";
					
					}
				}
				//$this->result['rows'][$i]['cell'] = array($row['id'].'_'.$this->page, $row['title'],$row['size'],$this->level,$parent.'_'.$this->page , $is_leaf, FALSE);
				$this->result['rows'][$i]['cell'] = array($row['id'].'_1', $title,$row['size'],$is_bucket,$this->level,$parent.'_'.$this->page , $is_leaf, FALSE);
				$i++;
			}
			$result = $this->db->query(" SELECT count(*) as count_c  FROM s3objects WHERE ".$this->buildQuery());
			$cou = 0;
//			$node = $this->get('nodeid',0);
			foreach($result as $row) {
				$cou = $row['count_c'];
			}
			$display=$this->limit*$this->page;
			if ($cou>$display) {
				$first=$display+1;
				if (($cou-$display)<$this->limit){
				    $last=$cou;
				}else{
				    $last=$display+$this->limit;
				}
				$ss=" SELECT id_parent,title FROM s3objects WHERE id=".$this->id_parent;
//				echo $ss;
				$result = $this->db->query($ss);
				$id_pp = 0;
				$name='';
				foreach($result as $row) {
				    $id_pp = $row['id_parent'];
				    $name = $row['title'];
				}
				$title=$row['title'];
				$is_bucket =false;
				if ($id_pp==0){
				    $is_bucket =true;
				    $title="<font color='vodka'>".$title."</font>";
				} else {
					$selr = $this->db->query(" SELECT * FROM s3objects WHERE id=$id_pp ");
					$p_r = 0;
					foreach($selr as $row1) {
						$p_r = $row1['id_parent'];
					}
					if ($p_r==0) {
						$title="<b><font color='blue'>".$title."</font></b>";
					
					}
				}
				$this->result['records']++;
				$this->level =  $this->get('n_level',0); //get id folder
				$page_child=$this->page+1;
				$this->result['rows'][$i]['id']=$this->id_parent."_".$page_child;
				$this->result['rows'][$i]['cell'] = array($this->id_parent.'_'.$page_child, $name.'('.$first.'-'.$last.' of '.$cou.')','',$is_bucket,$this->level,$id_pp.'_'.$this->page ,false, FALSE);
			}
	}
	
	
	/**
	 * Функция подсчитывает число записей, которые будут выбраны из базы
	 * с учетом пользовательского фильтра. И возвращает их количество
	 * @return int
	 */
	private function countRecords()
	{
		$qer="select count(*) as count_c from s3objects where ".$this->buildQuery();
		$result = $this->db->query($qer);
		foreach($result as $row) {
			$count = $row["count_c"];
		}
		return $count;
	}
	/**
	 * Устанавливает порядок сортировки, если таковой задан пользователем
	 */
	private function setupOrder()
	{
		/*
		 * если указан столбец для сортировки выдачи,
		 * то добавим оператор order by
		 */ 
		if($sidx = $this->get('sidx','id'))
		{
			$direction = $this->get('sord','asc');
			$this->query['order'] = "order by $sidx $direction";
		}
	}
	
	/**
	 * Функция проверяет, установлен ли пользовательский фильтр. 
	 * Если да, до добавляет условие where к запросу.
	 */
	private function buildjqGridWhere()
	{
		$this->id_parent=0;
		$this->page=1;
		$this->level  =  $this->get('n_level',0); //get id folder
		$node = $this->get('nodeid',0);
		if($node) {
			list($id_parent,$page_child)= split ("_", $node);
			$this->query['where'] = 'id_parent ='.$id_parent;
			$this->level = $this->level+1;
			$this->id_parent=$id_parent;
			$this->page=$page_child;
		} else {
			$this->query['where'] = 'id_parent=0';   // Select Root 
		} 
	}
	
	/**
	 * Безопасное получение переменных запроса.
	 * Если переменная не существует, то возвращается значение по умолчанию.
	 * Иначе значение переменной декодируется и возвращается/
	 * @param string $name
	 * @param string $defaultvalue
	 * @return string
	 */
	private function get($name, $defaultvalue = false)
	{
		return (isset($_REQUEST[$name]))?htmlspecialchars(urldecode($_REQUEST[$name])):$defaultvalue;
	}
	
	
	/**
	 * Функция получает на вход текстовое значение оператора сравнения.
	 * Затем выполняет поиск в массиве операторов сравнения.
	 * И если строка стравнения была найдена, то в нее подставлется 
	 * значение переменной и строка возвращается пользователю.
	 * @param string $operation
	 * @param string $value
	 * @return string
	 */
	private function buildOperator($operation,$value)
	{
		if(!array_key_exists($operation,$this->operations))
			$operation = 'eq';
		return str_replace('[val]',$value,$this->operations[$operation]);
	}
	
	private function buildQuery()
	{
		
		$result = $this->query['where'].' ';
		$result .= $this->query['order'].' ';
	//	$result .= $this->query['limit'];
		return $result;
	}
	
	
	private function printResult()
	{
		echo json_encode($this->result);
	}
}

$command = new bs3s();
$command->execute();
   
?>