$taskName
$taskName : string
Class MongoDbTask
__initialization(integer $taskId, integer $workerPid, string $taskName, string $methodName, \PG\MSF\Helpers\Context $context, \PG\AOP\Wrapper|\PG\MSF\Base\Pool $objectPool)
Tasker进程中初始化任务
integer | $taskId | Task ID |
integer | $workerPid | worker pid |
string | $taskName | 任务类名 |
string | $methodName | 任务类方法 |
\PG\MSF\Helpers\Context | $context | 请求上下文对象 |
\PG\AOP\Wrapper|\PG\MSF\Base\Pool | $objectPool | 对象池对象 |
__call(string $name, array $arguments) : \PG\MSF\Coroutine\CTask
__call魔术方法
string | $name | 任务方法名 |
array | $arguments | 执行参数 |
getPack() : \PG\MSF\Pack\IPack
获取运行server实例打包对象
getRedisPool(string $poolName) : boolean|\PG\AOP\Wrapper|\PG\MSF\Pools\CoroutineRedisProxy|\Redis
获取Redis连接池
string | $poolName | 配置的Redis连接池名称 |
getRedisProxy(string $proxyName) : boolean|\PG\AOP\Wrapper|\PG\MSF\Pools\CoroutineRedisProxy|\Redis
获取Redis代理
string | $proxyName | 配置的Redis代理名称 |
setContext(\PG\MSF\Helpers\Context $context) : $this
设置上下文
\PG\MSF\Helpers\Context | $context | 请求上下文对象 |
query(array $query = array(), array $fields = array(), array $sort = null, integer $limit = null, integer $skip = null, integer $timeout = 2000) : \PG\MSF\Tasks\array:
查询文档,返回二维数组的数据
array | $query | 查询条件,如:['_id' => new \MongoId('0f6821586b9887e3174e7c78')] |
array | $fields | 返回的字段列表,默认全部,如:['name' => true, 'age' => true] |
array | $sort | 排序,如:['create_time' => 1, '_id' => -1] |
integer | $limit | 限制返回的数据文档数 |
integer | $skip | 开始返回的offset |
integer | $timeout | 查询超时时间,default 2s, 0 wait forever. |
findOne(array $query = array(), array $fields = array(), integer $timeout = 2000) : array|null
查询返回一条数据
array | $query | 查询条件,如:['_id' => new \MongoId('0f6821586b9887e3174e7c78')] |
array | $fields | 返回的字段列表,默认全部,如:['name' => true, 'age' => true] |
integer | $timeout | 查询超时时间,default 2s, 0 wait forever. |
count(array $query = array(), integer|null $limit = null, integer|null $skip = null, integer $timeout = 2000) : integer
返回符合条件的文档数
array | $query | 查询条件,如:['_id' => new \MongoId('0f6821586b9887e3174e7c78')] |
integer|null | $limit | 限制返回的数据文档数 |
integer|null | $skip | 开始查询的offset |
integer | $timeout | 查询超时时间,default 2s, 0 wait forever. |
batchAdd(array $docs, boolean $continueOnError = true, integer $timeout = 2000, integer $w = 1, boolean $fsync = false) : boolean
批量新建文档
array | $docs | 新建文档的二维数组 |
boolean | $continueOnError | 出现错误是否继续插入 |
integer | $timeout | 查询超时时间,default 2s, 0 wait forever. |
integer | $w | |
boolean | $fsync | 是否立即写入磁盘 |
modify(array $criteria, array $doc, boolean $multiple = true, boolean $upsert = false, integer $timeout = 2000, integer $w = 1, boolean $fsync = false) : boolean
修改文档(包含set关键字)
array | $criteria | 更新条件 |
array | $doc | 要更新的字段和值 |
boolean | $multiple | 是否更新所有符合条件的文档 |
boolean | $upsert | 没有符合条件的文档时,是否插入新文档 |
integer | $timeout | 超时时间,单位ms |
integer | $w | 成功写入到多少个复制时返回 |
boolean | $fsync | 是否等待MongoDB将数据更新到磁盘 |
updateDoc(array $criteria, array $doc, boolean $multiple = true, boolean $upsert = false, integer $timeout = 2000, integer $w = 1, boolean $fsync = false) : boolean
修改文档
array | $criteria | 更新条件 |
array | $doc | 要更新的字段和值 |
boolean | $multiple | 是否更新所有符合条件的文档 |
boolean | $upsert | 没有符合条件的文档时,是否插入新文档 |
integer | $timeout | 超时时间,单位ms |
integer | $w | 成功写入到多少个复制时返回 |
boolean | $fsync | 是否等待MongoDB将数据更新到磁盘 |
delete(array $criteria, boolean $justOne = false, integer $timeout = 5000, integer $w = 1, boolean $fsync = false) : boolean
删除文档
array | $criteria | 删除条件 |
boolean | $justOne | 是否只删除符合条件的第一条 |
integer | $timeout | 超时时间,单位ms |
integer | $w | 成功写入到多少个复制时返回 |
boolean | $fsync | 是否等待MongoDB将数据更新到磁盘 |