|
|
|
@ -149,7 +149,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
* Set the Hibernate SessionFactory that should be used to create |
|
|
|
* Set the Hibernate SessionFactory that should be used to create |
|
|
|
* Hibernate Sessions. |
|
|
|
* Hibernate Sessions. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
public void setSessionFactory(@Nullable SessionFactory sessionFactory) { |
|
|
|
public void setSessionFactory(@Nullable SessionFactory sessionFactory) { |
|
|
|
this.sessionFactory = sessionFactory; |
|
|
|
this.sessionFactory = sessionFactory; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -184,7 +184,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
* @see #enableFilters(Session) |
|
|
|
* @see #enableFilters(Session) |
|
|
|
* @see Session#enableFilter(String) |
|
|
|
* @see Session#enableFilter(String) |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
public void setFilterNames(@Nullable String... filterNames) { |
|
|
|
public void setFilterNames(@Nullable String... filterNames) { |
|
|
|
this.filterNames = filterNames; |
|
|
|
this.filterNames = filterNames; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -465,9 +465,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@Nullable |
|
|
|
@Nullable |
|
|
|
public <T> T get(final Class<T> entityClass, final Serializable id, @Nullable final LockMode lockMode) |
|
|
|
public <T> T get(Class<T> entityClass, Serializable id, @Nullable LockMode lockMode) throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return executeWithNativeSession(session -> { |
|
|
|
return executeWithNativeSession(session -> { |
|
|
|
if (lockMode != null) { |
|
|
|
if (lockMode != null) { |
|
|
|
return session.get(entityClass, id, new LockOptions(lockMode)); |
|
|
|
return session.get(entityClass, id, new LockOptions(lockMode)); |
|
|
|
@ -486,9 +484,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@Nullable |
|
|
|
@Nullable |
|
|
|
public Object get(final String entityName, final Serializable id, @Nullable final LockMode lockMode) |
|
|
|
public Object get(String entityName, Serializable id, @Nullable LockMode lockMode) throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return executeWithNativeSession(session -> { |
|
|
|
return executeWithNativeSession(session -> { |
|
|
|
if (lockMode != null) { |
|
|
|
if (lockMode != null) { |
|
|
|
return session.get(entityName, id, new LockOptions(lockMode)); |
|
|
|
return session.get(entityName, id, new LockOptions(lockMode)); |
|
|
|
@ -505,7 +501,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public <T> T load(final Class<T> entityClass, final Serializable id, @Nullable final LockMode lockMode) |
|
|
|
public <T> T load(Class<T> entityClass, Serializable id, @Nullable LockMode lockMode) |
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
@ -524,9 +520,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public Object load(final String entityName, final Serializable id, @Nullable final LockMode lockMode) |
|
|
|
public Object load(String entityName, Serializable id, @Nullable LockMode lockMode) throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
if (lockMode != null) { |
|
|
|
if (lockMode != null) { |
|
|
|
return session.load(entityName, id, new LockOptions(lockMode)); |
|
|
|
return session.load(entityName, id, new LockOptions(lockMode)); |
|
|
|
@ -539,7 +533,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"unchecked", "deprecation"}) |
|
|
|
public <T> List<T> loadAll(final Class<T> entityClass) throws DataAccessException { |
|
|
|
public <T> List<T> loadAll(Class<T> entityClass) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<T>>) session -> { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<T>>) session -> { |
|
|
|
Criteria criteria = session.createCriteria(entityClass); |
|
|
|
Criteria criteria = session.createCriteria(entityClass); |
|
|
|
criteria.setResultTransformer(Criteria.DISTINCT_ROOT_ENTITY); |
|
|
|
criteria.setResultTransformer(Criteria.DISTINCT_ROOT_ENTITY); |
|
|
|
@ -550,7 +544,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"deprecation"}) |
|
|
|
@SuppressWarnings({"deprecation"}) |
|
|
|
public void load(final Object entity, final Serializable id) throws DataAccessException { |
|
|
|
public void load(Object entity, Serializable id) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
session.load(entity, id); |
|
|
|
session.load(entity, id); |
|
|
|
return null; |
|
|
|
return null; |
|
|
|
@ -558,12 +552,12 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void refresh(final Object entity) throws DataAccessException { |
|
|
|
public void refresh(Object entity) throws DataAccessException { |
|
|
|
refresh(entity, null); |
|
|
|
refresh(entity, null); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void refresh(final Object entity, @Nullable final LockMode lockMode) throws DataAccessException { |
|
|
|
public void refresh(Object entity, @Nullable LockMode lockMode) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
if (lockMode != null) { |
|
|
|
if (lockMode != null) { |
|
|
|
session.refresh(entity, new LockOptions(lockMode)); |
|
|
|
session.refresh(entity, new LockOptions(lockMode)); |
|
|
|
@ -576,14 +570,14 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public boolean contains(final Object entity) throws DataAccessException { |
|
|
|
public boolean contains(Object entity) throws DataAccessException { |
|
|
|
Boolean result = executeWithNativeSession(session -> session.contains(entity)); |
|
|
|
Boolean result = executeWithNativeSession(session -> session.contains(entity)); |
|
|
|
Assert.state(result != null, "No contains result"); |
|
|
|
Assert.state(result != null, "No contains result"); |
|
|
|
return result; |
|
|
|
return result; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void evict(final Object entity) throws DataAccessException { |
|
|
|
public void evict(Object entity) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
session.evict(entity); |
|
|
|
session.evict(entity); |
|
|
|
return null; |
|
|
|
return null; |
|
|
|
@ -616,7 +610,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
//-------------------------------------------------------------------------
|
|
|
|
//-------------------------------------------------------------------------
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void lock(final Object entity, final LockMode lockMode) throws DataAccessException { |
|
|
|
public void lock(Object entity, LockMode lockMode) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
session.buildLockRequest(new LockOptions(lockMode)).lock(entity); |
|
|
|
session.buildLockRequest(new LockOptions(lockMode)).lock(entity); |
|
|
|
return null; |
|
|
|
return null; |
|
|
|
@ -624,7 +618,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void lock(final String entityName, final Object entity, final LockMode lockMode) |
|
|
|
public void lock(String entityName, Object entity, LockMode lockMode) |
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
@ -634,7 +628,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public Serializable save(final Object entity) throws DataAccessException { |
|
|
|
public Serializable save(Object entity) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
return session.save(entity); |
|
|
|
return session.save(entity); |
|
|
|
@ -642,7 +636,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public Serializable save(final String entityName, final Object entity) throws DataAccessException { |
|
|
|
public Serializable save(String entityName, Object entity) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
return session.save(entityName, entity); |
|
|
|
return session.save(entityName, entity); |
|
|
|
@ -655,7 +649,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void update(final Object entity, @Nullable final LockMode lockMode) throws DataAccessException { |
|
|
|
public void update(Object entity, @Nullable LockMode lockMode) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
session.update(entity); |
|
|
|
session.update(entity); |
|
|
|
@ -672,7 +666,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void update(final String entityName, final Object entity, @Nullable final LockMode lockMode) |
|
|
|
public void update(String entityName, Object entity, @Nullable LockMode lockMode) |
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
@ -686,7 +680,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void saveOrUpdate(final Object entity) throws DataAccessException { |
|
|
|
public void saveOrUpdate(Object entity) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
session.saveOrUpdate(entity); |
|
|
|
session.saveOrUpdate(entity); |
|
|
|
@ -695,7 +689,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void saveOrUpdate(final String entityName, final Object entity) throws DataAccessException { |
|
|
|
public void saveOrUpdate(String entityName, Object entity) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
session.saveOrUpdate(entityName, entity); |
|
|
|
session.saveOrUpdate(entityName, entity); |
|
|
|
@ -704,9 +698,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void replicate(final Object entity, final ReplicationMode replicationMode) |
|
|
|
public void replicate(Object entity, ReplicationMode replicationMode) throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
session.replicate(entity, replicationMode); |
|
|
|
session.replicate(entity, replicationMode); |
|
|
|
@ -715,7 +707,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void replicate(final String entityName, final Object entity, final ReplicationMode replicationMode) |
|
|
|
public void replicate(String entityName, Object entity, ReplicationMode replicationMode) |
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
@ -726,7 +718,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void persist(final Object entity) throws DataAccessException { |
|
|
|
public void persist(Object entity) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
session.persist(entity); |
|
|
|
session.persist(entity); |
|
|
|
@ -735,7 +727,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void persist(final String entityName, final Object entity) throws DataAccessException { |
|
|
|
public void persist(String entityName, Object entity) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
session.persist(entityName, entity); |
|
|
|
session.persist(entityName, entity); |
|
|
|
@ -745,7 +737,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings("unchecked") |
|
|
|
@SuppressWarnings("unchecked") |
|
|
|
public <T> T merge(final T entity) throws DataAccessException { |
|
|
|
public <T> T merge(T entity) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
return (T) session.merge(entity); |
|
|
|
return (T) session.merge(entity); |
|
|
|
@ -754,7 +746,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings("unchecked") |
|
|
|
@SuppressWarnings("unchecked") |
|
|
|
public <T> T merge(final String entityName, final T entity) throws DataAccessException { |
|
|
|
public <T> T merge(String entityName, T entity) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
return nonNull(executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
return (T) session.merge(entityName, entity); |
|
|
|
return (T) session.merge(entityName, entity); |
|
|
|
@ -767,7 +759,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void delete(final Object entity, @Nullable final LockMode lockMode) throws DataAccessException { |
|
|
|
public void delete(Object entity, @Nullable LockMode lockMode) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
if (lockMode != null) { |
|
|
|
if (lockMode != null) { |
|
|
|
@ -784,7 +776,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void delete(final String entityName, final Object entity, @Nullable final LockMode lockMode) |
|
|
|
public void delete(String entityName, Object entity, @Nullable LockMode lockMode) |
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
@ -798,7 +790,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void deleteAll(final Collection<?> entities) throws DataAccessException { |
|
|
|
public void deleteAll(Collection<?> entities) throws DataAccessException { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
executeWithNativeSession(session -> { |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
checkWriteOperationAllowed(session); |
|
|
|
for (Object entity : entities) { |
|
|
|
for (Object entity : entities) { |
|
|
|
@ -835,8 +827,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings("unchecked") |
|
|
|
public List<?> findByCriteria(DetachedCriteria criteria, int firstResult, int maxResults) |
|
|
|
public List<?> findByCriteria(final DetachedCriteria criteria, final int firstResult, final int maxResults) |
|
|
|
|
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
Assert.notNull(criteria, "DetachedCriteria must not be null"); |
|
|
|
Assert.notNull(criteria, "DetachedCriteria must not be null"); |
|
|
|
@ -870,8 +861,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"unchecked", "deprecation"}) |
|
|
|
public <T> List<T> findByExample( |
|
|
|
public <T> List<T> findByExample(@Nullable String entityName, T exampleEntity, int firstResult, int maxResults) |
|
|
|
@Nullable final String entityName, final T exampleEntity, final int firstResult, final int maxResults) |
|
|
|
|
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
Assert.notNull(exampleEntity, "Example entity must not be null"); |
|
|
|
Assert.notNull(exampleEntity, "Example entity must not be null"); |
|
|
|
@ -898,7 +888,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Deprecated |
|
|
|
@Deprecated |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
public List<?> find(final String queryString, @Nullable final Object... values) throws DataAccessException { |
|
|
|
public List<?> find(String queryString, @Nullable Object... values) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
ReflectionUtils.invokeMethod(createQueryMethod, session, queryString)); |
|
|
|
ReflectionUtils.invokeMethod(createQueryMethod, session, queryString)); |
|
|
|
@ -923,7 +913,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Deprecated |
|
|
|
@Deprecated |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
public List<?> findByNamedParam(final String queryString, final String[] paramNames, final Object[] values) |
|
|
|
public List<?> findByNamedParam(String queryString, String[] paramNames, Object[] values) |
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
if (paramNames.length != values.length) { |
|
|
|
if (paramNames.length != values.length) { |
|
|
|
@ -943,8 +933,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Deprecated |
|
|
|
@Deprecated |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
public List<?> findByValueBean(final String queryString, final Object valueBean) |
|
|
|
public List<?> findByValueBean(String queryString, Object valueBean) throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
@ -963,7 +952,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Deprecated |
|
|
|
@Deprecated |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
public List<?> findByNamedQuery(final String queryName, @Nullable final Object... values) throws DataAccessException { |
|
|
|
public List<?> findByNamedQuery(String queryName, @Nullable Object... values) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
ReflectionUtils.invokeMethod(getNamedQueryMethod, session, queryName)); |
|
|
|
ReflectionUtils.invokeMethod(getNamedQueryMethod, session, queryName)); |
|
|
|
@ -989,7 +978,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
public List<?> findByNamedQueryAndNamedParam( |
|
|
|
public List<?> findByNamedQueryAndNamedParam( |
|
|
|
final String queryName, @Nullable final String[] paramNames, @Nullable final Object[] values) |
|
|
|
String queryName, @Nullable String[] paramNames, @Nullable Object[] values) |
|
|
|
throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
if (values != null && (paramNames == null || paramNames.length != values.length)) { |
|
|
|
if (values != null && (paramNames == null || paramNames.length != values.length)) { |
|
|
|
@ -1011,8 +1000,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Deprecated |
|
|
|
@Deprecated |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "unchecked", "deprecation"}) |
|
|
|
public List<?> findByNamedQueryAndValueBean(final String queryName, final Object valueBean) |
|
|
|
public List<?> findByNamedQueryAndValueBean(String queryName, Object valueBean) throws DataAccessException { |
|
|
|
throws DataAccessException { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<List<?>>) session -> { |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
@ -1031,7 +1019,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Deprecated |
|
|
|
@Deprecated |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "deprecation"}) |
|
|
|
public Iterator<?> iterate(final String queryString, @Nullable final Object... values) throws DataAccessException { |
|
|
|
public Iterator<?> iterate(String queryString, @Nullable Object... values) throws DataAccessException { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<Iterator<?>>) session -> { |
|
|
|
return nonNull(executeWithNativeSession((HibernateCallback<Iterator<?>>) session -> { |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
ReflectionUtils.invokeMethod(createQueryMethod, session, queryString)); |
|
|
|
ReflectionUtils.invokeMethod(createQueryMethod, session, queryString)); |
|
|
|
@ -1059,7 +1047,7 @@ public class HibernateTemplate implements HibernateOperations, InitializingBean |
|
|
|
@Deprecated |
|
|
|
@Deprecated |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@SuppressWarnings({"rawtypes", "deprecation"}) |
|
|
|
@SuppressWarnings({"rawtypes", "deprecation"}) |
|
|
|
public int bulkUpdate(final String queryString, @Nullable final Object... values) throws DataAccessException { |
|
|
|
public int bulkUpdate(String queryString, @Nullable Object... values) throws DataAccessException { |
|
|
|
Integer result = executeWithNativeSession(session -> { |
|
|
|
Integer result = executeWithNativeSession(session -> { |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
org.hibernate.Query queryObject = queryObject( |
|
|
|
ReflectionUtils.invokeMethod(createQueryMethod, session, queryString)); |
|
|
|
ReflectionUtils.invokeMethod(createQueryMethod, session, queryString)); |
|
|
|
|