<?php
	
	if($security_key != 'akz2TaXRfaZ4dAqEeugt') die(":(");
	
	/*
	 * Connect to DB
	 */
	class dbConnect extends config
	{	
		public $connection;
	
		public function connectDB()
		{
			$con = mysqli_connect($this->mysql_host, $this->mysql_user, $this->mysql_pass, $this->mysql_db);
			mysqli_set_charset($con,"utf8");
		    if($con) $this->connection = $con;
			else die('Could not connect to database!');
	   
		 	return $this->connection;
		}
	
		public function getDBLink()
		{
		    return $this->connection;
		}
	
		public function closeDB()
		{
		    mysqli_close($this->connection);
		}

		public function esc($escape)
		{
			return mysqli_real_escape_string($this->connection,$escape);
		}
	
		public function run($query, $return_as_array = true,$debug = false)
		{
			if($debug == true) echo $query."<br />";
		
			$data 	= array();
			$result = mysqli_query($this->connection, $query) or die( "Error:". mysqli_error($this->connection)." | Query : ". $query);	
				
			if(!$result) return null;
		
			while($row = mysqli_fetch_assoc($result)){
				array_push($data,$row);
		    }

			if($return_as_array == true) return $data;
			else return $data[0];
				
		}
	
		public function get($table,$column,$value,$return=null,$debug=false)
		{
			$r = $this->run("SELECT * FROM `$table` WHERE `$column` = '$value'",$debug);
		
			if($return != null) return $r[$return];
			else return $r;
		
		}
	
		public function insert($table,$columns,$values,$debug=false)
		{	
			$sql 	= "INSERT INTO $table (`".implode("`,`",$columns)."`) VALUES ('".implode("','",$values)."')";
			$query 	= mysqli_query($this->connection, $sql) or die( "Error:". mysqli_error($this->connection)." | Query : ". $query);	
		
			return mysqli_insert_id($this->connection);					
		}
	
		public function update($sql,$debug=false)
		{	
			if($debug == true) echo ">".$sql."<";
		
			$query 	= mysqli_query($this->connection, $sql) or die( "Error:". mysqli_error($this->connection)." | Query : ". $query);	
		
			return $query;					
		}

		public function dbInsert($table_name, $form_data,$test_query=false)
		{
		    // retrieve the keys of the array (column titles)
		    $fields = array_keys($form_data);

		    // build the query
		    $sql = "INSERT INTO ".$table_name."
		    (`".implode('`,`', $fields)."`)
		    VALUES ('".implode("','", $form_data)."')";
		
			if($test_query == true){
				echo $sql."<br />";
			}
			else{
				// run and return the query result resource
				$q = mysqli_query($this->connection, $sql) or die( "Error:". mysqli_error($this->connection)." | Query : ". $query);
				return mysqli_insert_id($this->connection);		
			}
		
					
		}
		
		public function dbUpdate($table_name,$update_column,$update_id,$post_data)
		{
	
			array_walk($post_data, create_function('&$i,$k','$i=" `$k` = \'$i\'";'));
			$values = implode($post_data,", ");
		    $sql 	= "UPDATE ". $table_name ." SET $values WHERE `klant_id` = ". $_SESSION['user_id'];
			
			$q = mysqli_query($this->connection, $sql) or die( "Error:". mysqli_error($this->connection)." | Query : ". $query);
			return mysqli_insert_id($this->connection);	
		}
			
	
		public function rowCount($sql){
		
			$query 	= mysqli_query($this->connection, $sql) or die( "Error:". mysqli_error($this->connection)." | Query : ". $sql);	
			return mysqli_num_rows($query);
		
		}
	
		public function getQueryLimit($view_page)
		{
			$start 			= ($view_page-1)*$this->items_per_page;
			$limit_query	= ($this->items_per_page != null) ? " LIMIT $start,$this->items_per_page" : null;
			return $limit_query;
		}
		
	
	}

	
	
?>