<?php
class BaseModel {
protected $conn;
public function __construct()
{
$servername = "localhost";
$username = "root";
$password = "";
$this->conn = mysqli_connect($servername,$username,$password);
if($this->conn->connect_error)
{
die("Connection failed: ".$this->conn->connect_error);
}
mysqli_select_db($this->conn,"crud") or die("error to select db");
}
private function query($sql)
{
return mysqli_query($this->conn, $sql);
}
public function insert_by_tbl($table_name, $arr_data = array())
{
$arr_sql_field = array_keys($arr_data);
$arr_sql_val = array_values($arr_data);
$sql = "INSERT INTO ".$table_name." (".implode(",",$arr_sql_field).") VALUES('".$arr_sql_val."')";
$this->query($sql);
}
public function update_by_tbl($table_name, $arr_data = array(), $wh_query)
{
$arr_sql_set = array();
foreach($arr_data as $field_name=>$field_val)
{
$arr_sql_set[] = $field_name."=".$field_val;
}
$sql = "UPDATE ".$table_name." SET ".implode(",",$arr_sql_set)." WHERE 1 AND ".$wh_query;
return $this->query($sql);
}
public function get_by_tbl($table_name, $wh_query="" , $select_field = "*")
{
$sql = "SELECT ".$select_field." FROM ".$table_name." WHERE 1 ";
if(!empty($wh_query))
{
$sql .= $wh_query;
}
$res = $this->query($sql);
return $arr_data = mysqli_fetch_all($res,MYSQLI_ASSOC);
while($row = mysqli_fetch_assoc($res))
{
$arr_data[] = $row;
}
return $arr_data;
}
}
======================================
<?php
require_once(__DIR__."/BaseModel.php");
class ContactModel Extends BaseModel{
public function get()
{
return parent::get_by_tbl("tbl_contact");
}
}
class BaseModel {
protected $conn;
public function __construct()
{
$servername = "localhost";
$username = "root";
$password = "";
$this->conn = mysqli_connect($servername,$username,$password);
if($this->conn->connect_error)
{
die("Connection failed: ".$this->conn->connect_error);
}
mysqli_select_db($this->conn,"crud") or die("error to select db");
}
private function query($sql)
{
return mysqli_query($this->conn, $sql);
}
public function insert_by_tbl($table_name, $arr_data = array())
{
$arr_sql_field = array_keys($arr_data);
$arr_sql_val = array_values($arr_data);
$sql = "INSERT INTO ".$table_name." (".implode(",",$arr_sql_field).") VALUES('".$arr_sql_val."')";
$this->query($sql);
}
public function update_by_tbl($table_name, $arr_data = array(), $wh_query)
{
$arr_sql_set = array();
foreach($arr_data as $field_name=>$field_val)
{
$arr_sql_set[] = $field_name."=".$field_val;
}
$sql = "UPDATE ".$table_name." SET ".implode(",",$arr_sql_set)." WHERE 1 AND ".$wh_query;
return $this->query($sql);
}
public function get_by_tbl($table_name, $wh_query="" , $select_field = "*")
{
$sql = "SELECT ".$select_field." FROM ".$table_name." WHERE 1 ";
if(!empty($wh_query))
{
$sql .= $wh_query;
}
$res = $this->query($sql);
return $arr_data = mysqli_fetch_all($res,MYSQLI_ASSOC);
while($row = mysqli_fetch_assoc($res))
{
$arr_data[] = $row;
}
return $arr_data;
}
}
======================================
<?php
require_once(__DIR__."/BaseModel.php");
class ContactModel Extends BaseModel{
public function get()
{
return parent::get_by_tbl("tbl_contact");
}
}
==========================================
<?php
$action = !empty($_GET["action"]) ? $_GET["action"] : "list";
$pk = !empty($_GET["pk"]) ? $_GET["pk"] : "";
require_once(__DIR__."/Model/ContactModel.php");
$obj_contact = new ContactModel();
if($action == "list")
{
$contact_res = $obj_contact->get();
echo "<pre>";
print_r($contact_res);
}
No comments:
Post a Comment