-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathDb.php
138 lines (112 loc) · 3.42 KB
/
Db.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
127
128
129
130
131
132
133
134
135
136
137
138
<?php
/**
* Класс для работы с БД
*
* @category
* @package _Db
* @version 1.0
* @since File available since Release 1.0
*/
class Db_Db extends mysqli
{
/**
* Установка соединения с БД
*/
public function __construct($host, $user, $pass, $db, $port)
{
parent::__construct($host, $user, $pass, $db, $port);
if ($this->connect_errno) {
throw new Exception('Connect Error (' . $this->connect_errno . ') ' . $this->connect_error);
} else {
parent::query('SET NAMES cp1251');
}
}
/**
* Выполнение запроса к БД (приватный метод)
*/
private function _query($query)
{
return parent::query($query);
}
/**
* Выполнение запроса к БД (публичный метод)
*/
public function setQuery($query)
{
return $this->_query($query);
}
/**
* Выполнение запроса к БД с возвратом количества затронутых строк (публичный метод)
*/
public function setQueryAffectedRows($query)
{
$this->_query($query);
return $this->affected_rows;
}
/**
* Выполнение запроса к БД с возвратом сгенерированного ID (публичный метод)
*/
public function setQueryLastInsertId($query)
{
$this->_query($query);
return $this->insert_id;
}
/**
* Получение ID, сгенерированного при последнем INSERT-запросе.
*/
public function getLastInsertId()
{
return $this->insert_id;
}
/**
* Получение нумерованного массива данных результата выполнения запроса к БД
*/
public function getArray($query)
{
$data = array();
if ($result = $this->_query($query)) {
while ($row = $result->fetch_row()) {
array_push($data, $row);
}
$result->free();
}
return $data;
}
/**
* Получение ассоциативного массива данных результата выполнения запроса к БД
*/
public function getAssoc($query)
{
$data = array();
if ($result = $this->_query($query)) {
while ($row = $result->fetch_assoc()) {
array_push($data, $row);
}
$result->free();
}
return $data;
}
/**
* Получение первой записи нумерованного массива данных результата выполнения запроса к БД
*/
public function getArrayFirst($query)
{
if ($result = $this->_query($query)) {
return $result->fetch_row();
$result->free();
}
}
/**
* Получение первой записи ассоциативного массива данных результата выполнения запроса к БД
*
* @param string $query
* @return array
*/
public function getAssocFirst($query)
{
if ($result = $this->_query($query)) {
return $result->fetch_assoc();
$result->free();
}
}
}