@@ -60,7 +60,7 @@ public function createAcl(ObjectIdentityInterface $oid)
60
60
$ this ->createObjectIdentity ($ oid );
61
61
62
62
$ pk =$ this ->retrieveObjectIdentityPrimaryKey ($ oid );
63
- $ this ->connection ->executeQuery ($ this ->getInsertObjectIdentityRelationSql ($ pk ,$ pk ));
63
+ $ this ->connection ->executeUpdate ($ this ->getInsertObjectIdentityRelationSql ($ pk ,$ pk ));
64
64
65
65
$ this ->connection ->commit ();
66
66
}catch (\Exception $ e ) {
@@ -119,7 +119,7 @@ public function deleteAcl(ObjectIdentityInterface $oid)
119
119
*/
120
120
public function deleteSecurityIdentity (SecurityIdentityInterface $ sid )
121
121
{
122
- $ this ->connection ->executeQuery ($ this ->getDeleteSecurityIdentityIdSql ($ sid ));
122
+ $ this ->connection ->executeUpdate ($ this ->getDeleteSecurityIdentityIdSql ($ sid ));
123
123
}
124
124
125
125
/**
@@ -334,7 +334,7 @@ public function updateAcl(MutableAclInterface $acl)
334
334
335
335
// persist any changes to the acl_object_identities table
336
336
if (count ($ sets ) >0 ) {
337
- $ this ->connection ->executeQuery ($ this ->getUpdateObjectIdentitySql ($ acl ->getId (),$ sets ));
337
+ $ this ->connection ->executeUpdate ($ this ->getUpdateObjectIdentitySql ($ acl ->getId (),$ sets ));
338
338
}
339
339
340
340
$ this ->connection ->commit ();
@@ -373,7 +373,7 @@ public function updateAcl(MutableAclInterface $acl)
373
373
*/
374
374
public function updateUserSecurityIdentity (UserSecurityIdentity $ usid ,$ oldUsername )
375
375
{
376
- $ this ->connection ->executeQuery ($ this ->getUpdateUserSecurityIdentitySql ($ usid ,$ oldUsername ));
376
+ $ this ->connection ->executeUpdate ($ this ->getUpdateUserSecurityIdentitySql ($ usid ,$ oldUsername ));
377
377
}
378
378
379
379
/**
@@ -750,7 +750,7 @@ private function createObjectIdentity(ObjectIdentityInterface $oid)
750
750
{
751
751
$ classId =$ this ->createOrRetrieveClassId ($ oid ->getType ());
752
752
753
- $ this ->connection ->executeQuery ($ this ->getInsertObjectIdentitySql ($ oid ->getIdentifier (),$ classId ,true ));
753
+ $ this ->connection ->executeUpdate ($ this ->getInsertObjectIdentitySql ($ oid ->getIdentifier (),$ classId ,true ));
754
754
}
755
755
756
756
/**
@@ -768,7 +768,7 @@ private function createOrRetrieveClassId($classType)
768
768
return $ id ;
769
769
}
770
770
771
- $ this ->connection ->executeQuery ($ this ->getInsertClassSql ($ classType ));
771
+ $ this ->connection ->executeUpdate ($ this ->getInsertClassSql ($ classType ));
772
772
773
773
return $ this ->connection ->executeQuery ($ this ->getSelectClassIdSql ($ classType ))->fetchColumn ();
774
774
}
@@ -789,7 +789,7 @@ private function createOrRetrieveSecurityIdentityId(SecurityIdentityInterface $s
789
789
return $ id ;
790
790
}
791
791
792
- $ this ->connection ->executeQuery ($ this ->getInsertSecurityIdentitySql ($ sid ));
792
+ $ this ->connection ->executeUpdate ($ this ->getInsertSecurityIdentitySql ($ sid ));
793
793
794
794
return $ this ->connection ->executeQuery ($ this ->getSelectSecurityIdentityIdSql ($ sid ))->fetchColumn ();
795
795
}
@@ -801,7 +801,7 @@ private function createOrRetrieveSecurityIdentityId(SecurityIdentityInterface $s
801
801
*/
802
802
private function deleteAccessControlEntries ($ oidPK )
803
803
{
804
- $ this ->connection ->executeQuery ($ this ->getDeleteAccessControlEntriesSql ($ oidPK ));
804
+ $ this ->connection ->executeUpdate ($ this ->getDeleteAccessControlEntriesSql ($ oidPK ));
805
805
}
806
806
807
807
/**
@@ -811,7 +811,7 @@ private function deleteAccessControlEntries($oidPK)
811
811
*/
812
812
private function deleteObjectIdentity ($ pk )
813
813
{
814
- $ this ->connection ->executeQuery ($ this ->getDeleteObjectIdentitySql ($ pk ));
814
+ $ this ->connection ->executeUpdate ($ this ->getDeleteObjectIdentitySql ($ pk ));
815
815
}
816
816
817
817
/**
@@ -821,7 +821,7 @@ private function deleteObjectIdentity($pk)
821
821
*/
822
822
private function deleteObjectIdentityRelations ($ pk )
823
823
{
824
- $ this ->connection ->executeQuery ($ this ->getDeleteObjectIdentityRelationsSql ($ pk ));
824
+ $ this ->connection ->executeUpdate ($ this ->getDeleteObjectIdentityRelationsSql ($ pk ));
825
825
}
826
826
827
827
/**
@@ -832,12 +832,12 @@ private function deleteObjectIdentityRelations($pk)
832
832
private function regenerateAncestorRelations (AclInterface $ acl )
833
833
{
834
834
$ pk =$ acl ->getId ();
835
- $ this ->connection ->executeQuery ($ this ->getDeleteObjectIdentityRelationsSql ($ pk ));
836
- $ this ->connection ->executeQuery ($ this ->getInsertObjectIdentityRelationSql ($ pk ,$ pk ));
835
+ $ this ->connection ->executeUpdate ($ this ->getDeleteObjectIdentityRelationsSql ($ pk ));
836
+ $ this ->connection ->executeUpdate ($ this ->getInsertObjectIdentityRelationSql ($ pk ,$ pk ));
837
837
838
838
$ parentAcl =$ acl ->getParentAcl ();
839
839
while (null !==$ parentAcl ) {
840
- $ this ->connection ->executeQuery ($ this ->getInsertObjectIdentityRelationSql ($ pk ,$ parentAcl ->getId ()));
840
+ $ this ->connection ->executeUpdate ($ this ->getInsertObjectIdentityRelationSql ($ pk ,$ parentAcl ->getId ()));
841
841
842
842
$ parentAcl =$ parentAcl ->getParentAcl ();
843
843
}
@@ -873,7 +873,7 @@ private function updateNewFieldAceProperty($name, array $changes)
873
873
874
874
$ objectIdentityId =$ name ==='classFieldAces ' ?null :$ ace ->getAcl ()->getId ();
875
875
876
- $ this ->connection ->executeQuery ($ this ->getInsertAccessControlEntrySql ($ classId ,$ objectIdentityId ,$ field ,$ i ,$ sid ,$ ace ->getStrategy (),$ ace ->getMask (),$ ace ->isGranting (),$ ace ->isAuditSuccess (),$ ace ->isAuditFailure ()));
876
+ $ this ->connection ->executeUpdate ($ this ->getInsertAccessControlEntrySql ($ classId ,$ objectIdentityId ,$ field ,$ i ,$ sid ,$ ace ->getStrategy (),$ ace ->getMask (),$ ace ->isGranting (),$ ace ->isAuditSuccess (),$ ace ->isAuditFailure ()));
877
877
$ aceId =$ this ->connection ->executeQuery ($ this ->getSelectAccessControlEntryIdSql ($ classId ,$ objectIdentityId ,$ field ,$ i ))->fetchColumn ();
878
878
$ this ->loadedAces [$ aceId ] =$ ace ;
879
879
@@ -909,7 +909,7 @@ private function updateOldFieldAceProperty($name, array $changes)
909
909
$ ace =$ old [$ i ];
910
910
911
911
if (!isset ($ currentIds [$ ace ->getId ()])) {
912
- $ this ->connection ->executeQuery ($ this ->getDeleteAccessControlEntrySql ($ ace ->getId ()));
912
+ $ this ->connection ->executeUpdate ($ this ->getDeleteAccessControlEntrySql ($ ace ->getId ()));
913
913
unset($ this ->loadedAces [$ ace ->getId ()]);
914
914
}
915
915
}
@@ -947,7 +947,7 @@ private function updateNewAceProperty($name, array $changes)
947
947
948
948
$ objectIdentityId =$ name ==='classAces ' ?null :$ ace ->getAcl ()->getId ();
949
949
950
- $ this ->connection ->executeQuery ($ this ->getInsertAccessControlEntrySql ($ classId ,$ objectIdentityId ,null ,$ i ,$ sid ,$ ace ->getStrategy (),$ ace ->getMask (),$ ace ->isGranting (),$ ace ->isAuditSuccess (),$ ace ->isAuditFailure ()));
950
+ $ this ->connection ->executeUpdate ($ this ->getInsertAccessControlEntrySql ($ classId ,$ objectIdentityId ,null ,$ i ,$ sid ,$ ace ->getStrategy (),$ ace ->getMask (),$ ace ->isGranting (),$ ace ->isAuditSuccess (),$ ace ->isAuditFailure ()));
951
951
$ aceId =$ this ->connection ->executeQuery ($ this ->getSelectAccessControlEntryIdSql ($ classId ,$ objectIdentityId ,null ,$ i ))->fetchColumn ();
952
952
$ this ->loadedAces [$ aceId ] =$ ace ;
953
953
@@ -981,7 +981,7 @@ private function updateOldAceProperty($name, array $changes)
981
981
$ ace =$ old [$ i ];
982
982
983
983
if (!isset ($ currentIds [$ ace ->getId ()])) {
984
- $ this ->connection ->executeQuery ($ this ->getDeleteAccessControlEntrySql ($ ace ->getId ()));
984
+ $ this ->connection ->executeUpdate ($ this ->getDeleteAccessControlEntrySql ($ ace ->getId ()));
985
985
unset($ this ->loadedAces [$ ace ->getId ()]);
986
986
}
987
987
}
@@ -1029,6 +1029,6 @@ private function updateAce(\SplObjectStorage $aces, $ace)
1029
1029
$ sets [] =sprintf ('audit_failure = %s ' ,$ this ->connection ->getDatabasePlatform ()->convertBooleans ($ propertyChanges ['auditFailure ' ][1 ]));
1030
1030
}
1031
1031
1032
- $ this ->connection ->executeQuery ($ this ->getUpdateAccessControlEntrySql ($ ace ->getId (),$ sets ));
1032
+ $ this ->connection ->executeUpdate ($ this ->getUpdateAccessControlEntrySql ($ ace ->getId (),$ sets ));
1033
1033
}
1034
1034
}