3 require_once
'interface/DatabaseInterface.php';
35 $this->_oDb = $oConnection;
51 $this->_oDb->setFetchMode($iFetchMode);
64 public function getDb($blType =
true)
73 public function getOne($sSql, $aParams = array(), $blType =
true)
75 return $this->
getDb($blType)->getOne($sSql, $aParams);
89 public function getArray($sSql, $aParams = array(), $blType =
true)
91 return $this->
getDb($blType)->getArray($sSql, $aParams);
97 public function getRow($sSql, $aParams = array(), $blType =
true)
99 return $this->
getDb($blType)->getRow($sSql, $aParams);
105 public function getAll($sSql, $aParams = array(), $blType =
true)
108 return $this->
getDb($blType)->getAll($sSql, $aParams);
114 public function select($sSql, $aParams = array(), $blType =
true)
116 return $this->
getDb($blType)->execute($sSql, $aParams);
131 public function getAssoc($sSql, $aParams = array(), $blType =
true)
133 return $this->
getDb($blType)->getAssoc($sSql, $aParams);
139 public function getCol($sSql, $aParams = array(), $blType =
true)
141 return $this->
getDb($blType)->getCol($sSql, $aParams);
147 public function selectLimit($sSql, $iRows = -1, $iOffset = -1, $aParams = array(), $blType =
true)
149 return $this->
getDb($blType)->SelectLimit($sSql, $iRows, $iOffset, $aParams);
155 public function execute($sSql, $aParams = array())
157 return $this->
getDb(
false)->execute($sSql, $aParams);
170 public function query($sSql, $aParams = array())
172 return $this->
getDb(
false)->Query($sSql, $aParams);
185 return $this->
getDb(
false)->Affected_Rows();
198 return $this->
getDb(
false)->ErrorNo();
211 return $this->
getDb(
false)->ErrorMsg();
225 return $this->
getDb(
false)->qstr($sValue);
233 return $this->
getDb(
false)->quote($sValue);
241 foreach ($aStrArray as $sKey => $sString) {
242 $aStrArray[$sKey] = $this->
quote($sString);
253 return $this->
getDb(
false)->MetaColumns($sTable);
268 return $this->
getDb(
false)->MetaColumnNames($sTable, $blNumIndexes);
276 return $this->
getDb(
false)->execute(
'START TRANSACTION');
284 return $this->
getDb(
false)->execute(
'COMMIT');
292 return $this->
getDb(
false)->execute(
'ROLLBACK');
302 $aLevels = array(
'READ UNCOMMITTED',
'READ COMMITTED',
'REPEATABLE READ',
'SERIALIZABLE');
303 if (in_array(strtoupper($sLevel), $aLevels)) {
304 $blResult = $this->
getDb(
false)->execute(
'SET TRANSACTION ISOLATION LEVEL ' . $sLevel);
317 public function UI($iPollSecs = 5)
319 $this->
getDb(
false)->UI($iPollSecs);
355 return $this->
getDb(
false)->Insert_ID();