org.databene.benerator.engine.statement
Class GenerateOrIterateStatement

java.lang.Object
  extended by org.databene.benerator.engine.statement.AbstractStatement
      extended by org.databene.benerator.engine.statement.GenerateOrIterateStatement
All Implemented Interfaces:
java.io.Closeable, Statement, PageListener

public class GenerateOrIterateStatement
extends AbstractStatement
implements java.io.Closeable, PageListener

Creates a number of entities in parallel execution and a given page size.

Created: 01.02.2008 14:43:15

Author:
Volker Bergmann

Field Summary
protected  BeneratorContext childContext
           
protected  BeneratorContext context
           
protected  Generator<java.lang.Long> countGenerator
           
protected  boolean infoLog
           
protected  boolean isSubCreator
           
protected  org.databene.script.Expression<java.lang.Long> minCount
           
protected  PageListener pageListener
           
protected  org.databene.script.Expression<PageListener> pageListenerEx
           
protected  org.databene.script.Expression<java.lang.Long> pageSize
           
protected  GenerateAndConsumeTask task
           
 
Constructor Summary
GenerateOrIterateStatement(java.lang.String productName, Generator<java.lang.Long> countGenerator, org.databene.script.Expression<java.lang.Long> minCount, org.databene.script.Expression<java.lang.Long> pageSize, org.databene.script.Expression<PageListener> pageListenerEx, org.databene.script.Expression<org.databene.commons.ErrorHandler> errorHandler, boolean infoLog, boolean isSubCreator, BeneratorContext context)
           
 
Method Summary
protected  boolean beInitialized(BeneratorContext context)
           
 void close()
           
protected  java.util.List<PageListener> evaluatePageListeners(org.databene.commons.Context context)
           
 boolean execute(BeneratorContext ctx)
           
protected  void executeTask(java.lang.Long requestedExecutions, java.lang.Long minExecutions, java.lang.Long pageSizeValue, java.util.List<PageListener> pageListeners, org.databene.commons.ErrorHandler errorHandler)
           
 java.lang.Long generateCount(BeneratorContext context)
           
 BeneratorContext getChildContext()
           
 BeneratorContext getContext()
           
 GenerateAndConsumeTask getTask()
           
 void pageFinished()
           
 void pageStarting()
           
 void setTask(GenerateAndConsumeTask task)
           
 
Methods inherited from class org.databene.benerator.engine.statement.AbstractStatement
cache, getErrorHandler, handleError, handleError, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

task

protected GenerateAndConsumeTask task

countGenerator

protected Generator<java.lang.Long> countGenerator

minCount

protected org.databene.script.Expression<java.lang.Long> minCount

pageSize

protected org.databene.script.Expression<java.lang.Long> pageSize

pageListenerEx

protected org.databene.script.Expression<PageListener> pageListenerEx

pageListener

protected PageListener pageListener

infoLog

protected boolean infoLog

isSubCreator

protected boolean isSubCreator

context

protected BeneratorContext context

childContext

protected BeneratorContext childContext
Constructor Detail

GenerateOrIterateStatement

public GenerateOrIterateStatement(java.lang.String productName,
                                  Generator<java.lang.Long> countGenerator,
                                  org.databene.script.Expression<java.lang.Long> minCount,
                                  org.databene.script.Expression<java.lang.Long> pageSize,
                                  org.databene.script.Expression<PageListener> pageListenerEx,
                                  org.databene.script.Expression<org.databene.commons.ErrorHandler> errorHandler,
                                  boolean infoLog,
                                  boolean isSubCreator,
                                  BeneratorContext context)
Method Detail

setTask

public void setTask(GenerateAndConsumeTask task)

getTask

public GenerateAndConsumeTask getTask()

getContext

public BeneratorContext getContext()

getChildContext

public BeneratorContext getChildContext()

execute

public boolean execute(BeneratorContext ctx)
Specified by:
execute in interface Statement

generateCount

public java.lang.Long generateCount(BeneratorContext context)

close

public void close()
Specified by:
close in interface java.io.Closeable

pageStarting

public void pageStarting()
Specified by:
pageStarting in interface PageListener

pageFinished

public void pageFinished()
Specified by:
pageFinished in interface PageListener

evaluatePageListeners

protected java.util.List<PageListener> evaluatePageListeners(org.databene.commons.Context context)

beInitialized

protected boolean beInitialized(BeneratorContext context)

executeTask

protected void executeTask(java.lang.Long requestedExecutions,
                           java.lang.Long minExecutions,
                           java.lang.Long pageSizeValue,
                           java.util.List<PageListener> pageListeners,
                           org.databene.commons.ErrorHandler errorHandler)


Copyright © 2013. All Rights Reserved.