Javaweb06-JDBC

1、jdbc.properties配置文件

jdbc.properties

1. driverClass=com.mysql.jdbc.Driver
2. jdbcUrl=jdbc:mysql://localhost:3306/animedb?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2b8
3. user=root
4. password=root

复制代码

2、JDBCUtil 工具类

JDBCUtil.java

1. package com.kgc.jdbc;
3. import java.io.InputStream;
4. import java.sql.Connection;
5. import java.sql.DriverManager;
6. import java.sql.PreparedStatement;
7. import java.sql.ResultSet;
8. import java.sql.Statement;
9. import java.util.Properties;
11. /**
12. * JDBC数据库操作工具类-都是公共的静态方法（不需要实例化），减少代码冗余
13. * @author zhukang
14. *
15. */
16. public class JDBCUtil {
17.        
18.         /**
19.          * 读取外部的数据库连接信息配置文件，获取数据库连接对象
20.          */
21.         public static Connection getConnection() throws Exception {
22.                
23.                 // 创建Properties属性对象
24.                 Properties properties = new Properties();
25.                
26.                 // 使用反射机制，读取外部配置文件
27.                 InputStream inputStream = JDBCUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");
28.                
29.                 // 加载输入流对象，获取配置文件内容
30.                 properties.load(inputStream);
31.                
32.                 // 读取数据库连接信息
33.                 String driverClass = properties.getProperty("driverClass");
34.                 String jdbcUrl = properties.getProperty("jdbcUrl");
35.                 String user = properties.getProperty("user");
36.                 String password = properties.getProperty("password");
37.                
38.                 // 加载驱动
39.                 Class.forName(driverClass);
40.                
41.                 // 获取数据库连接对象
42.                 return DriverManager.getConnection(jdbcUrl, user, password);
43.         }
44.        
45.         /**
46.          * 增删改的通用方法：只需要提供执行的SQL语句和SQL语句需要的参数，使用预处理对象
47.          */
48.         public static int update(String executeSql, Object ... params){
49.                
50.                 // 定义数据库连接和预处理操作对象
51.                 Connection conn = null;
52.                 PreparedStatement pstmt = null;
53.                
54.                 // 定义SQL语句执行的影响行数
55.                 int row = 0;
56.                
57.                 // 公共执行增删改的处理代码
58.                 try {
59.                         // 获取数据库连接
60.                         conn = getConnection();
61.                        
62.                         // 创建预处理操作对象
63.                         pstmt = conn.prepareStatement(executeSql);
64.                        
65.                         // 实现动态传参，注意: 传入的预编译SQL的?和传入的参数个数和顺序要一致，即：要保证一一对应
66.                         for (int i = 0; i < params.length; i++) {
67.                                 pstmt.setObject(i + 1, params[i]);
68.                         }
69.                        
70.                         // 执行增删改操作，并获取影响行数
71.                         row = pstmt.executeUpdate();
72.                 } catch (Exception e) {
73.                         e.printStackTrace();
74.                 } finally {
75.                         releaseResource(conn, pstmt, null);
76.                 }
77.                
78.                 // 返回影响行数
79.                 return row;
80.                
81.         }
82.        
83.         /**
84.          * 查询的通用方法：只需要提供执行的SQL语句和SQL语句需要的参数，使用预处理对象
85.          */
86.         public static ResultSet select(String executeSql, Object ... params){
87.                
88.                 // 定义数据库连接,预处理操作对象,结果集对象
89.                 Connection conn = null;
90.                 PreparedStatement pstmt = null;
91.                 ResultSet rs = null;
92.                
93.                 // 公共执行查询的处理代码
94.                 try {
95.                         // 获取数据库连接
96.                         conn = getConnection();
97.                        
98.                         // 创建预处理操作对象
99.                         pstmt = conn.prepareStatement(executeSql);
100.                        
101.                         // 实现动态传参，注意: 传入的预编译SQL的?和传入的参数个数和顺序要一致，即：要保证一一对应
102.                         for (int i = 0; i < params.length; i++) {
103.                                 pstmt.setObject(i + 1, params[i]);
104.                         }
105.                        
106.                         // 执行查询操作，并获取结果集
107.                         rs = pstmt.executeQuery();
108.                 } catch (Exception e) {
109.                         e.printStackTrace();
110.                 } finally {
111.                         //最好不释放资源，因为rs要返回，关闭后，直接外层不可以使用
112.                         releaseResource(conn, pstmt, rs);
113.                 }
114.                
115.                 // 返回查询结果集
116.                 return rs;
117.                
118.         }
119.        
120.         /**
121.          * 释放数据库操作对象资源
122.          */
123.         public static void releaseResource(Connection conn, Statement stmt, ResultSet rs){
124.                 try {
125.                         // 手动释放
126.                         if (null != rs) {
127.                                 rs.close();
128.                         }
129.                        
130.                         if (null != stmt) {
131.                                 stmt.close();
132.                         }
134.                         if (null != conn) {
135.                                 conn.close();
136.                         }
137.                 } catch (Exception e) {
138.                         e.printStackTrace();
139.                 }
140.         }
142. }

复制代码

3、作业总结技巧 (JdbcUtil 页面跳转  Jstl)

这些只是我个人的思考，可能会比较冗余，我是为了多思考，记录当时的感受；
且以访问资源为主和jstl，后面的以Ajax为主；
3.1Jstl妙用 (基于 Jstl遍历数据添加元素)

3.1 类型cid->类型名  显示数据时 外键信息对应

animesList:为动漫list集合的数据，放在request域中；
categoriesList：为动漫的类型，放在session域中(主要是因为方便修改和添加的时候方便获取类型)；
外层循环，遍历每条动漫数据，内层循环，查询动漫对应的类型名称；

1. <c:forEach items="${animesList}" var ="anime" varStatus="status">
2.    
3.     <c:forEach items="${categoriesList}" var ="category" varStatus="status">
4.         
5.         <c:if test="${ anime.cid eq category.id}" var="flag">
6.             ${category.name}
7.         </c:if>
8.     </c:forEach>
9. </c:forEach>

复制代码

3.2 类型cid->类型名   修改数据时  外键信息对应

修改动漫数据，跳修改页面后显示数据，类型可以选择并且，选择了以前的类型selected="selected"

1. <select name="cid" id="categories">
3.     <c:forEach items="${categoriesList}" var ="category" varStatus="status">
4.         <option value="${category.id }"
5.             <c:if test="${ upAnimes.cid eq category.id}" var="flag">
6.                     selected="selected"
7.             </c:if>
8.         >${category.name }</option>
9.     </c:forEach>
10. </select>

复制代码

3.2.response 返回弹窗，并跳转

直接在返回中写javaScript;

1. resp.getWriter().print("");

复制代码

3.3 getPartment(str) 再次理解

如果属性，没有参数就是空字符串“”  ,如果没有属性，获取的就是null

1. getPartment(str); //如果属性，没有参数就是空字符串“”  ,如果没有属性，获取的就是null
2. getPartment(str).trim(); //防止不小心多输入空格，去掉前后的空格,但是 trim()必须保证参数值不为 null

复制代码

3.4 模糊 sql拼接

like concat(''%,?,'%') 方便模糊查询
sql拼接及 Object数组 数组动态添加参数的弊端(后面使用List集合添加数组，最后在转成数组)；

1. //注意这种参数判断的思想
2. //条件查询动漫
3. public List<Animes> searchAnimes(Search search) throws SQLException{
4.     List<Animes> animesList = new ArrayList<>();
6.     String executeSql = "select `id`,`cid`,`name`,`author`,`actor`,`produce`,`create_date` from animes";
7.     //参数
8.     Object[] params = {};
10.     //如果有参数
11.     if(!"".equals(String.valueOf(search.getAnimeName())) || !"".equals(String.valueOf(search.getAnimeAuthor())) || !"0".equals(String.valueOf(search.getAnimeCategory()))) {
12.         executeSql = executeSql.concat(" where");
13.     }
15.     //如果有动漫名
16.     if(!"".equals(String.valueOf(search.getAnimeName()))) {
17.         executeSql = executeSql.concat(" name like concat('%',?,'%')");
18.         Object[] params1 = {search.getAnimeName()};
19.         params = params1;
20.     }
22.     //如果有动漫名 和作者
23.     if(!"".equals(String.valueOf(search.getAnimeName())) && !"".equals(String.valueOf(search.getAnimeAuthor()))) {
24.         executeSql = executeSql.concat(" and author like concat('%',?,'%')");
25.         Object[] params2 = {search.getAnimeName(),search.getAnimeAuthor()};
26.         params = params2;
27.     }else if(!"".equals(String.valueOf(search.getAnimeAuthor()))){
28.         //如果 作者
29.         executeSql = executeSql.concat(" author like concat('%',?,'%')");
30.         Object[] params3 = {search.getAnimeAuthor()};
31.         params = params3;
32.     }
34.     //如果有 作者名 和 动漫名 和 类型
35.     if(!"".equals(String.valueOf(search.getAnimeName())) && !"".equals(String.valueOf(search.getAnimeAuthor())) && !"0".equals(String.valueOf(search.getAnimeCategory()))) {
36.         executeSql = executeSql.concat(" and cid = ?");
37.         Object[] params4 = {search.getAnimeName(),search.getAnimeAuthor(),search.getAnimeCategory()};
38.         params = params4;
39.     }else if(!"".equals(String.valueOf(search.getAnimeName())) && !"0".equals(String.valueOf(search.getAnimeCategory()))) {
40.         //动漫名 和 类型
41.         executeSql = executeSql.concat(" and cid = ?");
42.         Object[] params5 = {search.getAnimeName(),search.getAnimeCategory()};
43.         params = params5;
44.     }else if(!"".equals(String.valueOf(search.getAnimeAuthor())) && !"0".equals(String.valueOf(search.getAnimeCategory()))) {
45.         //作者 和 类型
46.         executeSql = executeSql.concat(" and cid = ?");
47.         Object[] params6 = {search.getAnimeAuthor(),search.getAnimeCategory()};
48.         params = params6;
49.     }else if(!"0".equals(String.valueOf(search.getAnimeCategory()))){
50.         //类型
51.         executeSql = executeSql.concat(" cid = ?");
52.         Object[] params7 = {search.getAnimeCategory()};
53.         params = params7;
54.     }
56.     System.out.println("searchAnimes 搜索的SQL==>"+executeSql);
58.     ResultSet rs = JDBCUtil.select(executeSql, params);
60.     while(rs.next()) {
61.         Animes anime = new Animes();
62.         anime.setId(rs.getInt("id"));
63.         anime.setCid(rs.getInt("cid"));
64.         anime.setName(rs.getString("name"));
65.         anime.setAuthor(rs.getString("author"));
66.         anime.setActor(rs.getString("actor"));
67.         anime.setProduce(rs.getString("produce"));
68.         anime.setCreate_date(rs.getDate("create_date"));
69.         animesList.add(anime);
70.     }
71.     System.out.println("----- AnimesImpl  遍历数据库中查询的数据 ----");
72.     for (int i = 0; i < animesList.size(); i++) {
73.         System.out.println(animesList.get(i).toString());
74.     }
75.     System.out.println("----- AnimesImpl  遍历数据库中查询的数据结束 ---");
77.     return animesList;
79. }

复制代码

3.5  标记 搜索关键字

在数据查询的时候将关键字进行替换 replace(oldstr,new str)；

1. //标记关键字 name
2. String markName = "replace(`name`,'"+search.getAnimeName() +"',""+search.getAnimeName()+"") as 'name'";
3. //标记关键字 author
4. String markAuthor = "replace(`author`,'"+search.getAnimeAuthor() +"',""+search.getAnimeAuthor()+"") as 'author'";
6. //执行的sql
7. String executeSql = "select `id`,`cid`,"+markName+","+markAuthor+",`actor`,`produce`,`create_date` from animes";

复制代码

3.6 分页查询

1. //分页查询所有的动漫数据
2. public List<Animes> pageSelectAllAnimes(PageUtil pageUtil) throws SQLException{
3.     List<Animes> animesList = new ArrayList<>();
5.     String executeSql = "select `id`,`cid`,`name`,`author`,`actor`,`produce`,`create_date` from animes limit ?,?";
7.     //参数
8.     Object[] params = {(pageUtil.getPageNum()-1)*pageUtil.getPageSize(),pageUtil.getPageSize()};
10.     ResultSet rs = JDBCUtil.select(executeSql, params);
12.     while(rs.next()) {
13.         Animes anime = new Animes();
14.         anime.setId(rs.getInt("id"));
15.         anime.setCid(rs.getInt("cid"));
16.         anime.setName(rs.getString("name"));
17.         anime.setAuthor(rs.getString("author"));
18.         anime.setActor(rs.getString("actor"));
19.         anime.setProduce(rs.getString("produce"));
20.         anime.setCreate_date(rs.getDate("create_date"));
21.         animesList.add(anime);
22.     }
23.     System.out.println("----- AnimesImpl 打印测试  当前页=》"+pageUtil.getPageNum()+",页面大小=》"+pageUtil.getPageSize());
24.     for (int i = 0; i < animesList.size(); i++) {
25.         System.out.println(animesList.get(i).toString());
26.     }
27.     System.out.println("-----------------------------------");
29.     return animesList;
30. }

复制代码

3.7 分页工具类

1. //分页工具类
2. public class PageUtil {
4.         //一共多少条数据
5.         private int dateCount;
6.         //每页显示的数据条数
7.         private int pageSize = 5;
8.         //当前页
9.         private int pageNum = 1;
10.         //最大页数
11.         private int maxPageNum;
12.        
13.         //构造方法,需要  数据量 和 页面大小
14.         public PageUtil(int dateCount) {
15.                 this.dateCount = dateCount;
16.                 this.maxPageNum = (this.dateCount%pageSize) == 0 ? (this.dateCount/pageSize) : (this.dateCount/pageSize) +1 ;
17.         }
19.         //获取当前页面
20.         public int getPageNum() {
21.                 return pageNum;
22.         }
23.        
24.         //设置当前页面
25.         public void setPageNum(int pageNum) {
26.                 this.pageNum = pageNum;
27.         }
30.         //获取最大页面数
31.         public int getMaxPageNum() {
32.                 return this.maxPageNum;
33.         }
35.         //获取页面大小
36.         public int getPageSize() {
37.                 return pageSize;
38.         }
40.         //设置页面大小
41.         public void setPageSize(int pageSize) {
42.                 this.pageSize = pageSize;
43.                 //页面大小切换后应该重新切换页面数量
44.                 this.maxPageNum = (this.dateCount%pageSize) == 0 ? (this.dateCount/pageSize) : (this.dateCount/pageSize) +1 ;
45.         }
47.         //获取数据总条数
48.         public int getDateCount() {
49.                 return dateCount;
50.         }
51.        
52. }

复制代码

3.8  获取select的值 change()事件动态获取pageSize  并拼接参数

select标签的change()事件, 切换选项时触发；

1. [/code]跳转页面的链接 [b]首页，上一页，下一页，尾页[/b]
2. [code]<a target="_blank" href="https://www.cnblogs.com/pageSearch?pageNum=1&pageSize=" >首页</a> | 
3. <c:if test="${pageUtil.pageNum ne 1}" var="sexFlag">
4.     <a target="_blank" href="https://www.cnblogs.com/pageSearch?pageNum=${pageUtil.pageNum -1 }&pageSize=" ><<上一页</a> | 
5. </c:if>
6. <c:if test="${pageUtil.pageNum ne pageUtil.maxPageNum}" var="sexFlag">
7.     <a target="_blank" href="https://www.cnblogs.com/pageSearch?pageNum=${pageUtil.pageNum +1 }&pageSize=" >下一页>></a> | 
8. </c:if>
9. <a target="_blank" href="https://www.cnblogs.com/pageSearch?pageNum=${pageUtil.maxPageNum }&pageSize=" >尾页</a> | 

复制代码

3.9 动态显示pageSize

1. <select name="pageSize" id="pageSize">
2.    
3.     <c:forEach items="${pageSizeList}" var ="pageSize" varStatus="status">
4.         <option value="${pageSize.pageSize}"
5.                 <c:if test="${pageUtil.pageSize eq pageSize.pageSize}">
6.         selected = "selected"
7.         </c:if>
8.     >${pageSize.pageSize}</option>
9. </c:forEach>
10. </select>

复制代码

3.10 登录 AnimeServlet 第一次跳转到展示页面 需要准备一些数据

1. @Override
2. protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
4.     //======从数据库获取动漫数据  不走条件查询======
5.     List<Animes> animesList = new ArrayList<>();
6.     AnimesImpl animesImpl = new AnimesImpl();
7.     //                try {
8.     //                        animesList = animesImpl.selectAllAnimes();
9.     //                } catch (SQLException e) {
10.     //                        e.printStackTrace();
11.     //                }
14.     //======从数据库获取动漫数据  走条件查询======
15.     //获取动漫的总条数
16.     int dateCount = 0;
17.     try {
18.         dateCount = animesImpl.selectAllAnimesCounts();
19.     } catch (SQLException e) {
20.         e.printStackTrace();
21.     }
23.     PageUtil pageUtil = new PageUtil(dateCount);
24.     //将分页对象放进session域中，初始化页面对象
25.     req.getSession().setAttribute("pageUtil", pageUtil);
26.     try {
27.         animesList = animesImpl.pageSelectAllAnimes(pageUtil);
28.     } catch (SQLException e) {
29.         e.printStackTrace();
30.     }
33.     //将动漫集合放入request中
34.     req.setAttribute("animesList", animesList);
36.     //======动漫类型======
37.     List<Category> categoriesList = new ArrayList<>();
38.     CategoryImpl categoryImpl = new CategoryImpl();
40.     try {
41.         categoriesList = categoryImpl.selectAllCategories();
42.     } catch (SQLException e) {
43.         e.printStackTrace();
44.     }
45.     //将类型数据放进session中
46.     req.getSession().setAttribute("categoriesList", categoriesList);
48.     //页面大小
49.     List<PageSize> pageSizeList = new ArrayList<PageSize>();
50.     pageSizeList.add(new PageSize("3"));
51.     pageSizeList.add(new PageSize("5"));
52.     pageSizeList.add(new PageSize("10"));
53.     pageSizeList.add(new PageSize("15"));
54.     //将pageSize放进session中
55.     req.getSession().setAttribute("pageSizeList", pageSizeList);
57.     System.out.println("==AnimeServlet 动漫数据条数"+dateCount+"当前页"+pageUtil.getPageNum()+"最大页"+pageUtil.getMaxPageNum()+"===");
59.     //转发到动漫列表页面
60.     req.getRequestDispatcher("web6Jdbc/animeListJson.jsp").forward(req, resp);
62. }

复制代码

3.11 分页Servlet->PageSelectAnimeServlet

1. @Override
2. protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
3.     //第几页
4.     int pageNum = Integer.parseInt(req.getParameter("pageNum")==null ? "1" :req.getParameter("pageNum"));
5.     //页面大小
6.     int pageSize = Integer.parseInt(req.getParameter("pageSize")==null ? "5" :req.getParameter("pageSize"));
8.     System.out.println("PageSelectAnimeServlet 当前页=》"+pageNum+",页面大小=》"+pageSize);
11.     AnimesImpl animesImpl = new AnimesImpl();
12.     PageUtil pageUtil = null;
13.     try {
14.         //现在每次实例化都先获取数据总数,后面考虑更好的方法 ??小问题
15.         pageUtil = new PageUtil(animesImpl.selectAllAnimesCounts());
16.     } catch (SQLException e1) {
17.         e1.printStackTrace();
18.     }
19.     pageUtil.setPageNum(pageNum);
20.     pageUtil.setPageSize(pageSize);
22.     //每次分页查询要将分页工具类重新更新
23.     req.getSession().setAttribute("pageUtil", pageUtil);
25.     List<Animes> animesList = new ArrayList<Animes>();
26.     try {
27.         animesList = animesImpl.pageSelectAllAnimes(pageUtil);
28.         //将动漫集合放入request中
29.         req.setAttribute("animesList", animesList);
30.     } catch (SQLException e) {
31.         e.printStackTrace();
32.     }
34.     //转发到动漫列表页面
35.     req.getRequestDispatcher("web6Jdbc/animeListJson.jsp").forward(req, resp);
37. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！