59 lines
1.2 KiB
PHP
59 lines
1.2 KiB
PHP
<?php
|
|
|
|
class DatabaseAccess{
|
|
|
|
private $conn;
|
|
|
|
public function __construct(){
|
|
$this->conn = new DatabaseConnection();
|
|
$this->conn = $this->conn->getConnection();
|
|
}
|
|
|
|
public function query($query, $paramType = null, $params = array()){
|
|
if (mysqli_connect_errno()) {
|
|
die("Connection failed: " . $conn->connect_error);
|
|
}
|
|
|
|
$stmt = $this->conn->prepare($query);
|
|
|
|
if($paramType != null){
|
|
$stmt->bind_param($paramType, ...$params);
|
|
}
|
|
|
|
$runStmt = $stmt->execute();
|
|
if (!$runStmt) {
|
|
echo "Execute failed: (" . $stmt->errno . ") " . $stmt->error;
|
|
}else{
|
|
$method = explode(' ', $query)[0];
|
|
$result;
|
|
switch (strtoupper($method)) {
|
|
case "SELECT":
|
|
$result = $stmt->get_result();
|
|
//var_dump($result);
|
|
//$row = $result->fetch_array(MYSQLI_ASSOC);
|
|
//var_dump($row);
|
|
//echo "$row[lastName]";
|
|
break;
|
|
case 'UPDATE':
|
|
case "INSERT":
|
|
case 'DELETE':
|
|
$result = $stmt->affected_rows;
|
|
break;
|
|
}
|
|
$stmt->close();
|
|
//$this->conn->close();
|
|
return $result;
|
|
|
|
}
|
|
}
|
|
|
|
public function getInsertId(){
|
|
return mysqli_insert_id($this->conn);
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
?>
|