Java Web的数据库操作(一)

一、JDBC技术

1、JDBC简介

JDBC是Java程序与数据库系统通信的标准API，它定义在JDK的API中，通过JDBC技术，Java程序可以非常方便地与各种数据库交互，JDBC在Java程序与数据库系统之间假期了一座桥梁。

JDBC由一组用Java语言编写的类和接口组成，它对数据库的操作提供了基本方法，但由于数据库种类跟多且多有不同，所以对数据库的细节操作由数据库厂商进行实现，且厂商需要提供数据库的驱动程序，下图为Java程序与数据库相交互的示意图：

2、JDBC连接数据库的过程

l  下载驱动包

在JDK中，不包含数据库的驱动程序，使用JDBC操作数据库需要实现下载数据库厂商提供的驱动包，并导入到开发环境中。

l  注册数据库驱动

连接数据库前，需要将数据库厂商提供的数据库驱动注册到JDBC的驱动管理器中，一般是通过将数据库驱动类加载到JVM来实现的，例如连接MYSQL数据库：

Class.forName(“com.mysql.jdbc.Driver”);

l  构建数据库连接URL

URL由数据库厂商制定，不同数据库它的URL有所区别，但都符合一个基本的格式，即“JDBC协议+IP地址或域名+端口+数据库名称”，例如MYSQL数据库为”jdbc:mysql://localhost:8080/test”。

前两步中不同数据库有所差别，不同数据库连接请参考这篇文章：

http://blog.csdn.net/zhai56565/article/details/8959184

l  获取Connection对象

通过驱动管理器获得数据库的连接Connection，只有创建此对象后才可以对数据库进行操作，方法如下：

DriverManager.getConnection(url , username , password);

下面是一个完整的连接数据库的例子：

1. try {
2. //加载数据库驱动，注册到去送管理器
3. Class.forName(“com.mysql.jdbc.Driver”);
4. String url = “jdbc:mysql://localhost:8080/test”;
5. String username = “admin”;
6. String password = “123456”;
7. Connection conn = DriverManager.getConnection(url , username , password);
8. if (conn != null)
9. System.out.println(“数据库连接成功!”);
10. else
11. System.out.println(“数据库连接失败!”);
12. //完成后记得关闭数据库连接
13. conn.close();
14. } catch (ClassNotFoundException e) {
15. e.printStackTrace();
16. } catch (SQLException e) {
17. e.printStackTrace();
18. }

二、JDBC API

JDBC是Java程序操作数据库的标准，它由一组用Java语言编写的类和接口组成，Java通过JDBC可以对多种关系数据库进行统一访问。下面介绍主要类和接口的作用，详细方法请参考J2SE的API。

1、 Connection接口

与特定数据库的连接会话，只有获得特定数据库的连接对象才能访问数据库，操作数据库中的数据表、视图和存储过程等。

2、DriverManager类

主要作用与用户及驱动程序之间，它是JDBC中的管理层，通过它可以管理数据库厂商提供的驱动程序，并建立应用程序与数据库之间的连接。

3、 Statement接口

Statement接口封装了执行SQL语句和获取查询接口的基本方法。

4、PreparedStatement接口

Statement接口封装了JDBC执行SQL语句的方法，但在实际开发过程中，SQL语句往往需要将程序中的变量做查询条件参数等。使用Statement接口进行操作过于繁琐且存在安全缺陷。而PreparedStatement接口继承与Statement接口，且对带有参数SQL语句的执行操作进行了扩展。应用于PreparedStatement接口中的SQL语句可以使用占位符”?”来代替SQL语句中的参数，然后再对其进行赋值。

5、ResultSet接口

ResultSet对象封装了数据查询的结果集，它包含了符合SQL语句的所有行，针对Java中的数据类型提供了一套getXXX()的方法，通过这些方法可以获取每一行中的数据。ResultSet还提供了光标的功能，通过光标可以自由定位到某一行中的数据。

三、JDBC操作数据库

上一篇介绍了JDBC API，之后就可以通过API来操作数据库，实现对数据库的CRUD操作了。

http://blog.csdn.net/zhai56565/article/details/9794225

下面仅以示例 的方式对数据库操作进行说明

1、 添加数据

使用PreparedStatement添加数据：

1. String sql = “INSERT INTO tb_books(name,price,count,author)valuse(?,?,?,?)”;
2. PreparedStatement ps = conn.prepareStatement(sql);
3. ps.setString(1, “西游记”);
4. ps.setDouble(2, 66.0);
5. ps.setInt(3, 200);
6. ps.setString(4, “吴承恩”);
7. int row = ps.executeUpdate();
8. if(row > 0)
9. System.out.println(“成功添加了” + row + “条数据”);

使用Statement添加数据：

1. String sql = “INSERT INTO tb_books(name,price,count,author)valuse(” + “西游记” + “,” + 66.0 + “,” + 200 + “,” + “吴承恩” + “)”;
2. ps.close();
3. Statement ps = conn.createStatement();
4. int row = ps.executeUpdate(sql);
5. if(row > 0)
6. System.out.println(“成功添加了” + row + “条数据”);
7. ps.close();

2、查询数据

查询数据是通过一个Web项目来演示，通过JDBC查询图书信息表中的图书信息数据，并将其显示在JSP页面中：

创建Book类：

1. package com;
2. public class Book {
3. private int id;
4. private String name;
5. private double price;
6. private int count;
7. private String author;
8. public Book(int id , String name , double price , int count , String author) {
9. this.id = id;
10. this.name = name;
11. this.price = price;
12. this.count = count;
13. this.author = author;
14. }
15. public int getId(){
16. return id;
17. }
18. public void setId(int id){
19. this.id = id;
20. }
21. public String getName(){
22. return name;
23. }
24. public void setName(String name){
25. this.name = name;
26. }
27. public double getPrice(){
28. return price;
29. }
30. public void setPrice(double price){
31. this.price = price;
32. }
33. public int getCount(){
34. return count;
35. }
36. public void setCount(int count){
37. this.count = count;
38. }
39. public String getAuthor(){
40. return author;
41. }
42. public void setAuthor(String author){
43. this.author = author;
44. }
45. }

创建Servlet对象FindServlet：

1. @WebServlet(“/FindServlet”)
2. public class FindServlet extends HttpServlet {
3. private static final long serialVersionUID = 1L;
4. public FindServlet() {
5. super();
6. }
7. protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
8. doPost(request, response);
9. }
10. protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
11. try {
12. Class.forName(“com.mysql.jdbc.Driver”);
13. String url = “jdbc:mysql://localhost:8080/db_test”;
14. String username = “admin”;
15. String password = “123456”;
16. Connection connection = DriverManager.getConnection(url, username, password);
17. Statement statement = connection.createStatement();
18. String sql = “SELECT * FROM tb_books”;
19. ResultSet rs = statement.executeQuery(sql);
20. ArrayList<Book> list = new ArrayList<Book>();
21. while (rs.next()) {
22. Book book = new Book(rs.getInt(“id”) , rs.getString(“name”) ,
23. rs.getDouble(“price”) , rs.getInt(“count”) , rs.getString(“author”));
24. list.add(book);
25. }
26. request.setAttribute(“list”, list);
27. rs.close();
28. statement.close();
29. connection.close();
30. } catch (ClassNotFoundException e) {
31. e.printStackTrace();
32. } catch (SQLException e) {
33. e.printStackTrace();
34. }
35. //将请求转发到book_list.jsp
36. request.getRequestDispatcher(“book_list.jsp”).forward(request, response);
37. }
38. }

创建book_list.jsp页面：

1. <body>
2. <table align=”center” width=”450″ border=”2″>
3. <tr>
4. <td align=”center” colspan=”2″><h2>所有图书信息</h2></td>
5. </tr>
6. <tr align=”center”>
7. <td><b>ID</b></td>
8. <td><b>图书名称</b></td>
9. <td><b>价格</b></td>
10. <td><b>数量</b></td>
11. <td><b>作者</b></td>
12. </tr>
13. <%
14. //获取图书信息集合
15. ArrayList<Book> list = (ArrayList<Book>)request.getAttribute(“list”);
16. if(list == null || list.size() < 1)
17. out.print(“没有数据!”);
18. else{
19. for(Book book : list){
20. %>
21. <tr align=”center”>
22. <td><%= book.getId() %></td>
23. <td><%= book.getName() %></td>
24. <td><%= book.getPrice() %></td>
25. <td><%= book.getCount() %></td>
26. <td><%= book.getAuthor() %></td>
27. </tr>
28. <%
29. }
30. }
31. %>
32. </table>
33. </body>

创建index.jsp页面：

1. <body>
2. <a href=”FindServlet”>查看所有图书</a>
3. </body>

3、修改数据

修改数据的方法，除了SQL语句外其它都与添加数据相同，其SQL语句为：

UPDATE 表 SET 属性=xxx WHERE 属性=xxx

在实际开发中，通常都是由程序传递SQL语句中的参数，所以修改数据也需要使用PreparedStatement对象进行操作。

4、删除数据

修改数据的方法，除了SQL语句外其它都与添加数据相同，其SQL语句为：

DELETE FROM 表 WHERE 属性=xxx

在实际开发中，通常都是由程序传递SQL语句中的参数，所以删除数据也需要使用PreparedStatement对象进行操作。

5、批处理

JDBC中批处理的原理是将批量的SQL语句一次性发送到数据库中进行执行，从而解决多次与数据库连接所产生的速度瓶颈。下面是一个使用批处理添加数据的方法：

1. public int saveBatch() {
2. int row = 0;
3. try {
4. String sql = “INSERT INTO tb_books(id,name,price,count,anthor) VALUES(?,?,?,?,?)”;
5. PreparedStatement ps = connection.prepareStatement(sql);
6. for (int i = 0; i < 10; i++) {
7. ps.setInt(1, i);
8. ps.setString(2, “书” + i);
9. ps.setDouble(3, i*10.5);
10. ps.setInt(4, i*20);
11. ps.setString(5, “作者” + i);
12. //添加批处理命令
13. ps.addBatch();
14. }
15. //执行批处理操作并返回计数组成的数据
16. int[] rows = ps.executeBatch();
17. row = rows.length;
18. ps.close();
19. connection.close();
20. } catch (SQLException e) {
21. e.printStackTrace();
22. }
23. return row;
24. }

6、调用存储过程

在JDBC API中提供了调用存储过程的方法，通过CallableStatement对象进行操作。CallableStatement对象位于java.sql包中，它继承于Statement对象，主要用于执行数据库中定义的存储过程，其调用方法如下：

{call <procedure-name>[(<arg1>,<arg2>,…)]}

其中arg1、arg2为存储过程中的参数，如果存储过程中需要传递参数，可以对其进行赋值操作。

存储过程是一个SQL语句和可选控制流语句的预编译集合。编译完成后存放在数据库中，这样就省去了执行SQL语句时对SQL语句进行编译所花费的时间。在执行存储过程时只需要将参数传递到数据库中，而不需要将整条SQL语句都提交给数据库，从而减少了网络传输的流量，提高了程序的运行速度。

各种数据库创建存储过程的方法并非一致,下面以SQL Server 2012调用存储过程的方法做讲解,其他数据库请参考其帮助文档：

首先打开 SQL Server Management Studio，依次打开实例、数据库、你的数据库、可编程性、存储过程，右键存储过程选择新建存储过程。这是会弹出文本窗口，内有许多文本，鉴于初学者，将文本内容全部删掉，以下面的代码代替之：

1. USE [test]
2. GO
3. CREATE PROCEDURE findAllBooks
4. AS
5. BEGIN
6. SELECT * from tb_books
7. END
8. GO

在程序中关键代码如下：

1. CallableStatement cs = connection.prepareCall(“{call findAllBook()}”);
2. ResultSet resultSet = cs.executeQuery();

3. 前面介绍了JDBC技术和JDBC API及API的使用示例，下面详细介绍JDBC在Web中的应用。

   Java Web—-Java Web的数据库操作(一)

   Java Web—-Java Web的数据库操作(二)

   四、JDBC在Java Web中的应用

   通常情况下，Web程序操作数据库都是通过JDBC实现，即使目前数据库方面的开源框架有许多，但其底层实现都离不开JDBC API。

   1、开发模式

   在Java Web开发中使用JDBC，应遵循MVC的设计思想，从而使Web程序拥有一定的健壮性、可扩展性。每个Java Web程序员都应该深谙MVC的设计思想，下面对其简单介绍。

   MVC(Model-View-Controller)是一种设计理念，该理念将软件分成3层结构，分别为模型层、视图层和控制层。

   •  模型层泛指程序中的业务逻辑，用于处理真正的业务操作；
   •  视图层是指程序与用户交互的界面，对用户呈现出视图，但不包括业务逻辑；
   •  控制层是对用户各种请求的分发处理，将制定的请求分配给制定的业务逻辑进行处理。

   JDBC应用于Java Web开发中，处于MVC中的模型层位置，如图所示：

   

   客户端通过JSP页面与程序进行交互，对于数据的增、删、改、查请求由Servlet对其进行分发处理，如Servlet接收到添加数据请求，就会分发给增加数据的JavaBean对象，而真正的数据库操作是通过JDBC封装的JavaBean进行实现。

   2、分页查询

   分页查询用于在数据库量非常大，不适合将所有数据显示在一页中的情况。通过JDBC实现分页查询的方法有很多种，而且不同的数据库机制也提供了不同的分页方式，在这里介绍两种非常典型的分页方法：

          1)、通过ResultSet的光标实现分页

   ResultSet为查询结果集对象，在该对象中有一个“光标”的概念(可以参考第一篇中的JDBC API介绍)，光标通过上下移动定位查询结果集中的行，从而获取数据。所以通过移动“光标”，可以设置ResultSet对象中记录的起始位置和结束为止，来实现数据的分页显示。

          2)、通过数据库机制进行分页

   很多数据库自身都提供了分页机制，如SQL Server中提供的top关键字，MySQL中提供的limit关键字，他们都可以设置数据返回的记录数。

   下面是MYSQL数据库提供的分页机制，关键代码如下：

   1. String sql = “SELECT * FROM tb_book ORDER BY id DESC LIMIT ?,?”;
   2. PreparedStatement ps = connection.prepareStatement(sql);
   3. ps.setInt(1, (page – 1)*Book.PAGE_SIZE);//page为页数
   4. ps.setInt(2, Book.PAGE_SIZE);
   5. ResultSet rs = ps.executeQuery();

   Limit关键字能够控制查询数据结果集起始位置及返回记录的数量，它的两个参数分别用于指定查询记录的其实位置和所返回的记录数。而返回总记录数可以使用以下方法：

   1. int count = 0;
   2. String sql = “SELECT count(*) FROM tb_book”;
   3. Statement statement = connection.createStatement();
   4. ResultSet resultSet = statement.executeQuery(sql);
   5. if (resultSet.next())
   6. count = resultSet.getInt(1);

   下面是一个使用MySQL数据库实现分页查询的源码，可以参考下：

   http://download.csdn.net/detail/zhai56565/5885775