7.dbutils

Posted 2020-10-24 重庆刘亦菲

编写通用的增删改查

c3p0-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
	<default-config>
		<property name="driverClass">com.mysql.jdbc.Driver</property>
		<property name="jdbcUrl">jdbc:mysql://localhost:3306/day14</property>
		<property name="user">root</property>
		<property name="password">moujinling321</property>
	</default-config>
</c3p0-config>

MyJdbcUtils

public class MyJdbcUtils {
	
	// C3P0的连接池
	private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
	
	/**
	 * 获取C3P0的连接池
	 * @return
	 */
	public static DataSource getDataSource(){
		return dataSource;
	}
	
	/**
	 * 获取链接
	 * @return
	 * @throws Exception
	 */
	public static Connection getConn() throws Exception{
		// 获取连接，从连接池中
		return dataSource.getConnection();
	}
	
	
	/**
	 * 释放资源（释放查询）
	 * @param rs
	 * @param stmt
	 * @param conn
	 */
	public static void release(ResultSet rs,Statement stmt,Connection conn){
		if(rs!=null){
			try {
				rs.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
			rs=null;
		}
		if(stmt!=null){
			try {
				stmt.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
			stmt=null;
		}
		if(conn!=null){
			try {
				conn.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
			conn=null;
		}
	}
	
	/**
	 * 释放资源（增删改）
	 * @param stmt
	 * @param conn
	 */
	public static void release(Statement stmt,Connection conn){
		if(stmt!=null){
			try {
				stmt.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
			stmt=null;
		}
		if(conn!=null){
			try {
				// 现在close是归还连接的方法，不是销毁连接
				conn.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
			conn=null;
		}
	}
}

Account

/**
 * 账户
 * @author mjl
 *
 */
public class Account {

	private int id;
	private String username;
	private double money;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getUsername() {
		return username;
	}
	public void setUsername(String username) {
		this.username = username;
	}
	public double getMoney() {
		return money;
	}
	public void setMoney(double money) {
		this.money = money;
	}
	
	
	public Account() {
		super();
	}
	public Account(int id, String username, double money) {
		super();
		this.id = id;
		this.username = username;
		this.money = money;
	}
	@Override
	public String toString() {
		return "Account [id=" + id + ", username=" + username + ", money=" + money + "]";
	}
	
}

ResultSetHandler

/**
 * 封装结果集的接口
 * @author mjl
 *
 */
public interface ResultSetHandler<T> {//自定义泛型类
	public T handle(ResultSet rs) throws SQLException;
}

BeanHandler

public class BeanHandler implements ResultSetHandler<Account>{

	/**
	 * 让用户自己来封装结果集的
	 * @throws SQLException 
	 */
	@Override
	public Account handle(ResultSet rs) throws SQLException {
		if(rs.next()){
			Account ac=new Account();
			ac.setId(rs.getInt("id"));
			ac.setUsername(rs.getString("name"));
			ac.setMoney(rs.getDouble("money"));
			return ac;
		}
		return null;
	}
}

MyDBUtils

public class MyDBUtils {

	/**
	 * 通用的增删改的方法
	 * @param sql
	 * @param params
	 */
	public void update(String sql,Object...params){
		Connection conn=null;
		PreparedStatement ps=null;
		try {
			conn=MyJdbcUtils.getConn();
			//原来：编写的SQL语句，现在不用写了
			//直接预编译
			ps=conn.prepareStatement(sql);
			//设置参数...根据SQL语句的? 来设置参数
			//思路：能获取到SQL语句? 的个数，通过参数元数据的方式
			ParameterMetaData metaData=ps.getParameterMetaData();
			
			//获取SQL语句?的个数
			int count=metaData.getParameterCount();
			for(int i=1;i<=count;i++){
				//设值
				ps.setObject(i, params[i-1]);
			}
			
			//执行
			ps.executeUpdate();
		} catch (Exception e) {
			
			e.printStackTrace();
		}finally{
			MyJdbcUtils.release(ps, conn);
		}
	}
	
	/**
	 * 通用的查询的方法分析：
	 * 返回值类型不同，封装结果集不同，sql语句不同，参数不同
	 * 	SQL语句，参数 通过方法的参数的方式传递进来
	 * 	返回值类型 封装结果集不同
	 * 
	 * 编写通用的查询的方法，让用户来使用。知道用户想怎么样来封装数据吗？
	 * 把封装数据的权力交给用户做。提供结果集，让用户自己来封装结果集。
	 * 实现思想：定义一个接口，当成通用的查询方法的参数。
	 */
	
	
	/**
	 * 通用的查询的方法
	 * @param sql
	 * @param rs
	 * @param params
	 * @return
	 */
	public <T> T query(String sql,ResultSetHandler<T> rsh, Object...params){
		Connection conn=null;
		PreparedStatement ps=null;
		ResultSet rs=null;
				
		try {
			conn=MyJdbcUtils.getConn();
			ps=conn.prepareStatement(sql);
			
			//获取SQL语句 中?的个数
			ParameterMetaData metaData=ps.getParameterMetaData();
			int count=metaData.getParameterCount();
			//设置参数
			for(int i=1;i<=count;i++){
				ps.setObject(i, params[i-1]);
			}
			//执行
			rs=ps.executeQuery();
			
			//结果集用户封装的，作为编写通用方法的人，
			T result=rsh.handle(rs);
			return result;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
	
}

Demo

public class Demo1 {

	/**
	 * 使用void 
	 * 方法内部不能有参数
	 */
	@Test
	public void run1(){
		/**
		 * 添加数据的代码
		 * 1.加载驱动
		 * 2.获取链接
		 * 3.编写sql语句
		 * 4.预编译
		 * 5.设置参数
		 * 6.执行sql
		 * 7.释放资源
		 */
		
		Connection conn=null;
		PreparedStatement ps=null;
		try {
			conn=MyJdbcUtils.getConn();
			String sql="insert into account values(null,?,?)";
			ps=conn.prepareStatement(sql);
			ps.setString(1, "小风");
			ps.setDouble(2, 100);
			ps.executeUpdate();
		} catch (Exception e) {
			
			e.printStackTrace();
		}finally{
			MyJdbcUtils.release(ps, conn);
		}
	}
	
	@Test
	public void run2(){
		MyDBUtils mydb=new MyDBUtils();
		
		//使用通用的增删改
		//mydb.update("insert into account values(?,?,?)", 5,"美美",50);
		//mydb.update("delete from account where id=?", 5);
		
		//使用通用的查询的方法
		System.out.println(mydb.query("select * from account where id=?", new BeanHandler(), 1));
		
	}
}

 

**QueryRunner类和方法（核心的类）**

　　1.QueryRunner类可以来完成增删改查所有的功能
　　2.常用的方法
　　　　* QueryRunner() -- 构造方法，没有任何参数，说明他不管理连接的。
　　　　* QueryRunner(DataSource ds) -- 构造方法，传入连接池，说明他已经管理连接（从连接池中获取连接，归还连接）

　　　　* int update(String sql, Object... params) -- 连接已经管理了
　　　　* int update(Connection conn, String sql, Object... params) -- 说明连接没有管理

　　　　* <T> T query(String sql, ResultSetHandler<T> rsh, Object... params)
　　　　* <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)

　　3.总结
　　　　* 完成增删改的方法
　　　　　　* 和事务无关的
　　　　　　　　* QueryRunner(DataSource ds)
　　　　　　　　* int update(String sql, Object... params)
　　　　　　* 和事务有关的（说明事务是在业务层开启的，把conn通过参数的方法传递下来的）
　　　　　　　　* QueryRunner()
　　　　　　　　* int update(Connection conn, String sql, Object... params)

　　　　* 完成查询的方法
　　　　　　* 和事务无关的
　　　　　　　　* QueryRunner(DataSource ds)
　　　　　　　　* <T> T query(String sql, ResultSetHandler<T> rsh, Object... params)

　　　　* 和事务有关的
　　　　　　* QueryRunner()
　　　　　　* <T> T query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)

public class Demo2 {
	

	@Test
	public void run1() throws SQLException{
		//测试update的方法
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		//测试添加数据
		/**
		 * 中心思想：可以完成增删改，底层管理连接(从连接池中获取连接，归还连接）
		 */
		runner.update("insert into account values(null,?,?)","熊大",100);
	}
	
	/**
	 * 自己管理连接(跟事务有关)
	 * @throws Exception
	 */
	@Test
	public void run2() throws Exception{
		QueryRunner runner=new QueryRunner();
		//需要自己来获取连接
		Connection conn=MyJdbcUtils.getConn();
		
		//conn传进去
		runner.update(conn,"insert into account values(null,?,?)","不二家",300);
		//没有关闭连接
		conn.close();
	}
	
	/**
	 * 测试查询的方法
	 * @throws Exception
	 */
	@Test
	public void run3() throws Exception{
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		
		//conn传进去
		runner.update("select * from account where id=?",new MyHandler(),3);
		
	}
}

class MyHandler implements ResultSetHandler<Account>{

	@Override
	public Account handle(ResultSet rs) throws SQLException {
		//做封装
		return null;
	}
}

　　

**ResultSetHandler接口及其实现类**

　　1.ResultSetHandler接口，提供了一个方法，让用户自己来封装结果集。
　　2.接口中提供了9个实现类，封装结果集的类型都是不同的
　　　　* BeanHandler -- 把一条记录封装到一个JavaBean的对象中。
　　　　* BeanListHandler -- 把一条记录封装到一个JavaBean对象中，再把这些JavaBean封装到一个List集合中。List<JavaBean>

　　　　* ArrayHandler -- 把一条记录封装到一个数组中
　　　　* ArrayListHandler -- 把一条记录封装到一个数组中，把这些数组封装到List集合中

　　　　* MapHandler -- 把一条记录封装到Map集合中
　　　　* MapListHandler -- 把一条记录封装到Map集合中，这些map封装到List集合中

　　　　* ColumnListHandler -- 查询的是某列的数据（select username from t_account），把该列封装到List集合中

　　　　* KeyedHandler -- 把一条记录封装到Map集合中，再把这些map封装到一个大的map集合中

　　　　* ScalarHandler -- 封装的是聚集函数（count sum avg max min）

　　3.重点的实现类（在JavaWEB阶段使用的实现类）
　　　　* BeanHandler
　　　　* BeanListHandler
　　　　* ScalarHandler
　　　　* MapListHandler

/**
 * 演示ResultSetHandler接口的实现类
 * @author mjl
 *
 */
public class Demo3 {
	/**
	 * 把一条记录封装到一个JavaBean的对象中
	 * @throws SQLException 
	 */
	@Test
	public void run1() throws SQLException{
		//创建QueryRunner类
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		Account ac=runner.query("select * from account where id=?", new BeanHandler<Account>(Account.class),1);
		System.out.println(ac);
	}
	
	/**
	 * 把一条记录封装到一个JavaBean对象中，再把这些JavaBean封装到一个List集合中。List<JavaBean>
	 * @throws SQLException
	 */
	@Test
	public void run2() throws SQLException{
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		List<Account> list=runner.query("select * from account", new BeanListHandler<Account>(Account.class));
		for (Account account : list) {
			System.out.println(account);
		}
	}
	
	/**
	 * 把一条记录封装到Map集合中
	 * @throws SQLException
	 */
	@Test
	public void run3() throws SQLException{
		//创建QueryRunner类
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		//key:表的字段  value:字段对应的值
		Map<String,Object> map=runner.query("select * from account where id=?", new MapHandler(),1);
		System.out.println(map);
	}
	
	/**
	 * 把一条记录封装到Map集合中，这些map封装到List集合中
	 * @throws SQLException
	 */
	@Test
	public void run4() throws SQLException{
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		List<Map<String, Object>> list=runner.query("select * from account", new MapListHandler());
		for (Map<String, Object> map : list) {
			System.out.println(map);
		}
	}
	
	/**
	 * 查询的是某列的数据（select username from t_account），把该列封装到List集合中
	 * @throws SQLException
	 */
	@Test
	public void run5() throws SQLException{
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		List<Object> list=runner.query("select name from account", new ColumnListHandler());
		for (Object object : list) {
			System.out.println(object);
		}
	}
	
	/**
	 * 把一条记录封装到Map集合中，再把这些map封装到一个大的map集合中
	 * @throws SQLException
	 */
	@Test
	public void run6() throws SQLException{
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		Map<Object,Map<String,Object>> map=runner.query("select * from account", new KeyedHandler());
		System.out.println(map);
	}
	
	/**
	 * 封装的是聚集函数（count sum avg max min）
	 * @throws SQLException
	 */
	@Test 
	public void run7() throws SQLException{
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		Long count=(Long) runner.query("select count(*) from account", new ScalarHandler());
		System.out.println(count);
	}
}

　　

案例：添加商品，查询所有商品

用到的jsp页面

add.jsp
<%@ page language="java" pageEncoding="UTF-8"%>
<html>
<HEAD>
<meta http-equiv="Content-Language" content="zh-cn">
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<LINK href="${pageContext.request.contextPath}/admin/css/Style.css"
	type="text/css" rel="stylesheet">


</HEAD>

<body>
	<!-- 
		enctype="multipart/form-data" 做文件上传的时候使用的
	 -->
	<form id="userAction_save_do" name="Form1" action="${pageContext.request.contextPath }/product" method="post">
		 
		<!-- 添加隐藏域  随form表单一起提交 -->
		<input type="hidden" name="method" value="addProduct"/>
		<table cellSpacing="1" cellPadding="5" width="100%" align="center"
			bgColor="#eeeeee" style="border: 1px solid #8ba7e3" border="0">
			<tr>
				<td class="ta_01" align="center" bgColor="#afd1f3" colSpan="4"
					height="26"><strong><STRONG>添加商品</STRONG> </strong>
					<!-- 显示错误的信息 -->
					${requestScope.msg } 
				</td>
			</tr>


			<tr>
				<td align="center" bgColor="#f5fafe" class="ta_01">商品名称：</td>
				<td class="ta_01" bgColor="#ffffff">
					<!-- BeanUtils工具类封装数据 -->
					<input type="text" name="pname" class="bg"/>
				</td>
				<td align="center" bgColor="#f5fafe" class="ta_01">商品价格：</td>
				<td class="ta_01" bgColor="#ffffff">
					<input type="text" name="price" class="bg" />
				</td>
			</tr>
			<tr>
				<td align="center" bgColor="#f5fafe" class="ta_01">商品数量：</td>
				<td class="ta_01" bgColor="#ffffff">
					<input type="text" name="pnum" class="bg" />
				</td>
				<td align="center" bgColor="#f5fafe" class="ta_01">商品类别：</td>
				<td class="ta_01" bgColor="#ffffff"><select name="category" id="category">
						<option value="" selected="selected">--选择商品类加--</option>
						<option value="文学">文学</option>
						<option value="生活">生活</option>
						<option value="计算机">计算机</option>
						<option value="外语">外语</option>
						<option value="经营">经营</option>
						<option value="励志">励志</option>
						<option value="社科">社科</option>
						<option value="学术">学术</option>
						<option value="少儿">少儿</option>
						<option value="艺术">艺术</option>
						<option value="原版">原版</option>
						<option value="科技">科技</option>
						<option value="考试">考试</option>
						<option value="生活百科">生活百科</option>
				</select>
				</td>
			</tr>


			<tr>
				<td align="center" bgColor="#f5fafe" class="ta_01">商品图片：</td>
				<td class="ta_01" bgColor="#ffffff" colSpan="3">
					<input type="file" name="upload" size="30" value=""/>
				</td>
			</tr>
			<TR>
				<TD class="ta_01" align="center" bgColor="#f5fafe">商品描述：</TD>
				<TD class="ta_01" bgColor="#ffffff" colSpan="3">
					<textarea name="description" cols="30" rows="3" style="WIDTH: 96%"></textarea>
				</TD>
			</TR>
			<TR>
				<td align="center" colSpan="4" class="sep1"><img
					src="${pageContext.request.contextPath}/admin/images/shim.gif">
				</td>
			</TR>


			<tr>
				<td class="ta_01" style="WIDTH: 100%" align="center"
					bgColor="#f5fafe" colSpan="4">
					
					
						
					<input type="submit" class="button_ok" value="确定">	
						
					<FONT face="宋体">       </FONT>
					
					<input type="reset" value="重置" class="button_cancel">

					<FONT face="宋体">       </FONT> 
					
					<INPUT class="button_ok" type="button" onclick="history.go(-1)" value="返回" />
					<span id="Label1">
					
					</span>
				</td>
			</tr>
		</table>
	</form>
</body>
</HTML>


list.jsp
<%@ page language="java" pageEncoding="UTF-8"%>
<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<HTML>
<HEAD>
<meta http-equiv="Content-Language" content="zh-cn">
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<link href="${pageContext.request.contextPath}/admin/css/Style.css"
	rel="stylesheet" type="text/css" />
<script language="javascript"
	src="${pageContext.request.contextPath}/admin/js/public.js"></script>
<script type="text/javascript">
	//点击添加的按钮，跳转到添加商品的页面
	function addProduct() {
		//相当于超链接
		window.location.href = "${pageContext.request.contextPath}/admin/products/add.jsp";
	}
</script>
</HEAD>
<body>
	<br>
	<form id="Form1" name="Form1"
		action="${pageContext.request.contextPath}/findProductByManyCondition"
		method="post">
		<table cellSpacing="1" cellPadding="0" width="100%" align="center"
			bgColor="#f5fafe" border="0">
			<TBODY>
				<tr>
					<td class="ta_01" align="center" bgColor="#afd1f3"><strong>查
							询 条 件</strong>
					</td>
				</tr>
				<tr>
					<td>
						<table cellpadding="0" cellspacing="0" border="0" width="100%">
							<tr>
								<td height="22" align="center" bgColor="#f5fafe" class="ta_01">
									商品编号</td>
								<td class="ta_01" bgColor="#ffffff"><input type="text"
									name="id" size="15" value="" id="Form1_userName" class="bg" />
								</td>
								<td height="22" align="center" bgColor="#f5fafe" class="ta_01">
									类别：</td>
								<td class="ta_01" bgColor="#ffffff"><select name="category"
									id="category">
										<option value="" selected="selected">--选择商品类加--</option>
										<option value="文学">文学</option>
										<option value="生活">生活</option>
										<option value="计算机">计算机</option>
										<option value="外语">外语</option>
										<option value="经营">经营</option>
										<option value="励志">励志</option>
										<option value="社科">社科</option>
										<option value="学术">学术</option>
										<option value="少儿">少儿</option>
										<option value="艺术">艺术</option>
										<option value="原版">原版</option>
										<option value="科技">科技</option>
										<option value="考试">考试</option>
										<option value="生活百科">生活百科</option>
								</select></td>
							</tr>

							<tr>
								<td height="22" align="center" bgColor="#f5fafe" class="ta_01">
									商品名称：</td>
								<td class="ta_01" bgColor="#ffffff"><input type="text"
									name="name" size="15" value="" id="Form1_userName" class="bg" />
								</td>
								<td height="22" align="center" bgColor="#f5fafe" class="ta_01">
									价格区间(元)：</td>
								<td class="ta_01" bgColor="#ffffff"><input type="text"
									name="minprice" size="10" value="" />- <input type="text"
									name="maxprice" size="10" value="" /></td>
							</tr>

							<tr>
								<td width="100" height="22" align="center" bgColor="#f5fafe"
									class="ta_01"></td>
								<td class="ta_01" bgColor="#ffffff"><font face="宋体"
									color="red">  </font>
								</td>
								<td align="right" bgColor="#ffffff" class="ta_01"><br>
									<br></td>
									
								<td align="right" bgColor="#ffffff" class="ta_01">
									<button type="submit" id="search" name="search"
										value="查询" class="button_view">
										查询</button>       <input
									type="reset" name="reset" value="重置"
									class="button_view" />
								</td>
								
							</tr>
						</table>
					</td>

				</tr>
				<tr>
					<td class="ta_01" align="center" bgColor="#afd1f3"><strong>商品列表</strong>
					</TD>
				</tr>
				<tr>
					<td class="ta_01" align="right">
						<!-- 
							添加的按钮
							添加的按钮
							添加的按钮
							添加的按钮
							添加的按钮
							添加的按钮
							添加的按钮
							添加的按钮
						 -->
						<button type="button" id="add" name="add" value="添加;"
							class="button_add" onclick="addProduct()">添加
						</button>
					</td>
				</tr>
				<tr>
					<td class="ta_01" align="center" bgColor="#f5fafe">
						<table cellspacing="0" cellpadding="1" rules="all"
							bordercolor="gray" border="1" id="DataGrid1"
							style="BORDER-RIGHT: gray 1px solid; BORDER-TOP: gray 1px solid; BORDER-LEFT: gray 1px solid; WIDTH: 100%; WORD-BREAK: break-all; BORDER-BOTTOM: gray 1px solid; BORDER-COLLAPSE: collapse; BACKGROUND-COLOR: #f5fafe; WORD-WRAP: break-word">
							<tr
								style="FONT-WEIGHT: bold; FONT-SIZE: 12pt; HEIGHT: 25px; BACKGROUND-COLOR: #afd1f3">
								<td align="center" width="24%">序号</td>
								<td align="center" width="18%">商品名称</td>
								<td align="center" width="9%">商品价格</td>
								<td align="center" width="9%">商品数量</td>
								<td width="8%" align="center">商品类别</td>
								<td width="8%" align="center">编辑</td>

								<td width="8%" align="center">删除</td>
							</tr>

							<!-- for标签想象增强for循环 for(数据类型 变量：要遍历的集合) -->
							<c:forEach var="p" items="${pList }" varStatus="vs"> <!-- varStatus用于迭代数据，从1开始 -->
								<tr onmouseover="this.style.backgroundColor = ‘white‘"
									onmouseout="this.style.backgroundColor = ‘#F5FAFE‘;">
									<td style="CURSOR: hand; HEIGHT: 22px" align="center"
										width="23">${vs.count }</td>
									<td style="CURSOR: hand; HEIGHT: 22px" align="center"
										width="18%">${p.pname }</td>
									<td style="CURSOR: hand; HEIGHT: 22px" align="center"
										width="8%">${p.price }</td>
									<td style="CURSOR: hand; HEIGHT: 22px" align="center"
										width="8%">${p.pnum }</td>
									<td style="CURSOR: hand; HEIGHT: 22px" align="center">
										${p.category }</td>
									<td align="center" style="HEIGHT: 22px" width="7%"><a
										href="../products/edit.jsp">
											<img
											src="${pageContext.request.contextPath}/admin/images/i_edit.gif"
											border="0" style="CURSOR: hand"> </a>
									</td>

									<td align="center" style="HEIGHT: 22px" width="7%"><a
										href="#">
											<img
											src="${pageContext.request.contextPath}/admin/images/i_del.gif"
											width="16" height="16" border="0" style="CURSOR: hand">
									</a>
									</td>
								</tr>
							</c:forEach>
						</table>
					</td>
				</tr>
			</TBODY>
		</table>
	</form>
</body>
</HTML>


left.jsp
<%@ page language="java" pageEncoding="UTF-8"%>
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title>菜单</title>
<link href="${pageContext.request.contextPath}/admin/css/left.css" rel="stylesheet" type="text/css">
</head>
<body>
<table width="100" border="0" cellspacing="0" cellpadding="0">
  <tr>
    <td height="12"></td>
  </tr>
</table>
<table width="100%" border="0">
  <tr>
    <td>
<div class="dtree">

	<a href="javascript: d.openAll();">展开所有</a> | <a href="javascript: d.closeAll();">关闭所有</a>
	<link rel="StyleSheet" href="${pageContext.request.contextPath}/admin/css/dtree.css" type="text/css" />
	<script type="text/javascript" src="${pageContext.request.contextPath}/admin/js/dtree.js"></script>
	<script type="text/javascript">
		
		d = new dTree(‘d‘);
		/*本身id 父id 名称*/
		d.add(0,-1,‘系统菜单树‘);
		d.add(1,0,‘商品管理‘,‘/bookStore/admin/login/welcome.jsp‘,‘‘,‘mainFrame‘);
		d.add(2,0,‘订单管理‘,‘/bookStore/admin/login/welcome.jsp‘,‘‘,‘mainFrame‘);
		
		
		//子目录添加
		d.add(11,1,‘商品查看‘,‘${pageContext.request.contextPath}/product?method=findAll‘,‘‘,‘mainFrame‘);
		
		d.add(12,1,‘销售榜单‘,‘/bookStore/admin/products/download.jsp‘,‘‘,‘mainFrame‘)
		
		d.add(21,2,‘订单查看‘,‘/bookStore/admin/orders/list.jsp‘,‘‘,‘mainFrame‘);
	
		
		document.write(d);
		
	</script>
</div>	</td>
  </tr>
</table>
</body>
</html>

　　Product

public class Product {
	private String pid;
	private String pname;
	private double price;
	private String category;
	private int pnum;
	private String imgUrl;
	private String description;
	public String getPid() {
		return pid;
	}
	public void setPid(String pid) {
		this.pid = pid;
	}
	public String getPname() {
		return pname;
	}
	public void setPname(String pname) {
		this.pname = pname;
	}
	public double getPrice() {
		return price;
	}
	public void setPrice(double price) {
		this.price = price;
	}
	public String getCategory() {
		return category;
	}
	public void setCategory(String category) {
		this.category = category;
	}
	public int getPnum() {
		return pnum;
	}
	public void setPnum(int pnum) {
		this.pnum = pnum;
	}
	public String getImgUrl() {
		return imgUrl;
	}
	public void setImgUrl(String imgUrl) {
		this.imgUrl = imgUrl;
	}
	public String getDesription() {
		return description;
	}
	public void setDescription(String description) {
		this.description = description;
	}
	public Product(String pid, String pname, double price, String category, int pnum, String imgUrl,
			String description) {
		super();
		this.pid = pid;
		this.pname = pname;
		this.price = price;
		this.category = category;
		this.pnum = pnum;
		this.imgUrl = imgUrl;
		this.description = description;
	}
	public Product() {
		super();
	}
	@Override
	public String toString() {
		return "Product [pid=" + pid + ", pname=" + pname + ", price=" + price + ", category=" + category + ", pnum="
				+ pnum + ", imgUrl=" + imgUrl + ", desription=" + description + "]";
	}
	
}

　　三层架构

public class BaseServlet extends HttpServlet {
	
	//自己重写service方法
	public void service(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException{
		
		//解决中文乱码问题,解决的是post中文乱码
		request.setCharacterEncoding("utf-8");
		
		//自己编写
		//要求用户：想访问哪个方法，传递一个 参数
		/**
		 * 1.想访问哪个方法，传递一个method参数  ?method=login
		 * 2.xxxServlet中方法的签名是：request(HttpServletRequest request, HttpServletResponse response)
		 */
		String method=request.getParameter("method");
		
		//如果用户忘记传method
		if(method==null){
			throw new RuntimeException("亲，你在干嘛，不传Method");
		}
		
		//反射Class Method(代表方法的对象)
		//先获取当前类的Class对象
		Class clazz=this.getClass();
		Method me=null;
		//获取方法的对象
		try {
			me=clazz.getMethod(method, HttpServletRequest.class,HttpServletResponse.class);
			
		} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException("传的啥玩意儿，这个方法不存在");
		} 
		
		//让login方法执行就OK了
		try {
			/*obj - 从中调用底层方法的对象（简单的说就是调用谁的方法用谁的对象）
			args - 用于方法调用的参数 */
			me.invoke(this, request,response);
		} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException("亲，方法内部错误！");
		}
	}
}

/**
 * 商品的控制器
 * @author mjl
 *
 */
public class ProductServlet extends BaseServlet {
	
	/**
	 * 添加商品
	 * @param request
	 * @param response
	 * @throws ServletException
	 * @throws IOException
	 */
	public void addProduct(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		/**
		 * 1.接收数据
		 * 2.封装数据
		 * 3.处理数据
		 * 4.显示数据
		 */

		//接收数据
		Map<String,String[]> map=request.getParameterMap();
		Product p=new Product();
		try {
			//封装数据
			BeanUtils.populate(p, map);
			System.out.println(p);
			
			//处理数据
			ProductService ps=new ProductService();
			//保存数据
			ps.save(p);
			
			//如果添加成功,重定向到findAll  
			response.sendRedirect(request.getContextPath()+"/product?method=findAll");
		} catch (Exception e) {
			e.printStackTrace();
			//捕获异常
			request.setAttribute("msg", e.getMessage());
			request.getRequestDispatcher("/admin/products/add.jsp").forward(request, response);
		}
	}
	
	/**
	 * 查询所有的商品
	 * @param request
	 * @param response
	 * @throws ServletException
	 * @throws IOException
	 */
	public void findAll(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		System.out.println("findAll");
		/**
		 * 1.接收数据
		 * 2.封装数据
		 * 3.处理数据
		 * 4.显示数据
		 */
		
		//没有参数，也不用封装
		ProductService ps=new ProductService();
		//查询所有的商品的信息
		List<Product> pList=ps.findAll();
		//存入到request域对象中
		request.setAttribute("pList", pList);
		request.getRequestDispatcher("/admin/products/list.jsp").forward(request, response);
		
		/*前后两个页面 有数据传递 用请求转发，没有则用重定向。
		比如servlet查询了数据需要在页面显示，就用请求转发。
		比如servlet做了update操作跳转到其他页面，就用重定向。*/
	}
}

/**
 * 商品业务层
 * @author mjl
 *
 */
public class ProductService {
	
	/**
	 * 保存商品
	 * @param p
	 * @throws SQLException 
	 * @throws MyException 
	 */
	public void save(Product p) throws SQLException, MyException{
		//自己维护主键
		p.setPid(MyUUIDUtils.getUUID());
		
		//先设置imgurl属性值为Null
		p.setImgUrl(null);
		
		//调用持久层，保存数据
		ProductDao dao=new ProductDao();
		dao.save(p);
	}

	/**
	 * 查询所有的商品
	 * @return
	 */
	public List<Product> findAll() {
		
		ProductDao dao=new ProductDao();
		return dao.findAll();
	}

}


/**
 * 商品的持久层
 * @author mjl
 *
 */
public class ProductDao {

	public void save(Product p) throws SQLException, MyException{
		//使用DBUtils工具类
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		//编写sql语句
		String sql="insert into products values(?,?,?,?,?,?,?)";
		Object [] params={p.getPid(),p.getPname(),p.getPrice(),p.getCategory(),p.getPnum(),p.getImgUrl(),p.getDesription()};
		//执行sql语句，如果成功，返回1
		int count=runner.update(sql, params);
		if(count!=1){
			throw new MyException("亲，添加商品错误");
		}
	}

	public List<Product> findAll() {
		
		QueryRunner runner=new QueryRunner(MyJdbcUtils.getDataSource());
		try {
			return runner.query("select * from products", new BeanListHandler<Product>(Product.class));
		} catch (SQLException e) {
			e.printStackTrace();
			throw new RuntimeException("查询所有的商品错误了！");
		}
	}

}