DatabaseWrapper.java 文件源码

@Nonnull
@CheckReturnValue
private <T> List<T> selectSqlQuery(@Nonnull final Function<EntityManager, Query> queryFunc,
                                   @Nullable final Map<String, Object> parameters)
        throws DatabaseException, PersistenceException, ClassCastException {
    final EntityManager em = this.databaseConnection.getEntityManager();
    try {
        final Query q = queryFunc.apply(em);
        if (parameters != null) {
            parameters.forEach(q::setParameter);
        }
        return selectNativeSqlQuery(em, q);
    } finally {
        em.close();
    }
}