MYSQL分頁存儲過程及事務處理

最近給客戶做的一小系統是SQLSERVER的數據庫，因為特殊原因要切換到MYSQL上去，切換數據庫確實讓人頭疼的，SQLSERVER和MYSQL的存儲過程還是有很大差別的，下面是我做切換時轉換的MYSQL版的分頁過程，和事務處理的一個測試過程，事務處理也不像SQLSERVER那樣。不多說了，供學習MYSQL的兄弟們參考下，我用的MYSQL5.5版本，經過測試都是可行的。

 

/*
--名稱：MYSQL版查詢分頁存儲過程 by peace 2013-8-14
--輸入參數：@fields        -- 要查詢的字段用逗號隔開
--輸入參數：@tables        -- 要查詢的表
--輸入參數：@where        -- 查詢條件
--輸入參數：@orderby    -- 排序字段
--輸出參數：@page        -- 當前頁計數從1開始
--輸出參數：@pagesize    -- 每頁大小
--輸出參數：@totalcount -- 總記錄數
--輸出參數：@pagecount  -- 總頁數 
*/
DROP PROCEDURE IF EXISTS Query_Pagination; 
CREATE PROCEDURE Query_Pagination
(
    in _fields varchar(2000),   
    in _tables text, 
    in _where varchar(2000),  
    in _orderby varchar(200),
    in _pageindex int,
    in _pagesize int,
    in _sumfields  varchar(200),/*增加統計字段2013-5-8 peaceli*/
    out _totalcount int ,
    out _pagecount int 
)
begin
   set @startRow = _pageSize*(_pageIndex -1);
   set @pageSize = _pageSize;  set @rowindex = 0;
     set @strsql = CONCAT('select sql_calc_found_rows @rowindex:=@rowindex+1 as rownumber,',_fields,' from ',_tables,case ifnull(_where,'') when '' then '' else concat(' where ',_where) end,' order by ',_orderby,' limit ',@startRow,',',@pageSize);
     prepare strsql from @strsql;
     execute strsql;
   deallocate prepare strsql;
   set _totalcount = found_rows(); 

 if (_totalcount <= _pageSize) then

                    set _pagecount = 1;
                    else if (_totalcount % _pageSize > 0) then
                    set _pagecount = _totalcount / _pageSize + 1;
                    else
                     set _pagecount = _totalcount / _pageSize;
            end if;
        end if;

if(ifnull(_sumfields,'') <> '') then set @sumsql = contact('select ',_sumfields,' from ',_tables,case ifnull(_where,'') when '' then '' else concat(' where ',_where) end); prepare sumsql from @sumsql; execute sumsql; deallocate prepare sumsql; end if; end

CREATE PROCEDURE TransTest(in p1 VARCHAR(20),in p2 VARCHAR(50))
BEGIN
declare err int default 0;  
 /*如果出現sql異常，則將err設置為1后繼續執行后面的操作 */  
declare continue handler for sqlexception set err=1; -- 出錯處理  
set autocommit = 0;
insert into sy_queryconfig(syq_id) values(p1); 
insert into sy_queryconfig(syq_id) values(p2); 
if err=1 then  
 ROLLBACK;
ELSE
 COMMIT;
end if;
END

 

CREATE PROCEDURE TransTest2(in p1 VARCHAR(20),in p2 VARCHAR(50))
BEGIN
/*只要發生異常就回滾*/ 
declare exit handler for sqlexception 
BEGIN
    ROLLBACK;
  /*返回異常處理結果等其它操作*/  
END; 
START TRANSACTION;
insert into sy_queryconfig(syq_id) values(p1); 
insert into sy_queryconfig(syq_id) values(p2); 
COMMIT;
END