public function execute($writeConcern = 1)
    {
        $connection = Ioc::make(Pool::class)->getConnection();
        $manager = $connection->getRawManager();

        $namespace = $connection->defaultDatabase.'.'.$this->schema->collection;

        return $manager->executeBulkWrite(
            $namespace,
            $this->getBulkWrite(),
            ['writeConcern' => new WriteConcern($writeConcern)]
        );
    }