查询图书的功能实现

如何知道浏览器往服务器传入的参数

1、在编写好查询页面后，使用火狐浏览器的friebug (全部—>POST—>参数)

2、编写GradeListServlet，重写doGet()和doPOST()方法

服务器处理页面请求的过程

1、重写doPOST()方法。

处理过程

1、连接数据库 2、创建JSONObject对象 3、格式化数据 4、将处理后的数据以{key,value}放入到JSONObject对象中 5、响应客户端的请求

获取页面请求的参数 使用方法：request.getParameter(“page/rows”);

创建PageBean类 将获取来的参数传入到PageBean类进行初始化。

PageBean

package com.it.model;

public class PageBean {

private int page;//第几页

private int rows;//每页的记录数

private int start;//起始页

public PageBean(int page, int rows) {

super();

this.page = page;

this.rows = rows;

}

public int getPage() {

return page;

}

public void setPage(int page) {

this.page = page;

}

public int getRows() {

return rows;

}

public void setRows(int rows) {

this.rows = rows;

}

public int getStart() {

return (page-1)*rows;

}

}

创建从数据库查询出来的数据转化成JSON格式的数据

JSON将数据转化成了字符串类型的数据

转化对象后是键值对的形式 {name：value}

JSON格式转化的工具类

package com.it.util;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import net.sf.json.JSONArray;

import net.sf.json.JSONObject;

/*

* Json 工具包 用来处理JSon格式

* 用来转化格式

* JSONArray格式是 键值对形式的

*/

public class JsonUtil {

/**

* 将数据库内的数据集转化成JSON格式的数据 输出到浏览器页面

* @param rs 数据库查询返回的集合

* @return

* @throws Exception

*/

public static JSONArray formatRsToJsonArray(ResultSet rs)throws Exception{

ResultSetMetaData md=rs.getMetaData();//获取纵向集合

int num = md.getColumnCount();//获取ResultSetMetaData 有多少行

JSONArray array=new JSONArray();

//JSONArray 里的每一个对象是 JSONObject

while(rs.next()){ //横向的遍历

JSONObject mapOfColValues=new JSONObject(); //JSONArray 里的每一个对象叫JSONObject

for(int i=1;i<=num;i++){

mapOfColValues.put(md.getColumnName(i), rs.getObject(i));//给对象赋值

}

array.add(mapOfColValues);

}

return array;//添加到JSONArray数组

}

}

GradeListServlet

package com.it.web;

import java.io.IOException;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import net.sf.json.JSONArray;

import net.sf.json.JSONObject;

import com.it.dao.GradeDao;

import com.it.model.PageBean;

import com.it.util.Dbutil;

import com.it.util.JsonUtil;

import com.it.util.ResponseUtil;

public class GradeListServlet extends HttpServlet {

Dbutil dbUtil=new Dbutil();

GradeDao gradeDao=new GradeDao();

@Override

protected void doGet(HttpServletRequest request, HttpServletResponse response)

throws ServletException, IOException {

this.doPost(request, response);

}

@Override

protected void doPost(HttpServletRequest request, HttpServletResponse response)

throws ServletException, IOException {

String page = request.getParameter("page");//页面请求 page

String rows = request.getParameter("rows");//每页的记录数

PageBean pageBean=new PageBean(Integer.parseInt(page),Integer.parseInt(rows));

Connection con=null;

try{

con=dbUtil.getCon();

JSONObject result=new JSONObject(); //创建JSONObject对象用来存放JSONArray 数组

JSONArray jsonArray = JsonUtil.formatRsToJsonArray(gradeDao.gradeList(con, pageBean));//将返回的结果集转化成JSON格式的数据

// ResultSet rs=gradeDao.gradeList(con, pageBean);

// gradeDao.print(con, rs);

int total=gradeDao.gradeCount(con);//返回统计的总行数

result.put("rows", jsonArray);

result.put("total", total);

ResponseUtil.write(response, result);

}catch(Exception e){

e.printStackTrace();

}finally{

try {

dbUtil.closeCon(con);

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

## 数据库处理层GradeDao类 ##

package com.it.dao;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import com.it.model.Grade;

import com.it.model.PageBean;

public class GradeDao {

public ResultSet gradeList(Connection con,PageBean pageBean)throws Exception{

StringBuffer sb=new StringBuffer("select * from t_grade");

if(pageBean!=null){

sb.append(" limit "+pageBean.getStart()+","+pageBean.getRows());

}

PreparedStatement pstmt = con.prepareStatement(sb.toString());

return pstmt.executeQuery();

}

public int gradeCount(Connection con)throws Exception{

String sql="select count(*) as total from t_grade";// as total 是起的别名

PreparedStatement psmt = con.prepareStatement(sql);

ResultSet rs = psmt.executeQuery();

if(rs.next()){

return rs.getInt("total");

}else{

return 0;

}

}

public void print(Connection con,ResultSet rs)throws Exception{

while(rs.next()){

Grade grade=new Grade();

grade.setId(rs.getInt("id"));

grade.setGradeName(rs.getString("gradeName"));

grade.setGradeDesc(rs.getString("gradeDesc"));

System.out.println(grade);

}

}

}

响应页面的工具类

package com.it.util;

import java.io.PrintWriter;

import javax.servlet.http.HttpServletResponse;

import net.sf.json.JSONObject;

public class ResponseUtil {

public static void write(HttpServletResponse response,JSONObject jsonObject)throws Exception{

response.setContentType("text/html;charaset=UTF-8");

response.setCharacterEncoding("UTF-8");//解决无法输出中文的问题

PrintWriter out = response.getWriter();

out.println(jsonObject.toString());

out.flush();

out.close();

}

}