<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006~2017 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: liu21st <liu21st@gmail.com>
// +----------------------------------------------------------------------
namespace think\db;
use PDO;
use think\Cache;
use think\Collection;
use think\Config;
use think\Db;
use think\db\exception\BindParamException;
use think\db\exception\DataNotFoundException;
use think\db\exception\ModelNotFoundException;
use think\Exception;
use think\exception\DbException;
use think\exception\PDOException;
use think\Loader;
use think\Model;
use think\model\Relation;
use think\model\relation\OneToOne;
use think\Paginator;
class Query
{
// 数据库Connection对象实例
protected $connection;
// 数据库Builder对象实例
protected $builder;
// 当前模型类名称
protected $model;
// 当前数据表名称(含前缀)
protected $table = '';
// 当前数据表名称(不含前缀)
protected $name = '';
// 当前数据表主键
protected $pk;
// 当前数据表前缀
protected $prefix = '';
// 查询参数
protected $options = [];
// 参数绑定
protected $bind = [];
// 数据表信息
protected static $info = [];
// 回调事件
private static $event = [];
/**
* 构造函数
* @access public
* @param Connection $connection 数据库对象实例
* @param string $model 模型名
*/
public function __construct(Connection $connection = null, $model = '')
{
$this->connection = $connection ?: Db::connect([], true);
$this->prefix = $this->connection->getConfig('prefix');
$this->model = $model;
// 设置当前连接的Builder对象
$this->setBuilder();
}
/**
* 利用__call方法实现一些特殊的Model方法
* @access public
* @param string $method 方法名称
* @param array $args 调用参数
* @return mixed
* @throws DbException
* @throws Exception
*/
public function __call($method, $args)
{
if (strtolower(substr($method, 0, 5)) == 'getby') {
// 根据某个字段获取记录
$field = Loader::parseName(substr($method, 5));
$where[$field] = $args[0];
return $this->where($where)->find();
} elseif (strtolower(substr($method, 0, 10)) == 'getfieldby') {
// 根据某个字段获取记录的某个值
$name = Loader::parseName(substr($method, 10));
$where[$name] = $args[0];
return $this->where($where)->value($args[1]);
} else {
throw new Exception('method not exist:' . __CLASS__ . '->' . $method);
}
}
/**
* 获取当前的数据库Connection对象
* @access public
* @return Connection
*/
public function getConnection()
{
return $this->connection;
}
/**
* 切换当前的数据库连接
* @access public
* @param mixed $config
* @return $this
*/
public function connect($config)
{
$this->connection = Db::connect($config);
$this->setBuilder();
return $this;
}
/**
* 设置当前的数据库Builder对象
* @access protected
* @return void
*/
protected function setBuilder()
{
$class = $this->connection->getBuilder();
$this->builder = new $class($this->connection, $this);
}
/**
* 获取当前的模型对象名
* @access public
* @return string
*/
public function getModel()
{
return $this->model;
}
/**
* 获取当前的builder实例对象
* @access public
* @return Builder
*/
public function getBuilder()
{
return $this->builder;
}
/**
* 指定默认的数据表名(不含前缀)
* @access public
* @param string $name
* @return $this
*/
public function name($name)
{
$this->name = $name;
return $this;
}
/**
* 指定默认数据表名(含前缀)
* @access public
* @param string $table 表名
* @return $this
*/
public function setTable($table)
{
$this->table = $table;
return $this;
}
/**
* 得到当前或者指定名称的数据表
* @access public
* @param string $name
* @return string
*/
public function getTable($name = '')
{
if ($name || empty($this->table)) {
$name = $name ?: $this->name;
$tableName = $this->prefix;
if ($name) {
$tableName .= Loader::parseName($name);
}
} else {
$tableName = $this->table;
}
return $tableName;
}
/**
* 将SQL语句中的__TABLE_NAME__字符串替换成带前缀的表名(小写)
* @access public
* @param string $sql sql语句
* @return string
*/
public function parseSqlTable($sql)
{
if (false !== strpos($sql, '__')) {
$prefix = $this->prefix;
$sql = preg_replace_callback("/__([A-Z0-9_-]+)__/sU", function ($match) use ($prefix) {
return $prefix . strtolower($match[1]);
}, $sql);
}
return $sql;
}
/**
* 执行查询 返回数据集
* @access public
* @param string $sql sql指令
* @param array $bind 参数绑定
* @param boolean $master 是否在主服务器读操作
* @param bool|string $class 指定返回的数据集对象
* @return mixed
* @throws BindParamException
* @throws PDOException
*/
public function query($sql, $bind = [], $master = false, $class = false)
{
return $this->connection->query($sql, $bind, $master, $class);
}
/**
* 执行语句
* @access public
* @param string $sql sql指令
* @param array $bind 参数绑定
* @return int
* @throws BindParamException
* @throws PDOException
*/
public function execute($sql, $bind = [])
{
return $this->connection->execute($sql, $bind);
}
/**
* 获取最近插入的ID
* @access public
* @param string $sequence 自增序列名
* @return string
*/
public function getLastInsID($sequence = null)
{
return $this->connection->getLastInsID($sequence);
}
/**
* 获取最近一次查询的sql语句
* @access public
* @return string
*/
public function getLastSql()
{
return $this->connection->getLastSql();
}
/**
* 执行数据库事务
* @access public
* @param callable $callback 数据操作方法回调
* @return mixed
*/
public function transaction($callback)
{
return $this->connection->transaction($callback);
}
/**
* 启动事务
* @access public
* @return void
*/
public function startTrans()
{
$this->connection->startTrans();
}
/**
* 用于非自动提交状态下面的查询提交
* @access public
* @return void
* @throws PDOException
*/
public function commit()
{
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
双端影视APP源码【美化过】 (2000个子文件)
fb60d5fd34351b374b15627566e53f5c.bmp 153KB
web.config 577B
dx.ios.default.css 775KB
xenon.css 744KB
dx.ios7.default.css 311KB
xenon-skins.css 267KB
amazeui.min.css 249KB
light-bootstrap-dashboard.css 215KB
dx.win8.black.css 188KB
xenon-core.css 185KB
dx.win8.white.css 182KB
dx.light.css 174KB
dx.dark.css 170KB
xenon-components.css 164KB
uikit.gradient.css 150KB
dx.android.holo-light.css 148KB
dx.android.holo-dark.css 147KB
uikit.almost-flat.css 146KB
uikit.css 138KB
bootstrap.css 129KB
bootstrap.css 124KB
bootstrap.min.css 120KB
elusive-embedded.css 115KB
style.css 99KB
bootstrap.css 90KB
dx.common.css 90KB
uikit.css 84KB
uikit.gradient.min.css 84KB
uikit.almost-flat.min.css 81KB
bootstrap.min.css 79KB
uikit.min.css 75KB
style_user.css 74KB
xenon-forms.css 68KB
animate.css 67KB
linecons-embedded.css 65KB
aui.css 63KB
aui.css 61KB
animate.min.css 60KB
uikit.css 48KB
meteocons-embedded.css 38KB
editor_ie7.css 37KB
app.css 36KB
style.css 36KB
editor_iequirks.css 36KB
editor_ie8.css 36KB
editor_ie.css 35KB
editor_gecko.css 35KB
editor.css 34KB
editor.css 34KB
uikit.gradient.addons.css 32KB
uikit.almost-flat.addons.css 31KB
font-awesome.min.css 30KB
elusive-ie7.css 28KB
uikit.addons.css 28KB
elusive-ie7-codes.css 28KB
font-awesome.css 26KB
zhibo.css 22KB
font-awesome.min.css 21KB
fullcalendar.css 21KB
_all.css 20KB
select2.css 19KB
dialog_ie7.css 17KB
jquery.dataTables.css 17KB
dialog_ie8.css 17KB
dialog_iequirks.css 16KB
dialog_ie.css 16KB
elusive.css 16KB
dialog.css 16KB
uikit.gradient.addons.min.css 15KB
jquery.dataTables.min.css 15KB
elusive-codes.css 14KB
uikit.almost-flat.addons.min.css 14KB
layer.css 14KB
_all.css 14KB
_all.css 14KB
editor_ie7.css 14KB
editor_ie.css 13KB
editor_iequirks.css 13KB
editor_ie8.css 13KB
editor_gecko.css 13KB
uikit.addons.min.css 12KB
spectrum.css 12KB
_all.css 12KB
bootstrap-responsive.css 12KB
rwd-table.css 12KB
jquery.dataTables_themeroller.css 12KB
dropzone.css 11KB
rwd-table.min.css 11KB
dialog_ie.css 10KB
dataTables.tableTools.css 10KB
dialog_ie7.css 10KB
swiper.min.css 10KB
dialog_ie8.css 10KB
dialog_opera.css 10KB
base.css 10KB
fullcalendar.min.css 10KB
dialog_iequirks.css 10KB
dialog.css 10KB
demo.css 10KB
pe-icon-7-stroke.css 9KB
共 2000 条
- 1
- 2
- 3
- 4
- 5
- 6
- 20
资源评论
- wndex2019-08-12加密的文件
视界汇科技
- 粉丝: 151
- 资源: 51
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功