mysqlストアド・プロシージャが動的SQL内で戻り値を取得する方法の詳細

MySql汎用ページング・ストレージ・プロシージャ
プロセスパラメータ

 
  
p_cloumns varchar(500),p_tables varchar(100),p_where varchar(4000),p_order varchar(100),p_pageindex int,p_pagesize int,out p_recordcount int,out p_pagecount int 
  
 
  
 $:begin 
  
    declare v_sqlcounts varchar(4000); 
  
    declare v_sqlselect varchar(4000); 
  
 
   #        SQL  
   set v_sqlcounts = concat('select count(*) into @recordcount from ',p_tables,p_where); 
  
    #select v_sqlcounts;leave $; 
  
   set @sqlcounts = v_sqlcounts; 
  
   prepare stmt from @sqlcounts; 
  
        execute stmt; 
  
  deallocate prepare stmt; 
  
 
     #    SQL     
  set p_recordcount = @recordcount; 
  
 
    #             
   set p_pagecount = ceiling((p_recordcount+0.0)/p_pagesize); 
  
   if p_pageindex <1 then 
  
       set p_pageindex = 1; 
  
     elseif p_pageindex > p_pagecount and p_pagecount <> 0 then 
  
       set p_pageindex = p_pagecount; 
  
   end if; 
  
   
  #           SQL  
   set v_sqlselect = concat('select ',p_cloumns,' from ',p_tables,p_where,if(p_order is not null,p_order,''),' limit ',(p_pageindex-1)*p_pagesize,' , ',p_pagesize); 
  
   #select v_sqlselect;leave $; 
  
   set @sqlselect = v_sqlselect; 
  
    prepare stmtselect from @sqlselect; 
  
   execute stmtselect; 
  
    deallocate prepare stmtselect; 
  
   end $ 
  
 
 

 
  
 
  #        SQL     
  
set v_sqlcounts = concat('select count(*) into @recordcount from ',v_tables,v_where);   
  
set @sqlcounts := v_sqlcounts;   
  
 
  #     SQL   
prepare stmt from @sqlcounts;   
  
 
  #    SQL      
  
set @s1= categoryid;   
  
execute stmt using @s1;   
  
deallocate prepare stmt;   
  
 
  #    SQL        
set recordcount = @recordcount;  
  
 
 

#クエリの合計レコードをつづるSQL文set v_sqlcounts = concat('select count(*) into @recordcount from ',v_tables,v_where);
set @sqlcounts := v_sqlcounts;
#動的SQL prepare stmt from@sqlcounts;
#動的SQL内パラメータset@s 1=categoryidを渡します.execute stmt using @s1; deallocate prepare stmt;
#動的SQL文の戻り値set recordcount=@recordcountを取得します.
以上、ストレージ・プロシージャのページングで動的SQLでクエリーしたcountレコードの数を変数@recordcountを介してrecordcountに入れました.
mysqlのIF ELSEは他のデータベースとは少し判断が異なり、簡単な判断文は以下の通りです.

 
  
#                
  
set pagecount = ceiling((recordcount+0.0)/pagesize);   
  
if pageindex <1 then  
  
    set pageindex = 1;   
  
elseif pageindex > pagecount then  
  
    set pageindex = pagecount;   
  
else  
  
    select pageindex,pagecount;   
  
end if;  
  
 
 

#合計レコードホップ数から合計ページ数set pagecount=ceiling((recordcount+0.0)/pagesize)を算出します.if pageindex <1 then set pageindex = 1; elseif pageindex > pagecount then set pageindex = pagecount; else select pageindex,pagecount; end if;