db.php

<?php

// AUTHOR: Lasse Pihlainen
// CREATED: 22.10.2017
// Edited: 23.10.2017, 20.12.2017, 27.2.2018, 17.11.2019
// LICENSE: BSD


class apidb /*extends SQLite3*/ {
	protected $dbpath;
	protected $table = '';
	private $createTable = 0;		// if new tables should be created
	protected $db;
	protected $DEBUG = 1;
	protected $date;
	protected $debuglines = array();

	public function __construct($arg = null) {
		if ($arg == null) {
			//$this->pe('no arg given');
			return;
		}
		$this->dbpath = dirname(__FILE__).'/'.$arg.'.db';
		$this->pi($this->dbpath);
		$this->date = date("H:i:s");
		$this->createDBConnection();
	}

	/**
	 * TODO: return false on fail.
	 */
	private function createDBConnection() {
		$this->db = null;
		if ($this->createTable != 1 && !file_exists($this->dbpath)) return;
		$this->db = new PDO("sqlite:$this->dbpath");
		$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
		return true;
	}

	public function printMessages() {
		print_r($this->debuglines);
	}

	# print errors
	public function pe($arg = null) {
		if ($arg == null || $this->DEBUG != 1) return;
		echo "[ERROR $this->date] ".$arg . PHP_EOL;
		$this->debuglines[] = "[ERROR $this->date] ".$arg. PHP_EOL;
	}

	# print info
	public function pi($arg = null) {
		if ($arg == null || $this->DEBUG != 1) return;
		echo "[INFO $this->date] ".$arg . PHP_EOL;
		$this->debuglines[] = "[INFO $this->date] ".$arg . PHP_EOL;
	}

	# debug print ARRAY
	public function pa($arg = null, $title = false) {
		if ($arg == null || $this->DEBUG != 1) return;
		echo "[ARRAY $this->date $title] ";
		print_r($arg);
		//echo "<br><br>\n";
		$this->debuglines[] = "[ARRAY $this->date $title] ".print_r($arg, true). PHP_EOL;
	}

	# create new database for our project
	private function createDB () {
		if ($this->createTable != 1) return;
		$this->pi("Creating Database for Korvamato");

		$sqlString = "CREATE VIRTUAL TABLE korvamadot using FTS4(NICK,PVM,QUOTE,INFO1,INFO2,CHANNEL,ARTIST,TITLE,LINK1,LINK2,DELETED);";
		$ret = 0;
		try {
			$ret = $this->db->exec($sqlString);
		} catch(PDOException $e) {
			$this->pe("PDO exception: ".$e->getMessage());
		} catch(Exception $e) {
			$this->pe("Exception: " .$e->getMessage());
		}
		return $ret;
	}

	public function disco() {
		$this->db = null;
	}

	# insert line into Database
	public function insertIntoDB($sqlString = null, $params = null) {
		if ($sqlString === null) return false;
		$this->pi(__FUNCTION__.": sqlString: " .$sqlString);
		try {
			if ($pdostmt = $this->db->prepare($sqlString)) {
				if ($pdostmt->execute($params)) {
					$this->db = null;
					//return $pdostmt->lastInsertRowID();
					return true;
				} else {
					$this->pe(__FUNCTION__.": ERROR.. $sqlString");
					#$this->pa($pdostmt);
				}
			} else {
				$this->pe(__FUNCTION__.": prepare statement error.");//: ".$pdostmt->errorInfo);
			}
		} catch(PDOException $e) {
			$this->pe(__FUNCTION__.": PDOException: ".print_r($e,1));
		} catch(EXCeption $e) {
			$this->pe(__FUNCTION__.": Exception: ".$e);
		}
		$this->db = null;
		return false;
	}

	public function getResultsFromDBQuery($querystr = null) {
		if ($querystr === null) return -1;
		
		//$this->db = new PDO("sqlite:$this->dbpath");
		try {
			if ($pdostmt = $this->db->prepare($querystr)) {
				if ($pdostmt->execute()) {
					$results = $pdostmt->fetchAll();
					$this->db = null;
					return $results;
				}
			}
			$this->pe("Prepare didn't match!");
		} catch(PDOException $e) {
			$this->pe("getResultsFromDBQuery: ".$e);
		} catch(Exception $e) {
			$this->pe("getResultsFromDBQuery: ".$e);
		}
		$this->db = null;
		return -2;
	}

	public function bindSQL($query = false, $params = false) {
		if ($query == false || $params == false) return false;
		$this->pi(__FUNCTION__.':'.__LINE__." bindSQL query: $query, dbpath: $this->dbpath");
		$this->pa($params, "bindSQL params");
		try {
			if ($pdostmt = $this->db->prepare($query)) {
				//$this->pa($pdostmt, "bindSQL pdostmt");
				if ($result = $pdostmt->execute($params)) {

					$this->pa($result, "bindSQL Result from query");
					return $result;
				}
				$this->pe("bindSQL DB execute erroor.");
				return false;
			}
			$this->pe("bindSQL DB prepare Erröör.");
			return false;
		} catch(PDOException $e) {
			$this->pe("bindSQL ".print_r($e,1));
		} catch(Exception $e) {
			$this->pe("bindSQL Exception: ".$e);
		}
		$this->pe("bindSQL failed..");
		return false;
	}

	public function getResultHandle($query = null) {
		if ($query === null) return false;
		$this->pi("getResultHandle, SQL query: $query");
		//$this->db = new PDO("sqlite:$this->dbpath");
		//$this->pa($this->db, "getResultHandle this->db");
		try {
			if ($pdostmt = $this->db->prepare($query)) {
				if ($line = $pdostmt->execute()) {
					//$this->pa($pdostmt, "getResultHandle Result from query, lines: $line");
					//$this->db = null;
					return $pdostmt;
				}
			}
			$this->pe("getResultHandle DB prepare Errör.");
		} catch(PDOException $e) {
			$this->pe("getResultHandle PDOException: ".$e);
		} catch(Exception $e) {
			$this->pe("getResultHandle Exception: ".$e);
		}
		$this->pe("getResultHandle error..");
		return false;
	}

	public function setDB($name = false) {
		if ($name === false) return false;
		$this->dbpath = dirname(__FILE__).'/'.$name.'.db';
		return $this->createDBConnection();
	}

	private function setTable($name = false) {
		if ($name === false) return false;
		// Sanity check
		if (preg_match("/^[a-zA-Z0-9_]*$/", $name)) {
			$this->table = $name;
		} else {
			return false;
		}
	}

	public function getMethod($string = false) {
		$sql = "SELECT rowid,* from $this->table";
	}

}
?>