iwa-panda1

SQLDatabase.php (3077B)

---

 <?php
 
 namespace Lollipop {
 	use mysqli;
 
 	class SQLDatabase
 	{
 		public mysqli $conn;
 
 		function __construct(string $host, string $username, string $password, string $database = null, int $port = null)
 		{
 			$this->conn = new mysqli($host, $username, $password, $database, $port);
 		}
 
 		function get(string $table_class)
 		{
 			/* this function accepts a $table_name creates a Database object with the class $table_name
 			*  retuns a Database object  
 			*/
 			$cls = new $table_class($this);
 			return $cls;
 		}
 
 		function all_where(string $table_name, array $vars)
 		{
 			/* this function accepts a table name and an array[$column_name => $value]
 			* statement is select * from $table_name where $column_name = $value AND etc...
 			* returns an array of classes
 			*/
 			if (!sizeof($vars)) {
 				return [];
 			}
 			$cls = new $table_name($this);
 
 			$sql = "SELECT * FROM {$cls->get_table()} WHERE ";
 			$params = [];
 
 			$i = 0;
 			foreach ($vars as $key => $value) {
 				if ($i > 0) {
 					$sql .= ' AND ';
 				}
 				$sql .= " $key LIKE ?";
 				$params[] = $value;
 				$i++;
 			}
 
 			$stmt = $this->conn->prepare($sql);
 			$stmt->execute($params);
 			$result = $stmt->get_result();
 
 			if (!$result || $result->num_rows == 0) {
 				return [];
 			}
 
 			$objects = [];
 			while ($row = $result->fetch_assoc()) {
 				$o = new $table_name($this);
 				$o->setData($row);
 				$objects[] = $o;
 			}
 			return $objects;
 		}
 
 		function all(string $table_name)
 		{
 			/* loads whole table $table_name
 			* returns array of objects 
 			*/
 			$cls = new $table_name($this);
 
 			$sql = "SELECT * FROM {$cls->get_table()}";
 
 			$result = $this->conn->query($sql);
 
 			if (!$result || $result->num_rows == 0) {
 				return [];
 			}
 
 			$objects = [];
 			while ($row = $result->fetch_assoc()) {
 				$o = new $table_name($this);
 				$o->setData($row);
 				$objects[] = $o;
 			}
 			return $objects;
 		}
         public function getDateRange(string $table_name, array $query, $order)
         {
             if($query == null)
                 return [];
 
             $cls = new $table_name($this);
 
             $sql = "SELECT * FROM {$cls->get_table()} WHERE ";
             $index = 0;
             $values = [];
             foreach($query as $key => $q) {
                 foreach ($q as $k => $value) {
                     if ($index > 0) {
                         $sql .= " AND ";
                     }
                     $sql .= "{$key} {$k} ?";
                     $values[] = $value;
                     $index++;
                 }
             }
 
 			$sql .= " ORDER BY date_time " . $order;
 			$sql .= " LIMIT 1000";
             $stmt = $this->conn->prepare($sql);
             $stmt->execute($values);
             $result = $stmt->get_result();
 
             if ($result->num_rows == 0) {
                 return [];
             }
 
             $objects = [];
             while ($row = $result->fetch_assoc()) {
                 $o = new $table_name($this);
                 $o->setData($row);
                 $objects[] = $o;
             }
             return $objects;
         }
 	}
 }
 ?>