?? gdpage.java
字號:
package com.gd.mvc.util;
import java.sql.Connection;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import javax.sql.rowset.CachedRowSet;
import com.gd.jdbc.GdPageCachedRowSet;
import com.gd.jdbc.impl.GdDbConnection;
public class GdPage {
public GdPageCachedRowSet pageCrs = null;
Map[] map = null;
private List list;
private String action = "";
private int row;
private String page;
protected String sql;
/**
* 構造函數
* @param request
* @param sql,要分頁查詢的sql語句
* @param row,每頁要現實的筆數
* @throws Exception
*/
public GdPage(HttpServletRequest request, String sql, String row) {
//獲取連接
GdDbConnection conn = new GdDbConnection(this);
row = request.getParameter("gd_row") == null ? row : (String) request.getParameter("gd_row");
//獲取設定每頁顯示筆數
this.row = Integer.parseInt(row);
//表示獲取要調轉到的頁面
page = request.getParameter("gd_jumpPage") == null ? "" : (String) request.getParameter("gd_jumpPage");
//表示跳轉的時候要查詢的sql
String gd_querSql = request.getParameter("gd_querSql") == null ? "" : (String) request.getParameter("gd_querSql");
//是否重新設定了sql
String gd_resetSql = request.getAttribute("gd_resetSql") == null ? "" : (String) request.getAttribute("gd_resetSql");
//如果重新設定了sql,則page為空,表示從第一頁開始
if ("true".equals(gd_resetSql))
page = "";
//如果跳轉的時候要查詢的sql,重新設定了sql,則送給數據庫的為從參數中傳來的sql
if ("".equals(gd_querSql) || "true".equals(gd_resetSql)) {
this.sql = sql;
} else {
this.sql = gd_querSql;//否則使用頁面隱藏的sql
}
//開始進入數據庫進行查詢
try {
if (!"".equals(this.sql)) {
pageCrs = new GdPageCachedRowSet(conn.getConnection(this), request, this.sql);
//設定每頁顯示的筆數
pageCrs.setPageSize(Integer.parseInt(row));
//假如指定了調整的頁碼,則調轉到該頁
if (!"".equals(page))
gotoPage(page);
map = queryAllMap(pageCrs.getCachedRowSet());
}
} catch (Exception e) {
e.printStackTrace();
}
}
public GdPage(HttpServletRequest request, Connection conn, String sql, String row) {
row = request.getParameter("gd_row") == null ? row : (String) request.getParameter("gd_row");
//獲取設定每頁顯示筆數
this.row = Integer.parseInt(row);
//表示獲取要調轉到的頁面
page = request.getParameter("gd_jumpPage") == null ? "" : (String) request.getParameter("gd_jumpPage");
//表示跳轉的時候要查詢的sql
String gd_querSql = request.getParameter("gd_querSql") == null ? "" : (String) request.getParameter("gd_querSql");
//是否重新設定了sql
String gd_resetSql = request.getAttribute("gd_resetSql") == null ? "" : (String) request.getAttribute("gd_resetSql");
//如果重新設定了sql,則page為空,表示從第一頁開始
if ("true".equals(gd_resetSql))
page = "";
//如果跳轉的時候要查詢的sql,重新設定了sql,則送給數據庫的為從參數中傳來的sql
if ("".equals(gd_querSql) || "true".equals(gd_resetSql)) {
this.sql = sql;
} else {
this.sql = gd_querSql;//否則使用頁面隱藏的sql
}
//開始進入數據庫進行查詢
try {
if (!"".equals(this.sql)) {
pageCrs = new GdPageCachedRowSet(conn, request, this.sql);
//設定每頁顯示的筆數
pageCrs.setPageSize(Integer.parseInt(row));
//假如指定了調整的頁碼,則調轉到該頁
if (!"".equals(page))
gotoPage(page);
map = queryAllMap(pageCrs.getCachedRowSet());
}
} catch (Exception e) {
e.printStackTrace();
}
}
//設定頁面表單的action動作
public void setAction(String action) {
this.action = action;
}
//獲取頁面表單的action動作
public String getAction() {
return this.action;
}
/**
* 獲取分頁查詢的結果
*
* @return Map[]
*/
public Map[] getDataMaps() {
return this.map;
}
/**
* 返回當頁查詢后的筆數
*
* @return int
*/
public int getPageRowsCount() {
return pageCrs.getPageRowsCount();
}
/**
* 返回顯示內容
*
* @return String
*/
public String getBtnHtml() {
//隱藏2個字段,用來存儲要調轉的頁面和要查詢的sql語句
StringBuffer sb = new StringBuffer();
sb.append("<table width='100%' cellspacing='0' cellpadding='0' border=0><tr><td>");
sb.append("<input type='hidden' name='gd_jumpPage' value='" + page
+ "'>");
sb.append("<input type='hidden' name='gd_querSql' value=\"" + sql
+ "\">");
//sql語句為空,則返回空
if ("".equals(this.sql))
return "";
//開始組裝分頁按鈕
sb.append("<A HREF='javascript:gotoPage(1)'>首頁</A>");
if (1 == pageCrs.getPageCount()) {
sb.append(" 上一頁 ");
sb.append(" 下一頁 ");
} else if (pageCrs.getCurPage() == 1) {
sb.append(" 上一頁 ");
sb.append("<A HREF='javascript:gotoPage("
+ (pageCrs.getCurPage() + 1)
+ ")'> 下一頁 </A>");
} else if (pageCrs.getCurPage() == pageCrs.getPageCount()) {
sb.append("<A HREF='javascript:gotoPage("
+ (pageCrs.getCurPage() - 1)
+ ")'> 上一頁 </A>");
sb.append(" 下一頁 ");
} else {
sb.append("<A HREF='javascript:gotoPage("
+ (pageCrs.getCurPage() - 1)
+ ")'> 上一頁 </A>");
sb.append("<A HREF='javascript:gotoPage("
+ (pageCrs.getCurPage() + 1)
+ ")'> 下一頁 </A>");
}
sb.append("<A HREF='javascript:gotoPage("
+ pageCrs.getPageCount() + ")'> 尾頁 </A>");
sb.append("跳至第 ");
sb.append("\n <select name='").append("gd_pageNo").append(
"' onchange='javascript:gotoPage(this.value)'>\n");
for (int i = 0; pageCrs != null && i < pageCrs.getPageCount(); i++)
if (pageCrs.getCurPage() == i + 1)
sb.append("<option value='").append(i + 1).append(
"' selected>").append(i + 1).append("\n");
else
sb.append("<option value='").append(i + 1).append("'>")
.append(i + 1).append("\n");
sb.append("</select>");
sb.append(" ");
sb.append("\n <input type＝'text' size='2' name='").append(
"gd_pageNoTxt").append("' value='1' >頁\n");
sb
.append("<A HREF='javascript:gotoPage(form1.gd_pageNoTxt.value)'>GO </A>");
sb.append("每頁行數 ");
sb.append("\n <select name='").append("gd_row").append("' >\n");
sb.append("<option value='").append(row).append("'>").append(row)
.append("\n");
int str[] = {5, 10, 15, 20, 30, 50};
for (int i = 0; i < str.length; i++)
if (this.row == str[i])
sb.append("<option value='").append(str[i]).append(
"' selected>").append(str[i]).append("\n");
else
sb.append("<option value='").append(str[i]).append("'>").append(str[i]).append("\n");
sb.append("</select>");
//生成script腳本
sb.append("<script>");
if ("".equals(this.action)) {
sb.append("function gotoPage(pagenum){if (isNaN(pagenum)) {alert('每頁必須是數字');}else {document.form1.gd_jumpPage.value = pagenum;var f = document.form1;var ot = f.target;var oa = f.action;f.target='_self';f.submit();f.target=ot;f.action=oa;return ;}}");
} else {
sb.append("function gotoPage(pagenum){if (isNaN(pagenum)) {alert('每頁必須是數字');}else {document.form1.gd_jumpPage.value = pagenum;var f = document.form1;var ot = f.target;var oa = f.action;f.target='_self';f.action='"
+ this.action
+ "'; f.submit();f.target=ot;f.action=oa;return ;}}");
}
sb.append("</script>");
sb.append("</td></tr></table>");
return sb.toString();
}
/**
* 轉到指定頁
*/
private void gotoPage(String page) {
pageCrs.gotoPage(Integer.parseInt(page));
}
/**
* 該方法用來將獲取的欄位名稱和欄位內容相對應
*
* @param rs
* @return Map
*/
private Map getMapFromRs(CachedRowSet rs) throws SQLException {
Map map = new HashMap();
List columnNamesList = new ArrayList();
int columnCount = 0;
try {
//獲取ResultSetMetaData的字段數目
columnCount = rs.getMetaData().getColumnCount();
//獲取每個字段的名稱
columnNamesList = setColumnNameByMeta(rs.getMetaData());
for (int i = 0; i < columnCount; i++) {
//將字段名和對應的值存入Map
map.put((String) columnNamesList.get(i), rs.getString(i + 1));
}
} catch (SQLException e) {
throw new SQLException("執行getMapFromRS失敗" + e);
} finally {
return map;
}
}
/**
* 該方法用來獲取處理數據庫中的欄位名和欄位數目
* @param rsMetadata
* @return List
*/
private List setColumnNameByMeta(ResultSetMetaData rsMetadata) throws SQLException {
List columnNamesList = new ArrayList();
try {
//獲取ResultSetMetaData的字段數目
for (int i = 0; i < rsMetadata.getColumnCount(); i++) {
columnNamesList.add(rsMetadata.getColumnName(i + 1));//獲取每個字段的名稱
}
} catch (SQLException e) {
throw new SQLException("執行setColumnNameByMeta失敗" + e);
} finally {
return columnNamesList;
}
}
/**
* 用來獲取多筆數據結果集
* @param sql
* @return Map[]
* @throws SQLException
*/
public Map[] queryAllMap(CachedRowSet crs) throws SQLException {
Map[] map = null;
CachedRowSet rs = null;
List list = new ArrayList();
try {
//通過getAllCachedRowSet獲取rs，然后循環將每筆轉換為map
for (rs = crs; rs.next();) {
list.add(getMapFromRs(rs));//將每筆轉換為map
} catch (SQLException e) {
throw new SQLException("執行queryAllMap失敗" + sql + e);
} finally {
if (rs != null) {
rs.close();//關閉rs
}
if (list.size() != 0) {
map = new Map[list.size()];
list.toArray(map);//將list轉換為map數組
}
return map;
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -