��ѧۧݧ�ӧ�� ާ֧ߧ֧էا֧�

��ѧۧݧ�ӧ�� ާ֧ߧ֧էا֧� - ��֧էѧܧ�ڧ��ӧѧ�� - /home/alphpwcp/public_html/us/alphachat/lib/core/lhcore/lhdbtrait.php

��ѧ٧ѧ�
<?php trait erLhcoreClassDBTrait { public function setState(array $properties) { foreach ($properties as $key => $val) { $this->$key = $val; } } public function saveThis($params = array()) { $this->beforeSave($params); self::getSession()->saveOrUpdate($this, (isset($params['ignore']) ? $params['ignore'] : array()), (isset($params['update']) ? $params['update'] : array())); $this->afterSave($params); $this->clearCache(); } public function saveThisOnly($params = array()) { $this->beforeSave($params); self::getSession()->save($this, (isset($params['ignore']) ? $params['ignore'] : array()), (isset($params['update']) ? $params['update'] : array())); $this->afterSave($params); $this->clearCache(); } public function saveOrUpdate($params = array()) { $this->beforeSave($params); self::getSession()->saveOrUpdate($this, (isset($params['ignore']) ? $params['ignore'] : array()), (isset($params['update']) ? $params['update'] : array())); $this->afterSave($params); $this->clearCache(); } public function updateThis($params = array()) { $this->beforeUpdate($params); self::getSession()->update($this, (isset($params['ignore']) ? $params['ignore'] : array()), (isset($params['update']) ? $params['update'] : array())); $this->afterUpdate($params); $this->clearCache(); } public function removeThis() { $this->beforeRemove(); self::getSession()->delete($this); $this->afterRemove(); $this->clearCache(); } public function syncAndLock($columnsToSync = '') { if ($this->id === null) { return; } $db = ezcDbInstance::get(); $stmt = $db->prepare('SELECT ' . $columnsToSync . ' FROM ' . self::$dbTable . ' WHERE id = :id FOR UPDATE;'); $stmt->bindValue(':id', $this->id); $stmt->execute(); $data = $stmt->fetch(PDO::FETCH_ASSOC); if (is_array($data)) { $this->setState($data); } } public function beforeSave($params = array()) { } public function beforeUpdate($params = array()) { } public function beforeRemove() { } public function afterSave($params = array()) { } public function afterUpdate($params = array()) { } public function afterRemove() { } public function refreshThis() { self::getSession()->refresh($this); } public function clearCache() { $cache = CSCacheAPC::getMem(); $cache->increaseCacheVersion('site_attributes_version_' . strtolower(__CLASS__)); if (isset($this->id)) { $cache->delete('object_' . strtolower(__CLASS__) . '_' . $this->id); if (isset($GLOBALS[__CLASS__ . $this->id])) { unset($GLOBALS[__CLASS__ . $this->id]); } } $this->clearCacheClassLevel(); } public function clearCacheClassLevel() { } public function getFields() { return include 'lib/core/lhabstract/fields/' . strtolower(__CLASS__) . '.php'; } public static function getSession() { static $dbHandler = false; $url = './'; if (isset(self::$dbSessionHandlerUrl) && self::$dbSessionHandlerUrl != '') { $url = self::$dbSessionHandlerUrl; } if ($dbHandler === false) { $dbHandler = call_user_func(self::$dbSessionHandler, $url); } return $dbHandler; } public static function fetch($id, $useCache = true, $throwException = false) { if (isset($GLOBALS[__CLASS__ . $id]) && $useCache == true) return $GLOBALS[__CLASS__ . $id]; if ($throwException == false) { try { $object = self::getSession()->load(__CLASS__, $id); } catch (Exception $e) { $object = false; } } else { $object = self::getSession()->load(__CLASS__, $id); } if ($useCache == false) { return $object; } $GLOBALS[__CLASS__ . $id] = $object; return $GLOBALS[__CLASS__ . $id]; } public static function fetchAndLock($id, $useCache = false) { if (isset($GLOBALS[__CLASS__ . $id]) && $useCache == true) return $GLOBALS[__CLASS__ . $id]; try { $GLOBALS[__CLASS__ . $id] = self::getSession()->loadAndLock(__CLASS__, $id); } catch (Exception $e) { $GLOBALS[__CLASS__ . $id] = false; } return $GLOBALS[__CLASS__ . $id]; } /* * Similar to above just uses memcache if available * */ public static function fetchCache($id) { $cache = CSCacheAPC::getMem(); $cacheKey = 'object_' . strtolower(__CLASS__) . '_' . $id; if (($object = $cache->restore($cacheKey)) === false) { $object = self::fetch($id, true); $cache->store($cacheKey, $object); } return $object; } public static function isOwner($id, $skipChecking = false) { $obj = self::fetch($id); if ($skipChecking == true) return $obj; $currentUser = erLhcoreClassUser::instance(); if ($obj->user_id == $currentUser->getUserID()) return $obj; return false; } public static function findOne($paramsSearch = array()) { $paramsSearch['limit'] = 1; $list = self::getList($paramsSearch); if (!empty($list)) { reset($list); return current($list); } return false; } public static function estimateRows() { $db = ezcDbInstance::get(); $stmt = $db->prepare("SELECT `table_rows` FROM `information_schema`.`tables` WHERE `table_schema` = :table_schema AND `table_name` = :table_name"); $stmt->bindValue(':table_schema',erConfigClassLhConfig::getInstance()->getSetting( 'db', 'database' ),PDO::PARAM_STR); $stmt->bindValue(':table_name',self::$dbTable,PDO::PARAM_STR); $stmt->execute(); return $stmt->fetch(PDO::FETCH_COLUMN); } public static function getCount($params = array(), $operation = 'COUNT', $field = false, $rawSelect = false, $fetchColumn = true, $fetchAll = false, $fetchColumnAll = false, $groupedCount = false) { if (isset($params['enable_sql_cache']) && $params['enable_sql_cache'] == true) { $sql = erLhcoreClassModuleFunctions::multi_implode(',', $params); $cache = CSCacheAPC::getMem(); $cacheKey = isset($params['cache_key']) ? md5($operation . $field . $sql . $params['cache_key']) : md5('objects_count_' . strtolower(__CLASS__) . '_v_' . $cache->getCacheVersion('site_attributes_version_' . strtolower(__CLASS__)) . $sql . $operation . $field); if (($result = $cache->restore($cacheKey)) !== false) { return $result; } } $session = self::getSession(); $q = $session->database->createSelectQuery(); if ($rawSelect === false) { $q->select($operation . "(" . self::$dbTable . "." . ($field === false ? self::$dbTableId : $field) . ")")->from(self::$dbTable); } else { $q->select($rawSelect)->from(self::$dbTable); } $conditions = self::getConditions($params, $q); if (count($conditions) > 0) { $q->where($conditions); } if (isset($params['limit']) && $params['limit'] !== false) { $q->limit($params['limit'], (isset($params['offset']) ? $params['offset'] : 0)); } if (isset($params['sort']) && $params['sort'] !== false) { $q->orderBy($params['sort']); } $stmt = $q->prepare(); $stmt->execute(); // I know I should use sub select, but just no time for that. Only canned messages is using that thing if ($groupedCount === true) { return count($stmt->fetchAll(PDO::FETCH_COLUMN)); } if ($fetchColumn == true) { $result = $stmt->fetchColumn(); } elseif ($fetchAll == true) { $result = $stmt->fetchAll($fetchColumnAll === false ? PDO::FETCH_ASSOC : PDO::FETCH_COLUMN); } else { $result = $stmt->fetch(PDO::FETCH_ASSOC); } if (isset($params['enable_sql_cache']) && $params['enable_sql_cache'] == true) { $cache->store($cacheKey, $result); } return $result; } public static function getList($paramsSearch = array()) { $paramsDefault = array('limit' => 500, 'offset' => 0); $params = array_merge($paramsDefault, $paramsSearch); if (isset($params['enable_sql_cache']) && $params['enable_sql_cache'] == true) { $sql = self::multi_implode(',', $params); $cache = CSCacheAPC::getMem(); $cacheKey = isset($params['cache_key']) ? md5($sql . $params['cache_key']) : md5('objects_list_' . strtolower(__CLASS__) . '_v_' . $cache->getCacheVersion('site_attributes_version_' . strtolower(__CLASS__)) . $sql); if (($result = $cache->restore($cacheKey)) !== false) { return $result; } } $session = self::getSession(); $q = $session->createFindQuery(__CLASS__, isset($params['ignore_fields']) ? $params['ignore_fields'] : array()); $conditions = self::getConditions($params, $q); if (count($conditions) > 0) { $q->where($conditions); } if (isset($params['lock']) && $params['lock'] == true) { $q->doLock(); } if ($params['limit'] !== false) { $q->limit($params['limit'], $params['offset']); } if (!isset($params['sort']) \|\| $params['sort'] !== false) { if (isset(self::$dbDefaultSort)) { $q->orderBy(isset($params['sort']) ? $params['sort'] : self::$dbDefaultSort); } else { $q->orderBy(isset($params['sort']) ? $params['sort'] : self::$dbTable . "." . self::$dbTableId . " " . self::$dbSortOrder); } } $objects = $session->find($q); if (isset($params['prefill_attributes'])) { foreach ($params['prefill_attributes'] as $attr => $prefillOptions) { $teamsId = array(); foreach ($objects as $object) { $teamsId[] = $object->$prefillOptions['attr_id']; } if (!empty($teamsId)) { $teams = call_user_func($object->$prefillOptions['function'], array('limit' => false, 'sort' => false, 'filterin' => array('id' => $teamsId))); foreach ($objects as & $object) { if (isset($teams[$object->$prefillOptions['attr_id']])) { $object->$prefillOptions['attr_name'] = $teams[$object->$prefillOptions['attr_id']]; } } } } } if (isset($params['enable_sql_cache']) && $params['enable_sql_cache'] == true) { if (isset($params['sql_cache_timeout'])) { $cache->store($cacheKey, $objects, $params['sql_cache_timeout']); } else { $cache->store($cacheKey, $objects); } } return $objects; } public static function getConditions($params, $q) { $conditions = array(); if (isset($params['filter']) && count($params['filter']) > 0) { foreach ($params['filter'] as $field => $fieldValue) { if (is_array($fieldValue)) { if (!empty($fieldValue)) { $conditions[] = $q->expr->in($field, $fieldValue); } } else { $conditions[] = $q->expr->eq($field, $q->bindValue($fieldValue)); } } } if (isset($params['filterfields']) && count($params['filterfields']) > 0) { foreach ($params['filterfields'] as $combination) { foreach ($combination as $field => $fieldValue) { if (is_array($fieldValue)) { if (!empty($fieldValue)) { $conditions[] = $q->expr->in($field, $fieldValue); } } else { $conditions[] = $q->expr->eq($field, $q->bindValue($fieldValue)); } } } } if (isset($params['filterin']) && count($params['filterin']) > 0) { foreach ($params['filterin'] as $field => $fieldValue) { if (empty($fieldValue)) { break; } else { $conditions[] = $q->expr->in($field, $fieldValue); } } } if (isset($params['filterinfields']) && count($params['filterinfields']) > 0) { foreach ($params['filterinfields'] as $combination) { foreach ($combination as $field => $fieldValue) { if (empty($fieldValue)) { break; } else { $conditions[] = $q->expr->in($field, $fieldValue); } } } } if (isset($params['filterlt']) && count($params['filterlt']) > 0) { foreach ($params['filterlt'] as $field => $fieldValue) { $conditions[] = $q->expr->lt($field, $q->bindValue($fieldValue)); } } if (isset($params['filterltfields']) && count($params['filterltfields']) > 0) { foreach ($params['filterltfields'] as $combination) { foreach ($combination as $field => $fieldValue){ $conditions[] = $q->expr->lt($field, $q->bindValue($fieldValue)); } } } if (isset($params['filtergt']) && count($params['filtergt']) > 0) { foreach ($params['filtergt'] as $field => $fieldValue) { $conditions[] = $q->expr->gt($field, $q->bindValue($fieldValue)); } } if (isset($params['filtergtfields']) && count($params['filtergtfields']) > 0) { foreach ($params['filtergtfields'] as $combination) { foreach ($combination as $field => $fieldValue) { $conditions[] = $q->expr->gt($field, $q->bindValue($fieldValue)); } } } if (isset($params['filtergte']) && count($params['filtergte']) > 0) { foreach ($params['filtergte'] as $field => $fieldValue) { $conditions[] = $q->expr->gte($field, $q->bindValue($fieldValue)); } } if (isset($params['filtergtenbind']) && count($params['filtergtenbind']) > 0) { foreach ($params['filtergtenbind'] as $field => $fieldValue) { $conditions[] = $q->expr->gte($field, $fieldValue); } } if (isset($params['filtergtefields']) && count($params['filtergtefields']) > 0) { foreach ($params['filtergtefields'] as $combination) { foreach ($combination as $field => $fieldValue) { $conditions[] = $q->expr->gte($field, $q->bindValue($fieldValue)); } } } if (isset($params['filterlte']) && count($params['filterlte']) > 0) { foreach ($params['filterlte'] as $field => $fieldValue) { $conditions[] = $q->expr->lte($field, $q->bindValue($fieldValue)); } } if (isset($params['filterltenbind']) && count($params['filterltenbind']) > 0) { foreach ($params['filterltenbind'] as $field => $fieldValue) { $conditions[] = $q->expr->lte($field, $fieldValue); } } if (isset($params['filterltefields']) && count($params['filterltefields']) > 0) { foreach ($params['filterltefields'] as $combination) { foreach ($combination as $field => $fieldValue) { $conditions[] = $q->expr->lte($field, $q->bindValue($fieldValue)); } } } if (isset($params['filternot']) && count($params['filternot']) > 0) { foreach ($params['filternot'] as $field => $fieldValue) { if (is_array($fieldValue)) { if (!empty($fieldValue)) { $conditions[] = $q->expr->not($q->expr->in($field, $fieldValue)); } } else { $conditions[] = $q->expr->neq($field, $q->bindValue($fieldValue)); } } } if (isset($params['filternotfields']) && count($params['filternotfields']) > 0) { foreach ($params['filternotfields'] as $combination) { foreach ($combination as $field => $fieldValue) { $conditions[] = $q->expr->neq($field, $q->bindValue($fieldValue)); } } } if (isset($params['filterall']) && count($params['filterall']) > 0) { foreach ($params['filterall'] as $field => $fieldValue) { $conditions[] = $q->expr->allin($field, $fieldValue); } } if (isset($params['filterlike']) && count($params['filterlike']) > 0) { foreach ($params['filterlike'] as $field => $fieldValue) { $conditions[] = $q->expr->like($field, $q->bindValue('%' . $fieldValue . '%')); } } if (isset($params['filterlikefields']) && count($params['filterlikefields']) > 0) { foreach ($params['filterlikefields'] as $combination) { foreach ($combination as $field => $fieldValue) { $conditions[] = $q->expr->like($field, $q->bindValue('%' . $fieldValue . '%')); } } } if (isset($params['filternotlikefields']) && count($params['filternotlikefields']) > 0) { foreach ($params['filternotlikefields'] as $combination) { foreach ($combination as $field => $fieldValue) { $conditions[] = $q->expr->not($q->expr->like($field, $q->bindValue('%' . $fieldValue . '%'))); } } } if (isset($params['filterlikeright']) && count($params['filterlikeright']) > 0) { foreach ($params['filterlikeright'] as $field => $fieldValue) { $conditions[] = $q->expr->like($field, $q->bindValue($fieldValue . '%')); } } if (isset($params['leftjoin']) && count($params['leftjoin']) > 0) { foreach ($params['leftjoin'] as $table => $joinOn) { $q->leftJoin($table, $q->expr->eq($joinOn[0], $joinOn[1])); } } if (isset($params['leftjoinraw']) && count($params['leftjoinraw']) > 0) { foreach ($params['leftjoinraw'] as $table => $joinOn) { $q->leftJoin($table, $joinOn); } } if (isset($params['innerjoinsame']) && count($params['innerjoinsame']) > 0) { foreach ($params['innerjoinsame'] as $table => $joinOn) { $q->innerJoin($q->alias($table, 't2'), $q->expr->eq($joinOn[0], $joinOn[1])); } } if (isset($params['filterlor']) && count($params['filterlor']) > 0) { $conditionsLor = array(); foreach ($params['filterlor'] as $field => $fieldValue) { foreach ($fieldValue as $fv) { $conditionsLor[] = $q->expr->eq($field, $q->bindValue($fv)); } } $conditions[] = $q->expr->lOr($conditionsLor); } if (isset($params['filterlorf']) && count($params['filterlorf']) > 0) { $conditionsLor = array(); foreach ($params['filterlorf'] as $field => $fieldValue) { foreach ($fieldValue as $fv) { $conditionsLor[] = $q->expr->eq($fv, $q->bindValue($field)); } } $conditions[] = $q->expr->lOr($conditionsLor); } if (isset($params['filternotin']) && count($params['filternotin']) > 0) { foreach ($params['filternotin'] as $field => $fieldValue) { if (!empty($fieldValue)) { $conditions[] = $q->expr->not($q->expr->in($field, $fieldValue)); } } } if (isset($params['filter_custom']) && count($params['filter_custom']) > 0) { foreach ($params['filter_custom'] as $fieldValue) { $conditions[] = $fieldValue; } } if (isset($params['customfilter']) && count($params['customfilter']) > 0) { foreach ($params['customfilter'] as $fieldValue) { $conditions[] = $fieldValue; } } if (isset($params['innerjoin']) && count($params['innerjoin']) > 0) { foreach ($params['innerjoin'] as $table => $joinOn) { $q->innerJoin($table, $q->expr->eq($joinOn[0], $joinOn[1])); } } if (isset($params['leftouterjoin']) && count($params['leftouterjoin']) > 0) { foreach ($params['leftouterjoin'] as $table => $joinOn) { $q->leftOuterJoin($table, $joinOn); } } if (isset($params['group']) && $params['group'] != '') { $q->groupBy($params['group']); } if (isset($params['having']) && $params['having'] != '') { $q->having($params['having']); } if (isset($params['use_index'])) { $q->useIndex($params['use_index']); } if (isset($params['select_columns']) && !empty($params['select_columns'])) { $q->select($params['select_columns']); } return $conditions; } public static function multi_implode($glue, $pieces, $key = null) { $string = ''; if (is_array($pieces)) { reset($pieces); foreach ($pieces as $key => $value) { $string .= $key . '_' . $glue . self::multi_implode($glue, $value, $key); } } else { return "{$key}_{$pieces}"; } return trim($string, $glue); } } ?>

| ver. 1.4 | Github | . | PHP 8.2.30 | ��֧ߧ֧�ѧ�ڧ� ��ѧߧڧ��: 0 | proxy | phpinfo | ��ѧ��ۧܧ�