1 |
<? |
2 |
|
3 |
/* mnoGoSearch-db_func-php v.1.0 |
4 |
* free convenient API to database backends |
5 |
* (C) 1999,2000 by Sergey Kartashoff <gluke@biosys.net> |
6 |
* oracle7 support by Roman V. Petrov (poma@mail.ru) |
7 |
* |
8 |
* supports: MySQL , Oracle (both v7 and v8) and PostgreSQL |
9 |
* also supports connection through ODBC interface |
10 |
*/ |
11 |
|
12 |
// API: |
13 |
// ---- |
14 |
// db_init($dbtype,$dbname,$dbhost, |
15 |
// $dbuser,$dbpass,$dbport, |
16 |
// $dbodbc,$dbodbc_cursor_type) ; return nothing dbodbc can be 0 or 1 |
17 |
// db_numrows($res) ; return number of rown in result |
18 |
// db_query($query) ; return handle to result or false if error |
19 |
// db_fetchrow($res) ; return array with fetched row or false if error or end of rows |
20 |
// db_dataseek($res,$from) ; return true if success or false if error |
21 |
// db_freeresult($res) ; return nothing |
22 |
// db_error() ; return database error string |
23 |
|
24 |
// old function calls: |
25 |
// ------------------- |
26 |
// initdb() |
27 |
// query($query) |
28 |
// fetch_row($res) |
29 |
// db_data_seek($res,$from) |
30 |
// free_result($res) |
31 |
|
32 |
// ----------------------------------------------- |
33 |
// initdb() - OLD |
34 |
// ----------------------------------------------- |
35 |
function initdb(){ |
36 |
global $dbtype,$dbname,$dbhost,$dbuser,$dbpass,$dbport; |
37 |
global $dbodbc,$dbodbc_cursor_type; |
38 |
db_init($dbtype,$dbname,$dbhost,$dbuser,$dbpass,$dbport,$dbodbc,$dbodbc_cursor_type); |
39 |
} |
40 |
|
41 |
// ----------------------------------------------- |
42 |
// query($query) |
43 |
// ----------------------------------------------- |
44 |
function query($query) { |
45 |
return db_query($query); |
46 |
} |
47 |
|
48 |
// ----------------------------------------------- |
49 |
// fetch_row($res) |
50 |
// ----------------------------------------------- |
51 |
function fetch_row($res) { |
52 |
return db_fetchrow($res); |
53 |
} |
54 |
|
55 |
// ----------------------------------------------- |
56 |
// db_data_seek($res,$from) |
57 |
// ----------------------------------------------- |
58 |
function db_data_seek($res,$from) { |
59 |
return db_dataseek($res,$from); |
60 |
} |
61 |
|
62 |
// ----------------------------------------------- |
63 |
// free_result($res) |
64 |
// ----------------------------------------------- |
65 |
function free_result($res) { |
66 |
db_freeresult($res); |
67 |
} |
68 |
|
69 |
// ----------------------------------------------- |
70 |
// db_init($dbtype,$dbname,$dbhost,$dbuser,$dbpass,$dbport) |
71 |
// ----------------------------------------------- |
72 |
function db_init($dbtype,$dbname,$dbhost,$dbuser,$dbpass,$dbport,$dbodbc,$dbodbc_cursor_type){ |
73 |
global $dbconn; |
74 |
global $cur_row_array; |
75 |
global $num_rows_array; |
76 |
|
77 |
if ($dbodbc) { |
78 |
if ($dbodbc_cursor_type) { |
79 |
if (! $dbconn=odbc_pconnect($dbname,$dbuser,$dbpass,$dbodbc_cursor_type)) |
80 |
print_db_error("Cannot connect to odbc datasource $dbname as user $dbuser"); |
81 |
} else { |
82 |
if (! $dbconn=odbc_pconnect($dbname,$dbuser,$dbpass)) |
83 |
print_db_error("Cannot connect to odbc datasource $dbname as user $dbuser"); |
84 |
} |
85 |
} else { |
86 |
switch($dbtype) { |
87 |
case 'mysql': |
88 |
if (($dbhost == '') || ($dbhost == '_socket')) { |
89 |
if (!mysql_pconnect('',$dbuser,$dbpass)) |
90 |
print_db_error("Cannot connect to local mysql socket as user $dbuser"); |
91 |
} else { |
92 |
if ($dbport == '') { |
93 |
if (!mysql_pconnect($dbhost,$dbuser,$dbpass)) |
94 |
print_db_error("Cannot connect to mysql host $dbhost as user $dbuser"); |
95 |
} else { |
96 |
if (!mysql_pconnect("$dbhost:$dbport",$dbuser,$dbpass)) |
97 |
print_db_error("Cannot connect to mysql host $dbhost:$dbport as user $dbuser"); |
98 |
} |
99 |
} |
100 |
if (! mysql_select_db($dbname)) |
101 |
print_db_error("DB $dbname select error"); |
102 |
|
103 |
break; |
104 |
case 'oracle': |
105 |
case 'oracle8': |
106 |
if (! $dbconn=OCIPLogon($dbuser,$dbpass,$dbname)) |
107 |
print_db_error("Cannot connect to oracle db $dbname as user $dbuser"); |
108 |
|
109 |
break; |
110 |
case 'oracle7': |
111 |
if (! $dbconn=ora_plogon("$dbuser/$dbpass@$dbname","")) |
112 |
print_db_error("Cannot connect to oracle db $dbname as user $dbuser"); |
113 |
if (! $dbconn=ora_open($dbconn)) |
114 |
print_db_error("Cannot connect to oracle db $dbname as user $dbuser"); |
115 |
break; |
116 |
case 'pgsql': |
117 |
if (($dbhost == '') || ($dbhost == '_socket')) { |
118 |
if (! $dbconn=pg_pconnect("dbname=$dbname user=$dbuser password=$dbpass")) |
119 |
print_db_error("Cannot connect to local pgsql socket as user $dbuser"); |
120 |
} else { |
121 |
if ($dbport == '') { |
122 |
if (! $dbconn=pg_pconnect("dbname=$dbname host=$dbhost user=$dbuser password=$dbpass")) |
123 |
print_db_error("Cannot connect to pgsql host $dbhost as user $dbuser"); |
124 |
} else { |
125 |
if (! $dbconn=pg_pconnect("dbname=$dbname host=$dbhost port=$dbport user=$dbuser password=$dbpass")) |
126 |
print_db_error("Cannot connect to pgsql host $dbhost:$dbport as user $dbuser"); |
127 |
} |
128 |
} |
129 |
|
130 |
$cur_row_array = array(); |
131 |
$num_rows_array = array(); |
132 |
|
133 |
break; |
134 |
default: |
135 |
print_db_error("Unknown DBType: $dbtype"); |
136 |
} |
137 |
} |
138 |
} |
139 |
|
140 |
// ----------------------------------------------- |
141 |
// db_numrows($res) |
142 |
// ----------------------------------------------- |
143 |
function db_numrows($res) { |
144 |
global $dbtype; |
145 |
global $dbodbc; |
146 |
|
147 |
if ($dbodbc) { |
148 |
$rows=odbc_num_rows($res); |
149 |
} else { |
150 |
switch($dbtype) { |
151 |
case 'mysql': |
152 |
$rows=mysql_numrows($res); |
153 |
break; |
154 |
case 'pgsql': |
155 |
$rows=pg_numrows($res); |
156 |
break; |
157 |
default: |
158 |
print_db_error("Unknown DBType: $dbtype"); |
159 |
} |
160 |
} |
161 |
return($rows); |
162 |
} |
163 |
|
164 |
// ----------------------------------------------- |
165 |
// db_query($query) |
166 |
// ----------------------------------------------- |
167 |
function db_query($query) { |
168 |
global $dbtype; |
169 |
global $dbodbc; |
170 |
global $dbconn; |
171 |
global $cur_row_array; |
172 |
global $num_rows_array; |
173 |
|
174 |
if ($dbodbc) { |
175 |
$res=odbc_exec($dbconn,$query); |
176 |
} else { |
177 |
switch($dbtype) { |
178 |
case 'mysql': |
179 |
$res=mysql_query($query); |
180 |
break; |
181 |
case 'oracle': |
182 |
case 'oracle8': |
183 |
if (! $pres=OCIPArse($dbconn,$query)) return $pres; |
184 |
$res=OCIExecute($pres); |
185 |
if ($res) return ($pres); |
186 |
break; |
187 |
case 'oracle7': |
188 |
if (! $pres=ora_parse($dbconn, $query)) return $pres; |
189 |
$res=ora_exec($dbconn); |
190 |
if ($res) return ($pres); |
191 |
break; |
192 |
case 'pgsql': |
193 |
$res=pg_exec($dbconn,$query); |
194 |
$cur_row_array[$res]=0; |
195 |
$num_rows_array[$res]=db_numrows($res); |
196 |
break; |
197 |
default: |
198 |
print_db_error("Unknown DBType: $dbtype"); |
199 |
} |
200 |
} |
201 |
return($res); |
202 |
} |
203 |
|
204 |
// ----------------------------------------------- |
205 |
// db_fetchrow($res) |
206 |
// ----------------------------------------------- |
207 |
function db_fetchrow($res) { |
208 |
global $dbtype; |
209 |
global $dbodbc; |
210 |
global $dbconn; |
211 |
global $cur_row_array; |
212 |
global $num_rows_array; |
213 |
|
214 |
if ($dbodbc) { |
215 |
if (! odbc_fetch_into($res,&$row)) $row=array(); |
216 |
} else { |
217 |
switch($dbtype) { |
218 |
case 'mysql': |
219 |
$row=mysql_fetch_row($res); |
220 |
break; |
221 |
case 'oracle': |
222 |
case 'oracle8': |
223 |
$result=OCIFetchInto($res,&$row,OCI_NUM+OCI_RETURN_NULLS ); |
224 |
if (! $result) $row=array(); |
225 |
break; |
226 |
case 'oracle7': |
227 |
$result=ora_fetch($dbconn); |
228 |
$errno=ora_errorcode($dbconn); |
229 |
if(1403 == $errno || !$result) |
230 |
{ // 1043 means no more records found |
231 |
return array(); |
232 |
} |
233 |
|
234 |
for($ix=0;$ix<ora_numcols($dbconn);$ix++) |
235 |
{ |
236 |
$col=strtolower(ora_columnname($dbconn,$ix)); |
237 |
$value=ora_getcolumn($dbconn,$ix); |
238 |
$row[ "$col" ] = $value; |
239 |
$row[ $ix ] = $value; |
240 |
} |
241 |
break; |
242 |
case 'pgsql': |
243 |
if ($cur_row_array[$res] >= $num_rows_array[$res]) { |
244 |
$row=array(); |
245 |
} else { |
246 |
$row=pg_fetch_row($res,$cur_row_array[$res]); |
247 |
$cur_row_array[$res]++; |
248 |
} |
249 |
break; |
250 |
default: |
251 |
print_db_error("Unknown DBType: $dbtype"); |
252 |
} |
253 |
} |
254 |
return($row); |
255 |
} |
256 |
|
257 |
// ----------------------------------------------- |
258 |
// db_dataseek($res,$from) |
259 |
// ----------------------------------------------- |
260 |
function db_dataseek($res,$from) { |
261 |
global $dbtype; |
262 |
global $dbodbc; |
263 |
global $cur_row_array; |
264 |
|
265 |
if ($dbodbc) { |
266 |
$dataseek=1; |
267 |
for ($i=0; $i<$from; $i++) { |
268 |
$row=db_fetchrow($res); |
269 |
if (! $row) { |
270 |
$dataseek=0; |
271 |
break; |
272 |
} |
273 |
} |
274 |
} else { |
275 |
switch($dbtype) { |
276 |
case 'mysql': |
277 |
$dataseek=mysql_data_seek($res,$from); |
278 |
break; |
279 |
case 'oracle': |
280 |
case 'oracle8': |
281 |
case 'oracle7': |
282 |
$dataseek=1; |
283 |
for ($i=0; $i<$from; $i++) { |
284 |
$row=db_fetchrow($res); |
285 |
if (! $row) { |
286 |
$dataseek=0; |
287 |
break; |
288 |
} |
289 |
} |
290 |
break; |
291 |
case 'pgsql': |
292 |
$dataseek=1; |
293 |
$cur_row_array[$res]=$from; |
294 |
break; |
295 |
default: |
296 |
print_db_error("Unknown DBType: $dbtype"); |
297 |
} |
298 |
} |
299 |
return($dataseek); |
300 |
} |
301 |
|
302 |
// ----------------------------------------------- |
303 |
// db_freeresult($res) |
304 |
// ----------------------------------------------- |
305 |
function db_freeresult($res) { |
306 |
global $dbtype; |
307 |
global $dbodbc; |
308 |
|
309 |
if ($dbodbc) { |
310 |
odbc_free_result($res); |
311 |
} else { |
312 |
switch($dbtype) { |
313 |
case 'mysql': |
314 |
mysql_free_result($res); |
315 |
break; |
316 |
case 'oracle': |
317 |
case 'oracle8': |
318 |
OCIFreeStatement($res); |
319 |
break; |
320 |
case 'oracle7': |
321 |
break; |
322 |
case 'pgsql': |
323 |
pg_freeresult($res); |
324 |
break; |
325 |
default: |
326 |
print_db_error("Unknown DBType: $dbtype"); |
327 |
} |
328 |
} |
329 |
} |
330 |
|
331 |
// ----------------------------------------------- |
332 |
// db_error() |
333 |
// ----------------------------------------------- |
334 |
function db_error() { |
335 |
global $dbtype; |
336 |
global $dbodbc; |
337 |
global $dbconn; |
338 |
|
339 |
if ($dbodbc) { |
340 |
$error='ODBC error occured'; |
341 |
} else { |
342 |
switch($dbtype) { |
343 |
case 'mysql': |
344 |
$error=mysql_error(); |
345 |
break; |
346 |
case 'oracle': |
347 |
case 'oracle8': |
348 |
$error=OCIError(); |
349 |
break; |
350 |
case 'oracle7': |
351 |
$error=Ora_Error($dbconn); |
352 |
break; |
353 |
case 'pgsql': |
354 |
$error=pg_errormessage(); |
355 |
break; |
356 |
default: |
357 |
print_db_error("Unknown DBType: $dbtype"); |
358 |
} |
359 |
} |
360 |
return $error; |
361 |
} |
362 |
|
363 |
// ----------------------------------------------- |
364 |
// print_db_error($str) |
365 |
// ----------------------------------------------- |
366 |
function print_db_error($str){ |
367 |
print "$str\n"; |
368 |
exit; |
369 |
} |
370 |
|
371 |
?> |