![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to TinderboxDS.php CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [Paefchen] / FreeBSD / tinderbox / webui / core|
Return to TinderboxDS.php CVS log | Up to [Paefchen] / FreeBSD / tinderbox / webui / core |
1.1 as 1: <?php
2: #-
3: # Copyright (c) 2004-2005 FreeBSD GNOME Team <freebsd-gnome@FreeBSD.org>
4: # All rights reserved.
5: #
6: # Redistribution and use in source and binary forms, with or without
7: # modification, are permitted provided that the following conditions
8: # are met:
9: # 1. Redistributions of source code must retain the above copyright
10: # notice, this list of conditions and the following disclaimer.
11: # 2. Redistributions in binary form must reproduce the above copyright
12: # notice, this list of conditions and the following disclaimer in the
13: # documentation and/or other materials provided with the distribution.
14: #
15: # THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
16: # ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
17: # IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
18: # ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
19: # FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
20: # DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
21: # OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
22: # HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
23: # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
24: # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
25: # SUCH DAMAGE.
26: #
27: # $MCom: portstools/tinderbox/webui/core/TinderboxDS.php,v 1.36 2007/10/13 02:28:47 ade Exp $
28: #
29:
30: require_once 'DB.php';
31: require_once 'Build.php';
32: require_once 'BuildPortsQueue.php';
33: require_once 'Config.php';
34: require_once 'Jail.php';
35: require_once 'Port.php';
36: require_once 'PortsTree.php';
37: require_once 'PortFailReason.php';
38: require_once 'User.php';
39: require_once 'inc_ds.php';
40: require_once 'inc_tinderbox.php';
41:
42: $objectMap = array(
43: "Build" => "builds",
44: "BuildPortsQueue" => "build_ports_queue",
45: "Config" => "config",
46: "Jail" => "jails",
47: "Port" => "ports",
48: "PortsTree" => "ports_trees",
49: "PortFailReason" => "port_fail_reasons",
50: "User" => "users",
51: );
52:
53: class TinderboxDS {
54: var $db;
55: var $error;
56: var $packageSuffixCache; /* in use by getPackageSuffix() */
57:
58: function TinderboxDS() {
59: global $DB_HOST, $DB_DRIVER, $DB_NAME, $DB_USER, $DB_PASS;
60:
61: # XXX: backwards compatibility
62: if ($DB_DRIVER == "")
63: $DB_DRIVER = "mysql";
64:
65: $dsn = "$DB_DRIVER://$DB_USER:$DB_PASS@$DB_HOST/$DB_NAME";
66:
67: $this->db = DB::connect($dsn);
68:
69: if (DB::isError($this->db)) {
70: die ("Tinderbox DS: Unable to initialize datastore: " . $this->db->getMessage() . "\n");
71: }
72:
73: $this->db->setFetchMode(DB_FETCHMODE_ASSOC);
74: $this->db->setOption('persistent', true);
75: }
76:
77: function start_transaction() {
78: $this->db->autoCommit( false );
79: }
80:
81: function commit_transaction() {
82: $this->db->commit();
83: $this->db->autoCommit( true );
84: }
85:
86: function rollback_transaction() {
87: $this->db->rollback();
88: $this->db->autoCommit( true );
89: }
90:
91: function getAllMaintainers() {
92: $query = "SELECT DISTINCT LOWER(port_maintainer) AS port_maintainer FROM ports where port_maintainer IS NOT NULL ORDER BY LOWER(port_maintainer)";
93: $rc = $this->_doQueryHashRef($query, $results, array());
94:
95: if (!$rc) {
96: return array();
97: }
98:
99: foreach($results as $result)
100: $data[]=$result['port_maintainer'];
101:
102: return $data;
103: }
104:
105: function getAllPortsByPortID($portid) {
106: $query = "SELECT p.*,
107: bp.build_id,
108: bp.last_built,
109: bp.last_status,
110: bp.last_successful_built,
111: bp.last_failed_dependency,
112: bp.last_run_duration,
113: bp.last_built_version,
114: CASE bp.last_fail_reason
115: WHEN '__nofail__' THEN ''
116: ELSE bp.last_fail_reason
117: END
118: AS last_fail_reason
119: FROM ports p,
120: build_ports bp
121: WHERE p.port_id = bp.port_id
122: AND bp.port_id=$portid";
123:
124: $rc = $this->_doQueryHashRef($query, $results, array());
125:
126: if (!$rc) {
127: return null;
128: }
129:
130: $ports = $this->_newFromArray("Port", $results);
131:
132: return $ports;
133: }
134:
135:
136: function addUser($user) {
137: $query = "INSERT INTO users
138: (user_name,user_email,user_password,user_www_enabled)
139: VALUES
140: (?,?,?,?)";
141:
142: $rc = $this->_doQuery($query, array($user->getName(),$user->getEmail(),$user->getPassword(),$user->getWwwEnabled()),$res);
143:
144: if (!$rc) {
145: return false;
146: }
147:
148: return true;
149: }
150:
151: function deleteUser($user) {
152: if( !$user->getId() || $this->deleteUserPermissions($user,'') ) {
153: if ($user->getId()) {
154: $this->deleteBuildPortsQueueByUserId($user);
155: }
156: $query = "DELETE FROM users
157: WHERE user_name=?";
158:
159: $rc = $this->_doQuery($query, array($user->getName()),$res);
160:
161: if (!$rc) {
162: return false;
163: }
164:
165: return true;
166: }
167: return false;
168: }
169:
170: function updateUser($user) {
171: $query = "UPDATE users
172: SET user_name=?,user_email=?,user_password=?,user_www_enabled=?
173: WHERE user_id=?";
174:
175: $rc = $this->_doQuery($query, array($user->getName(),$user->getEmail(),$user->getPassword(),$user->getWwwEnabled(),$user->getId()),$res);
176:
177: if (!$rc) {
178: return false;
179: }
180:
181: return true;
182: }
183:
184: function getUserByLogin($username,$password) {
185: $hashPass = md5($password);
186: $query = "SELECT user_id,user_name,user_email,user_password,user_www_enabled FROM users WHERE user_name=? AND user_password=?";
187: $rc = $this->_doQueryHashRef($query, $results, array($username,$hashPass));
188:
189: if (!$rc) {
190: return null;
191: }
192:
193: $user = $this->_newFromArray("User", $results);
194:
195: return $user[0];
196: }
197:
198: function getUserPermissions($user_id,$object_type,$object_id) {
199:
200: $query = "
201: SELECT
202: CASE user_permission
203: WHEN 1 THEN 'IS_WWW_ADMIN'
204: WHEN 2 THEN 'PERM_ADD_QUEUE'
205: WHEN 3 THEN 'PERM_MODIFY_OWN_QUEUE'
206: WHEN 4 THEN 'PERM_DELETE_OWN_QUEUE'
207: WHEN 5 THEN 'PERM_PRIO_LOWER_5'
208: WHEN 6 THEN 'PERM_MODIFY_OTHER_QUEUE'
209: WHEN 7 THEN 'PERM_DELETE_OTHER_QUEUE'
210: ELSE 'PERM_UNKNOWN'
211: END
212: AS user_permission
213: FROM user_permissions
214: WHERE user_id=?
215: AND user_permission_object_type=?
216: AND user_permission_object_id=?";
217:
218: $rc = $this->_doQueryHashRef($query, $results, array($user_id,$object_type,$object_id));
219:
220: if (!$rc) {
221: return null;
222: }
223:
224: return $results;
225: }
226:
227: function deleteUserPermissions($user, $object_type) {
228:
229: $query = "
230: DELETE FROM user_permissions
231: WHERE user_id=?";
232:
233: if( $object_type )
234: $query .= " AND user_permission_object_type='$object_type'";
235:
236: $rc = $this->_doQuery($query, array($user->getId()), $res);
237:
238: if (!$rc) {
239: return false;
240: }
241:
242: return true;
243: }
244:
245: function addUserPermission($user_id,$object_type,$object_id,$permission) {
246:
247: switch( $permission ) {
248: // case 'IS_WWW_ADMIN': $permission = 1; break; /* only configureable via shell */
249: case 'PERM_ADD_QUEUE': $permission = 2; break;
250: case 'PERM_MODIFY_OWN_QUEUE': $permission = 3; break;
251: case 'PERM_DELETE_OWN_QUEUE': $permission = 4; break;
252: case 'PERM_PRIO_LOWER_5': $permission = 5; break;
253: case 'PERM_MODIFY_OTHER_QUEUE': $permission = 6; break;
254: case 'PERM_DELETE_OTHER_QUEUE': $permission = 7; break;
255: default: return false;
256: }
257:
258: $query = "
259: INSERT INTO user_permissions
260: (user_id,user_permission_object_type,user_permission_object_id,user_permission)
261: VALUES
262: (?,?,?,?)";
263:
264: $rc = $this->_doQuery($query, array($user_id,$object_type,$object_id,$permission), $res);
265:
266: if (!$rc) {
267: return false;
268: }
269:
270: return true;
271: }
272:
273: function getBuildPortsQueueEntries($build_id) {
274: $query = "SELECT build_ports_queue.*, builds.build_name AS build_name, users.user_name AS user_name
275: FROM build_ports_queue, builds, users
276: WHERE build_ports_queue.build_id=?
277: AND builds.build_id = build_ports_queue.build_id
278: AND users.user_id = build_ports_queue.user_id
279: ORDER BY priority ASC, build_ports_queue_id ASC";
280: $rc = $this->_doQueryHashRef($query, $results, array($build_id));
281:
282: if (!$rc) {
283: return null;
284: }
285:
286: $build_ports_queue_entries = $this->_newFromArray("BuildPortsQueue", $results);
287:
288: return $build_ports_queue_entries;
289: }
290:
291: function deleteBuildPortsQueueEntry($entry_id) {
292: $query = "DELETE FROM build_ports_queue
293: WHERE build_ports_queue_id=?";
294:
295: $rc = $this->_doQuery($query, $entry_id, $res);
296:
297: if (!$rc) {
298: return false;
299: }
300:
301: return true;
302: }
303:
304: function deleteBuildPortsQueueByUserId($user) {
305: $query = "DELETE FROM build_ports_queue
306: WHERE user_id=?";
307:
308: $rc = $this->_doQuery($query, $user->getId(), $res);
309:
310: if (!$rc) {
311: return false;
312: }
313:
314: return true;
315: }
316:
317: function createBuildPortsQueueEntry($build_id,$priority,$port_directory,$user_id,$email_on_completion) {
318: switch( $email_on_completion ) {
319: case '1': $email_on_completion = 1; break;
320: default: $email_on_completion = 0; break;
321: }
322:
323: $entries[] = array('build_id' => $build_id,
324: 'priority' => $priority,
325: 'port_directory' => $port_directory,
326: 'user_id' => $user_id,
327: 'enqueue_date' => date("Y-m-d H:i:s", time()),
328: 'email_on_completion' => $email_on_completion,
329: 'status' => 'ENQUEUED');
330:
331: $results = $this->_newFromArray("BuildPortsQueue",$entries);
332:
333: return $results[0];
334: }
335:
336: function updateBuildPortsQueueEntry($entry) {
337:
338: $query = "UPDATE build_ports_queue
339: SET build_id=?, priority=?, email_on_completion=?, status=?
340: WHERE build_ports_queue_id=?";
341:
342: $rc = $this->_doQuery($query, array($entry->getBuildId(),$entry->getPriority(),$entry->getEmailOnCompletion(),$entry->getStatus(),$entry->getId()), $res);
343:
344: if (!$rc) {
345: return false;
346: }
347:
348: return true;
349: }
350:
351: function addBuildPortsQueueEntry($entry) {
352: $query = "INSERT INTO build_ports_queue
353: (enqueue_date,build_id,priority,port_directory,user_id,email_on_completion,status)
354: VALUES
355: (?,?,?,?,?,?,?)";
356:
357: $rc = $this->_doQuery($query, array($entry->getEnqueueDate(),$entry->getBuildId(),$entry->getPriority(),$entry->getPortDirectory(),$entry->getUserId(),$entry->getEmailOnCompletion(),$entry->getStatus()), $res);
358:
359: if (!$rc) {
360: return false;
361: }
362:
363: return true;
364: }
365:
366: function getBuildPortsQueueEntryById($id) {
367: $results = $this->getBuildPortsQueue(array( 'build_ports_queue_id' => $id ));
368:
369: if (is_null($results)) {
370: return null;
371: }
372:
373: return $results[0];
374: }
375:
376: function getPortsForBuild($build, $sortby = 'port_directory') {
377: $sortbytable = "bp";
378: if ($sortby == "") $sortby = "port_directory";
379: if ($sortby == "port_directory") $sortbytable = "p";
380: if ($sortby == "port_maintainer") $sortbytable = "p";
381: $query = "SELECT p.*,
382: bp.last_built,
383: bp.last_status,
384: bp.last_successful_built,
385: bp.last_built_version,
386: bp.last_failed_dependency,
387: bp.last_run_duration,
388: CASE bp.last_fail_reason
389: WHEN '__nofail__' THEN ''
390: ELSE bp.last_fail_reason
391: END
392: AS last_fail_reason
393: FROM ports p,
394: build_ports bp
395: WHERE p.port_id = bp.port_id
396: AND bp.build_id=?
397: ORDER BY $sortbytable.$sortby";
398:
399: $rc = $this->_doQueryHashRef($query, $results, $build->getId());
400:
401: if (!$rc) {
402: return null;
403: }
404:
405: $ports = $this->_newFromArray("Port", $results);
406:
407: return $ports;
408: }
409:
410: function getLatestPorts($build_id,$limit="") {
411: $query = "SELECT p.*,
412: bp.build_id,
413: bp.last_built,
414: bp.last_status,
415: bp.last_successful_built,
416: bp.last_built_version,
417: bp.last_failed_dependency,
418: bp.last_run_duration,
419: CASE bp.last_fail_reason
420: WHEN '__nofail__' THEN ''
421: ELSE bp.last_fail_reason
422: END
423: AS last_fail_reason
424: FROM ports p,
425: build_ports bp
426: WHERE p.port_id = bp.port_id
427: AND bp.last_built IS NOT NULL ";
428: if($build_id)
429: $query .= "AND bp.build_id=$build_id ";
430: $query .= " ORDER BY bp.last_built DESC ";
431: if($limit)
432: $query .= " LIMIT $limit";
433:
434: $rc = $this->_doQueryHashRef($query, $results, array());
435:
436: if (!$rc) {
437: return null;
438: }
439:
440: $ports = $this->_newFromArray("Port", $results);
441:
442: return $ports;
443: }
444:
445: function getBuildPorts($port_id,$build_id) {
446: $query = "SELECT p.*,
447: bp.last_built,
448: bp.last_status,
449: bp.last_successful_built,
450: bp.last_failed_dependency,
451: bp.last_run_duration,
452: CASE bp.last_fail_reason
453: WHEN '__nofail__' THEN ''
454: ELSE bp.last_fail_reason
455: END
456: AS last_fail_reason
457: FROM ports p,
458: build_ports bp
459: WHERE p.port_id = bp.port_id
460: AND bp.build_id=?
461: AND bp.port_id=?";
462:
463: $rc = $this->_doQueryHashRef($query, $results, array($build_id, $port_id));
464: if (!$rc) return null;
465:
466: $ports = $this->_newFromArray("Port", $results);
467:
468: return $ports[0];
469: }
470:
471:
472: function getPortsByStatus($build_id,$maintainer,$status,$notstatus) {
473: $query = "SELECT p.*,
474: bp.build_id,
475: bp.last_built,
476: bp.last_status,
477: bp.last_successful_built,
478: bp.last_built_version,
479: bp.last_failed_dependency,
480: bp.last_run_duration,
481: CASE bp.last_fail_reason
482: WHEN '__nofail__' THEN ''
483: ELSE bp.last_fail_reason
484: END
485: AS last_fail_reason
486: FROM ports p,
487: build_ports bp
488: WHERE p.port_id = bp.port_id ";
489:
490: if($build_id)
491: $query .= "AND bp.build_id=$build_id ";
492: if($status<>'')
493: $query .= "AND bp.last_status='$status' ";
494: if($notstatus<>'')
495: $query .= "AND bp.last_status<>'$notstatus' AND bp.last_status<>'UNKNOWN'";
496: if($maintainer)
497: $query .= "AND p.port_maintainer='$maintainer'";
498: $query .= " ORDER BY bp.last_built DESC ";
499:
500: $rc = $this->_doQueryHashRef($query, $results, array());
501:
502: if (!$rc) {
503: return null;
504: }
505:
506: $ports = $this->_newFromArray("Port", $results);
507:
508: return $ports;
509: }
510:
511: function getBuildStatsWithStatus($build_id) {
512: $query = 'SELECT last_status,COUNT(*) AS c FROM build_ports WHERE build_id = ? GROUP BY last_status';
513: $rc = $this->_doQueryHashRef($query, $results, $build_id);
514: if (!$rc) return null;
515: return $results;
516: }
517:
518:
519: function getBuildStats($build_id) {
520: $query = 'SELECT COUNT(*) AS fails FROM build_ports WHERE last_status = \'FAIL\' AND build_id = ?';
521: $rc = $this->_doQueryHashRef($query, $results, $build_id);
522: if (!$rc) return null;
523: return $results[0];
524: }
525:
526: function getPortById($id) {
527: $results = $this->getPorts(array( 'port_id' => $id ));
528:
529: if (is_null($results)) {
530: return null;
531: }
532:
533: return $results[0];
534: }
535:
536: function getPortByDirectory($dir) {
537: $results = $this->getPorts(array( 'port_directory' => $dir ));
538:
539: if (is_null($results)) {
540: return null;
541: }
542:
543: return $results[0];
544: }
545:
546: function getCurrentPortForBuild($build_id) {
547: $query = 'SELECT port_id AS id FROM build_ports WHERE build_id = ? AND currently_building = \'1\'';
548: $rc = $this->_doQueryHashRef($query, $results, array($build_id));
549: if (!$rc) return null;
550: $port = $this->getPortById($results[0]['id']);
551:
552: return $port;
553: }
554:
555: function getObjects($type, $params = array()) {
556: global $objectMap;
557:
558: if (!isset($objectMap[$type])) {
559: die("Unknown object type, $type\n");
560: }
561:
562: $table = $objectMap[$type];
563: $condition = "";
564:
565: $values = array();
566: $conds = array();
567: foreach ($params as $field => $param) {
568: # Each parameter makes up and OR portion of a query. Within
569: # each parameter can be a hash reference that make up the AND
570: # portion of the query.
571: if (is_array($param)) {
572: $ands = array();
573: foreach ($param as $andcond => $value) {
574: array_push($ands, "$andcond=?");
575: array_push($values, $value);
576: }
577: array_push($conds, "(" . (implode(" AND ", $ands)) . ")");
578: } else {
579: array_push($conds, "(" . $field . "=?)");
580: array_push($values, $param);
581: }
582: }
583:
584: $condition = implode(" OR ", $conds);
585:
586: if ($condition != "") {
587: $query = "SELECT * FROM $table WHERE $condition";
588: }
589: else {
590: $query = "SELECT * FROM $table";
591: }
592:
593: $results = array();
594: $rc = $this->_doQueryHashRef($query, $results, $values);
595:
596: if (!$rc) {
597: return null;
598: }
599:
600: return $this->_newFromArray($type, $results);
601: }
602:
603: function getBuildByName($name) {
604: $results = $this->getBuilds(array( 'build_name' => $name ));
605:
606: if (is_null($results)) {
607: return null;
608: }
609:
610: return $results[0];
611: }
612:
613: function getBuildById($id) {
614: $results = $this->getBuilds(array( 'build_id' => $id ));
615:
616: if (is_null($results)) {
617: return null;
618: }
619:
620: return $results[0];
621: }
622:
623: function getJailById($id) {
624: $results = $this->getJails(array( 'jail_id' => $id ));
625:
626: if (is_null($results)) {
627: return null;
628: }
629:
630: return $results[0];
631: }
632:
633: function getPortsTreeForBuild($build) {
634: $portstree = $this->getPortsTreeById($build->getPortsTreeId());
635:
636: return $portstree;
637: }
638:
639: function getPortsTreeByName($name) {
640: $results = $this->getPortsTrees(array( 'ports_tree_name' => $name ));
641: if (is_null($results)) {
642: return null;
643: }
644:
645: return $results[0];
646: }
647:
648: function getPortsTreeById($id) {
649: $results = $this->getPortsTrees(array( 'ports_tree_id' => $id ));
650:
651: if (is_null($results)) {
652: return null;
653: }
654:
655: return $results[0];
656: }
657:
658: function getUserById($id) {
659: $results = $this->getUsers(array( 'user_id' => $id ));
660:
661: if (is_null($results)) {
662: return null;
663: }
664:
665: return $results[0];
666: }
667:
668: function getUserByName($name) {
669: $results = $this->getUsers(array( 'user_name' => $name ));
670:
671: if (is_null($results)) {
672: return null;
673: }
674:
675: return $results[0];
676: }
677:
678: function getConfig($params = array()) {
679: return $this->getObjects("Config", $params);
680: }
681:
682: function getBuildPortsQueue($params = array()) {
683: return $this->getObjects("BuildPortsQueue", $params);
684: }
685:
686: function getBuilds($params = array()) {
687: return $this->getObjects("Build", $params);
688: }
689:
690: function getPorts($params = array()) {
691: return $this->getObjects("Port", $params);
692: }
693:
694: function getJails($params = array()) {
695: return $this->getObjects("Jail", $params);
696: }
697:
698: function getPortFailReasons($params = array()) {
699: return $this->getObjects("PortFailReason", $params);
700: }
701:
702: function getPortsTrees($params = array()) {
703: return $this->getObjects("PortsTree", $params);
704: }
705:
706: function getUsers($params = array()) {
707: return $this->getObjects("User", $params);
708: }
709:
710: function getAllConfig() {
711: $config = $this->getConfig();
712:
713: return $config;
714: }
715:
716: function getAllBuilds() {
717: $builds = $this->getBuilds();
718:
719: return $builds;
720: }
721:
722: function getAllJails() {
723: $jails = $this->getJails();
724:
725: return $jails;
726: }
727:
728: function getAllPortFailReasons() {
729: $results = $this->getPortFailReasons();
730:
731: return $results;
732: }
733:
734: function getAllPortsTrees() {
735: $ports_trees = $this->getPortsTrees();
736:
737: return $ports_trees;
738: }
739:
740: function getAllUsers() {
741: $users = $this->getUsers();
742:
743: return $users;
744: }
745:
746: function addError($error) {
747: return $this->error[] = $error;
748: }
749:
750: function getErrors() {
751: return $this->error;
752: }
753:
754: function _doQueryNumRows($query, $params = array()) {
755: $rows = 0;
756: $rc = $this->_doQuery($query, $params, $res);
757:
758: if (!$rc) {
759: return -1;
760: }
761:
762: if ($res->numRows() > -1) {
763: $rows = $res->numRows();
764: }
765: else {
766: while($res->fetchRow()) {
767: $rows++;
768: }
769: }
770:
771: $res->free();
772:
773: return $rows;
774: }
775:
776: function _doQueryHashRef($query, &$results, $params = array()) {
777: $rc = $this->_doQuery($query, $params, $res);
778:
779: if (!$rc) {
780: $results = null;
781: return 0;
782: }
783:
784: $results = array();
785: while ($row = $res->fetchRow()) {
786: array_push($results, $row);
787: }
788:
789: $res->free();
790:
791: return 1;
792: }
793:
794: function _doQuery($query, $params, &$res) {
795: $sth = $this->db->prepare($query);
796:
797: if (DB::isError($this->db)) {
798: $this->addError($this->db->getMessage());
799: return 0;
800: }
801:
802: if (count($params)) {
803: $_res = $this->db->execute($sth, $params);
804: }
805: else {
806: $_res = $this->db->execute($sth);
807: }
808:
809: if (DB::isError($_res)) {
810: $this->addError($_res->getMessage());
811: return 0;
812: }
813:
814: if (!is_null($_res)) {
815: $res = $_res;
816: }
817: else {
818: $res->free();
819: }
820:
821: return 1;
822: }
823:
824: function _newFromArray($type, $arr) {
825: $objects = array();
826:
827: foreach ($arr as $item) {
828: eval('$obj = new $type($item);');
829: if (!is_a($obj, $type)) {
830: return null;
831: }
832: array_push($objects, $obj);
833: }
834:
835: return $objects;
836: }
837:
838: function destroy() {
839: $this->db->disconnect();
840: $this->error = null;
841: }
842:
843: function getPackageSuffix($jail_id) {
844: if (empty($jail_id)) return "";
845: /* Use caching to avoid a lot of SQL queries */
846: if ( isset($this->packageSuffixCache[$jail_id])) {
847: return $this->packageSuffixCache[$jail_id];
848: } else {
849: $jail = $this->getJailById($jail_id);
850: if (substr($jail->getName(), 0, 1) <= "4") {
851: $this->packageSuffixCache[$jail_id] = ".tgz";
852: return ".tgz";
853: } else {
854: $this->packageSuffixCache[$jail_id] = ".tbz";
855: return ".tbz";
856: }
857:
858: }
859: }
860: }
861: ?>