QueryEach

queryEach(query, function(row [, currentRow] [, query] ){} [, parallel] [, maxThreadCount])

<cfscript>
    myQuery = queryNew("id,name,amount","Integer,Varchar,Integer", 
                [ 
                        {id=1,name="One",amount=15}, 
                        {id=2,name="Two",amount=18}, 
                        {id=3,name="Three",amount=32} 
                ]); 
   QueryEach(myQuery,function(any obj){
        writeOutput(obj.name & "<br/>")
   })
</cfscript>

<cfscript>
               qoptions = {result="myresult", datasource="cfbookclub", fetchclientinfo="yes"};
               sampleQuery = QueryExecute("select * from books order by bookid", [] ,qoptions);
               
               function printQuery(any Obj){
                              WriteDump(Obj);
               }
               WriteOutput("QueryEach: ");
               QueryEach(sampleQuery, printQuery);
</cfscript>

<cfscript>
       myResult=QueryExecute("SELECT * FROM EMPLOYEES",[],{datasource="cfdocexamples"});
       // Execute the function to call each row and return the values of Location
       myResult.each(function(count){
             myList=#count.LOCATION#;
             WriteOutput(myList);
       });
</cfscript>

 
<cfscript> 
    myQuery = queryNew("id,name,amount","Integer,Varchar,Integer",  
                [  
                        {id=1,name="One",amount=15},  
                        {id=2,name="Two",amount=18},  
                        {id=3,name="Three",amount=32} , 
      {id=4,name="Three",amount=32}, 
      {id=5,name="Three",amount=32}, 
      {id=6,name="Three",amount=32}, 
      {id=7,name="Three",amount=32}, 
      {id=8,name="Three",amount=32}, 
      {id=9,name="Three",amount=32}, 
      {id=10,name="Three",amount=32}, 
      {id=11,name="Three",amount=32} 
       
                ]);  
    function callbck(any obj){ 
        writeOutput(obj.name & "<br>") 
   } 
   QueryEach(myQuery,callbck,true,10) 
</cfscript> 
 
<cfscript> 
               qoptions = {result="myresult", datasource="cfbookclub", fetchclientinfo="yes"}; 
               sampleQuery = QueryExecute("select * from books order by bookid", [] ,qoptions); 
                 
               function printQuery(any Obj){ 
                              Writeoutput(Obj.bookimage & "<br>"); 
               } 
               WriteOutput("QueryEach: "); 
               QueryEach(query =sampleQuery,callback= printQuery,parallel=false,maxthreadcount=5); 
      QueryEach(query =sampleQuery,callback= printQuery,parallel=false); 
</cfscript> 
 
<cfscript> 
       myResult=QueryExecute("SELECT * FROM EMPLOYEES",[],{datasource="cfdocexamples"}); 
       // Execute the function to call each row and return the values of Location 
       myResult.each(function(count){ 
             myList=#count.LOCATION#; 
             WriteOutput(myList & "<br>"); 
       },true,10); 
</cfscript>

<cfscript> 
    // Install the package derby before executing this code. cfpm>install derby 
    qoptions = {result="myresult", datasource="cfbookclub", fetchclientinfo="yes"}; 
    sampleQuery = QueryExecute("select * from books order by bookid", [] ,qoptions); 
                     
    function printQuery(any Obj){ 
        return Obj; 
    } 
    t_start=GetTickCount() 
    QueryEach(query =sampleQuery,callback= printQuery,parallel=true,maxthreadcount=50) 
    t_end=GetTickCount() 
    writeoutput("<br>Time taken with 50 threads:" &  t_end-t_start) 
</cfscript>

<cfscript> 
    myResult=QueryExecute("SELECT * FROM EMPLOYEES",[],{datasource="cfdocexamples"}); 
    // Execute the function to call each row and return the values of Location 
    t_start=GetTickCount() 
        myResult.each(function(count){ 
                  myList=#count.LOCATION#; 
                  WriteOutput(myList); 
        },true,50) 
    t_end=GetTickCount() 
    writeOutput("<br>Time taken with 50 threads:" &  t_end-t_start) 
</cfscript>