Библиотека работы с MySql

Решил поделиться своими наработками в части работы с базой данных mySql с применением языка PHP.

Сразу оговорюсь, объектно-ориентированных подход в данном случае не используется, все написано не в плане максимально приближения к идеалу, а в плане максимального упрощения программирования.

Дополнительными плюсами использования данной библиотеки являются:
- В глобальной переменной $sql_time всегда хранится время выполнения всех sql запросов
- При установке значения $debug[error] = true; на экран выводятся все ошибки исполнения запросов
- При установке значения $debug[sql] = true; на экран выводятся все выполняемые запросы + время на выполнения каждого

Минусы тоже присутствуют:
- Во всех текстовых полях нельзя использовать знак #, удаляем, заменяем, но быть его не должно
- Если в таблице нет auto_increment поля insertTable вернет 0

И еще один минус, через месяц работы с этой библиотекой вы забудете как на самом деле по шагам должны были работать с mySql, я к примеру уже не помню

Подключение к базе данных, не мучайте себя безумными кусками кода, которые приходиться постоянно вставлять в различные файлы:

Код (Text):

1.  
2. $dbh = @mysql_connect($mysql_host, $mysql_user, $mysql_pass);
3.  
4. if (!@mysql_select_db($mysql_database, $dbh)) {
5.      errorLog("Mysql server $mysql_host may be down\n", "error.fatal.log");
6.     @mysql_close($dbh);
7.      exit();
8. }
9. execSql("SET NAMES 'cp1251';");
10. register_shutdown_function(exitDb);

при использовании библиотеки:

Код (Text):

1. connectMysql($mysql_database, $mysql_host, $mysql_user, $mysql_pass);

Далее очень часто нам необходимо получить всего одну строку:

Код (Text):

1. $sql     = "SELECT * FROM table WHERE key='some' LIMIT 0,1";
2. $result = mysql_query($sql);
3. $part = fetchArray($result);

При использовании библиотеки:

Код (Text):

1.  
2. $part = getOneRow("table", "key='some'");

Получение количества строк

Код (Text):

1.  
2. $sql     = "SELECT COUNT(*) as numRows FROM table WHERE key='some'";
3. $result = mysql_query($sql);
4. $part = fetchArray($result);
5. $numRows = $part[numRows]; 

С использованием библиотеки:

Код (Text):

1.  
2. $numRows = getNumRows ("table", "key='some'");

Вставляем новые строки в базу данных

Код (Text):

1.  
2. $sql = "INSERT INTO table (field1, field2) values ('value1', 'value2')";
3. $result = mysql_query($sql);
4. $lastId = mysql_insert_id();   

С использованием библиотеки:

Код (Text):

1.  
2. $lastId = insertTable("table", "", "field1# field2", "$value1# $value2");

Обновляем строки в базе данных

Код (Text):

1.  
2. $sql = "UPDATE table SET field1='value1', field2='value2' WHERE key='some'";
3. $result = mysql_query($sql);
4. $numRows = mysql_affected_rows (); 

С использованием библиотеки:

Код (Text):

1.  
2. $numRows = insertTable("table", "", "field1# field2", "$value1# $value2");

Бывают ситуации, когда мы неуверенны, есть ли в базе данных данная запись, но сохранить данные необходимо

Код (Text):

1.  
2. If (getNumRows("table", "where")) {
3.    updateTable("table", "where", "fields", "values");
4. } else {
5.    insertTable("table", "", "fields", "values");
6. }  

Код (Text):

1.  
2. $numRows = modifyTable("table", "key='some'", "field1# field2", "$value1# $value2");

Вот собственно и все, вопросы комментарии?

 

Собственно сама библиотека

PHP:

1.  
2. <?
3. // ===========================================================================================================
4. // SQL Class
5. // VER. 10.0.0.0
6. //
7. // Developed by Miftahov Nariman.
8. // [url=http://vseznaut.ru/]http://vseznaut.ru/[/url]
9. // [email=miftahovn@gmail.com]miftahovn@gmail.com[/email]
10. // ===========================================================================================================
11.  
12. // Подключение к базе данных
13. // ===============================================================================
14. function connectMysql($mysql_database, $mysql_host, $mysql_user, $mysql_pass) {
15.     global $dbh;
16.  
17.     $dbh = @mysql_connect($mysql_host, $mysql_user, $mysql_pass);
18.  
19.     if (!@mysql_select_db($mysql_database, $dbh)) {
20.         errorLog("Mysql server $mysql_host may be down\n", "error.fatal.log");
21.         @mysql_close($dbh);
22.         exit();
23.     }
24.     execSql("SET NAMES 'cp1251';");
25.     register_shutdown_function(exitDb);
26. }
27.  
28.  
29. // Функция завершения связи с Mysql. Вызывается тихо, но всегда
30. // ===============================================================================
31. function exitDb() {
32.     global $dbh;
33.  
34.     flush();
35.     @mysql_close($dbh);
36. }
37.  
38.  
39. // Получаем результат запроса
40. // ===============================================================================
41. function getResults($table, $where="1") {
42.  
43.     $sql = "SELECT * FROM ".$table." WHERE ".$where;
44.     return execSql($sql);
45. }
46.  
47. // Здесь должны выполнятся все SQL выражения!
48. // ==========================================
49. function execSql($sql) {
50.     global $_SESSION, $sql_time, $debug;
51.  
52.     // =======================================
53.     $this_time = getmicrotime();
54.  
55.     if ($result=@mysql_query($sql)) {
56.  
57.         $end_time   = getmicrotime();
58.         $spent_time = $end_time - $this_time;
59.         $sql_time  += $spent_time;
60.  
61.         if ($debug[sql]) {  
62.             echo sprintf("%01.2f", $spent_time)." + ";
63.             echo $sql."<br>";
64.         }
65.         return $result;
66.  
67.     } else {
68.         if ($debug[error]) {  
69.             echo substr($sql, 0, 5000);
70.             echo "<br>".mysql_errno().": ".mysql_error();
71.         }
72.         return false;
73.     }
74. }
75.  
76. // Fetch // Согласен некрасиво, но длинное выражение запомнить не удается -)
77. // ===============================================================================
78. function fetchArray($result) {
79.     return mysql_fetch_array($result);
80. }
81.  
82.  
83. // Получаем одну строку
84. //================================================================================
85. function getOneRow($table, $where) {
86.        
87.     if (!eregi("LIMIT", $where)) {
88.         $where .= " LIMIT 0, 1";
89.     }
90.  
91.     if ($result = getResults($table, $where)) {
92.         if ($fetch = fetchArray($result)) {
93.             return $fetch;
94.         }
95.     }
96.     return false;
97. }
98.  
99. // Получаем количество строк
100. // ===============================================================================
101. function getNumRows($table, $where) {
102.     $sql = "SELECT COUNT(*) as numRows FROM $table WHERE $where";
103.     return mysql_result(execSql($sql), 0, 0);
104. }
105.  
106. // Удаление из таблицы
107. // ===============================================================================
108. function deleteFrom($table, $where) {
109.  
110.     $sql = "DELETE FROM ".$table." WHERE ".$where;
111.  
112.     if (execSql($sql)) {
113.         return mysql_affected_rows();
114.     } else {
115.         return false;
116.     }
117. }
118.  
119. // InsertTable // Поля fields и $values должны быть представлены в виде "test1# test2# test3"
120. // ==========================================================================================
121. function insertTable($table, $where, $fields, $values) {
122.     $fields = explode("# ", $fields);
123.     $values = explode("# ", $values);
124.  
125.     while (list($key, $field) = each($fields)) {   
126.         if ($field_list) $field_list .= ", ";
127.         $field_list .= $field;
128.     }
129.     while (list($key, $value) = each($values)) {   
130.         if ($value_list) $value_list .= ", ";
131.         $value_list .= "'$value'";
132.     }
133.        
134.     $sql =  "INSERT INTO ".$table." (".$field_list.") values (".$value_list.")";
135.  
136.     // Возвращает последний индекс вставки
137.     // ===================================
138.     if (execSql($sql)) {
139.         return mysql_insert_id();
140.     } else {
141.         return false;
142.     }
143. }
144.  
145. // Update table // Поля fields и $values должны быть представлены в виде "test1# test2# test3"
146. // ===========================================================================================
147. function updateTable($table, $where, $fields, $values) {
148.     $fields = explode("# ", $fields);
149.     $values = explode("# ", $values);
150.  
151.     if (!fill($where)) {
152.         return false;
153.     }
154.  
155.     while (list($key, $field) = each($fields)) {   
156.  
157.         list($key, $value) = each($values);
158.  
159.         if ($set)
160.             $set .= ", ";
161.        
162.         // Если знак @ то не ставим кавычки для SET on=on+1
163.         // ------------------------------------------------
164.         if (substr($value, 0, 1) == "@") {
165.             $set .= "$field=".substr($value, 1, 128);
166.         } else {
167.             $set .= "$field='$value'";
168.         }
169.  
170.     }
171.     $sql =  "UPDATE ".$table." SET ".$set." WHERE ".$where;
172.  
173.     // Возвращает число затронутых строк
174.     // =================================
175.     if (execSql($sql)) {
176.         return mysql_affected_rows();
177.     } else {
178.         return false;
179.     }
180. }
181.  
182.  
183. // Insert OR Update
184. //===============================================================================
185. function modifyTable($table, $where, $fields, $values) {
186.  
187.     // Получаем результат
188.     // -------------------------------------
189.     if ($where) {
190.         $num = getNumRows($table, $where);
191.     }
192.  
193.     if ($num) {
194.         return  updateTable($table, $where, $fields, $values);
195.  
196.     } else {
197.         return  insertTable($table, $where, $fields, $values); 
198.  
199.     }
200. }
201.  
202. ?>
203.  

 

Что значит унифицировать обработку данных? Лично для меня стоит задача, как можно более упростить написание кода, а уже затем унификация, рационализация и другое.

Какие именно запросы лишние? Что именно криво? PS: Слово "постеснялся" пишется через "н"

Код (Text):

1. if (substr($value, 0, 1) == "@") {
2.   $set .= "$field=".substr($value, 1, 128);
3. } else {
4.   $set .= "$field='$value'";
5. }

Есть два варианта работы с updateTable()
1.

Код (Text):

1.  
2. updateTable("table", "where", "summ# count", "1# 2");
3. В итоге выполнит запрос вида:
4. UPDATE table SET summ='1', count='2' WHERE where

2.

Код (Text):

1.  
2. updateTable("table", "where", "summ# count", "1# @count+1");
3. В итоге выполнит запрос вида:
4. UPDATE table SET summ='1', count=count+1 WHERE where

 

Можно, но тогда сам процесс написания запроса усложняется на порядок ...

PS: Две функции которые используются в библиотеке, но в её текст не вошли:

PHP:

1.  
2. <?
3.     $ROOT     = $_SERVER["DOCUMENT_ROOT"]."/";
4.  
5.     function errorLog($string, $location) {
6.         global $ROOT;
7.  
8.         $string     = date("H:i:s d-m-Y")." | ".$string."\n";
9.         $location   = $ROOT.".temp/logs/".$location;
10.  
11.         error_log($string, 3, $location);
12.         echo $string."<br>";
13.  
14.         return true;
15.     }
16.  
17.     function getmicrotime() {
18.         list($usec, $sec) = explode(" ", microtime());
19.             return ((float)$usec + (float)$sec);
20.     }
21. ?>
22.  

[/php]

 

Что значит добавление в таблицу клиентов и товаров единообразно, пример?
Если имеется ввиду возможность каскадного обновления нескольких таблиц применительно к свойствам, собираемой статистике объектов, то это совершенно другой разговор пишите классы, наследуйте их, описывайте свойства объектов в виде свойств класса и будет необходимый результат.

Здесь же я представил пример библиотеки, которая является промежуточным звеном к mySql, и не берет на себя никаких функций касающихся представлению данных.

 

И много у Вас Олег программеров своих которым вы отрываете руки?

Мифтахов Нариман,
Павлодар Казахстан, Телецентр, ул. Павлова.

Вы можете говорить и писать все что угодно, но я поверю в это только тогда, когда Вы мне покажете свои проекты.
К примеру мой сайт http://students.tomsk.ru 5500 хостов 360000 хитов в сутки http://tbe.tom.ru/date/2007-7-23
55 000 пользователей и 28 миллионов записей в таблицах.

Еще раз говорю эта библиотека просто работает, и упрощает жизнь, хотите использовать всю мощь SQL пользуйтесь полными запросами...

 

насмешил, если уж тут PHP клуб, то мерятся именно веб-проектами,
я тоже могу сделать COUNT всех таблиц в рабочей базе данных MS Axapta, хранимых в Oracle
но те таблицы далеко не моих рук дело... пусть за них будет весело и радостно NAVISION и Microsoft ...