PHP实例开发源码—EasySNS 极简社区源码(小组版) PHP版.zip

<?php namespace esclass; use PDO; use PDOStatement; use PDOException; use RuntimeException; use InvalidArgumentException; class database { const VERSION = '1.0.1'; private static $_instance; /** * @var PDO */ protected $pdo; protected $pk; /** * @var PDOStatement */ protected $statement; /** * Database config * * @var array */ protected $dbConfig = array(); /** * SQL statement options * * @var array */ protected $options = array(); /** * SQL binding data * * @var array */ protected $bindData = array(); protected $model = array(); /** * Fetch the SQL statement? * * @var boolean */ protected $fetchSql = false; public $render = ''; /** * Is escape identifiers? * * @var boolean */ protected $escape = true; /** * SQL query logs * * @var array */ protected $queryLog = array(); /** * Constructor * Connect to the database server * * @param array $config * @throws PDOException */ private function __construct(array $config=[]) { if(empty($config)){ $config=config('database'); } if (!isset($config['options'])) { $config['options'] = array(); } if (isset($config['socket']) && $config['socket']) { $dsn = 'mysql:unix_socket=' . trim($config['socket']); } else { $dsn = 'mysql:host=' . trim($config['host']); if (isset($config['port']) && is_int($config['port'] * 1)) { $dsn .= ';port=' . $config['port']; } } if (isset($config['dbname']) && $config['dbname']) { $dsn .= ';dbname=' . trim($config['dbname']); } if (isset($config['charset']) && $config['charset']) { $dsn .= ';charset=' . trim($config['charset']); } try { $this->pdo = new PDO($dsn, trim($config['username']), $config['password'], $config['options']); } catch (PDOException $e) { throw $e; } $this->dbConfig = $config; } private function __clone() { }//覆盖__clone()方法，禁止克隆 public static function getInstance() { if(! (self::$_instance instanceof self) ) { self::$_instance = new self(); } return self::$_instance; } /** * Config database * * @param mixed $config * @param string $value * @return mixed */ public function dbConfig($config = null, $value = null) { if (!$config) { return $this->dbConfig; } elseif (is_array($config)) { $this->dbConfig = array_merge($this->dbConfig, $config); } elseif (is_string($config)) { if (is_null($value)) { return isset($this->dbConfig[$config]) ? $this->dbConfig[$config] : null; } else { $this->dbConfig[$config] = $value; return true; } } return null; } /** * Sets the database name * * @param string $dbname * @return self */ public function dbname($dbname) { $this->dbConfig['dbname'] = $dbname; return $this; } public function render($render='') { if(!empty($render)){ $this->render = $render; }else{ return $this->render; } } /** * Sets whether the distinct * * @param boolean $distinct * @return self */ public function distinct($distinct) { $this->options['distinct'] = (bool) $distinct; return $this; } /** * Parse the `DISTINCT` statement * * @access protected * @param boolean $distinct * @return string */ protected function parseDistinct($distinct) { return $distinct ? ' DISTINCT' : ''; } /** * Sets the select expression * * @param mixed $field The select expressions * @return self */ public function field($field) { if (is_string($field)) { $this->options['field'] = trim($field); } elseif (is_array($field)) { if (isset($this->options['field']) && is_array($this->options['field'])) { $this->options['field'] = array_merge($this->options['field'], $field); } else { $this->options['field'] = $field; } } elseif (is_scalar($field)) { $this->options['field'] = $field; } else { $this->options['field'] = '*'; } return $this; } /** * Parse the `SELECT EXPR` * * @access protected * @param mixed $fields Select expressions * @return string */ protected function parseField($fields) { $fieldsStr = '*'; if ('*' == $fields || !$fields) { $fieldsStr = '*'; } elseif (is_string($fields)) { // Ignore the special characters $chars = array('(', ')', ' AS ', '='); foreach ($chars as $char) { if (stripos($fields, $char) !== false) { return $fields; } } $fieldsStr = $this->quoteKey($fields); } elseif (is_array($fields)) { $array = array(); foreach ($fields as $key => $field) { if (!is_numeric($key) && $key) { $array[] = (strpos($field, '*') !== false ? $field : $this->quoteKey($field)) . ' AS ' . $this->quoteKey($key); } else { $array[] = $this->quoteKey($field); } } $fieldsStr = implode(', ', $array); } elseif (is_scalar($fields)) { $fieldsStr = $fields; } return $fieldsStr; } /** * Sets the table name for current statement * * @param mixed $table Table name * @param string $alias Table alias * @param boolean $prefix The prefix of table name * @return self */ public function table($table, $alias = null, $prefix = true) { if (is_string($table) && $table) { $tableName = trim($table); } elseif (is_array($table)) { $tableName = array_shift($table); if (!$alias && count($table) >= 1) { $alias = array_shift($table); } if (empty($tableName)) { throw new InvalidArgumentException('Unexpected empty value for "table"'); } } else { throw new InvalidArgumentException('Invalid argument for "table"'); } // Global prefix if (is_bool($prefix) && $prefix && !empty($this->dbConfig['prefix'])) { $tableName = $this->dbConfig['prefix'] . $tableName; } elseif (is_string($prefix) && $prefix) { // Custom prefix $tableName = trim($prefix) . $tableName; } // Filter alias if ($alias) { $alias = trim($alias); } if (!preg_match('/^([a-zA-Z0-9_]+)$/i', $alias)) { $alias = null; } $this->options['table'] = array($tableName, $alias); return $this; } /** * Parse the real table name that contains database * * @access protected * @param array $table * @return string */ protected function parseTable($table) { list($tableName, $alias) = $table; $tableName =camelcase2underline($tableName); if (!empty($this->dbConfig['dbname']) && strpos($tableName, '.') !== false) { $tableName = $this->dbConfig['dbname'] . '.' . $tableName; } $tabl