diff --git a/ActiveRecord.php b/ActiveRecord.php index 97dd11c8..fbb73e67 100644 --- a/ActiveRecord.php +++ b/ActiveRecord.php @@ -720,7 +720,7 @@ public static function updateAllCounters($counters, $condition = []) foreach ($primaryKeys as $pk) { $script = ''; foreach ($counters as $counter => $value) { - $script .= "ctx._source.{$counter} += params.{$counter};\n"; + $script .= "ctx._source.{$counter} = (ctx._source.{$counter} == null ? 0 : ctx._source.{$counter}) + params.{$counter};\n"; } $bulkCommand->addAction(["update" => ["_id" => $pk]], [ 'script' => [