Java Web的数据库操作
三、JDBC操作数据库
上一篇介绍了JDBC API，之后就可以通过API来操作数据库，实现对数据库的CRUD操作了。
下面仅以示例 的方式对数据库操作进行说明
1、 添加数据
使用PreparedStatement添加数据：
String sql = "INSERT INTO tb_books(name,price,count,author)valuse(?,?,?,?)"; PreparedStatement ps = conn.prepareStatement(sql); ps.setString(1, "西游记"); ps.setDouble(2, 66.0); ps.setInt(3, 200); ps.setString(4, "吴承恩"); int row = ps.executeUpdate(); if(row > 0) System.out.println("成功添加了" + row + "条数据"); 使用Statement添加数据：
String sql = "INSERT INTO tb_books(name,price,count,author)valuse(" + "西游记" + "," + 66.0 + "," + 200 + "," + "吴承恩" + ")"; ps.close(); Statement ps = conn.createStatement(); int row = ps.executeUpdate(sql); if(row > 0) System.out.println("成功添加了" + row + "条数据"); ps.close(); 2、查询数据
查询数据是通过一个Web项目来演示，通过JDBC查询图书信息表中的图书信息数据，并将其显示在JSP页面中：
创建Book类：
package com; public class Book { private int id; private String name; private double price; private int count; private String author; public Book(int id , String name , double price , int count , String author) { this.id = id; this.name = name; this.price = price; this.count = count; this.author = author; } public int getId(){ return id; } public void setId(int id){ this.id = id; } public String getName(){ return name; } public void setName(String name){ this.name = name; } public double getPrice(){ return price; } public void setPrice(double price){ this.price = price; } public int getCount(){ return count; } public void setCount(int count){ this.count = count; } public String getAuthor(){ return author; } public void setAuthor(String author){ this.author = author; }} 创建Servlet对象FindServlet： @WebServlet("/FindServlet")public class FindServlet extends HttpServlet { private static final long serialVersionUID = 1L; public FindServlet() { super(); } protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doPost(request, response); } protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { try { Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://localhost:8080/db_test"; String username = "admin"; String password = "123456"; Connection connection = DriverManager.getConnection(url, username, password); Statement statement = connection.createStatement(); String sql = "SELECT * FROM tb_books"; ResultSet rs = statement.executeQuery(sql); ArrayList list = new ArrayList (); while (rs.next()) { Book book = new Book(rs.getInt("id") , rs.getString("name") , rs.getDouble("price") , rs.getInt("count") , rs.getString("author")); list.add(book); } request.setAttribute("list", list); rs.close(); statement.close(); connection.close(); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } //将请求转发到book_list.jsp request.getRequestDispatcher("book_list.jsp").forward(request, response); }} 创建book_list.jsp页面： list = (ArrayList )request.getAttribute("list"); if(list == null || list.size() < 1) out.print("没有数据!"); else{ for(Book book : list){ %>
所有图书信息 | ||||
| ID | 图书名称 | 价格 | 数量 | 作者 |
| <%= book.getId() %> | <%= book.getName() %> | <%= book.getPrice() %> | <%= book.getCount() %> | <%= book.getAuthor() %> |
查看所有图书
3、修改数据
修改数据的方法，除了SQL语句外其它都与添加数据相同，其SQL语句为：
UPDATE 表 SET 属性=xxx WHERE 属性=xxx
在实际开发中，通常都是由程序传递SQL语句中的参数，所以修改数据也需要使用PreparedStatement对象进行操作。
4、删除数据
修改数据的方法，除了SQL语句外其它都与添加数据相同，其SQL语句为：
DELETE FROM 表 WHERE 属性=xxx
在实际开发中，通常都是由程序传递SQL语句中的参数，所以删除数据也需要使用PreparedStatement对象进行操作。
5、批处理
JDBC中批处理的原理是将批量的SQL语句一次性发送到数据库中进行执行，从而解决多次与数据库连接所产生的速度瓶颈。下面是一个使用批处理添加数据的方法：
public int saveBatch() { int row = 0; try { String sql = "INSERT INTO tb_books(id,name,price,count,anthor) VALUES(?,?,?,?,?)"; PreparedStatement ps = connection.prepareStatement(sql); for (int i = 0; i < 10; i++) { ps.setInt(1, i); ps.setString(2, "书" + i); ps.setDouble(3, i*10.5); ps.setInt(4, i*20); ps.setString(5, "作者" + i); //添加批处理命令 ps.addBatch(); } //执行批处理操作并返回计数组成的数据 int[] rows = ps.executeBatch(); row = rows.length; ps.close(); connection.close(); } catch (SQLException e) { e.printStackTrace(); } return row; } 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，依次打开实例、数据库、你的数据库、可编程性、存储过程，右键存储过程选择新建存储过程。这是会弹出文本窗口，内有许多文本，鉴于初学者，将文本内容全部删掉，以下面的代码代替之：
USE [test]GOCREATE PROCEDURE findAllBooks ASBEGIN SELECT * from tb_booksENDGO
在程序中关键代码如下：
CallableStatement cs = connection.prepareCall("{call findAllBook()}"); ResultSet resultSet = cs.executeQuery();
下一节介绍JDBC在Java Web中的应用