From d5eb6d66cad125ec575bd0fe447b6aceb54ff330 Mon Sep 17 00:00:00 2001
From: Lukas Kahwe Smith <smith@pooteeweet.org>
Date: Sat, 2 May 2015 13:12:18 +0200
Subject: [PATCH] fixed previous commit

---
 src/Jackalope/Transport/DoctrineDBAL/Client.php | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/Jackalope/Transport/DoctrineDBAL/Client.php b/src/Jackalope/Transport/DoctrineDBAL/Client.php
index 5a70de29..1540906a 100644
--- a/src/Jackalope/Transport/DoctrineDBAL/Client.php
+++ b/src/Jackalope/Transport/DoctrineDBAL/Client.php
@@ -530,11 +530,11 @@ public function getNamespaces()
      *
      * @param $query
      * @param array $params
-     * @param array $types
      * @throws DBALException
      */
-    private function executeUpdate($query, array $params = array(), array $types = array())
+    private function executeChunkedUpdate($query, array $params)
     {
+        $types = array(Connection::PARAM_INT_ARRAY);
         if ($this->conn->getDatabasePlatform() instanceof SqlitePlatform) {
             foreach (array_chunk($params, 999) as $chunk) {
                 $this->conn->executeUpdate($query, array($chunk), $types);
@@ -748,7 +748,7 @@ private function syncReferences()
             try {
                 foreach ($this->referenceTables as $table) {
                     $query = "DELETE FROM $table WHERE source_id IN (?)";
-                    $this->executeUpdate($query, array(array_keys($toUpdate)), array(Connection::PARAM_INT_ARRAY));
+                    $this->executeChunkedUpdate($query, array_keys($toUpdate));
                 }
             } catch (DBALException $e) {
                 throw new RepositoryException('Unexpected exception while cleaning up after saving', $e->getCode(), $e);
@@ -784,7 +784,7 @@ private function syncReferences()
             // remove all PropertyType::REFERENCE with a source_id on a deleted node
             try {
                 $query = "DELETE FROM phpcr_nodes_references WHERE source_id IN (?)";
-                $this->executeUpdate($query, array($params), array(Connection::PARAM_INT_ARRAY));
+                $this->executeChunkedUpdate($query, $params);
             } catch (DBALException $e) {
                 throw new RepositoryException('Unexpected exception while cleaning up deleted nodes', $e->getCode(), $e);
             }
@@ -823,7 +823,7 @@ private function syncReferences()
             try {
                 foreach ($this->referenceTables as $table) {
                     $query = "DELETE FROM $table WHERE target_id IN (?)";
-                    $this->executeUpdate($query, array($params), array(Connection::PARAM_INT_ARRAY));
+                    $this->executeChunkedUpdate($query, $params);
                 }
             } catch (DBALException $e) {
                 throw new RepositoryException('Unexpected exception while cleaning up deleted nodes', $e->getCode(), $e);