thinkphp5.x之数据库操作相关解析 Db类

风.fox
thinkphp5.x之Collection(集合)解析 php集合
http://blog.csdn.net/fenglailea/article/details/52723586
thinkphp5 数据库 链接
http://blog.csdn.net/fenglailea/article/details/52728899

db函数

本函数没什么好说,直接PASS

/**
     * 实例化数据库类
     * @param string        $name 操作的数据表名称(不含前缀)
     * @param array|string  $config 数据库配置参数
     * @param bool          $force 是否强制重新连接
     * @return \think\db\Query
     */
    function db($name = '', $config = [], $force = true)
    {
        return Db::connect($config, $force)->name($name);
    }

Db类

// 命名空间
namespace think;
// 框架入口
use think\App;
// 数据集
use think\Collection;
// 数据库操作动作类
use think\db\Query;
// 分页数据集 处理类
use think\paginator\Collection as PaginatorCollection;

/**
 * 这里就看出你的开发工具是否强大了。其他地方调用该类,都会有类的方法提示
 * Class Db
 * @package think
 * @method Query table(string $table) static 指定数据表(含前缀)
 * @method Query name(string $name) static 指定数据表(不含前缀)
 * @method Query where(mixed $field, string $op = null, mixed $condition = null) static 查询条件
 * @method Query join(mixed $join, mixed $condition = null, string $type = 'INNER') static JOIN查询
 * @method Query union(mixed $union, boolean $all = false) static UNION查询
 * @method Query limit(mixed $offset, integer $length = null) static 查询LIMIT
 * @method Query order(mixed $field, string $order = null) static 查询ORDER
 * @method Query cache(mixed $key = true , integer $expire = null) static 设置查询缓存
 * @method mixed value(string $field) static 获取某个字段的值
 * @method array column(string $field, string $key = '') static 获取某个列的值
 * @method Query view(mixed $join, mixed $field = null, mixed $on = null, string $type = 'INNER') static 视图查询
 * @method mixed find(mixed $data = []) static 查询单个记录
 * @method mixed select(mixed $data = []) static 查询多个记录
 * @method integer insert(array $data, boolean $replace = false, boolean $getLastInsID = false, string $sequence = null) static 插入一条记录
 * @method integer insertGetId(array $data, boolean $replace = false, string $sequence = null) static 插入一条记录并返回自增ID
 * @method integer insertAll(array $dataSet) static 插入多条记录
 * @method integer update(array $data) static 更新记录
 * @method integer delete(mixed $data = []) static 删除记录
 * @method boolean chunk(integer $count, callable $callback, string $column = null) static 分块获取数据
 * @method mixed query(string $sql, array $bind = [], boolean $fetch = false, boolean $master = false, mixed $class = false) static SQL查询
 * @method integer execute(string $sql, array $bind = [], boolean $fetch = false, boolean $getLastInsID = false, string $sequence = null) static SQL执行
 * @method PaginatorCollection paginate(integer $listRows = 15, mixed $simple = false, array $config = []) static 分页查询
 * @method mixed transaction(callable $callback) static 执行数据库事务
 * @method boolean batchQuery(array $sqlArray) static 批处理执行SQL语句
 */
class Db
{
    //  数据库连接实例
    private static $instance = [];
    // 查询次数
    public static $queryTimes = 0;
    // 执行次数
    public static $executeTimes = 0;

    /**
     * 数据库初始化 并取得数据库类实例
     * @static
     * @access public
     * @param mixed         $config 连接配置
     * @param bool|string   $name 连接标识 true 强制重新连接
     * @return \think\db\Connection
     * @throws Exception
     */
    public static function connect($config = [], $name = false)
    {
        // 变量$name值为布尔类型中的假值时,才会执行
        if (false === $name) {
            // 根据配置信息,序列化后,使用MD5 生成一个唯一标识
            $name = md5(serialize($config));
        }
        // 变量$name值为布尔类型中的真值时,且
        // 数组 $instance中 $name 的值 不存在时 才会执行
        if (true === $name || !isset(self::$instance[$name])) {
            // 解析连接参数 支持数组和字符串
            $options = self::parseConfig($config);
            // 数据驱动类型不存在,则报错
            if (empty($options['type'])) {
                throw new \InvalidArgumentException('Underfined db type');
            }
            // 获得 数据库驱动命名空间的地址
            $class = false !== strpos($options['type'], '\\') ? $options['type'] : '\\think\\db\\connector\\' . ucwords($options['type']);
            // 记录初始化信息
            if (App::$debug) {
                Log::record('[ DB ] INIT ' . $options['type'], 'info');
            }
            // $name 连接标识 为 true 强制重新连接
            if (true === $name) {
                // 重新实例化 数据库驱动,直接返回该对象
                return new $class($options);
            } else {
                // 重新实例化 数据库驱动,并保存到静态变量$instance[$name]中
                // 我不会告诉你这个是 设计模式中的 单例模式的
                self::$instance[$name] = new $class($options);
            }
        }
        return self::$instance[$name];
    }

    /**
     * 数据库连接参数解析
     * @static
     * @access private
     * @param mixed $config
     * @return array
     */
    private static function parseConfig($config)
    {
        // 数据库参数不存在时
        if (empty($config)) {
            // 读取 默认数据库信息
            $config = Config::get('database');
        }
        // 数据库参数$config 是字符串时,且 变量中不含有 / 时 ,执行
        elseif (is_string($config) && false === strpos($config, '/')) {
            // 支持读取配置参数
            $config = Config::get($config);
        }
        // 如果是字符串
        if (is_string($config)) {
            // 字符串 解析
            return self::parseDsn($config);
        } else {
            return $config;
        }
    }

    /**
     * DSN解析
     * 格式: mysql://username:passwd@localhost:3306/DbName?param1=val1&param2=val2#utf8
     * @static
     * @access private
     * @param string $dsnStr
     * @return array
     */
    private static function parseDsn($dsnStr)
    {
        // 解析 ,不知道的同学,请自觉查文档
        $info = parse_url($dsnStr);
        if (!$info) {
            return [];
        }
        // 变量初始化
        $dsn = [
            'type'     => $info['scheme'],
            'username' => isset($info['user']) ? $info['user'] : '',
            'password' => isset($info['pass']) ? $info['pass'] : '',
            'hostname' => isset($info['host']) ? $info['host'] : '',
            'hostport' => isset($info['port']) ? $info['port'] : '',
            'database' => !empty($info['path']) ? ltrim($info['path'], '/') : '',
            'charset'  => isset($info['fragment']) ? $info['fragment'] : 'utf8',
        ];

        if (isset($info['query'])) {
            //解析 ,不知道的同学,请自觉查文档
            parse_str($info['query'], $dsn['params']);
        } else {
            $dsn['params'] = [];
        }
        return $dsn;
    }

    // 调用驱动类的方法
    // __callStatic() 这个方法用来监视一个对象中的静态方法。如果你试着调用一个对象中不存在的静态方法,它将会被自动调用。
    // 不知道的同学,请自觉查文档
    public static function __callStatic($method, $params)
    {
        // 自动初始化数据库
        // call_user_func_array 调用回调函数,并把一个数组参数作为回调函数的参数
        // 不知道的同学,请自觉查文档
        return call_user_func_array([self::connect(), $method], $params);
    }
}
时间: 2024-10-31 12:48:39

thinkphp5.x之数据库操作相关解析 Db类的相关文章

C#中数据库操作相关

数据|数据库   /************************************************************************************************************* * 功能:数据库操作相关 * 作者:FlashICP * 时间:2005-7-22 * **************************************************************************************

3.数据库操作相关术语,Oracle认证,insert into,批量插入,update tablename set,delete和truncate的区别,sql文件导入

 1相关术语 语句 含义 操作 DML语句 (Data Manipulation Language) 数据库操作语言 insert update delete select DDL语言 (Date definition Language) 数据库定义语言 create table;create view index sequence synonvm同义词,truncate table DCL语言 (Data control Language) 数据控制语言 commit rollback s

VC实现ODBC数据库操作实例解析_C 语言

本文以VC实例介绍了实现数据库操作的各种方法,包括打开数据库.关联记录集.读取Excel数据.执行SQL查询.创建存取字符串等,相信对于初学VC的朋友有一定的参考价值,主要功能代码如下: //打开数据库 CDatabase database; database.OpenEx( _T( "DSN=zhuxue" ),CDatabase::noOdbcDialog);//zhuxue为数据源名称 //关联记录集 CRecordset recset(&database); //查询记

如何使用ANT自动进行数据库的相关操作

如何使用ANT自动进行数据库的相关操作  <?xml:namespace prefix = o ns = "urn:schemas-microsoft-com:office:office" /> 赵才文(vipcowrie@sina.com)版权所有            如今的系统,无论是基于CS的还是基于BS的架构,如果与数据库打交道,那么程序员在开发系统的时候,或者在进行单元测试的时候,经常要对数据库进行一些重复的操作,例如初始化,建库,删除表格,插入测试数据等等.每

asp对象化之:数据库操作类

对象|数据|数据库 <%  '────────────────────────────────   '功能说明:db类是实现数据库连接的类,里面留有数据库连接字符串接口  '包括模块:无,一般都是被其他模块包括  '调用方法:1.如果使用原有数据库连接,则不用更改数据库连接字符串ConnStr  '             具体操作为:Set DBC=New DataBaseClass  '                         DBC.ConnStr="其他连接字符串"

storm db-storm对数据库操作的相关类和接口

问题描述 storm对数据库操作的相关类和接口 可否详细讲解一下Storm中关于对数据库的操作的接口,类之间的作用,继承和调用的时机..顺便推荐几本 有用的博客和数据..谢谢了.网上查找的资料都是大同小异...哎 解决方案 http://www.csdn.net/article/2012-12-24/2813117-storm-realtime-big-data-analysis

CI框架中数据库操作函数$this-&amp;gt;db-&amp;gt;where()相关用法总结_php实例

本文实例总结了CI框架中数据库操作函数$this->db->where()相关用法.分享给大家供大家参考,具体如下: CI 框架数据库操作函数 this->db->where() 的使用 1) $this->db->where('MATCH (field) AGAINST ("value")', NULL, FALSE) 如果把$this->db->where() 接受可选的第三个参数设置为 FALSE, CodeIgniter 将不会为

CI框架连接数据库配置操作以及多数据库操作

数据库快速入门例子代码 下面的内容将简单说明怎样使用数据库.更详细的信息请阅读各个函数的单独介绍页面.   初始化数据库类 下面的代码将依据你的数据库配置载入并初始化数据库类:   $this->load->database();   一旦被载入,你可以在任何地方像这样使用它:   注意: 如果你的所有页面均要求初始化数据库类,你可以让它自动加载.详见 数据库连接.   多结果标准查询(对象形式) $query = $this->db->query('SELECT name, ti

数据库操作类mysql/mysqli/pdo

PDO,MySQL,MYSQLI的各自不同介绍,PDO,MYSQL,MYSQLI 性能哪个比较好 普通的mysql连接肯定是会被抛弃的 因为每次都要防止sql注入的问题 而且相对来说比较慢 首先, mysqli 连接是永久连接,而mysql是非永久连接 .什么意思呢? mysql连接每当第二次使用的时候,都会重新打开一个新的进程,而mysqli则只使用同一个进程,这样可以很大程度的减轻服务器端压力. mysqli是在普通mysql的基础上做的一次优化说实话很成功 预处理方式完全解决了sql注入的