MySQL存储过程分页兼返回总页数

gmysql 2011-10-06

因为MySQL目前不支持动态参数分页所以存储过程中要么传sql语句过去要么自己写个字符串连接方法

下为第二种方法 

把每个需要分割的地方单写一行,清除

  1. BEGIN  
  1. SELECT CEIL(COUNT(*)/pageNum) INTO pageCount FROM mytestdb.mttest WHERE tt_id = arg_mt_id;  
  1. SET @sqlStr = CONCAT('SELECT `mt_id`,`tt_id`,`tt_name` FROM `mytestdb`.`mttest` WHERE `tt_id` = ');  
  1. SET @sqlStr = CONCAT(@sqlStr,arg_mt_id);  
  1. SET @sqlStr = CONCAT(@sqlStr,' LIMIT ');SET @sqlStr = CONCAT(@sqlStr,((pageNum-1)*pageSize));  
  1. SET @sqlStr = CONCAT(@sqlStr,',');  
  1. SET @sqlStr = CONCAT(@sqlStr,pageSize);  
  1. SET @sqlStr = CONCAT(@sqlStr,';');  
  1. PREPARE s1 FROM @sqlStr;  
  1. EXECUTE s1;  
  1. DEALLOCATE PREPARE s1;  
  1. END  

或者写成一行,效率高但是更容易写错

  1. BEGIN  
  1. SELECT CEIL(COUNT(*)/pageNum) INTO pageCount FROM mytestdb.mttest WHERE tt_id = arg_mt_id;  
  1. SET @sqlStr = CONCAT('SELECT `mt_id`,`tt_id`,`tt_name` FROM `mytestdb`.`mttest` WHERE `tt_id` = ',arg_mt_id,' LIMIT '
  1. ((pageNum-1)*pageSize),',',pageSize';');  
  1. PREPARE s1 FROM @sqlStr;EXECUTE s1;DEALLOCATE PREPARE s1;END  

java端

  1. try {Connection conn = db.openDB(getServletContext());String sql = "{call `myPagingTest`(?,?,?,?)}";CallableStatement cs = conn.prepareCall(sql);cs.setInt(11);cs.setInt(21);cs.setInt(35);cs.registerOutParameter(4, Types.INTEGER);rs = cs.executeQuery();System.out.println(cs.getInt(4));while(rs.next()){out.println(rs.getInt(1));              out.println(rs.getInt(2));              out.println(rs.getString(3) + "<br>");    }} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}finally{          try {if(rs != null){rs.close();}if(db!=null){db.close();}} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}      }  

相关推荐

ganyouxianjava / 0评论 2012-05-31