|
@@ -255,6 +255,7 @@ class Mongo extends Base
|
|
|
}
|
|
|
public function delete($table, $param, $field)
|
|
|
{
|
|
|
+ $param = $this->param($param);
|
|
|
$bulk = new BulkWrite;
|
|
|
$bulk->delete($param);
|
|
|
$result = $this->update->executeBulkWrite($this->db . '.' . $table, $bulk);
|
|
@@ -289,7 +290,11 @@ class Mongo extends Base
|
|
|
}
|
|
|
$result['$' . $k][] = $where;
|
|
|
} else {
|
|
|
- $result[$k] = $this->where($k, $v);
|
|
|
+ if (isset($result[$k])) {
|
|
|
+ $result[$k] = array_merge($result[$k], $this->where($k, $v));
|
|
|
+ } else {
|
|
|
+ $result[$k] = $this->where($k, $v);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
} elseif ($param) {
|