@ Override protected int onExecuteUpdate ( ) { EntityMetadata m = getEntityMetadata ( ) ; Client client = m != null ? persistenceDelegeator . getClient ( m ) : persistenceDelegeator . getClient ( kunderaQuery . getPersistenceUnit ( ) ) ; externalProperties = ( ( CassandraClientBase ) client ) . getExternalProperties ( ) ; ApplicationMetadata appMetadata = kunderaMetadata . getApplicationMetadata ( ) ; String query = appMetadata . getQuery ( getJPAQuery ( ) ) ; boolean isNative = kunderaQuery . isNative ( ) ; if ( isNative ) { ( ( CassandraClientBase ) client ) . executeQuery ( m == null ? null : m . getEntityClazz ( ) , null , isNative , query != null ? query : getJPAQuery ( ) ) ; } else if ( kunderaQuery . isDeleteUpdate ( ) ) { // If query is not convertible to CQL, fetch and merge records usual // way, otherwise // convert to CQL and execute if ( ! isQueryConvertibleToCQL ( kunderaQuery ) ) { return onUpdateDeleteEvent ( ) ; } else { query = null ; if ( kunderaQuery . isUpdateClause ( ) ) { query = createUpdateQuery ( kunderaQuery ) ; } else { query = createDeleteQuery ( kunderaQuery ) ; } return ( ( CassandraClientBase ) client ) . executeUpdateDeleteQuery ( query ) ; } } return 0 ; }
On executeUpdate .