shen2 / mdo
A php asynchronous library for mysql (based on mysqli and mysqlnd driver)
Requires
- php: >=5.5.0
- ext-mysqlnd: *
This package is auto-updated.
Last update: 2024-12-23 19:18:13 UTC
README
MDO是一个用php编写的依赖mysqli和mysqlnd的ORM类(Object Relational Mapping),通过它你可以用面向对象的方式来写sql语句,也可以以面向对象的方式来操作每一条数据库记录。
MDO基于Zend Framework 1.x版本中的Zend_Db组件修改而来,经过彻底的修改和优化之后,去掉了对Zend Framework其他组件的依赖。能达到很高的性能,同时给你的编程带来极大的便利。
MDO由沈振宇开发,先后用于图虫网和多说网的服务器端php程序,经过2年多生产环境的考验,可靠稳定。
特性
性能方面
- MDO会将多个sql语句拼合在一起执行query操作,由于php会在第一条SQL语句执行完成之后就返回,因此能够在同步编程模式中实现类似于“伪异步”的效果,从而减少mysql阻塞时间,大大提高整体性能。
- MDO充分利用php SPL中的ArrayObject和SplFixedArray,使对于数据对象的访问、迭代速度相比Zend_Db有数量级的提升。
编程模式
- 倡导流式接口(fluent interface)
- 将数据表抽象成静态类,避免了无谓的实例化声明,去掉所有不必要的中间变量和赋值过程,从而简化代码
- 代码更接近自然语言。
希望MDO能让你的php编程变得更优雅,更快乐。
局限性
- MDO由于将所有数据表都抽象成静态类,因此无法应对需要做水平Sharding的数据表 (在多说上使用的是经过改进的MDO,从而使它支持Sharding)
- MDO虽然有beginTransaction()这样的方法,但事务操作未经过测试,不能保证可用性(因为作者所涉及的业务都不需要事务操作)
- MDO目前不支持主从读写分离,但是会考虑以后支持
环境和依赖
- php 5.3+,建议php5.4.11以上版本 (已知 php5.4.9 的mysqlnd存在bug,会导致出错)
- PDO扩展,建议安装mysqlnd扩展
- 建议使用autoload机制
类的基本说明
- MDO 基本常量声明
- MDO\Adapter 维护PDO connection的适配器
- MDO\DataObject 核心类,调用静态方法时是对数据表的操作,调用实例方法是对数据记录的操作
- MDO\Select.php SQL语句的抽象,可以流式接口编写SQL语句
- MDO\TableSelect Select对象的派生
- MDO\Statement 储存sql查询语句的中间结果,可以直接进行foreach迭代或者count()
- MDO\Expr SQL语句中的特殊表达式,比如 now(),n + 1 这样不需要经过转义的表达式
- MDO\Profiler 记录sql运行执行情况,可以只在development模式下使用,生产环境不加载
初始化方法
<?php require 'MDO.php'; require 'MDO/Adapter.php'; require 'MDO/DataObject.php'; require 'MDO/Select.php'; require 'MDO/TableSelect.php'; require 'MDO/Statement.php'; require 'MDO/Expr.php'; $configs = array( 'host' => 'localhost', // 主机名 'username' => 'username', // 用户名 'password' => 'password', // 密码 'dbname' => 'dbname', // 数据库名 'port' => 3306, // 端口号,可省略 'profiler' => false, // 是否启用Profiler,默认false 'persistent'=> true, // 是否持久化连接 'charset' => 'utf8', // 默认字符集 'fetchMode' => PDO::FETCH_ASSOC,//PDO的默认fetch模式 ); $db = new MDO\Adapter($configs); MDO\DataObject::setDefaultAdapter($db);
出于性能的考虑,即使你使用了autoload机制,仍然建议你显式地主动require以上那些php类定义文件,这样可以减少发动autoload的次数,避免不必要的性能浪费。
php和mysql部署在同一台服务器上时,最高性能配置方式是unix套接字和持久化,具体配置如下:
$configs = array( 'socket' => '/var/run/mysqld/mysqld.sock', 'host' => 'localhost', // 为了让最终host参数能变成 p:localhost,只有这样才能生效 'persistent'=> true, //...
DataObject类
DataObject是对数据表的抽象,DataObject的静态方法相当于对数据表的操作,实例化的DataObject是数据库记录对象,调用DataObject的动态方法,相当于对数据库记录的操作。 DataObject其实是一个抽象的基类,真正使用的时候需要将它派生成自己的类。
<?php class User extends MDO\DataObject{ protected static $_schema = 'dbname'; // 数据库的名字,默认是null,代表当前数据库 protected static $_name = 'pre_users'; // 数据表的名字 protected static $_primary = array('user_id'); // 主键字段,必须是数组 protected static $_sequence = true; // 主键是否是自增的 protected static $_defaultValues = array( ); // 默认数据,可以省略 // 你自己的方法... } ?>
如果你的数据表是双重主键,并且第二重主键是自增的,可以写成:
protected static $_primary = array('site_id', 'user_id'); protected static $_identity = 1; // 1代表$_primary[1],即’user_id‘是自增主键
MDO\Select 的用法
通常,我们通过已经派生的MDO\DataObject类的静态方法select()来创建 MDO\Select 实例。
$select = User::select(); // select * from `pre_users`;
where()
为了避免出现sql注入漏洞,所有包含变量的where条件,都应使用?来进行转义。
$select = User::select() ->where('name like ?', '小钢炮'); // select * from `pre_users` where name like '小钢炮';
如果有多个where条件,以and相连,直接调用多次where()就可以了。
$select = User::select() ->where('gender = ?', 'male') ->where('age > ?', 40); // select * from `pre_users` where gender = 'male' and age > 40;
order()
order()方法的参数就是排序字段名,asc/desc直接写在字符串里。
$select = User::select() ->order('created_at desc'); // select * from `pre_users` order by created_at desc;
如果有多个order字段,直接调用多次order函数就可以了。
$select = User::select() ->order('name asc') ->order('email asc'); // select * from `pre_users` order by name asc, email asc;
limit()
第一个参数是limit的字段数,第二个参数是offset(默认是0,可省略)
$select = User::select()
->order('name asc')
->order('email asc')
->limit(10, 30);
// select * from `pre_users` order by name asc, email asc limit 10 offset 30;
指定 select 的字段
如果你想获得指定的字段,而不需要所有字段(*),可以使用selectCol函数,比如:
$select = User::selectCol('count(*)'); // select count(*) from `pre_users`;
如果是多个字段,可以写成:
$select = User::selectCol(array('user_id', 'name', 'email')); // select user_id, name, email from `pre_users`;
如果给字段起别名,可以写成:
$select = User::selectCol(array('id' => 'user_id', 'name', 'email')); // select user_id as id, name, email from `pre_users`;
join()
例如现在有 pre_users 表和 pre_posts 表,我们要把posts表的查询结果和users表join。可以写成:
Post::select(true) ->joinInner('pre_users', 'pre_users.user_id = pre_posts.author_id', array('uid'=>'user_id', 'date'=>'updated')) ->where(...) // select `pre_posts`.*, `pre_users`.user_id as id, `pre_users`.updated as date from `pre_posts` inner join pre_users on pre_users.user_id = pre_posts.author_id;
assemble()
有时候你不确定写出的MDO\Select对象在执行的时候会转换成什么SQL语句,可以使用assemble()方法预览SQL语句
echo $select->assemble();
fetch封装方法
每个数据表类有四种种常用的调用方式:fetchAll(), fetchRow(), fetchOne() 和 find()
fetchAll()
$userList = User::select() ->where('created_at > ?', '2012-12-21') ->order('image_count desc') ->limit(5) ->fetchAll();
返回值是一个MDO\Statement,可以直接进行foreach迭代或者count()
fetchRow()
获取一行的方法
$user = User::select() ->where('email_hash = md5(?)', 'd269c7b5b75e3f6fd794e68e889b5daa') ->fetchRow();
不需要额外写limit(1),因为fetchRow()方法会自动给sql语句增加 limit 1
fetchOne()
如果结果集是单行单列的,用fetchOne()可以直接得到这个值
$count = User::selectCol('count(*)') ->where('created_at > ?', '2012-12-21') ->fetchOne();
find()
主键查询肯定是用得最广泛的,使用find()方法可以简化主键查询的过程。
$user = User::find(40)->current();
这样就可以查询到主键为40的user对象,如果记录不存在,返回值是null。
如果想通过多个ID一次查询多条记录,可以写成:
$userList = User::find(array(1,2,3,4,5));
返回值是一个MDO\Statement,可以直接foreach迭代。注意,结果集中的对象顺序未必和find的参数相同,结果集中的对象数量也可能小于find的参数。
find()还支持多重主键的查询:
$relationship = Friendship::find(123,456)->current();
MDO\Statement
$select->fetchAll()的返回值是一个MDO\Statement对象,这个对象未必含有查询的结果集,而有可能结果还在数据库中进行处理。
只有当你主动调用count(), fetch(),或者对它进行foreach迭代的时候,程序才会强制等待mysql数据库返回全部查询结果。
如果这给你带来了困扰,可以使用fetch()方法,获得真正的结果数据集(一个SplFixedArray对象):
$fixedArray = $select->fetchAll()->fetch();