December 2013 - Topia-commits - mailman.cloud.codelutin.com

r2940 - trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 23:54:50 +0100 (Wed, 18 Dec 2013) New Revision: 2940 Url: http://nuiton.org/projects/topia/repository/revisions/2940 Log: add findAllLazy(int batchsize) + open some api on AbstractTopiaDao Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 22:52:14 UTC (rev 2939) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 22:54:50 UTC (rev 2940) @@ -149,7 +149,7 @@ return newFromClause(null); } - protected String newFromClause(String alias) { + public String newFromClause(String alias) { String hql = "from " + getTopiaEntityEnum().getImplementationFQN(); if (StringUtils.isNotBlank(alias)) { hql += " " + alias; @@ -354,7 +354,7 @@ return result; } - protected TopiaQueryBuilderRunQueryStep<E> forHql(String hql, Map<String, Object> hqlParameters) { + public TopiaQueryBuilderRunQueryStep<E> forHql(String hql, Map<String, Object> hqlParameters) { TopiaQueryBuilderRunQueryStep<E> result = new TopiaQueryBuilderRunQueryStep<E>(this, hql, hqlParameters); return result; } @@ -504,7 +504,7 @@ return result; } - protected <K> List<K> find(String hql, Map<String, Object> hqlParameters, TopiaPagerBean pager) { + public <K> List<K> find(String hql, Map<String, Object> hqlParameters, TopiaPagerBean pager) { Preconditions.checkNotNull(hql); Preconditions.checkNotNull(hqlParameters); Preconditions.checkNotNull(pager); @@ -533,6 +533,12 @@ protected <K> Iterable<K> findAllLazy(String hql, Map<String, Object> hqlParameters) { + Iterable<K> result= findAllLazy(hql, hqlParameters, batchSize); + return result; + } + + protected <K> Iterable<K> findAllLazy(String hql, Map<String, Object> hqlParameters, int batchSize) { + Preconditions.checkNotNull(hql); Preconditions.checkNotNull(hqlParameters); @@ -870,6 +876,11 @@ } @Override + public Iterable<E> findAllLazy(int batchSize) { + return getNextStep().findAllLazy(batchSize); + } + + @Override public long count() { return getNextStep().count(); } @@ -979,6 +990,11 @@ } @Override + public Iterable<E> findAllLazy(int batchSize) { + return topiaDAO.findAllLazy(hql, hqlParameters, batchSize); + } + + @Override public List<E> find(int startIndex, int endIndex) { return topiaDAO.find(hql, hqlParameters, startIndex, endIndex); } Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java 2013-12-18 22:52:14 UTC (rev 2939) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java 2013-12-18 22:54:50 UTC (rev 2940) @@ -119,6 +119,8 @@ Iterable<E> findAllLazy(); + Iterable<E> findAllLazy(int batchSize); + List<E> find(int startIndex, int endIndex); List<E> find(TopiaPagerBean pager);

1 0

r2939 - in trunk: topia-persistence/src/main/java/org/nuiton/topia topia-templates/src/main/java/org/nuiton/topia/templates
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 23:52:14 +0100 (Wed, 18 Dec 2013) New Revision: 2939 Url: http://nuiton.org/projects/topia/repository/revisions/2939 Log: improve AbstractApplicationContext and his transformer Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/AbstractTopiaApplicationContext.java trunk/topia-templates/src/main/java/org/nuiton/topia/templates/ApplicationContextTransformer.java Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/AbstractTopiaApplicationContext.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/AbstractTopiaApplicationContext.java 2013-12-18 22:51:39 UTC (rev 2938) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/AbstractTopiaApplicationContext.java 2013-12-18 22:52:14 UTC (rev 2939) @@ -107,6 +107,16 @@ protected abstract Class<? extends TopiaEntity>[] getImplementationClasses(); + public abstract String getModelVersion() ; + + public abstract String getModelName() ; + + public abstract <T extends TopiaEntity> Class<T> getContractClass(Class<T> klass); + + public abstract <T extends TopiaEntity> Class<T> getImplementationClass(Class<T> klass); + + public abstract Class<? extends TopiaEntity>[] getContractClasses(); + protected String getImplementationClassesAsString() { StringBuilder buffer = new StringBuilder(); for (Class<? extends TopiaEntity> aClass : getImplementationClasses()) { Modified: trunk/topia-templates/src/main/java/org/nuiton/topia/templates/ApplicationContextTransformer.java =================================================================== --- trunk/topia-templates/src/main/java/org/nuiton/topia/templates/ApplicationContextTransformer.java 2013-12-18 22:51:39 UTC (rev 2938) +++ trunk/topia-templates/src/main/java/org/nuiton/topia/templates/ApplicationContextTransformer.java 2013-12-18 22:52:14 UTC (rev 2939) @@ -176,6 +176,7 @@ // getModelVersion method String modelVersion = model.getVersion(); op = addOperation(output, "getModelVersion", "String", ObjectModelJavaModifier.PUBLIC); + addAnnotation(output, op, Override.class); setOperationBody(op, "" /*{ return "<%=modelVersion%>"; @@ -184,6 +185,7 @@ // getModelName method op = addOperation(output, "getModelName", "String", ObjectModelJavaModifier.PUBLIC); + addAnnotation(output, op, Override.class); setOperationBody(op, "" /*{ return "<%=modelName%>"; @@ -192,6 +194,7 @@ // getContractClass method op = addOperation(output, "getContractClass", "<T extends TopiaEntity> Class<T>", ObjectModelJavaModifier.PUBLIC); + addAnnotation(output, op, Override.class); addParameter(op, "Class<T>", "klass"); setOperationBody(op, "" /*{ @@ -202,6 +205,7 @@ // getImplementationClass method op = addOperation(output, "getImplementationClass", "<T extends TopiaEntity> Class<T>", ObjectModelJavaModifier.PUBLIC); + addAnnotation(output, op, Override.class); addParameter(op, "Class<T>", "klass"); setOperationBody(op, "" /*{ @@ -212,6 +216,7 @@ // getContractClasses method op = addOperation(output, "getContractClasses", "Class<? extends TopiaEntity>[]", ObjectModelJavaModifier.PUBLIC); + addAnnotation(output, op, Override.class); setOperationBody(op, "" /*{ <%=entityEnumName%>[] values = <%=entityEnumName%>.values(); @@ -225,6 +230,7 @@ // getImplementationClasses method op = addOperation(output, "getImplementationClasses", "Class<? extends TopiaEntity>[]", ObjectModelJavaModifier.PUBLIC); + addAnnotation(output, op, Override.class); setOperationBody(op, "" /*{ <%=entityEnumName%>[] values = <%=entityEnumName%>.values();

1 0

r2938 - trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 23:51:39 +0100 (Wed, 18 Dec 2013) New Revision: 2938 Url: http://nuiton.org/projects/topia/repository/revisions/2938 Log: fixes #2973: Making migration service works again Modified: trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/AbstractTopiaMigrationCallback.java trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClass.java trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClassNG.java trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByMethod.java trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationEngine.java Modified: trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/AbstractTopiaMigrationCallback.java =================================================================== --- trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/AbstractTopiaMigrationCallback.java 2013-12-18 22:50:15 UTC (rev 2937) +++ trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/AbstractTopiaMigrationCallback.java 2013-12-18 22:51:39 UTC (rev 2938) @@ -28,7 +28,6 @@ import org.apache.commons.logging.LogFactory; import org.hibernate.jdbc.Work; import org.nuiton.topia.AbstractTopiaApplicationContext; -import org.nuiton.topia.AbstractTopiaPersistenceContext; import org.nuiton.topia.TopiaException; import org.nuiton.topia.TopiaHibernateSupport; import org.nuiton.topia.TopiaPersistenceContext; @@ -40,8 +39,6 @@ import java.sql.SQLException; import java.util.List; -import com.google.common.base.Preconditions; - /** * Abstract migration callback. * @@ -57,9 +54,6 @@ /** @return the available versions from the call back */ public abstract Version[] getAvailableVersions(); - /** @return the current application version (says the version to use) */ - public abstract Version getApplicationVersion(); - /** * Hook to ask user if migration can be performed. * @@ -70,8 +64,10 @@ public abstract boolean askUser(Version dbVersion, List<Version> versions); + protected abstract TopiaHibernateSupport getHibernateSupport(TopiaPersistenceContext tx); + protected abstract void migrateForVersion(Version version, - TopiaHibernateSupport tx, + TopiaPersistenceContext tx, boolean showSql, boolean showProgression) throws Exception; @@ -88,12 +84,12 @@ * * Note: pour chaque version a appliquer, on ouvre une nouvelle transaction. * - * @param applicationContext topia context de la transaction en cours - * @param dbVersion database version - * @param showSql drapeau pour afficher les requete sql - * @param showProgression drapeau pour afficher la progression - * @param versions all versions knwon by service @return migration a - * ggrement + * @param applicationContext topia context de la transaction en cours + * @param dbVersion database version + * @param showSql drapeau pour afficher les requete sql + * @param showProgression drapeau pour afficher la progression + * @param versions all versions knwon by service @return migration a + * ggrement * @return {@code true} si la migration est accepté, {@code false} autrement. */ public boolean doMigration(AbstractTopiaApplicationContext applicationContext, @@ -103,56 +99,49 @@ List<Version> versions) { boolean doMigrate = askUser(dbVersion, versions); - if (!doMigrate) { - // l'utilisateur a refuse la migration - return false; - } + if (doMigrate) { - for (Version v : versions) { - // ouverture d'une connexion direct JDBC sur la base - try { + for (Version v : versions) { + // ouverture d'une connexion direct JDBC sur la base + try { - TopiaPersistenceContext persistenceContext = applicationContext.newPersistenceContext(); - TopiaHibernateSupport hibernateSupport = null; - if (persistenceContext instanceof AbstractTopiaPersistenceContext) { - hibernateSupport = ((AbstractTopiaPersistenceContext)persistenceContext).getHibernateSupport(); - } - Preconditions.checkState(hibernateSupport != null); + TopiaPersistenceContext persistenceContext = + applicationContext.newPersistenceContext(); + try { - try { + log.info(String.format("Start migration to version %s", v)); - log.info(String.format("Start migration to version %s", v)); + migrateForVersion(v, persistenceContext, showSql, showProgression); - migrateForVersion(v, hibernateSupport, showSql, showProgression); + // commit des modifs + persistenceContext.commit(); - // commit des modifs - persistenceContext.commit(); + } catch (Exception eee) { + // en cas d'erreur + log.error("Could not migrate database", eee); + // rollback du travail en cours + persistenceContext.rollback(); + // propagation de l'erreur + throw eee; + } finally { + // close database connexion + if (persistenceContext != null) { + persistenceContext.closeContext(); + } + } } catch (Exception eee) { - // en cas d'erreur - log.error("Could not migrate database", eee); - // rollback du travail en cours - persistenceContext.rollback(); - // propagation de l'erreur - throw eee; - } finally { - // close database connexion - if (persistenceContext != null) { - persistenceContext.closeContext(); - } + log.error("Error lors de la tentative de migration", eee); + doMigrate = false; + // toute erreur arrête la mgration + break; } - - } catch (Exception eee) { - log.error("Error lors de la tentative de migration", eee); - doMigrate = false; - // toute erreur arrête la mgration - break; } } return doMigrate; } - public void executeSQL(TopiaHibernateSupport tx, String... sqls) + public void executeSQL(TopiaPersistenceContext tx, String... sqls) throws TopiaException { executeSQL(tx, false, false, sqls); } @@ -160,18 +149,18 @@ /** * Executes the given {@code sqls} requests. * - * @param tx the session * @param showSql flag to see sql requests * @param showProgression flag to see progession on console * @param sqls requests to execute * @throws TopiaException if any pb * @since 2.3.0 */ - public void executeSQL(TopiaHibernateSupport tx, + public void executeSQL(TopiaPersistenceContext tx, final boolean showSql, final boolean showProgression, final String... sqls) throws TopiaException { + TopiaHibernateSupport hibernateSupport = getHibernateSupport(tx); if (log.isInfoEnabled()) { log.info(String.format("Will execute %1$s requests...", sqls.length)); @@ -189,7 +178,7 @@ "--------------------------------------------------------------------------------\n" ); } - tx.getHibernateSession().doWork(new Work() { + hibernateSupport.getHibernateSession().doWork(new Work() { @Override public void execute(Connection connection) throws SQLException { Modified: trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClass.java =================================================================== --- trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClass.java 2013-12-18 22:50:15 UTC (rev 2937) +++ trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClass.java 2013-12-18 22:51:39 UTC (rev 2938) @@ -25,7 +25,7 @@ package org.nuiton.topia.migration; import org.nuiton.topia.TopiaException; -import org.nuiton.topia.TopiaHibernateSupport; +import org.nuiton.topia.TopiaPersistenceContext; import org.nuiton.util.ObjectUtil; import org.nuiton.util.Version; @@ -67,7 +67,7 @@ @Override protected void migrateForVersion(Version version, - TopiaHibernateSupport tx, + TopiaPersistenceContext tx, boolean showSql, boolean showProgression) throws Exception { @@ -100,7 +100,7 @@ } - protected String[] prepareMigration(TopiaHibernateSupport tx, + protected String[] prepareMigration(TopiaPersistenceContext tx, boolean showSql, boolean showProgression) throws TopiaException { @@ -111,17 +111,17 @@ return queries.toArray(new String[queries.size()]); } - protected abstract void prepareMigrationScript(TopiaHibernateSupport tx, + protected abstract void prepareMigrationScript(TopiaPersistenceContext tx, List<String> queries, boolean showSql, boolean showProgression) throws TopiaException; - public void executeSQL(TopiaHibernateSupport tx, + public void executeSQL(TopiaPersistenceContext tx, String... sqls) throws TopiaException { callBack.executeSQL(tx, sqls); } - public void executeSQL(TopiaHibernateSupport tx, + public void executeSQL(TopiaPersistenceContext tx, boolean showSql, boolean showProgression, String... sqls) throws TopiaException { Modified: trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClassNG.java =================================================================== --- trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClassNG.java 2013-12-18 22:50:15 UTC (rev 2937) +++ trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByClassNG.java 2013-12-18 22:51:39 UTC (rev 2938) @@ -27,7 +27,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.nuiton.topia.TopiaException; -import org.nuiton.topia.TopiaHibernateSupport; +import org.nuiton.topia.TopiaPersistenceContext; import org.nuiton.util.Version; import org.nuiton.util.VersionUtil; @@ -73,7 +73,7 @@ @Override protected void migrateForVersion(Version version, - TopiaHibernateSupport tx, + TopiaPersistenceContext tx, boolean showSql, boolean showProgression) throws Exception { @@ -103,7 +103,7 @@ this.callBack = callBack; } - protected String[] prepareMigration(TopiaHibernateSupport tx, + protected String[] prepareMigration(TopiaPersistenceContext tx, boolean showSql, boolean showProgression) throws TopiaException { @@ -114,17 +114,17 @@ return queries.toArray(new String[queries.size()]); } - protected abstract void prepareMigrationScript(TopiaHibernateSupport tx, + protected abstract void prepareMigrationScript(TopiaPersistenceContext tx, List<String> queries, boolean showSql, boolean showProgression) throws TopiaException; - public void executeSQL(TopiaHibernateSupport tx, + public void executeSQL(TopiaPersistenceContext tx, String... sqls) throws TopiaException { callBack.executeSQL(tx, sqls); } - public void executeSQL(TopiaHibernateSupport tx, + public void executeSQL(TopiaPersistenceContext tx, boolean showSql, boolean showProgression, String... sqls) throws TopiaException { Modified: trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByMethod.java =================================================================== --- trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByMethod.java 2013-12-18 22:50:15 UTC (rev 2937) +++ trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationCallbackByMethod.java 2013-12-18 22:51:39 UTC (rev 2938) @@ -26,7 +26,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.nuiton.topia.TopiaHibernateSupport; +import org.nuiton.topia.TopiaPersistenceContext; import org.nuiton.util.Version; import java.lang.reflect.Method; @@ -51,14 +51,14 @@ @Override protected void migrateForVersion(Version version, - TopiaHibernateSupport tx, + TopiaPersistenceContext tx, boolean showSql, boolean showProgression) throws Exception { String methodName = "migrateTo_" + version.getValidName(); Method m = getClass().getMethod(methodName, - TopiaHibernateSupport.class, + TopiaPersistenceContext.class, boolean.class, boolean.class ); Modified: trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationEngine.java =================================================================== --- trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationEngine.java 2013-12-18 22:50:15 UTC (rev 2937) +++ trunk/topia-service-migration/src/main/java/org/nuiton/topia/migration/TopiaMigrationEngine.java 2013-12-18 22:51:39 UTC (rev 2938) @@ -202,7 +202,8 @@ public boolean preInit(AbstractTopiaApplicationContext context) { applicationContext = context; - Properties config = null; //applicationContext.getConfig(); + Properties config = new Properties(); + config.putAll(applicationContext.getConfiguration()); String callbackStr = getSafeParameter(config, MIGRATION_CALLBACK); if (log.isDebugEnabled()) { @@ -299,7 +300,7 @@ detectDbVersion(); - Version version = callback.getApplicationVersion(); + Version version = getApplicationVersion(); log.info(String.format("Starting Topia Migration Service - Application version \\: %1$s, Database version \\: %2$s", version.getVersion(), @@ -424,7 +425,7 @@ checkInit(); - Version version = callback.getApplicationVersion(); + Version version = getApplicationVersion(); detectDbVersion(); @@ -504,6 +505,10 @@ dbVersion = version; } + protected Version getApplicationVersion() { + return VersionUtil.valueOf(applicationContext.getModelVersion()); + } + /** * Recupere depuis la base les états internes du service : *

1 0

r2937 - in trunk/topia-templates/src/main/resources: . META-INF META-INF/services
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 23:50:15 +0100 (Wed, 18 Dec 2013) New Revision: 2937 Url: http://nuiton.org/projects/topia/repository/revisions/2937 Log: fixes #2972: ToPIA tagValues and stereotypes are no more found wxhile generating a model Added: trunk/topia-templates/src/main/resources/META-INF/ trunk/topia-templates/src/main/resources/META-INF/services/ trunk/topia-templates/src/main/resources/META-INF/services/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider Removed: trunk/topia-templates/src/main/resources/META-INF.services/ trunk/topia-templates/src/main/resources/META-INF/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider Deleted: trunk/topia-templates/src/main/resources/META-INF/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider =================================================================== --- trunk/topia-templates/src/main/resources/META-INF.services/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider 2013-12-18 16:22:42 UTC (rev 2933) +++ trunk/topia-templates/src/main/resources/META-INF/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider 2013-12-18 22:50:15 UTC (rev 2937) @@ -1 +0,0 @@ -org.nuiton.topia.templates.TopiaGeneratorUtil$TopiaModelPropertiesProvider \ No newline at end of file Copied: trunk/topia-templates/src/main/resources/META-INF/services/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider (from rev 2933, trunk/topia-templates/src/main/resources/META-INF.services/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider) =================================================================== --- trunk/topia-templates/src/main/resources/META-INF/services/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider (rev 0) +++ trunk/topia-templates/src/main/resources/META-INF/services/org.nuiton.eugene.ModelPropertiesUtil$ModelPropertiesProvider 2013-12-18 22:50:15 UTC (rev 2937) @@ -0,0 +1 @@ +org.nuiton.topia.templates.TopiaGeneratorUtil$TopiaModelPropertiesProvider \ No newline at end of file

1 0

r2936 - trunk/topia-templates/src/main/java/org/nuiton/topia/templates
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 23:47:03 +0100 (Wed, 18 Dec 2013) New Revision: 2936 Url: http://nuiton.org/projects/topia/repository/revisions/2936 Log: fix javadoc Modified: trunk/topia-templates/src/main/java/org/nuiton/topia/templates/TopiaTagValues.java Modified: trunk/topia-templates/src/main/java/org/nuiton/topia/templates/TopiaTagValues.java =================================================================== --- trunk/topia-templates/src/main/java/org/nuiton/topia/templates/TopiaTagValues.java 2013-12-18 17:43:56 UTC (rev 2935) +++ trunk/topia-templates/src/main/java/org/nuiton/topia/templates/TopiaTagValues.java 2013-12-18 22:47:03 UTC (rev 2936) @@ -30,6 +30,7 @@ import org.nuiton.eugene.models.object.ObjectModelClass; import org.nuiton.eugene.models.object.ObjectModelClassifier; import org.nuiton.eugene.models.object.ObjectModelElement; +import org.nuiton.topia.TopiaDaoSupplier; import org.nuiton.topia.persistence.TopiaEntityContextable; import static org.nuiton.eugene.ModelPropertiesUtil.TagValueDefinition; @@ -55,7 +56,7 @@ /** * Tag pour que les entités etendent {@link TopiaEntityContextable} et - * se fasse injecter le {@link TopiaContext} par rapport aux autres + * se fasse injecter le {@link TopiaDaoSupplier} par rapport aux autres * entités qui ne l'ont pas. * * @since 2.5.3

1 0

r2935 - trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence
by bleny＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: bleny Date: 2013-12-18 18:43:56 +0100 (Wed, 18 Dec 2013) New Revision: 2935 Url: http://nuiton.org/projects/topia/repository/revisions/2935 Log: add some arguments checks in HqlAndParametersBuilder, add missing methods on TopiaQueryBuilderAddCriteriaStep Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 16:40:25 UTC (rev 2934) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 17:43:56 UTC (rev 2935) @@ -785,6 +785,18 @@ return this; } + @Override + public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addTopiaIdNotEquals(String property, String topiaId) { + hqlAndParametersBuilder.addTopiaIdNotEquals(property, topiaId); + return this; + } + + @Override + public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addTopiaIdNotIn(String property, Iterable<String> topiaIds) { + hqlAndParametersBuilder.addTopiaIdNotIn(property, topiaIds); + return this; + } + // shortcuts to next step @Override Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java 2013-12-18 16:40:25 UTC (rev 2934) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java 2013-12-18 17:43:56 UTC (rev 2935) @@ -66,38 +66,18 @@ this.entityClass = entityClass; } - public Set<String> getWhereClauses() { - return whereClauses; - } - - public void setWhereClauses(Set<String> whereClauses) { - this.whereClauses = whereClauses; - } - public void addNull(String property) { + Preconditions.checkArgument(StringUtils.isNotBlank(property)); whereClauses.add(alias + "." + property + " is null"); } public void addNotNull(String property) { + Preconditions.checkArgument(StringUtils.isNotBlank(property)); whereClauses.add(alias + "." + property + " is not null"); } - public void setParameters(Map<String, Object> parameters) { - this.parameters = parameters; - } - - public void setOrderByArguments(Set<String> orderByArguments) { - this.orderByArguments = orderByArguments; - } - - public void setOrderByArguments(String... orderByArguments) { - Set<String> orderByArgumentsAsSet = Sets.newLinkedHashSet(); - orderByArgumentsAsSet.addAll(Arrays.asList(orderByArguments)); - this.orderByArguments = orderByArgumentsAsSet; - } - public void addEquals(String property, Object value) { - Preconditions.checkNotNull(property); + Preconditions.checkArgument(StringUtils.isNotEmpty(property)); // TODO brendan 02/10/13 do not use HQL parameters of Object are primitive types // TODO brendan 02/10/13 if value is intanceof TopiaEntity, we can check type if (value == null) { @@ -109,7 +89,7 @@ } public void addNotEquals(String property, Object value) { - Preconditions.checkNotNull(property); + Preconditions.checkArgument(StringUtils.isNotEmpty(property)); // TODO brendan 02/10/13 do not use HQL parameters of Object are primitive types // TODO brendan 02/10/13 if value is intanceof TopiaEntity, we can check type if (value == null) { @@ -133,7 +113,7 @@ * must not be in given collection */ protected void addInOrNotIn(String property, Iterable<?> values, boolean in) { - Preconditions.checkNotNull(property); + Preconditions.checkArgument(StringUtils.isNotEmpty(property)); Preconditions.checkNotNull(values); // TODO brendan 02/10/13 if value is intanceof TopiaEntity, we can check type // TODO brendan 02/10/13 do not use HQL parameters of Object are primitive @@ -189,9 +169,18 @@ } public void addTopiaIdIn(String property, Iterable<String> topiaIds) { - addIn(property + "." + TopiaEntity.PROPERTY_TOPIA_ID, (Iterable) topiaIds); + addIn(property + "." + TopiaEntity.PROPERTY_TOPIA_ID, topiaIds); } + public void addTopiaIdNotEquals(String property, String topiaId) { + Preconditions.checkNotNull(topiaId); + addNotEquals(property + "." + TopiaEntity.PROPERTY_TOPIA_ID, topiaId); + } + + public void addTopiaIdNotIn(String property, Iterable<String> topiaIds) { + addNotIn(property + "." + TopiaEntity.PROPERTY_TOPIA_ID, (Iterable) topiaIds); + } + public void addContains(String property, Object value) { String hqlParameterName = putHqlParameterWithAvailableName(property, value); whereClauses.add(":" + hqlParameterName + " in elements(" + alias + "." + property + ")"); @@ -215,6 +204,31 @@ parameters.putAll(hqlParameters); } + public void setWhereClauses(Set<String> whereClauses) { + Preconditions.checkNotNull(whereClauses); + this.whereClauses = whereClauses; + } + + public Set<String> getWhereClauses() { + return whereClauses; + } + + public void setParameters(Map<String, Object> parameters) { + Preconditions.checkNotNull(parameters); + this.parameters = parameters; + } + + public void setOrderByArguments(Set<String> orderByArguments) { + Preconditions.checkNotNull(orderByArguments); + this.orderByArguments = orderByArguments; + } + + public void setOrderByArguments(String... orderByArguments) { + Set<String> orderByArgumentsAsSet = Sets.newLinkedHashSet(); + orderByArgumentsAsSet.addAll(Arrays.asList(orderByArguments)); + this.orderByArguments = orderByArgumentsAsSet; + } + public String getHql() { StringBuilder hqlStringBuilder = new StringBuilder(); hqlStringBuilder.append("from ").append(entityClass.getCanonicalName()).append(" ").append(alias); Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java 2013-12-18 16:40:25 UTC (rev 2934) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java 2013-12-18 17:43:56 UTC (rev 2935) @@ -103,6 +103,10 @@ TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addTopiaIdIn(String property, Iterable<String> topiaIds); + TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addTopiaIdNotEquals(String property, String topiaId); + + TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addTopiaIdNotIn(String property, Iterable<String> topiaIds); + TopiaQueryBuilderRunQueryStep<E> setOrderByArguments(Set<String> orderByArguments); TopiaQueryBuilderRunQueryStep<E> setOrderByArguments(String... orderByArguments);

1 0

r2934 - trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 17:40:25 +0100 (Wed, 18 Dec 2013) New Revision: 2934 Url: http://nuiton.org/projects/topia/repository/revisions/2934 Log: fixes #2971: Add some methods to use pager in TopiaDao and query builder Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 16:22:42 UTC (rev 2933) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 16:40:25 UTC (rev 2934) @@ -188,6 +188,11 @@ public TopiaPagerBean newPager(String hql, Map<String, Object> params, int pageSize) { TopiaPagerBean pager = new TopiaPagerBean(); + if (hqlContainsOrderBy(hql)) { + + // must remove the order by clause, otherwise some sql queries won't work. + hql = hql.substring(0, hql.toLowerCase().indexOf("order by")); + } long count = count("SELECT COUNT(*) " + hql, params); pager.setRecords(count); pager.setPageSize(pageSize); @@ -504,10 +509,13 @@ Preconditions.checkNotNull(hqlParameters); Preconditions.checkNotNull(pager); - boolean orderByClausePresent = hqlContainsOrderBy(hql); - Preconditions.checkState(!orderByClausePresent, "An 'order by' clause was already found in hql, can't use the order of the pager"); + if (StringUtils.isNotBlank(pager.getSortColumn())) { - if (StringUtils.isNotBlank(pager.getSortColumn())) { + // can't have a order by clause in hql query + Preconditions.checkState( + !hqlContainsOrderBy(hql), + "An 'order by' clause was already found in hql, can't use the order of the pager"); + hql += " order by " + pager.getSortColumn(); if (!pager.isSortAscendant()) { hql += " desc";

1 0

r2933 - trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 17:22:42 +0100 (Wed, 18 Dec 2013) New Revision: 2933 Url: http://nuiton.org/projects/topia/repository/revisions/2933 Log: fixes #2971: Add some methods to use pager in TopiaDao and query builder fixes some generics issues on query builder Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaDao.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 16:21:54 UTC (rev 2932) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/AbstractTopiaDao.java 2013-12-18 16:22:42 UTC (rev 2933) @@ -80,6 +80,7 @@ * @param <E> the managed entity type * @author bpoussin <poussin(a)codelutin.com> * @author Arnaud Thimel <thimel(a)codelutin.com> + * @author Tony CHEMIT <chemit(a)codelutin.com> */ public abstract class AbstractTopiaDao<E extends TopiaEntity> implements TopiaDao<E> { @@ -144,6 +145,10 @@ this.batchSize = batchSize; } + protected String newFromClause() { + return newFromClause(null); + } + protected String newFromClause(String alias) { String hql = "from " + getTopiaEntityEnum().getImplementationFQN(); if (StringUtils.isNotBlank(alias)) { @@ -165,15 +170,32 @@ } catch (InstantiationException e) { throw new TopiaException( "Impossible de trouver ou d'instancier la classe " - + implementation); + + implementation); } catch (IllegalAccessException e) { throw new TopiaException( "Impossible de trouver ou d'instancier la classe " - + implementation); + + implementation); } } @Override + public TopiaPagerBean newPager(int pageSize) { + TopiaPagerBean pager = newPager(newFromClause(), null, pageSize); + return pager; + } + + @Override + public TopiaPagerBean newPager(String hql, Map<String, Object> params, int pageSize) { + TopiaPagerBean pager = new TopiaPagerBean(); + + long count = count("SELECT COUNT(*) " + hql, params); + pager.setRecords(count); + pager.setPageSize(pageSize); + PagerBeanUtil.computeRecordIndexesAndPagesNumber(pager); + return pager; + } + + @Override public void addTopiaEntityListener(TopiaEntityListener listener) { topiaListenableSupport.addTopiaEntityListener(getEntityClass(), listener); } @@ -328,7 +350,7 @@ } protected TopiaQueryBuilderRunQueryStep<E> forHql(String hql, Map<String, Object> hqlParameters) { - TopiaQueryBuilderRunQueryStep result = new TopiaQueryBuilderRunQueryStep(this, hql, hqlParameters); + TopiaQueryBuilderRunQueryStep<E> result = new TopiaQueryBuilderRunQueryStep<E>(this, hql, hqlParameters); return result; } @@ -344,7 +366,7 @@ @Override public TopiaQueryBuilderAddCriteriaStep<E> forProperties(Map<String, Object> properties) { HqlAndParametersBuilder<E> hqlAndParametersBuilder = getHqlForProperties(properties); - TopiaQueryBuilderAddCriteriaStep result = new TopiaQueryBuilderAddCriteriaStep(this, hqlAndParametersBuilder); + TopiaQueryBuilderAddCriteriaStep<E> result = new TopiaQueryBuilderAddCriteriaStep<E>(this, hqlAndParametersBuilder); return result; } @@ -353,14 +375,14 @@ Object propertyValue, Object... otherPropertyNamesAndValues) { HqlAndParametersBuilder<E> hqlAndParametersBuilder = getHqlForProperties(propertyName, propertyValue, otherPropertyNamesAndValues); - TopiaQueryBuilderAddCriteriaStep result = new TopiaQueryBuilderAddCriteriaStep(this, hqlAndParametersBuilder); + TopiaQueryBuilderAddCriteriaStep<E> result = new TopiaQueryBuilderAddCriteriaStep<E>(this, hqlAndParametersBuilder); return result; } @Override public TopiaQueryBuilderAddCriteriaStep<E> newQueryBuilder() { HqlAndParametersBuilder<E> hqlAndParametersBuilder = newHqlAndParametersBuilder(); - TopiaQueryBuilderAddCriteriaStep result = new TopiaQueryBuilderAddCriteriaStep(this, hqlAndParametersBuilder); + TopiaQueryBuilderAddCriteriaStep<E> result = new TopiaQueryBuilderAddCriteriaStep<E>(this, hqlAndParametersBuilder); return result; } @@ -377,7 +399,7 @@ } @Override - public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> forIn(String propertyName, Iterable<Object> propertyValues) { + public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> forIn(String propertyName, Iterable<?> propertyValues) { TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> result = newQueryBuilder().addIn(propertyName, propertyValues); return result; } @@ -434,7 +456,7 @@ } protected <K> K findFirstOrNull(String hql, Map<String, Object> hqlParameters) throws QueryMissingOrderException { - if ( ! hql.toLowerCase().contains("order by")) { + if (!hqlContainsOrderBy(hql)) { throw new QueryMissingOrderException(hql, hqlParameters); } K result = findAnyOrNull(hql, hqlParameters); @@ -482,6 +504,9 @@ Preconditions.checkNotNull(hqlParameters); Preconditions.checkNotNull(pager); + boolean orderByClausePresent = hqlContainsOrderBy(hql); + Preconditions.checkState(!orderByClausePresent, "An 'order by' clause was already found in hql, can't use the order of the pager"); + if (StringUtils.isNotBlank(pager.getSortColumn())) { hql += " order by " + pager.getSortColumn(); if (!pager.isSortAscendant()) { @@ -504,9 +529,9 @@ Preconditions.checkNotNull(hqlParameters); final Iterator<K> iterator = new FindAllIterator<E, K>(this, - batchSize, - hql, - hqlParameters); + batchSize, + hql, + hqlParameters); Iterable<K> result = new Iterable<K>() { @Override @@ -577,6 +602,14 @@ return result; } + protected boolean hqlContainsOrderBy(String hql) { + return hql.toLowerCase().contains("order by"); + } + + protected boolean hqlContainsCount(String hql) { + return hql.toLowerCase().contains("count("); + } + // /** // * package locale method because this is hibernate specific method and // * we don't want expose it. @@ -599,47 +632,38 @@ protected final AbstractTopiaDao<E> dao; - protected final String hql; protected final Map<String, Object> params; - protected TopiaPagerBean pager; + protected final TopiaPagerBean pager; public FindAllIterator(AbstractTopiaDao<E> dao, int batchSize, String hql, Map<String, Object> params) { - this.dao = dao; - this.hql = hql; - this.params = params; - String hql2 = hql.toLowerCase(); - int i = hql2.indexOf("order by"); - if (i == -1) { + if (!dao.hqlContainsOrderBy(hql)) { throw new QueryMissingOrderException(hql, params); } - // get the count (removing the order-by) - long count2 = dao.count("SELECT COUNT(*) " + - hql.substring(0, i), params); - pager = new TopiaPagerBean(); - pager.setRecords(count2); - pager.setPageSize(batchSize); - PagerBeanUtil.computeRecordIndexesAndPagesNumber(pager); + this.dao = dao; + this.hql = hql; + this.params = params; + pager = dao.newPager(hql, params, batchSize); // empty iterator (will be changed at first next call) data = Iterators.emptyIterator(); } - + public boolean hasNext() { boolean result = data.hasNext() || // no more data - pager.getPageIndex() < pager.getPagesNumber(); + pager.getPageIndex() < pager.getPagesNumber(); return result; } - + public K next() { if (!hasNext()) { throw new NoSuchElementException(); @@ -663,7 +687,7 @@ return next; } - + public void remove() { throw new UnsupportedOperationException( "This iterator does not support remove operation."); @@ -676,8 +700,6 @@ protected HqlAndParametersBuilder<E> hqlAndParametersBuilder; - protected boolean hasOrderByClause = false; - protected TopiaQueryBuilderAddCriteriaStep(AbstractTopiaDao<E> topiaDAO, HqlAndParametersBuilder<E> hqlAndParametersBuilder) { this.topiaDAO = topiaDAO; this.hqlAndParametersBuilder = hqlAndParametersBuilder; @@ -685,7 +707,6 @@ @Override public TopiaQueryBuilderRunQueryStep<E> setOrderByArguments(Set<String> orderByArguments) { - hasOrderByClause = ! Iterables.isEmpty(orderByArguments); hqlAndParametersBuilder.setOrderByArguments(orderByArguments); return getNextStep(); } @@ -709,13 +730,13 @@ } @Override - public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addIn(String property, Iterable<Object> values) { + public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addIn(String property, Iterable<?> values) { hqlAndParametersBuilder.addIn(property, values); return this; } @Override - public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addNotIn(String property, Iterable<Object> values) { + public TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addNotIn(String property, Iterable<?> values) { hqlAndParametersBuilder.addNotIn(property, values); return this; } @@ -819,6 +840,11 @@ } @Override + public List<E> find(TopiaPagerBean pager) { + return getNextStep().find(pager); + } + + @Override public Iterable<E> findAllLazy() { return getNextStep().findAllLazy(); } @@ -834,6 +860,11 @@ } @Override + public List<String> findIds(TopiaPagerBean pager) { + return getNextStep().findIds(pager); + } + + @Override public List<String> findAllIds() { return getNextStep().findAllIds(); } @@ -841,7 +872,7 @@ protected TopiaQueryBuilderRunQueryStep<E> getNextStep() { String hql = hqlAndParametersBuilder.getHql(); Map<String, Object> hqlParameters = hqlAndParametersBuilder.getHqlParameters(); - TopiaQueryBuilderRunQueryStep nextStep = new TopiaQueryBuilderRunQueryStep(topiaDAO, hql, hqlParameters); + TopiaQueryBuilderRunQueryStep<E> nextStep = new TopiaQueryBuilderRunQueryStep<E>(topiaDAO, hql, hqlParameters); return nextStep; } @@ -853,7 +884,7 @@ protected final Map<String, Object> hqlParameters; - protected AbstractTopiaDao<E> topiaDAO; + protected final AbstractTopiaDao<E> topiaDAO; protected TopiaQueryBuilderRunQueryStep(AbstractTopiaDao<E> topiaDAO, String hql, Map<String, Object> hqlParameters) { this.hql = hql; @@ -933,6 +964,11 @@ } @Override + public List<E> find(TopiaPagerBean pager) { + return topiaDAO.find(hql, hqlParameters, pager); + } + + @Override public List<String> findAllIds() { String hqlWithSelectClause = "select topiaId " + hql; return topiaDAO.findAll(hqlWithSelectClause, hqlParameters); @@ -944,6 +980,11 @@ return topiaDAO.find(hqlWithSelectClause, hqlParameters, startIndex, endIndex); } + @Override + public List<String> findIds(TopiaPagerBean pager) { + String hqlWithSelectClause = "select topiaId " + hql; + return topiaDAO.find(hqlWithSelectClause, hqlParameters, pager); + } } } Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java 2013-12-18 16:21:54 UTC (rev 2932) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/HqlAndParametersBuilder.java 2013-12-18 16:22:42 UTC (rev 2933) @@ -120,11 +120,11 @@ } } - public void addIn(String property, Iterable<Object> values) { + public void addIn(String property, Iterable<?> values) { addInOrNotIn(property, values, true); } - public void addNotIn(String property, Iterable<Object> values) { + public void addNotIn(String property, Iterable<?> values) { addInOrNotIn(property, values, false); } @@ -132,7 +132,7 @@ * @param in true if property value must be in given collection, false if value * must not be in given collection */ - protected void addInOrNotIn(String property, Iterable<Object> values, boolean in) { + protected void addInOrNotIn(String property, Iterable<?> values, boolean in) { Preconditions.checkNotNull(property); Preconditions.checkNotNull(values); // TODO brendan 02/10/13 if value is intanceof TopiaEntity, we can check type Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaDao.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaDao.java 2013-12-18 16:21:54 UTC (rev 2932) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaDao.java 2013-12-18 16:22:42 UTC (rev 2933) @@ -28,6 +28,7 @@ import org.nuiton.topia.TopiaNoResultException; import org.nuiton.topia.event.TopiaEntityListener; import org.nuiton.topia.event.TopiaEntityVetoable; +import org.nuiton.topia.persistence.pager.TopiaPagerBean; import java.util.List; import java.util.Map; @@ -74,6 +75,33 @@ E newInstance(); /** + * Creates a new pager initialized for the first page of all data of the dao. + * + * Note: This method will execute a count query to init + * the pager. + * + * @param pageSize size of a page + * @return the initialized pager. + * @since 3.0 + */ + TopiaPagerBean newPager(int pageSize); + + /** + * Creates a new pager initialized for the first page of data of the given + * query. + * + * Note: This method will execute a count query to init + * the pager. + * + * @param hql query + * @param params params of the query + * @param pageSize size of a page + * @return the initialized pager. + * @since 3.0 + */ + TopiaPagerBean newPager(String hql, Map<String, Object> params, int pageSize); + + /** * Creates an entity not created without the DAO using any of the others * create methods. The instance may have been created elsewhere. * @@ -195,7 +223,7 @@ /** * @since 3.0 */ - TopiaQueryBuilderRunQueryStep<E> forIn(String propertyName, Iterable<Object> propertyValues); + TopiaQueryBuilderRunQueryStep<E> forIn(String propertyName, Iterable<?> propertyValues); /** * @since 3.0 Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java 2013-12-18 16:21:54 UTC (rev 2932) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderAddCriteriaStep.java 2013-12-18 16:22:42 UTC (rev 2933) @@ -56,14 +56,14 @@ * a one-to-one or a many-to-one property * @param values the value the field of the entity must be equals to one of the given values */ - TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addIn(String property, Iterable<Object> values); + TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addIn(String property, Iterable<?> values); /** * @param property the name of a field of the queried entity, must be * a one-to-one or a many-to-one property * @param values the value the field of the entity must not be equals to any of the given values */ - TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addNotIn(String property, Iterable<Object> values); + TopiaQueryBuilderAddCriteriaOrRunQueryStep<E> addNotIn(String property, Iterable<?> values); /** * @param property the name of a field of the queried entity, must be Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java 2013-12-18 16:21:54 UTC (rev 2932) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/persistence/TopiaQueryBuilderRunQueryStep.java 2013-12-18 16:22:42 UTC (rev 2933) @@ -28,6 +28,7 @@ import org.nuiton.topia.QueryMissingOrderException; import org.nuiton.topia.TopiaNoResultException; import org.nuiton.topia.TopiaNonUniqueResultException; +import org.nuiton.topia.persistence.pager.TopiaPagerBean; import java.util.List; @@ -120,8 +121,12 @@ List<E> find(int startIndex, int endIndex); + List<E> find(TopiaPagerBean pager); + List<String> findAllIds(); List<String> findIds(int startIndex, int endIndex); + List<String> findIds(TopiaPagerBean pager); + }

1 0

r2932 - trunk/topia-persistence/src/main/java/org/nuiton/topia
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 17:21:54 +0100 (Wed, 18 Dec 2013) New Revision: 2932 Url: http://nuiton.org/projects/topia/repository/revisions/2932 Log: exception are serializable Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/QueryMissingOrderException.java Modified: trunk/topia-persistence/src/main/java/org/nuiton/topia/QueryMissingOrderException.java =================================================================== --- trunk/topia-persistence/src/main/java/org/nuiton/topia/QueryMissingOrderException.java 2013-12-18 16:20:29 UTC (rev 2931) +++ trunk/topia-persistence/src/main/java/org/nuiton/topia/QueryMissingOrderException.java 2013-12-18 16:21:54 UTC (rev 2932) @@ -41,6 +41,8 @@ protected static final String MESSAGE = "given query needs an order by clause since the API call you use need the results sorting to be deterministic"; + private static final long serialVersionUID = 8154110639594660107L; + public QueryMissingOrderException(String hql, Map<String, Object> hqlParameters) { super(MESSAGE, hql, hqlParameters); }

1 0

r2931 - trunk/src/site/rst
by tchemit＠users.nuiton.org Dec. 18, 2013

Dec. 18, 2013

Author: tchemit Date: 2013-12-18 17:20:29 +0100 (Wed, 18 Dec 2013) New Revision: 2931 Url: http://nuiton.org/projects/topia/repository/revisions/2931 Log: update migration doc Modified: trunk/src/site/rst/migrate_to_3.0.rst Modified: trunk/src/site/rst/migrate_to_3.0.rst =================================================================== --- trunk/src/site/rst/migrate_to_3.0.rst 2013-12-18 10:28:57 UTC (rev 2930) +++ trunk/src/site/rst/migrate_to_3.0.rst 2013-12-18 16:20:29 UTC (rev 2931) @@ -36,7 +36,7 @@ ToPIA nécessite des versions minimum de Eugene et Hibernate. Vous devez utiliser les version suivantes : - * Eugene >= 2.6.4 + * Eugene >= 2.7.3 * Hibernate >= 4.2.1.Final

1 0