resourceConnection = $resourceConnection; } /** * @param ReservationInterface[] $reservations * @return void */ public function execute(array $reservations) { $connection = $this->resourceConnection->getConnection(); $tableName = $this->resourceConnection->getTableName('inventory_reservation'); $columns = [ ReservationInterface::STOCK_ID, ReservationInterface::SKU, ReservationInterface::QUANTITY, ReservationInterface::METADATA, ]; $data = []; /** @var ReservationInterface $reservation */ foreach ($reservations as $reservation) { $data[] = [ $reservation->getStockId(), $reservation->getSku(), $reservation->getQuantity(), $reservation->getMetadata(), ]; } $connection->insertArray($tableName, $columns, $data); } }