开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Linux/Unix编程 > 网络 > 查看源码
cb.database.php
资源名称：com_comprofiler.zip　[点击查看]
上传用户：stephen_wu
上传日期：2008-07-05
资源大小：1757k
文件大小：35k
源码类别：

网络

开发平台：

Unix_Linux

cb.database.php：源码内容
  1. <?php
  2. /**
  3. * @version $Id: cb.database.php 344 2007-07-25 02:25:39Z beat $
  4. * @package Community Builder
  5. * @subpackage cb.database.php
  6. * @author Beat and various
  7. * @copyright (C) Beat and various, www.joomlapolis.com
  8. * @license http://www.gnu.org/licenses/old-licenses/gpl-2.0.html GNU/GPL version 2
  9. */
  11. // no direct access
  12. if ( ! ( defined( '_VALID_CB' ) || defined( '_JEXEC' ) || defined( '_VALID_MOS' ) ) ) { die( 'Direct Access to this location is not allowed.' ); }
  15. /* MAMBO 4.5.2.3 FIXES + EXTENSIONS: */
  17. /**
  18. * Corrects bugs in mambo core database class and implements independant CB database layer ! :
  19. * 1) NULL values from SQL tables are not loaded !
  20. * 2) updateOrder method is buggy and does not allow to specify modified row ids to force them into the right position !
  21. */
  22. class comprofilerDBTable {
  23. var $_tbl;
  24. var $_tbl_key;
  25. /** Database object:
  26.  * @var CBdatabase */
  27. var $_db;
  28. var $_error = '';
  30. /**
  31. * Constructor to set table and key field
  32. * Can be overloaded/supplemented by the child class
  33. *
  34. * @param string      $table name of the table in the db schema relating to child class
  35. * @param string      $key name of the primary key field in the table
  36. * @param CBdatabase  $db  CB Database object
  37. */
  38. function comprofilerDBTable( $table, $key, &$db ) {
  39. $this->_tbl = $table;
  40. $this->_tbl_key = $key;
  41. $this->_db =& $db;
  42. }
  43. /**
  44. * Binds an array/hash from database to this object
  45. *
  46. * @param  int $oid  optional argument, if not specifed then the value of current key is used
  47. * @return mixed     any result from the database operation
  48. */
  49. function load( $oid = null ) {
  50. $k = $this->_tbl_key;
  51. if ($oid !== null) {
  52. $this->$k = $oid;
  53. }
  54. $oid = $this->$k;
  55. if ($oid === null) {
  56. return false;
  57. }
  59. //BB fix : resets default values to all object variables, because NULL SQL fields do not overide existing variables !
  60. //Note: Prior to PHP 4.2.0, Uninitialized class variables will not be reported by get_class_vars().
  61. $class_vars = get_class_vars(get_class($this));
  62. foreach ($class_vars as $name => $value) {
  63. if ( ($name != $k) and ($name != "_db") and ($name != "_tbl") and ($name != "_tbl_key") and ( substr( $name, 0 , 10 ) != "_history__" ) ) {
  64. $this->$name = $value;
  65. }
  66. }
  67. $this->reset();
  68. //end of BB fix.
  70. $query = "SELECT *"
  71. . "n FROM " . $this->_db->NameQuote( $this->_tbl )
  72. . "n WHERE " . $this->_db->NameQuote( $this->_tbl_key ) . " = " . $this->_db->Quote( $oid )
  73. ;
  74. $this->_db->setQuery( $query );
  76. return $this->_db->loadObject( $this );
  77. }
  78. /**
  79. * If table key (id) is NULL : inserts a new row
  80. * otherwise updates existing row in the database table
  81. *
  82. * Can be overridden or overloaded by the child class
  83. *
  84. * @param  boolean  $updateNulls  TRUE: null object variables are also updated, FALSE: not.
  85. * @return boolean                TRUE if successful otherwise FALSE
  86. */
  87. function store( $updateNulls = false ) {
  88. $k = $this->_tbl_key;
  90. if ( $this->$k != 0 ) {
  91. $ok = $this->_db->updateObject( $this->_tbl, $this, $this->_tbl_key, $updateNulls );
  92. } else {
  93. $ok = $this->_db->insertObject( $this->_tbl, $this, $this->_tbl_key );
  94. }
  96. if ( ! $ok ) {
  97. $this->_error = strtolower(get_class($this))."::store failed: " . $this->_db->getErrorMsg();
  98. }
  99. return $ok;
  100. }
  101. /**
  102. * @param string $where This is expected to be a valid (and safe!) SQL expression
  103. */
  104. function move( $dirn, $where = '', $ordering = 'ordering' ) {
  105. $k = $this->_tbl_key;
  107. $sql = "SELECT $this->_tbl_key, $ordering FROM $this->_tbl";
  109. if ($dirn < 0) {
  110. $sql .= "n WHERE $ordering < " . (int) $this->$ordering;
  111. $sql .= ($where ? "n AND $where" : '');
  112. $sql .= "n ORDER BY $ordering DESC";
  113. $sql .= "n LIMIT 1";
  114. } else if ($dirn > 0) {
  115. $sql .= "n WHERE $ordering > " . (int) $this->$ordering;
  116. $sql .= ($where ? "n AND $where" : '');
  117. $sql .= "n ORDER BY $ordering";
  118. $sql .= "n LIMIT 1";
  119. } else {
  120. $sql .= "nWHERE $ordering = " . (int) $this->$ordering;
  121. $sql .= ($where ? "n AND $where" : '');
  122. $sql .= "n ORDER BY $ordering";
  123. $sql .= "n LIMIT 1";
  124. }
  126. $this->_db->setQuery( $sql );
  128. $row = null;
  129. if ($this->_db->loadObject( $row )) {
  130. $query = "UPDATE $this->_tbl"
  131. . "n SET $ordering = " . (int) $row->$ordering
  132. . "n WHERE $this->_tbl_key = " . $this->_db->Quote( $this->$k )
  133. ;
  134. $this->_db->setQuery( $query );
  136. if (!$this->_db->query()) {
  137. $err = $this->_db->getErrorMsg();
  138. die( $err );
  139. }
  141. $query = "UPDATE $this->_tbl"
  142. . "n SET $ordering = " . (int) $this->$ordering
  143. . "n WHERE $this->_tbl_key = " . $this->_db->Quote( $row->$k )
  144. ;
  145. $this->_db->setQuery( $query );
  147. if (!$this->_db->query()) {
  148. $err = $this->_db->getErrorMsg();
  149. die( $err );
  150. }
  152. $this->$ordering = $row->$ordering;
  153. } else {
  154. $query = "UPDATE $this->_tbl"
  155. . "n SET $ordering = " . (int) $this->$ordering
  156. . "n WHERE $this->_tbl_key = " . $this->_db->Quote( $this->$k )
  157. ;
  158. $this->_db->setQuery( $query );
  160. if (!$this->_db->query()) {
  161. $err = $this->_db->getErrorMsg();
  162. die( $err );
  163. }
  164. }
  165. }
  167. /**
  168. * Private utility method for updateOrder() back-called by usort() for comparing orderings
  169. */
  170. function _cmp_obj($a, $b) {
  171. $k = $this->_cbc_cbc_ordering_tmp;
  172. if ( $a->$k == $b->$k ) {
  173.            return 0;
  174.        }
  175.        return ( $a->$k > $b->$k ) ? +1 : -1;
  176.    }
  177. /**
  178. * Compacts the ordering sequence of the selected records
  179. *
  180. * @param  string  $where     Additional where query to limit ordering to a particular subset of records
  181. * @param  array   $cids      of table key ids which should preserve their position (in addition of the negative positions) 
  182. * @param  string  $ordering  name of ordering column in table
  183. * @return boolean TRUE success, FALSE failed, with error of database updated.
  184. */
  185. function updateOrder( $where = '' , $cids = null, $ordering = 'ordering' ) {
  186. $k = $this->_tbl_key;
  188. if (!array_key_exists( $ordering, get_class_vars( strtolower(get_class( $this )) ) )) {
  189. $this->_error = "WARNING: ".strtolower(get_class( $this ))." does not support ordering field" . $ordering . ".";
  190. return false;
  191. }
  193. if ($this->_tbl == "#__content_frontpage") {
  194. $order2 = ", content_id DESC";
  195. } else {
  196. $order2 = "";
  197. }
  199. $this->_db->setQuery( "SELECT $this->_tbl_key, $ordering FROM $this->_tbl"
  200. . ($where ? "nWHERE $where" : '')
  201. . "nORDER BY " . $ordering . $order2
  202. );
  204. if (!($orders = $this->_db->loadObjectList())) {
  205. $this->_error = $this->_db->getErrorMsg();
  206. return false;
  207. }
  209. $n=count( $orders );
  210. $iOfThis = null;
  212. if($cids !== null) {
  213. $cidsOrderings = array(); // determine list of reserved/changed ordering numbers
  214. for ($i=0; $i < $n; $i++) {
  215. if (in_array($orders[$i]->$k, $cids)) {
  216. $cidsOrderings[$orders[$i]->$k] = $orders[$i]->$ordering;
  217. }
  218. }
  220. $j = 1; // change ordering numbers outside of reserved and negative ordering numbers list
  221. for ($i=0; $i < $n; $i++) {
  222. if ($orders[$i]->$k == $this->$k) {
  223. // place 'this' record in the desired location at the end !
  224. $iOfThis = $i;
  225. if ($orders[$i]->$ordering == $j) {
  226. $j++;
  227. }
  228. } else if (in_array($orders[$i]->$k, $cids)) {
  229. if ($orders[$i]->$ordering == $j) {
  230. $j++;
  231. }
  232. } else {
  233. if ($orders[$i]->$ordering >= 0) {
  234. $orders[$i]->$ordering = $j++;
  235. }
  236. while (in_array($orders[$i]->$ordering, $cidsOrderings)) {
  237. $orders[$i]->$ordering = $j++;
  238. }
  239. }
  240. }
  241. } else {
  242. $j = 1;
  243. for ($i=0; $i < $n; $i++) {
  244. if ($orders[$i]->$k == $this->$k) {
  245. // place 'this' record in the desired location at the end !
  246. $iOfThis = $i;
  247. if ($orders[$i]->$ordering == $j) {
  248. $j++;
  249. }
  250. } else if ($orders[$i]->$ordering != $this->$ordering && $this->$ordering > 0 && $orders[$i]->$ordering >= 0) {
  251. $orders[$i]->$ordering = $j++;
  252. } else if ($orders[$i]->$ordering == $this->$ordering && $this->$ordering > 0 && $orders[$i]->$ordering >= 0) {
  253. if ($orders[$i]->$ordering == $j) {
  254. $j++;
  255. }
  256. $orders[$i]->$ordering = $j++;
  257. }
  258. }
  259. }
  260. if ($iOfThis !== null) {
  261. $orders[$iOfThis]->$ordering = min( $this->$ordering, $j );
  262. }
  263. // sort entries by ->$ordering:
  264. $this->_cbc_cbc_ordering_tmp = $ordering;
  265. usort($orders, array( $this, "_cmp_obj" ));
  266. unset( $this->_cbc_cbc_ordering_tmp );
  268. // compact ordering:
  269. $j = 1;
  270. for ($i=0; $i < $n; $i++) {
  271. if ($orders[$i]->$ordering >= 0) {
  272. $orders[$i]->$ordering = $j++;
  273. }
  274. }
  276. for ($i=0; $i < $n; $i++) {
  277. if (($orders[$i]->$ordering >= 0) or ($orders[$i]->$k == $this->$k)) {
  278. $this->_db->setQuery( "UPDATE $this->_tbl"
  279. . "nSET $ordering='".$orders[$i]->$ordering."' WHERE $k='".$orders[$i]->$k."'"
  280. );
  281. $this->_db->query();
  282. }
  283. }
  285. // if we didn't find to reorder the current record, make it last
  286. if (($iOfThis === null) && ($this->$ordering > 0)) {
  287. $order = $n+1;
  288. $this->_db->setQuery( "UPDATE $this->_tbl"
  289. . "nSET $ordering='$order' WHERE $k='".$this->$k."'"
  290. );
  291. $this->_db->query();
  292. }
  293. return true;
  294. }
  296. /**
  297. * Resets public properties
  298. *
  299. * @param  mixed  $value  The value to set all properties to, default is null
  300. */
  301. function reset( $value=null ) {
  302. $keys = $this->getPublicProperties();
  303. foreach ( $keys as $k ) {
  304. $this->$k = $value;
  305. }
  306. }
  307. /**
  308. * Gets the value of the class variable
  309. *
  310. * @param  string  $var  The name of the class variable
  311. * @return mixed         The value of the class var (or null if no var of that name exists)
  312. */
  313. function get( $var ) {
  314. if ( isset( $this->$var ) ) {
  315. return $this->$var;
  316. } else {
  317. return null;
  318. }
  319. }
  320. /**
  321. * Sets the new value of the class variable
  322. *
  323. * @param  string  $var     The name of the class variable
  324. * @param  mixed   $newVal  The new value to assign to the variable
  325. */
  326. function set( $var, $newVal ) {
  327. $this->$var = $newVal;
  328. }
  329. /**
  330.  * Returns an array of public properties
  331.  *
  332.  * @return array
  333.  */
  334. function getPublicProperties() {
  335. static $keys = null;
  337. if ( $keys === null ) {
  338. $keys = array();
  339. foreach ( array_keys( get_class_vars( get_class( $this ) ) ) as $k ) {
  340. if (substr( $k, 0, 1 ) != '_') {
  341. $keys[] = $k;
  342. }
  343. }
  344. }
  345. return $keys;
  346. }
  347. /**
  348. * Generic check for whether dependancies exist for this object in the db schema
  349. * OVERRIDE !
  350. *
  351. * @param  int  $oid  key index
  352. * @return boolean
  353. */
  354. function canDelete( $oid = null ) {
  355. return true;
  356. }
  357. /**
  358. * Deletes this record (no checks)
  359. *
  360. * @param  int      $oid   Key id of row to delete (otherwise it's the one of $this)
  361. * @return boolean         TRUE if OK, FALSE if error
  362. */
  363. function delete( $oid = null ) {
  364. $k = $this->_tbl_key;
  365. if ( $oid ) {
  366. $this->$k = (int) $oid;
  367. }
  369. $query = "DELETE FROM " . $this->_db->NameQuote( $this->_tbl )
  370. . "n WHERE " . $this->_db->NameQuote( $this->_tbl_key )
  371. . " = "
  372. . ( is_int( $this->$k ) ? (int) $this->$k : $this->_db->Quote( $this->$k ) )
  373. ;
  374. $this->_db->setQuery( $query );
  376. if ($this->_db->query()) {
  377. return true;
  378. } else {
  379. $this->_error = $this->_db->getErrorMsg();
  380. return false;
  381. }
  382. }
  384. /**
  385. * Tests if item is checked out
  386. * @param  int      A user id
  387. * @return boolean
  388.  */
  389. function isCheckedOut( $user_id = 0 ) {
  390. if ( $user_id ) {
  391. return ( $this->checked_out && ( $this->checked_out != $user_id ) );
  392. } else {
  393. return $this->checked_out;
  394. }
  395. }
  397. /**
  398.  * Checkout object from database
  399.  *
  400.  * @param  int  $who
  401.  * @param  int  $oid
  402.  * @return unknown
  403.  */
  404. function checkout( $who, $oid = null ) {
  405. if ( ! array_key_exists( 'checked_out', get_class_vars( strtolower( get_class( $this ) ) ) ) ) {
  406. $this->_error = "WARNING: " . strtolower( get_class( $this ) ) . " does not support checkouts.";
  407. return false;
  408. }
  410. $k = $this->_tbl_key;
  411. if ( $oid !== null ) {
  412. $this->$k = $oid;
  413. }
  414. $time = date( "Y-m-d H:i:s" );
  415. $query = "UPDATE " . $this->_db->NameQuote( $this->_tbl )
  416. . "n SET checked_out = " . (int) $who . ", checked_out_time = " . $this->_db->Quote( $time )
  417. . "n WHERE " . $this->_db->NameQuote( $this->_tbl_key ) . " = " . $this->_db->Quote( $this->$k )
  418. ;
  419. $this->_db->setQuery( $query );
  420. return $this->_db->query();
  421. }
  423. function checkin( $oid = null ) {
  424. if ( ! array_key_exists( 'checked_out', get_class_vars( strtolower( get_class( $this ) ) ) ) ) {
  425. $this->_error = "WARNING: " . strtolower( get_class( $this ) ) . " does not support checkins.";
  426. return false;
  427. }
  428. $k = $this->_tbl_key;
  429. if ( $oid !== null ) {
  430. $this->$k = $oid;
  431. }
  432. $query = "UPDATE " . $this->_db->NameQuote( $this->_tbl )
  433. . "n SET checked_out = 0, checked_out_time = " . $this->_db->Quote( $this->_db->getNullDate() )
  434. . "n WHERE " . $this->_db->NameQuote( $this->_tbl_key ) . " = " . $this->_db->Quote( $this->$k )
  435. ;
  436. $this->_db->setQuery( $query );
  437. return $this->_db->query();
  438. }
  440. // EXTENSIONS: EXPERIMENTAL IN CB 1.2, NOT PART OF API:
  441. /**
  442. * Loads an array of typed objects of a given class (same class as current object by default)
  443. * which inherit from this class.
  444. * @access private
  445. *
  446. * @param  string  $class          [optional] class name
  447. * @param  string  $key            [optional] key name in db to use as key of array
  448. * @param  array   $additionalVars [optional] array of string additional key names to add as vars to object
  449. * @return array   of objects of the same class (empty array if no objects)
  450. */
  451. function & loadTrueObjects( $class = null, $key = "", $additionalVars = array() ) {
  452. $objectsArray = array();
  453. $resultsArray = $this->_db->loadAssocList( $key );
  454. if ( is_array($resultsArray) ) {
  455. if ( $class == null ) {
  456. $class = get_class($this);
  457. }
  458. foreach ( $resultsArray as $k => $value ) {
  459. $objectsArray[$k] =& new $class( $this->_db );
  460. // mosBindArrayToObject( $value, $objectsArray[$k], null, null, false );
  461. $objectsArray[$k]->bind( $value, null, null, false );
  462. foreach ( $additionalVars as $index ) {
  463. if ( array_key_exists( $index, $value ) ) {
  464. $objectsArray[$k]->$index = $value[$index];
  465. }
  466. }
  467. }
  468. }
  469. return $objectsArray;
  470. }
  471. /**
  472. * Check values before store method  (override if needed)
  473. * @return boolean  TRUE if the object is safe for saving
  474. */
  475. function check( ) {
  476. return true;
  477. }
  478. /**
  479. * Copy the named array or object content into this object as vars
  480. * only existing vars of object are filled.
  481. * When undefined in array, object variables are kept.
  482. * 
  483. * WARNING: DOES addslashes / escape BY DEFAULT
  484. * 
  485. * Can be overridden or overloaded.
  486. *
  487. * @param  array|object  $array         The input array or object
  488. * @param  string        $ignore        Fields to ignore
  489. * @param  string        $prefix        Prefix for the array keys
  490. * @param  boolean       $checkSlashes  TRUE: if magic_quotes are ON, remove slashes (TRUE BY DEFAULT !)
  491. * @return boolean                      TRUE: ok, FALSE: error on array binding
  492. */
  493. function bind( $array, $ignore='', $prefix = null, $checkSlashes = true  ) {
  494. if ( is_array( $array ) || is_object( $array ) ) {
  495. $ignore = ' ' . $ignore . ' ';
  496. foreach ( get_object_vars( $this ) as $k => $v ) {
  497. if( substr( $k, 0, 1 ) != '_' ) {
  498. if ( strpos( $ignore, ' ' . $k . ' ') === false) {
  499. $ak = $prefix . $k;
  500. if ( is_array( $array ) && isset( $array[$ak] ) ) {
  501. $this->$k = ( ( $checkSlashes && get_magic_quotes_gpc() ) ? cbStripslashes( $array[$ak] ) : $array[$ak] );
  502. } elseif ( isset( $array->$ak ) ) {
  503. $this->$k = ( ( $checkSlashes && get_magic_quotes_gpc() ) ? cbStripslashes( $array->$ak ) : $array->$ak );
  504. }
  505. }
  506. }
  507. }
  508. } else {
  509. $this->_error = get_class( $this ) . "::bind failed: not an array.";
  510. return false;
  511. }
  512. return true;
  513. }
  514. /**
  515.  * @return string Returns the error message
  516.  */
  517. function getError() {
  518. return $this->_error;
  519. }
  520. } // end class comprofilerDBTable
  522. /**
  523. * Provides CMS database independance and
  524. * Corrects bugs and backwards compatibility issues in mambo core database class ! :
  525. * 1) empty lists return empty arrays and not NULL values !
  526. * 2) gives a coherent interface to CB, independant of various CMS flavors
  527. */
  528. class CBdatabase {
  529. /**  Host CMS database class
  530. * @var database */
  531. var $_db;
  532. /* @var string  Holds database prefix replacer (replacing the $prefix (default '#__')). */
  533. var $_table_prefix = '';
  535. /**
  536. * Database object constructor
  537. */
  538. function CBdatabase( &$_CB_database ) {
  539. $this->_db =& $_CB_database;
  540. if ( isset( $_CB_database->_table_prefix ) ) {
  541. $this->_table_prefix = $_CB_database->_table_prefix;
  542. } else {
  543. global $_CB_framework;
  544. $this->_table_prefix = $_CB_framework->getCfg( 'dbprefix' );
  545. }
  546. }
  547. /**
  548. * Sets debug level
  549. * @param int
  550. */
  551. function debug( $level ) {
  552. $this->_db->debug( $level );
  553. }
  554. /**
  555. * @return int The error number for the most recent query
  556. */
  557. function getErrorNum( ) {
  558. return $this->_db->getErrorNum();
  559. }
  560. /**
  561. * @return string The error message for the most recent query
  562. */
  563. function getErrorMsg( ) {
  564. return stripslashes( $this->_db->getErrorMsg() );
  565. }
  566. /**
  567. * @param int      $errorNum  The error number for the most recent query
  568. */
  569. function setErrorNum( $errorNum) {
  570. $this->_db->_errorNum = $errorNum;
  571. }
  572. /**
  573. * @param  string  $errorMsg  The error message for the most recent query
  574. */
  575. function setErrorMsg( $errorMsg ) {
  576. $this->_db->_errorMsg = $errorMsg;
  577. }
  578. /**
  579. * Get a database escaped string
  580. *
  581. * @param  string  $text
  582. * @return string
  583. */
  584. function getEscaped( $text ) {
  585. return $this->_db->getEscaped( $text );
  586. }
  587. /**
  588. * Get a quoted database escaped string
  589. *
  590. * @param  string  $text
  591. * @return string
  592. */
  593. function Quote( $text ) {
  594. return ''' . $this->_db->getEscaped( $text ) . ''';
  595. }
  596. /**
  597. * Quote an identifier name (field, table, etc)
  598. *
  599. * @param  string  $s  The name
  600. * @return string      The quoted name
  601. */
  602. function NameQuote( $s ) {
  603. return '`' . $s . '`';
  604. }
  605. /**
  606. * Returns the zero date/time
  607. *
  608. * @param  string  $dateTime  'datetime', 'date', 'time'
  609. * @return string  Quoted null/zero date string
  610. */
  611. function getNullDate( $dateTime = 'datetime' ) {
  612. if ( $dateTime == 'datetime' ) {
  613. return '0000-00-00 00:00:00';
  614. } elseif ( $dateTime == 'date' ) {
  615. return '0000-00-00';
  616. } else {
  617. return '00:00:00';
  618. }
  619. }
  620. /**
  621. * Sets the SQL query string for later execution.
  622. *
  623. * This function replaces a string identifier $prefix with the
  624. * string held is the _table_prefix class variable.
  625. *
  626. * @param string $sql     The SQL query
  627. * @param int    $offset  The offset to start selection
  628. * @param int    $limit   The number of results to return
  629. * @param string $prefix  The common table prefix search for replacement string
  630. */
  631. function setQuery( $sql, $offset = 0, $limit = 0, $prefix='#__' ) {
  632. if ( in_array( checkJversion( 'product' ), array( 'Mambo', 'Elxis', 'MiaCMS' ) ) ) {
  633. if ( $offset || $limit ) {
  634. $sql .= " LIMIT ";
  635. if ( $offset ) {
  636. $sql .= ( (int) $offset ) . ', ';
  637. }
  638. $sql .= ( (int) $limit );
  639. }
  640. $this->_db->setQuery( $sql, $prefix );
  641. } else {
  642. $this->_db->setQuery( $sql, $offset, $limit, $prefix );
  643. }
  644. }
  645. /**
  646.  * Replace $prefix with $this->_table_prefix
  647.  *
  648.  * @param  string  $sql      SQL query
  649.  * @param  string  $prefix   Common table prefix
  650.  */
  651. function replacePrefix( $sql, $prefix='#__' ) {
  652. return $this->_db->replacePrefix( $sql, $prefix );
  653. }
  654. /**
  655. * @return string The current value of the internal SQL vairable
  656. */
  657. function getQuery( ) {
  658. return $this->_db->getQuery();
  659. }
  660. /**
  661. * Execute the query
  662. * 
  663. * @param  string  the query (optional, it will use the setQuery one otherwise)
  664. * @return mixed A database resource if successful, FALSE if not.
  665. */
  666. function query( $sql = null ) {
  667. if ( $sql ) {
  668. $this->setQuery( $sql );
  669. }
  670. return $this->_db->query();
  671. }
  672. /**
  673.  * Executes a series of SQL orders, optionally as a transaction
  674.  *
  675.  * @param  boolean $abort_on_error      Aborts on error (true by default)
  676.  * @param  boolean $p_transaction_safe  Encloses all in a single transaction (false by default)
  677.  * @return boolean true: success, false: error(s)
  678.  */
  679. function query_batch( $abort_on_error = true, $p_transaction_safe = false) {
  680. return $this->_db->query_batch( $abort_on_error, $p_transaction_safe );
  681. }
  682. /** for compatibility only: */
  683. function queryBatch( $abort_on_error = true, $p_transaction_safe = false) {
  684. return $this->query_batch( $abort_on_error, $p_transaction_safe );
  685. }
  686. /**
  687. * @return int The number of affected rows in the previous operation
  688. */
  689. function getAffectedRows( ) {
  690. if ( is_callable( array( $this->_db, 'getAffectedRows' ) ) ) {
  691. $affected = $this->_db->getAffectedRows();
  692. } elseif ( get_resource_type( $this->_db->_resource ) == 'mysql link' ) {
  693. $affected = mysql_affected_rows( $this->_db->_resource );
  694. } else {
  695. $affected = mysqli_affected_rows( $this->_db->_resource );
  696. }
  697. return $affected;
  698. }
  699. /**
  700. * Returns the number of rows returned from the most recent query.
  701. * 
  702. * @return int
  703. */
  704. function getNumRows( $cur = null ) {
  705. return $this->_db->getNumRows( $cur );
  706. }
  707. /**
  708.  * Explain of SQL
  709.  * 
  710.  * @return string
  711.  */
  712. function explain( ) {
  713. return $this->_db->explain();
  714. }
  715. /**
  716. * This method loads the first field of the first row returned by the query.
  717. *
  718. * @return The value returned in the query or null if the query failed.
  719. */
  720. function loadResult( ) {
  721. return $this->_db->loadResult();
  722. }
  723. function & _nullToArray( &$resultArray ) {
  724. if ( $resultArray === null ) { // mambo strangeness
  725. $resultArray = array();
  726. }
  727. return $resultArray;
  728. }
  729. /**
  730. * Load an array of single field results into an array
  731. */
  732. function loadResultArray( $numinarray = 0 ) {
  733. $resultArray = $this->_db->loadResultArray( $numinarray );
  734. return $this->_nullToArray( $resultArray );
  735. }
  736. /**
  737. * Fetch a result row as an associative array
  738. *
  739. * @return array
  740. */
  741. function loadAssoc( ) {
  742. if ( is_callable( array( $this->_db, 'loadAssoc' ) ) ) {
  743. return $this->_db->loadAssoc( );
  744. } else {
  745. // new independant efficient implementation:
  746. if ( ! ( $cur = $this->query() ) ) {
  747. $result = null;
  748. } else {
  749. $result = $this->m_fetch_assoc( $cur );
  750. if ( ! $result ) {
  751. $result = null;
  752. }
  753. $this->m_free_result( $cur );
  754. }
  755. return $result;
  756. }
  757. }
  758. /**
  759. * Load a assoc list of database rows
  760. * 
  761. * @param string The field name of a primary key
  762. * @return array If <var>key</var> is empty as sequential list of returned records.
  763. */
  764. function loadAssocList( $key = null ) {
  765. if ( ( $key == '' ) || ( checkJversion() >= 0 ) ) {
  766. $resultArray = $this->_db->loadAssocList( $key );
  767. return $this->_nullToArray( $resultArray );
  768. } else {
  769. // mambo 4.5.2 - 4.6.2 has a bug in key:
  770. if ( ! ( $cur = $this->query() ) ) {
  771. return null;
  772. }
  773. $array = array();
  774. while ( is_array( $row = $this->m_fetch_assoc( $cur ) ) ) {
  775. if ( $key ) {
  776. $array[$row[$key]] = $row; //  $row->key is not an object, but an array
  777. } else {
  778. $array[] = $row;
  779. }
  780. }
  781. $this->m_free_result( $cur );
  782. return $array;
  783. }
  784. }
  785. /**
  786. * This global function loads the first row of a query into an object
  787. *
  788. * If an object is passed to this function, the returned row is bound to the existing elements of <var>object</var>.
  789. * If <var>object</var> has a value of null, then all of the returned query fields returned in the object.
  790. * @param  stdClass  $object
  791. * @return boolean            Success
  792. */
  793. function loadObject( &$object ) {
  794. // return $this->_db->loadObject( $object );
  795. $cur = $this->query();
  796. if ( ! $cur ) {
  797. return false;
  798. }
  799. if ( $object != null ) {
  800. $array = $this->m_fetch_assoc( $cur );
  801. $this->m_free_result( $cur );
  802. if ( is_array( $array ) ) {
  804. foreach ( get_object_vars( $object ) as $k => $v) {
  805. if( substr( $k, 0, 1 ) != '_' ) {
  806. if ( isset( $array[$k] ) ) {
  807. $object->$k = $array[$k];
  808. }
  809. }
  810. }
  811. return true;
  812. }
  813. } else {
  814. $object = $this->m_fetch_object( $cur );
  815. $this->m_free_result( $cur );
  816. if ( is_object( $object ) ) {
  817. return true;
  818. } else {
  819. $object = null;
  820. }
  821. }
  822. return false;
  823. }
  824. /**
  825. * Load a list of database objects
  826. * If $key is not empty then the returned array is indexed by the value
  827. * the database key.  Returns NULL if the query fails.
  828. *
  829. * @param  string       $key          The field name of a primary key
  830. * @param  string|null  $className    The name of the class to instantiate, set the properties of and return. If not specified, a stdClass object is returned
  831. * @param  array|null   $ctor_params  An optional array of parameters to pass to the constructor for class_name objects
  832. * @return array                      If $key is empty as sequential list of returned records.
  833. */
  834. function loadObjectList( $key = null, $className = null, $ctor_params = null ) {
  835. if ( ! ( $cur = $this->query() ) ) {
  836. return null;
  837. }
  838. $array = array();
  839. while ( is_object( $row = $this->m_fetch_object( $cur, $className, $ctor_params ) ) ) {
  840. if ( $key ) {
  841. $array[$row->$key] = $row;
  842. } else {
  843. $array[] = $row;
  844. }
  845. }
  846. $this->m_free_result( $cur );
  847. return $array;
  848. }
  849. /**
  850. * @return The first row of the query.
  851. */
  852. function loadRow( ) {
  853. return $this->_db->loadRow();
  854. }
  855. /**
  856. * Load a list of database rows (numeric column indexing)
  857. * @param string The field name of a primary key
  858. * @return array If <var>key</var> is empty as sequential list of returned records.
  859. * If <var>key</var> is not empty then the returned array is indexed by the value
  860. * the database key.  Returns <var>null</var> if the query fails.
  861. */
  862. function loadRowList( $key = null ) {
  863. $resultArray = $this->_db->loadRowList( $key );
  864. return $this->_nullToArray( $resultArray );
  865. }
  866. /**
  867. * Insert an object into database
  868. *
  869. * @param string   $table This is expected to be a valid (and safe!) table name
  870. * @param stdClass $object
  871. * @param string   $keyName
  872. * @param boolean  $verbose
  873. * @param boolean  TRUE if insert succeeded, FALSE when error
  874. */
  875. function insertObject( $table, &$object, $keyName = NULL, $verbose=false ) {
  876. return $this->_db->insertObject( $table, $object, $keyName, $verbose );
  877. }
  878. /**
  879. * Updates an object into a database
  880. *
  881. * @param  string   $table        This is expected to be a valid (and safe!) table name
  882. * @param  stdClass $object
  883. * @param  string   $keyName
  884. * @param  boolean  $updateNulls
  885. * @return mixed    A database resource if successful, FALSE if not.
  886. */
  887. function updateObject( $table, &$object, $keyName, $updateNulls=true ) {
  888. // return $this->_db->updateObject( $table, $object, $keyName, $updateNulls );
  889. $fmtsql = "UPDATE $table SET %s WHERE %s";
  890. $tmp = array();
  891. foreach (get_object_vars( $object ) as $k => $v) {
  892. if( is_array($v) or is_object($v) or $k[0] == '_' ) { // internal or NA field
  893. continue;
  894. }
  895. if( $k == $keyName ) { // PK not to be updated
  896. $where = $keyName . '=' . $this->Quote( $v );
  897. continue;
  898. }
  899. if ($v === NULL && !$updateNulls) {
  900. continue;
  901. }
  902. if( $v === NULL ) {
  903. $val = "NULL"; // this case was missing in Mambo
  904. } elseif( $v == '' ) {
  905. $val = "''";
  906. } else {
  907. $val = $this->Quote( $v );
  908. }
  909. $tmp[] = $this->NameQuote( $k ) . '=' . $val;
  910. }
  911. $this->setQuery( sprintf( $fmtsql, implode( ",", $tmp ) , $where ) );
  912. return $this->query();
  913. }
  915. /**
  916. * Returns the formatted standard error message of SQL
  917. * @param  boolean $showSQL  If TRUE, displays the last SQL statement sent to the database
  918. * @return string  A standised error message
  919. */
  920. function stderr( $showSQL = false ) {
  921. return $this->_db->stderr( $showSQL );
  922. }
  923. /**
  924. * Returns the insert_id() from Mysql
  925. *
  926. * @return int
  927. */
  928. function insertid( ) {
  929. return $this->_db->insertid();
  930. }
  931. /**
  932. * Returns the version of MySQL
  933. *
  934. * @return string
  935. */
  936. function getVersion( ) {
  937. return $this->_db->getVersion();
  938. }
  939. /**
  940. * Returns a list of tables, with the prefix changed if needed.
  941. *
  942. * @param  string  $tableName  Name of table (SQL LIKE pattern), null: all tables
  943. * @param  string  $prefix     Prefix to change back
  944. * @return array               A list of all the tables in the database
  945. */
  946. function getTableList( $tableName = null, $prefix = '#__' ) {
  947. $this->setQuery( 'SHOW TABLES' . ( $tableName ? ' LIKE ' . $this->Quote( $tableName ) : '' ) );
  948. $tables = $this->loadResultArray();
  949. if ( $prefix ) {
  950. foreach ( $tables as $k => $n ) {
  951. $tables[$k] = preg_replace( '/^(' . $this->_table_prefix . ')/', $prefix, $n );
  952. }
  953. }
  954. return $tables;
  955. }
  956. /**
  957. * Returns the status of all tables, with the prefix changed if needed.
  958. *
  959. * @param  string  $tableName  Name of table (SQL LIKE pattern), null: all tables
  960. * @param  string  $prefix     Prefix to change back
  961. * @return array               A list of all the table statuses in the database
  962. */
  963. function getTableStatus( $tableName = null, $prefix = '#__' ) {
  964. $this->setQuery( 'SHOW TABLE STATUS' . ( $tableName ? ' LIKE ' . $this->Quote( $this->replacePrefix( $tableName, $prefix ) ) : '' ) );
  965. $tables = $this->loadObjectList();
  966. if ( $prefix ) {
  967. foreach ( $tables as $k => $n ) {
  968. $tables[$k]->Name = preg_replace( '/^(' . $this->_table_prefix . ')/', $prefix, $n->Name );
  969. }
  970. }
  971. return $tables;
  972. }
  973. /**
  974.  * @param array A list of valid (and safe!) table names
  975.  * @return array A list the create SQL for the tables
  976.  */
  977. function getTableCreate( $tables ) {
  978. $createQueries = array();
  979. foreach ( $tables as $tableName ) {
  980. $this->setQuery( 'SHOW CREATE table ' . $this->NameQuote( $tableName ) );
  981. $this->query();
  982. $createQueries[$tableName] = $this->loadResultArray( 1 );
  983. }
  984. return $createQueries;
  985. }
  986. /**
  987.  * Gets the fields as in DESCRIBE of MySQL
  988.  *
  989.  * @param  array|string  $tables    A (list of) table names
  990.  * @param  boolean       $onlyType  TRUE: only type without size, FALSE: full DESCRIBE MySql
  991.  * @return array                    EITHER: array( tablename => array( fieldname => fieldtype ) ) or of => fieldDESCRIBE
  992.  */
  993. function getTableFields( $tables, $onlyType = true ) {
  994. $result = array();
  995. $tables = (array) $tables;
  996. foreach ( $tables as $tbl ) {
  997. $this->setQuery( 'SHOW COLUMNS FROM ' . $this->NameQuote( $tbl ) );
  998. $result[$tbl] = $this->loadObjectList( 'Field' );
  999. if ( is_array( $result[$tbl] ) && $onlyType ) {
  1000. foreach ( $result[$tbl] as $k => $fld ) {
  1001. $result[$tbl][$k] = preg_replace( '/[(0-9)]/','', $fld->Type );
  1002. }
  1003. }
  1004. }
  1005. return $result;
  1006. }
  1007. /**
  1008.  * Gets the index of the table
  1009.  *
  1010.  * @param  array|string  $tables    A (list of) table names
  1011.  * @return array                    As
  1012.  */
  1013. function getTableIndex( $table, $prefix = '#__' ) {
  1014. $this->setQuery( 'SHOW INDEX FROM ' . $this->NameQuote( $table ) );
  1015. $indexes = $this->loadObjectList();
  1016. if ( $prefix ) {
  1017. foreach ( $indexes as $k => $n ) {
  1018. $indexes[$k]->Table = preg_replace( '/^(' . $this->_table_prefix . ')/', $prefix, $n->Table );
  1019. }
  1020. }
  1021. return $indexes;
  1022. }
  1023. /**
  1024. * Fudge method for ADOdb compatibility
  1025. */
  1026. function GenID( $foo1=null, $foo2=null ) {
  1027. return '0';
  1028. }
  1029. /**
  1030.  * Checks if database's collation is case-INsensitive
  1031.  * WARNING: individual table's fields might have a different collation
  1032.  *
  1033.  * @return boolean  TRUE if case INsensitive
  1034.  */
  1035. function isDbCollationCaseInsensitive( ) {
  1036. static $result = null;
  1038. if ( $result === null ) {
  1039. $query = "SELECT IF('a'='A', 1, 0);";
  1040. $this->setQuery( $query );
  1041. $result = $this->loadResult();
  1042. }
  1043. return ( $result == 1 );
  1044. }
  1045. /**
  1046.  * mysql/mysqli_fetch_assoc function
  1047.  *
  1048.  * @param  mysql_result  $cur  The result resource that is being evaluated. This result comes from a call to mysql_query().
  1049.  * @return array|boolean|null         False OR null if no more
  1050.  */
  1051. function m_fetch_assoc( &$cur ) {
  1052. if ( is_object( $cur ) && get_class( $cur ) == 'mysqli_result' ) {
  1053. return mysqli_fetch_assoc( $cur );
  1054. } else {
  1055. return mysql_fetch_assoc( $cur );
  1056. }
  1057. }
  1058. /**
  1059.  * mysql / mysqli fetch_object
  1060.  *
  1061.  * @param  mysql_result  $cur          The result resource that is being evaluated. This result comes from a call to mysql_query()
  1062.  * @param  string|null   $className    The name of the class to instantiate, set the properties of and return. If not specified, a stdClass object is returned
  1063.  * @param  array|null    $ctor_params  An optional array of parameters to pass to the constructor for class_name objects
  1064.  * @return object|boolean|null         False OR null if no more
  1065.  */
  1066. function m_fetch_object( &$cur, $className = null, $ctor_params = null ) {
  1067. if ( is_object( $cur ) && ( get_class( $cur ) == 'mysqli_result' ) ) {
  1068. // MySqli is PHP 5 only:
  1069. if ( $className === null ) {
  1070. return mysqli_fetch_object( $cur );
  1071. } else {
  1072. return mysqli_fetch_object( $cur, $className, $ctor_params );
  1073. }
  1074. } else {
  1075. // MySql:
  1076. if ( $className === null ) {
  1077. return mysql_fetch_object( $cur );
  1078. } elseif ( version_compare( phpversion(), '5.0.0', '>=' ) ) {
  1079. return mysql_fetch_object( $cur, $className, $ctor_params );
  1080. } else {
  1081. $objArr = $this->m_fetch_assoc( $cur );
  1082. if ( ! is_array( $objArr ) ) {
  1083. return $objArr;
  1084. }
  1085. $obj = $this->_m_new_class( $className, $ctor_params );
  1086. foreach ( $objArr as $k => $v) {
  1087. $obj->$k = $v;
  1088. }
  1089. return $obj;
  1090. }
  1091. }
  1092. }
  1093. /**
  1094.  * Emulation of a Reflection class for PHP 4 only
  1095.  *
  1096.  * In PHP 5.1.3+ that could be made as:
  1097.  * $reflectionObj = new ReflectionClass($className);
  1098.  * $obj = $reflectionObj->newInstanceArgs($cp); 
  1099.  * But as mysql_fetch_object handles it already in PHP 5.0, it's not needed.
  1100.  *
  1101.  * @param  string  $className
  1102.  * @param  array   $cp
  1103.  * @return object
  1104.  */
  1105. function _m_new_class( $className, &$cp ) {
  1106. if ( $cp === null ) {
  1107. return new $className();
  1108. } elseif ( is_array( $cp ) ) {
  1109. switch ( count( $cp ) ) {
  1110. case 0:
  1111. return new $className();
  1112. break;
  1113. case 1:
  1114. return new $className( $cp[0] );
  1115. break;
  1116. case 2:
  1117. return new $className( $cp[0], $cp[1] );
  1118. break;
  1119. case 3:
  1120. return new $className( $cp[0], $cp[1], $cp[2] );
  1121. break;
  1122. case 4:
  1123. return new $className( $cp[0], $cp[1], $cp[2], $cp[3] );
  1124. break;
  1125. case 5:
  1126. return new $className( $cp[0], $cp[1], $cp[2], $cp[3], $cp[4] );
  1127. break;
  1128. case 6:
  1129. return new $className( $cp[0], $cp[1], $cp[2], $cp[3], $cp[4], $cp[5] );
  1130. break;
  1131. case 7:
  1132. return new $className( $cp[0], $cp[1], $cp[2], $cp[3], $cp[4], $cp[5], $cp[6] );
  1133. break;
  1134. case 8:
  1135. return new $className( $cp[0], $cp[1], $cp[2], $cp[3], $cp[4], $cp[5], $cp[6], $cp[7] );
  1136. break;
  1137. case 9:
  1138. return new $className( $cp[0], $cp[1], $cp[2], $cp[3], $cp[4], $cp[5], $cp[6], $cp[7], $cp[8] );
  1139. break;
  1140. case 10:
  1141. return new $className( $cp[0], $cp[1], $cp[2], $cp[3], $cp[4], $cp[5], $cp[6], $cp[7], $cp[8], $cp[9] );
  1142. break;
  1144. default:
  1145. trigger_error( 'CBdatabase::m_fetch_object: constructor parameters count to large', E_USER_ERROR );
  1146. exit;
  1147. break;
  1148. }
  1149. }
  1150. }
  1151. function m_free_result( &$cur ) {
  1152. if ( is_object( $cur ) && get_class( $cur ) == 'mysqli_result' ) {
  1153. mysqli_free_result( $cur );
  1154. } else {
  1155. mysql_free_result( $cur );
  1156. }
  1157. }
  1158. } // class CBdatabase
  1160. // ----- NO MORE CLASSES OR FUNCTIONS PASSED THIS POINT -----
  1161. // Post class declaration initialisations
  1162. // some version of PHP don't allow the instantiation of classes
  1163. // before they are defined
  1165. global $_CB_database, $_CB_framework;
  1166. /** @global CBdatabase $_CB_Database */
  1167. $_CB_database = new CBdatabase( $_CB_framework->_cmsDatabase );
  1169. ?>