Tag: php

使用laravel封装mysql存储过程的调用接口

在使用存储过程时，调用时通常如下：

1
2
3
set @out_status = 0;
call procedure_name(param1, ...,, @out_status);
select @out_status;

比较啰嗦，有必要进行一次封装，如下：

READ MORE

mysql存储过程管理（laravel下）

直接在mysql这个层面（例如命令行或者phpmyadmin等）管理存储过程是一个非常麻烦的事情：

  • 变更很难管理
  • 无法进行版本控制

第一步：把存储过程文件都放到git下管理

例如放在项目的sql目录下：

1
2
3
4
5
6
$ ls sql/
proc_money_appeal_payout.sql             proc_money_apply_cash_payout.sql
proc_money_apply_cash_income_close.sql   proc_money_reward_income.sql
proc_money_apply_cash_income_fail.sql    proc_money_reward_payout.sql
proc_money_apply_cash_income_finish.sql  proc_money_security_deposit_income.sql
proc_money_apply_cash_income.sql         proc_money_security_deposit_payout.sql

第二步：生成导入数据库的sql文件

如果项目的存储过程比较多，每次更新时都可能会变得很麻烦，所以需要统一的导入入口，例如sql目录下生成source.sql文件，内容如下：

1
2
3
4
5
6
7
8
9
10
// vim sql/source.sql
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_appeal_payout.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_apply_cash_income.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_apply_cash_income_close.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_apply_cash_income_fail.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_apply_cash_income_finish.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_apply_cash_payout.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_apply_cash_payout_close.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_apply_cash_payout_finish.sql;
source /home/code/ibbd/yanjiuquan-php/sql/proc_money_reward_income.sql;

说明：这个source文件不应该加入git版本控制中。

这样只需要在命令行中，source这个文件即可：

1
source /path/to/source.sql

第三步：自动生成source.sql

如果手动管理这个文件，也是挺麻烦的，可以结合laravel自动生成：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
use Illuminate\Database\Seeder;
class ProcdureInitTableSeeder extends Seeder {
    public function run()
    {
        $path  = 'sql/proc_*.sql';
        $root  = getcwd();
        $files = glob($path);
        $source_file = $root . '/sql/source.sql';
        file_put_contents($source_file, "# @desc   导入及更新存储过程结构, 生成命令：php artisan db:seed\n");
        file_put_contents($source_file, "# @author Alex\n", FILE_APPEND);
        file_put_contents($source_file, "# @date   " . date('Y-m-d') . "\n\n", FILE_APPEND);
        foreach ($files as $file) {
            $sql = "source {$root}/{$file};\n";
            file_put_contents($source_file, $sql, FILE_APPEND);
        }
    }
}

The last

每次变化的时候，还是需要手动source一下，略麻烦。。。暂时没有更好的方式。。。

laravel项目中的数据表设计规范及使用方式

字段设计规范

1
2
3
4
5
6
7
8
9
10
11
12
13
14
// 主键
$table->increments('id');
// 加入 created_at 和 updated_at 字段
$table->timestamps();
// 加入 deleted_at 字段于软删除使用
$table->softDeletes();
// 加入整数 taggable_id 与字串 taggable_type
$table->morphs('taggable');
// 加入 remember_token 使用 VARCHAR(100) NULL
$table->rememberToken();

软删除

通过软删除方式删除了一个模型后，模型中的数据并不是真的从数据库被移除。而是会设定 deleted_at时间戳。要让模型使用软删除功能，只要在模型类里加入 SoftDeletingTrait 即可：

1
2
3
4
5
6
7
8
9
use Illuminate\Database\Eloquent\SoftDeletes;
class User extends Model {
    
    use SoftDeletes;
    protected $dates = ['deleted_at'];
}

现在当您使用模型调用 delete 方法时， deleted_at字段会被更新成现在的时间戳。在查询使用软删除功能的模型时，被「删除」的模型数据不会出现在查询结果里。

1
2
3
4
5
// 强制查询软删除数据(使用 withTrashed 方法)
$users = User::withTrashed()->where('account_id', 1)->get();
// 只想查询被软删除的模型数据，可以使用 onlyTrashed 方法
$users = User::onlyTrashed()->where('account_id', 1)->get();

时间戳

默认 Eloquent 会自动维护数据库表的 created_at 和 updated_at 字段。只要把这两个「时间戳」字段加到数据库表， Eloquent 就会处理剩下的工作。

范围查询

定义范围查询

范围查询可以让您轻松的重复利用模型的查询逻辑。要设定范围查询，只要定义有 scope 前缀的模型方法：

1
2
3
4
5
6
7
8
9
10
11
12
13
class User extends Model {
    public function scopePopular($query)
    {
        return $query->where('votes', '>', 100);
    }
    public function scopeWomen($query)
    {
        return $query->whereGender('W');
    }
}

使用范围查询

1
$users = User::popular()->women()->orderBy('created_at')->get();

动态范围查询

有时您可能想要定义可接受参数的范围查询方法。只要把参数加到方法里：

1
2
3
4
5
6
7
class User extends Model {
    public function scopeOfType($query, $type)
    {
        return $query->whereType($type);
    }
}

使用：

1
$users = User::ofType('member')->get();

使用枢纽表

如您所知，要操作多对多关联需要一个中间的数据库表。 Eloquent 提供了一些有用的方法可以和这张表互动。例如，假设 User 对象关联到很多 Role 对象。取出这些关联对象时，我们可以在关联模型上取得 pivot 数据库表的数据：

1
2
3
4
5
6
$user = User::find(1);
foreach ($user->roles as $role)
{
    echo $role->pivot->created_at;
}

注意我们取出的每个 Role 模型对象会自动给一个 pivot 属性。这属性包含了枢纽表的模型数据，可以像一般的 Eloquent 模型一样使用。

默认 pivot 对象只会有关联键的属性。如果您想让 pivot 可以包含其他枢纽表的字段，可以在定义关联方法时指定那些字段：

1
return $this->belongsToMany('App\Role')->withPivot('foo', 'bar');

其他操作：

1
2
3
4
5
// 删除枢纽表的关联数据
User::find(1)->roles()->detach();
// 更新枢纽表的数据
User::find(1)->roles()->updateExistingPivot($roleId, $attributes);

集合

所有 Eloquent 查询返回的数据，如果结果多于一条，不管是经由 get 方法或是 relationship，都会转换成集合对象返回。这个对象实现了 IteratorAggregate PHP 接口，所以可以像数组一般进行遍历。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
// 确认集合中里是否包含特定键值
$roles = User::find(1)->roles;
if ($roles->contains(2))
{
    //
}
// 集合遍历
$roles = $user->roles->each(function($role)
{
    //
});
// 集合过滤
$users = $users->filter(function($user)
{
    return $user->isAdmin();
});

待续。。。

封装redis基础类库

开发的时候，需要用到缓存，经常需要封装各种缓存类，有时为了所谓的缓存通用了，我们对redis做了统一性的封装，结果只能用到redis最基本的kv结构，大大浪费了。

所以封装redis的时候，应该恰到好处就好了，phpredis本身的api就已经挺好的了。

下面是一个封装：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
<?php
/** 
 * redis初始化类库
 * @author Alex <cyy0523xc@gmail.com>
 * @copyright IBBD.net
 * @see 
 * @todo 
 * @version 20141104
 */
namespace Common\Model;
class RedisModel 
{
    // redis对象
    private $handler = null;
    /**
     * 获取Redis缓存对象
     * @param array $options redis连接所需要的参数
     * @return Redis 
     */
    public static function getInstance(array $options = null)
    {
        static $instance = array();
        if(empty($options)) {
            // 加载配置文件
            $options = C('CACHE.REDIS_CONFIG');
        }
        $guid = to_guid_string($options);
        if (!isset($instance[$guid])) {
            $obj = new self($options);
            $instance[$guid] = $obj->getRedis();
        }
        
        return $instance[$guid];
    }
    /**
     * 构造函数
     * @param array $options redis需要的参数 
     */
    protected function __construct(array $options) 
    {
        if ( !extension_loaded('redis') ) {
            error_log('NOT_SUPPORT:redis');
        }
        $func = $options['persistent'] ? 'pconnect' : 'connect';
        $this->handler  = new \Redis;
        $options['timeout'] === false ?
            $this->handler->$func($options['host'], $options['port']) :
            $this->handler->$func($options['host'], $options['port'], $options['timeout']);
        // select db 
        isset($options['db']) && $this->select($options['db']);
    }
    /**
     * 获取redis处理对象
     * @return Redis 
     */
    protected function getRedis()
    {
        return $this->handler;
    }
}

用php将markdown格式的表格转化为sql语句

我们在设计数据表结构的时候，通常使用markdown格式，例如如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
## 用户表 
总的规则是：一个用户可以管理多个店铺，每个店铺需要配置不同的淘宝账号和密码。
### 用户登陆表：user_login
登陆表，保存用户基本的账号信息
字段              | 类型        | 其他属性                | 说明
------            | -------     | ---                     | --------
uid               | int(11)     | auto\_increment,primary | 自增主键。系统内的所有操作都与uid进行关联。
username          | varchar(32) | unique                  | 用户名。唯一键
email             | varchar(80) | unique                  | email。唯一键
password          | char(32)    |                         | 加密后的密码
status            | tinyint(3)  | default 0               | 状态，默认为0。定义如下
create\_time      | datetime    |                         | 注册时间
last\_login\_time | datetime    |                         | 最后登陆时间
登陆时，可以使用用户名登陆，或者邮箱登陆。

当我们需要创建表格的时候，可能还需要写成sql，这很费时费力，而且容易出错，难维护。所以写了一个php的解释工具，可以根据markdown文件快速生成对应的sql语句，生成的sql格式如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
# md文件：http://git.ibbd.net/ibbd/ibbd-bc-py/blob/master/doc/db-tables.md
# Create By http://git.ibbd.net/ibbd/ibbd-bc-py/blob/master/doc/markdown2sql.php
# Create At 2014-10-14 15:44:36
CREATE TABLE `user_login` {
    `uid` INT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT '自增主键。系统内的所有操作都与uid进行关联。',
    `username` VARCHAR(32) NOT NULL UNIQUE KEY COMMENT '用户名。唯一键',
    `email` VARCHAR(80) NOT NULL UNIQUE KEY COMMENT 'email。唯一键',
    `password` CHAR(32) NOT NULL COMMENT '加密后的密码',
    `status` TINYINT(3) NOT NULL DEFAULT 0 COMMENT '状态，默认为0。定义如下',
    `create_time` DATETIME NOT NULL COMMENT '注册时间',
    `last_login_time` DATETIME NOT NULL COMMENT '最后登陆时间'
} ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户登陆表';

php代码如下：

READ MORE