-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathdatabase.php
126 lines (104 loc) · 3.08 KB
/
database.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
<?php
class database{
private $host;
private $dbusername;
private $dbpassword;
private $dbname;
protected function connect(){
$this->host='localhost';
$this->dbusername='root';
$this->dbpassword='';
$this->dbname='crud';
$con=new mysqli($this->host,$this->dbusername,$this->dbpassword,$this->dbname);
return $con;
}
}
class query extends database{
public function getData ($table, $field='*', $condition_arr='', $order_by_field='', $order_by_type='desc', $limit=''){
$sql="select $field from $table ";
if($condition_arr!=''){
$sql.=' where ';
$c=count($condition_arr);
$i=1;
foreach($condition_arr as $key=>$val){
if($i==$c){
$sql.="$key='$val'";
}
else{
$sql.="$key='$val' and ";
}
$i++;
}
}
if($order_by_field!=''){
$sql.=" order by $order_by_field $order_by_type ";
}
if($limit!=''){
$sql.=" limit $limit ";
}
$result=$this->connect()->query($sql);
if($result->num_rows>0){
$arr=array();
while($row=$result->fetch_assoc()){
$arr[]=$row;
}
return $arr;
} else{
return 0;
}
}
public function insertData ($table, $condition_arr){
if($condition_arr!=''){
foreach($condition_arr as $key=>$val){
$fieldArr[]=$key;
$valueArr[]=$val;
}
$field=implode(",",$fieldArr);
$value=implode("','",$valueArr);
$value="'".$value."'";
$sql="insert into $table($field) values($value) ";
$result=$this->connect()->query($sql);
}
}
public function deleteData ($table, $condition_arr){
if($condition_arr!=''){
$sql="delete from $table where ";
$c=count($condition_arr);
$i=1;
foreach($condition_arr as $key=>$val){
if($i==$c){
$sql.="$key='$val'";
}
else{
$sql.="$key='$val' and ";
}
$i++;
}
$result=$this->connect()->query($sql);
}
}
public function updateData ($table, $condition_arr, $where_field, $where_value){
if($condition_arr!=''){
$sql="update $table set ";
$c=count($condition_arr);
$i=1;
foreach($condition_arr as $key=>$val){
if($i==$c){
$sql.="$key='$val'";
}
else{
$sql.="$key='$val', ";
}
$i++;
}
$sql.=" where $where_field='$where_value' ";
$result=$this->connect()->query($sql);
}
}
public function get_safe_str($str){
if($str!=''){
return mysqli_real_escape_string($this->connect(),$str);
}
}
}
?>