<?php

require_once 'DatabaseConnector.php';

class TestDB extends DatabaseConnector {

	function sendMail($from, $subject, $msg) {
		$emailTo ="yourname@mail.nl";
		$email_info .= "This is a demo\n\n";
		$email_info .= "---------------------";
		$email_info .="Afzender: ".$from."\n";
		$email_info .= "Bericht: ".$msg."\n";
		$mailheaders = "From: ".$from."\n";
		$mailheaders .= "Reply-To: ".$from."\n\n";
		if(mail($emailTo, $subject, $email_info, $mailheaders)) {
			return true;
		} else {
			return false; 
		}
	}
	
	function retrieveAll() {
		$link = $this->getConnection();
		$query = sprintf("SELECT * FROM introAMF");
		$result = mysql_query($query, $link);
		return $result;
	}
	
	function addNew($login, $pass, $fname, $lname) {
		$link = $this->getConnection();
		$query = sprintf("INSERT INTO introAMF(username, password, fname, lname) VALUES ('".$login."', '".$pass."', '".$fname."', '".$lname."')");
		$result = mysql_query($query, $link);
		return $result;
	}
	
	function retrieveArray() {
		$rows = array();
		$link = $this->getConnection();
		$query = sprintf("SELECT * FROM introAMF");
		$result = mysql_query($query, $link);
		while($row = mysql_fetch_array($result, MYSQL_ASSOC)) {
			array_push($rows, $row);
		}
		return $rows;
	}
	
	function removeUser($user) {
		$link = $this->getConnection();
		$query = sprintf("DELETE FROM introAMF WHERE username='".$user."'");
		$result = mysql_query($query, $link);
		return $result;
	}
	
	function login($user, $pass)	{
		$link = $this->getConnection();
		$loggedIn = false;	
		$query = sprintf("SELECT * FROM introAMF WHERE username='%s' AND
			password='%s'", $user, $pass);
		
		$result = mysql_query($query, $link);
		if(mysql_num_rows($result) > 0) {
			$loggedIn = true;
		}
		return array('response' => $loggedIn);
	}
}
?>