<?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()
{
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
2019千月双端,花钱买的,分享了 (2000个子文件)
index.html.bak 6KB
web.config 577B
dx.ios.default.css 780KB
xenon.css 766KB
dx.ios7.default.css 316KB
xenon-skins.css 274KB
amazeui.min.css 249KB
light-bootstrap-dashboard.css 224KB
pop.css 208KB
xenon-core.css 192KB
dx.win8.black.css 191KB
dx.win8.white.css 186KB
dx.light.css 178KB
dx.dark.css 174KB
xenon-components.css 170KB
uikit.gradient.css 157KB
uikit.almost-flat.css 153KB
dx.android.holo-light.css 151KB
dx.android.holo-dark.css 150KB
uikit.css 144KB
bootstrap.css 135KB
bootstrap.css 130KB
bootstrap.min.css 120KB
product.css 117KB
elusive-embedded.css 116KB
cart2main.css 108KB
style_xc.css 100KB
style.css 99KB
bootstrap.css 94KB
dx.common.css 94KB
uikit.css 89KB
uikit.gradient.min.css 84KB
uikit.almost-flat.min.css 81KB
bootstrap.min.css 80KB
aui.css 76KB
uikit.min.css 75KB
style_user.css 74KB
xenon-forms.css 71KB
animate.css 70KB
layui.css 68KB
aui.css 65KB
linecons-embedded.css 65KB
aui.css 63KB
qicai_aui.css 61KB
style_qicai.css 60KB
animate.min.css 60KB
layui.css 59KB
uikit.css 50KB
meteocons-embedded.css 38KB
app.css 38KB
style.css 38KB
editor_ie7.css 37KB
editor_iequirks.css 36KB
editor_ie8.css 36KB
editor_ie.css 35KB
editor_gecko.css 35KB
editor.css 34KB
editor.css 34KB
m-common.css 34KB
uikit.gradient.addons.css 33KB
uikit.almost-flat.addons.css 32KB
font-awesome.min.css 30KB
uikit.addons.css 29KB
style.css 29KB
elusive-ie7.css 28KB
elusive-ie7-codes.css 28KB
font-awesome.css 28KB
ratchet.min.css 23KB
zhibo.css 22KB
fullcalendar.css 22KB
font-awesome.min.css 21KB
_all.css 21KB
select2.css 20KB
jquery.dataTables.css 17KB
dialog_ie7.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
_all.css 15KB
elusive-codes.css 15KB
_all.css 15KB
uikit.almost-flat.addons.min.css 14KB
layer.css 14KB
layer.css 14KB
layer.css 14KB
editor_ie7.css 14KB
editor_ie.css 13KB
editor_iequirks.css 13KB
bootstrap-responsive.css 13KB
spectrum.css 13KB
_all.css 13KB
editor_ie8.css 13KB
editor_gecko.css 13KB
rwd-table.css 12KB
uikit.addons.min.css 12KB
jquery.dataTables_themeroller.css 12KB
共 2000 条
- 1
- 2
- 3
- 4
- 5
- 6
- 20
资源评论
- weixin_410135892019-05-14老板,这个需要授权,还需要自主购买授权码吗
- wanyoulin2019-05-07老板发个数据库和教程给我谢谢 120602347@qq.com 没有数据库就用不了
点点【年底快递即将停运】
- 粉丝: 5
- 资源: 2
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功