JavaWeb开发与代码的编写(十四)
数据库驱动
这里的驱动的概念和平时听到的那种驱动的概念是一样的，比如平时购买的声卡，网卡直接插到计算机上面是不能用的，必须要安装相应的驱动程序之后才能够使用声卡和网卡，同样道理，我们安装好数据库之后，我们的应用程序也是不能直接使用数据库的，必须要通过相应的数据库驱动程序，通过驱动程序去和数据库打交道，如下所示：
JDBC介绍
SUN公司为了简化、统一对数据库的操作，定义了一套Java操作数据库的规范（接口），称之为JDBC。这套接口由数据库厂商去实现，这样，开发人员只需要学习jdbc接口，并通过jdbc加载具体的驱动，就可以操作数据库。
如下图所示：
JDBC全称为：Java Data Base Connectivity（java数据库连接），它主要由接口组成。 组成JDBC的２个包： java.sql javax.sql 开发JDBC应用需要以上2个包的支持外，还需要导入相应JDBC的数据库实现(即数据库驱动)。
编写JDBC程序
搭建实验环境
1、在mysql中创建一个库，并创建user表和插入表的数据。
SQL脚本如下：
create database jdbcStudy character set utf8 collate utf8_general_ci;
use jdbcStudy;
create table users(
id int primary key,
name varchar(40),
password varchar(40),
email varchar(60),
birthday date
);
insert into users(id,name,password,email,birthday) values(1,'zhansan','123456','zs@sina.com','1980-12-04');
insert into users(id,name,password,email,birthday) values(2,'lisi','123456','lisi@sina.com','1981-12-04');
insert into users(id,name,password,email,birthday) values(3,'wangwu','123456','wangwu@sina.com','1979-12-04');2、新建一个Java工程，并导入数据驱动。 
3、编写程序从user表中读取数据，并打印在命令行窗口中。 具体代码如下：
package me.gacl.demo;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class JdbcFirstDemo {
public static void main(String[] args) throws Exception {
//要连接的数据库URL
String url = "jdbc:mysql://localhost:3306/jdbcStudy";
//连接的数据库时使用的用户名
String username = "root";
//连接的数据库时使用的密码
String password = "XDP";
//1.加载驱动
//DriverManager.registerDriver(new com.mysql.jdbc.Driver());不推荐使用这种方式来加载驱动
Class.forName("com.mysql.jdbc.Driver");//推荐使用这种方式来加载驱动
//2.获取与数据库的链接
Connection conn = DriverManager.getConnection(url, username, password);
//3.获取用于向数据库发送sql语句的statement
Statement st = conn.createStatement();
String sql = "select id,name,password,email,birthday from users";
//4.向数据库发sql,并获取代表结果集的resultset
ResultSet rs = st.executeQuery(sql);
//5.取出结果集的数据
while(rs.next()){
System.out.println("id=" + rs.getObject("id"));
System.out.println("name=" + rs.getObject("name"));
System.out.println("password=" + rs.getObject("password"));
System.out.println("email=" + rs.getObject("email"));
System.out.println("birthday=" + rs.getObject("birthday"));
}
//6.关闭链接，释放资源
rs.close();
st.close();
conn.close();
}
}运行结果如下：
DriverManager类讲解
Jdbc程序中的DriverManager用于加载驱动，并创建与数据库的链接，这个API的常用方法：
- DriverManager.registerDriver(new Driver())
- DriverManager.getConnection(url, user, password)，
注意：在实际开发中并不推荐采用registerDriver方法注册驱动。原因有二： 1、查看Driver的源代码可以看到，如果采用此种方式，会导致驱动程序注册两次，也就是在内存中会有两个Driver对象。 2、程序依赖mysql的api，脱离mysql的jar包，程序将无法编译，将来程序切换底层数据库将会非常麻烦。 推荐方式：Class.forName("com.mysql.jdbc.Driver"); 采用此种方式不会导致驱动对象在内存中重复出现，并且采用此种方式，程序仅仅只需要一个字符串，不需要依赖具体的驱动，使程序的灵活性更高。
数据库URL讲解
URL用于标识数据库的位置，通过URL地址告诉JDBC程序连接哪个数据库，URL的写法为：
常用数据库URL地址的写法：
- Oracle写法：jdbc:oracle:thin:@localhost:1521:sid
- SqlServer写法：jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid
- MySql写法：jdbc:mysql://localhost:3306/sid
如果连接的是本地的Mysql数据库，并且连接使用的端口是3306，那么的url地址可以简写为： jdbc:mysql:///数据库
Connection类讲解
Jdbc程序中的Connection，它用于代表数据库的链接，Collection是数据库编程中最重要的一个对象，客户端与数据库所有交互都是通过connection对象完成的，这个对象的常用方法：
- createStatement()：创建向数据库发送sql的statement对象。
- prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。
- prepareCall(sql)：创建执行存储过程的callableStatement对象。
- setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
- commit() ：在链接上提交事务。
- rollback() ：在此链接上回滚事务。
Statement类讲解
Jdbc程序中的Statement对象用于向数据库发送SQL语句， Statement对象常用方法：
- executeQuery(String sql) ：用于向数据发送查询语句。
- executeUpdate(String sql)：用于向数据库发送insert、update或delete语句
- execute(String sql)：用于向数据库发送任意sql语句
- addBatch(String sql) ：把多条sql语句放到一个批处理中。
- executeBatch()：向数据库发送一批sql语句执行。
ResultSet类讲解
Jdbc程序中的ResultSet用于代表Sql语句的执行结果。Resultset封装执行结果时，采用的类似于表格的方式。ResultSet 对象维护了一个指向表格数据行的游标，初始的时候，游标在第一行之前，调用ResultSet.next() 方法，可以使游标指向具体的数据行，进行调用方法获取该行的数据。 ResultSet既然用于封装执行结果的，所以该对象提供的都是用于获取数据的get方法： 获取任意类型的数据 getObject(int index) getObject(string columnName) 获取指定类型的数据，例如： getString(int index) getString(String columnName)
ResultSet还提供了对结果集进行滚动的方法：
- next()：移动到下一行
- Previous()：移动到前一行
- absolute(int row)：移动到指定行
- beforeFirst()：移动resultSet的最前面。
- afterLast() ：移动到resultSet的最后面。
释放资源
Jdbc程序运行完后，切记要释放程序在运行过程中，创建的那些与数据库进行交互的对象，这些对象通常是ResultSet, Statement和Connection对象，特别是Connection对象，它是非常稀有的资源，用完后必须马上释放，如果Connection不能及时、正确的关闭，极易导致系统宕机。Connection的使用原则是尽量晚创建，尽量早的释放。 为确保资源释放代码能运行，资源释放代码也一定要放在finally语句中。
statement对象
Jdbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。 Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sql语句，executeUpdate执行完后，将会返回一个整数(即增删改语句导致了数据库几行数据发生了变化)。 Statement.executeQuery方法用于向数据库发送查询语句，executeQuery方法返回代表查询结果的ResultSet对象。
CRUD操作-create
使用executeUpdate(String sql)方法完成数据添加操作，示例操作：
Statement st = conn.createStatement();
String sql = "insert into user(….) values(…..) ";
int num = st.executeUpdate(sql);
if(num>0){
System.out.println("插入成功！！！");
}CRUD操作-update
使用executeUpdate(String sql)方法完成数据修改操作，示例操作：
Statement st = conn.createStatement();
String sql = “update user set name=‘’ where name=‘’";
int num = st.executeUpdate(sql);
if(num>0){
System.out.println(“修改成功！！！");
}CRUD操作-delete
使用executeUpdate(String sql)方法完成数据删除操作，示例操作：
Statement st = conn.createStatement();
String sql = “delete from user where id=1;
int num = st.executeUpdate(sql);
if(num>0){
System.out.println(“删除成功！！！");
}CRUD操作-read
使用executeQuery(String sql)方法完成数据查询操作，示例操作：
Statement st = conn.createStatement();
String sql = “select * from user where id=1;
ResultSet rs = st.executeUpdate(sql);
while(rs.next()){
//根据获取列的数据类型，分别调用rs的相应方法映射到java对象中
}使用jdbc对数据库增删改查
搭建实验环境
1、在mysql中创建一个库，并创建user表和插入表的数据。
SQL脚本如下：
create database jdbcStudy;
use jdbcStudy;
create table users(
id int primary key,
name varchar(40),
password varchar(40),
email varchar(60),
birthday date
);2、新建一个JavaWeb工程，并导入MySQL数据库驱动。
3、在src目录下创建一个db.properties文件，如下图所示：
在db.properties中编写MySQL数据库的连接信息，代码如下所示：
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcStudy
username=root
password=XDP4、编写一个JdbcUtils工具类，用于连接数据库，获取数据库连接和释放数据库连接，代码如下：
1 package me.gacl.utils;
2
3 import java.io.InputStream;
4 import java.sql.Connection;
5 import java.sql.DriverManager;
6 import java.sql.ResultSet;
7 import java.sql.SQLException;
8 import java.sql.Statement;
9 import java.util.Properties;
10
11 public class JdbcUtils {
12
13 private static String driver = null;
14 private static String url = null;
15 private static String username = null;
16 private static String password = null;
17
18 static{
19 try{
20 //读取db.properties文件中的数据库连接信息
21 InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
22 Properties prop = new Properties();
23 prop.load(in);
24
25 //获取数据库连接驱动
26 driver = prop.getProperty("driver");
27 //获取数据库连接URL地址
28 url = prop.getProperty("url");
29 //获取数据库连接用户名
30 username = prop.getProperty("username");
31 //获取数据库连接密码
32 password = prop.getProperty("password");
33
34 //加载数据库驱动
35 Class.forName(driver);
36
37 }catch (Exception e) {
38 throw new ExceptionInInitializerError(e);
39 }
40 }
41
42 /**
43 * @Method: getConnection
44 * @Description: 获取数据库连接对象
46 *
47 * @return Connection数据库连接对象
48 * @throws SQLException
49 */
50 public static Connection getConnection() throws SQLException{
51 return DriverManager.getConnection(url, username,password);
52 }
53
54 /**
55 * @Method: release
56 * @Description: 释放资源，
57 * 要释放的资源包括Connection数据库连接对象，负责执行SQL命令的Statement对象，存储查询结果的ResultSet对象
59 *
60 * @param conn
61 * @param st
62 * @param rs
63 */
64 public static void release(Connection conn,Statement st,ResultSet rs){
65 if(rs!=null){
66 try{
67 //关闭存储查询结果的ResultSet对象
68 rs.close();
69 }catch (Exception e) {
70 e.printStackTrace();
71 }
72 rs = null;
73 }
74 if(st!=null){
75 try{
76 //关闭负责执行SQL命令的Statement对象
77 st.close();
78 }catch (Exception e) {
79 e.printStackTrace();
80 }
81 }
82
83 if(conn!=null){
84 try{
85 //关闭Connection数据库连接对象
86 conn.close();
87 }catch (Exception e) {
88 e.printStackTrace();
89 }
90 }
91 }
92 }使用statement对象完成对数据库的CRUD操作
测试代码如下：
1 package me.gacl.demo;
2
3 import java.sql.Connection;
4 import java.sql.ResultSet;
5 import java.sql.Statement;
6 import me.gacl.utils.JdbcUtils;
7
8 import org.junit.Test;
9
10 /**
11 * @ClassName: JdbcCRUDByStatement
12 * @Description: 通过Statement对象完成对数据库的CRUD操作
15 *
16 */
17 public class JdbcCRUDByStatement {
18
19 @Test
20 public void insert(){
21 Connection conn = null;
22 Statement st = null;
23 ResultSet rs = null;
24 try{
25 //获取一个数据库连接
26 conn = JdbcUtils.getConnection();
27 //通过conn对象获取负责执行SQL命令的Statement对象
28 st = conn.createStatement();
29 //要执行的SQL命令
30 String sql = "insert into users(id,name,password,email,birthday) values(3,'白虎神皇','123','bhsh@sina.com','1980-09-09')";
31 //执行插入操作，executeUpdate方法返回成功的条数
32 int num = st.executeUpdate(sql);
33 if(num>0){
34 System.out.println("插入成功！！");
35 }
36
37 }catch (Exception e) {
38 e.printStackTrace();
39 }finally{
40 //SQL执行完成之后释放相关资源
41 JdbcUtils.release(conn, st, rs);
42 }
43 }
44
45 @Test
46 public void delete(){
47 Connection conn = null;
48 Statement st = null;
49 ResultSet rs = null;
50 try{
51 conn = JdbcUtils.getConnection();
52 String sql = "delete from users where id=3";
53 st = conn.createStatement();
54 int num = st.executeUpdate(sql);
55 if(num>0){
56 System.out.println("删除成功！！");
57 }
58 }catch (Exception e) {
59 e.printStackTrace();
60
61 }finally{
62 JdbcUtils.release(conn, st, rs);
63 }
64 }
65
66 @Test
67 public void update(){
68 Connection conn = null;
69 Statement st = null;
70 ResultSet rs = null;
71 try{
72 conn = JdbcUtils.getConnection();
73 String sql = "update users set name='孤傲苍狼',email='gacl@sina.com' where id=3";
74 st = conn.createStatement();
75 int num = st.executeUpdate(sql);
76 if(num>0){
77 System.out.println("更新成功！！");
78 }
79 }catch (Exception e) {
80 e.printStackTrace();
81
82 }finally{
83 JdbcUtils.release(conn, st, rs);
84 }
85 }
86
87 @Test
88 public void find(){
89 Connection conn = null;
90 Statement st = null;
91 ResultSet rs = null;
92 try{
93 conn = JdbcUtils.getConnection();
94 String sql = "select * from users where id=3";
95 st = conn.createStatement();
96 rs = st.executeQuery(sql);
97 if(rs.next()){
98 System.out.println(rs.getString("name"));
99 }
100 }catch (Exception e) {
101 e.printStackTrace();
102 }finally{
103 JdbcUtils.release(conn, st, rs);
104 }
105 }
106 }
PreparedStatement对象
PreperedStatement是Statement的子类，它的实例对象可以通过调用Connection.preparedStatement()方法获得，相对于Statement对象而言：PreperedStatement可以避免SQL注入的问题。 Statement会使数据库频繁编译SQL，可能造成数据库缓冲区溢出。PreparedStatement可对SQL进行预编译，从而提高数据库的执行效率。并且PreperedStatement对于sql中的参数，允许使用占位符的形式进行替换，简化sql语句的编写。
使用PreparedStatement对象完成对数据库的CRUD操作
测试代码如下：
1 package me.gacl.demo;
2
3 import java.sql.Connection;
4 import java.sql.PreparedStatement;
5 import java.sql.ResultSet;
6 import java.util.Date;
7 import me.gacl.utils.JdbcUtils;
8 import org.junit.Test;
9
10 /**
11 * @ClassName: JdbcCRUDByPreparedStatement
12 * @Description: 通过PreparedStatement对象完成对数据库的CRUD操作
15 *
16 */
17 public class JdbcCRUDByPreparedStatement {
18
19 @Test
20 public void insert(){
21 Connection conn = null;
22 PreparedStatement st = null;
23 ResultSet rs = null;
24 try{
25 //获取一个数据库连接
26 conn = JdbcUtils.getConnection();
27 //要执行的SQL命令，SQL中的参数使用?作为占位符
28 String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
29 //通过conn对象获取负责执行SQL命令的prepareStatement对象
30 st = conn.prepareStatement(sql);
31 //为SQL语句中的参数赋值，注意，索引是从1开始的
32 /**
33 * SQL语句中各个字段的类型如下：
34 * +----------+-------------+
35 | Field | Type |
36 +----------+-------------+
37 | id | int(11) |
38 | name | varchar(40) |
39 | password | varchar(40) |
40 | email | varchar(60) |
41 | birthday | date |
42 +----------+-------------+
43 */
44 st.setInt(1, 1);//id是int类型的
45 st.setString(2, "白虎神皇");//name是varchar(字符串类型)
46 st.setString(3, "123");//password是varchar(字符串类型)
47 st.setString(4, "bhsh@sina.com");//email是varchar(字符串类型)
48 st.setDate(5, new java.sql.Date(new Date().getTime()));//birthday是date类型
49 //执行插入操作，executeUpdate方法返回成功的条数
50 int num = st.executeUpdate();
51 if(num>0){
52 System.out.println("插入成功！！");
53 }
54
55 }catch (Exception e) {
56 e.printStackTrace();
57 }finally{
58 //SQL执行完成之后释放相关资源
59 JdbcUtils.release(conn, st, rs);
60 }
61 }
62
63 @Test
64 public void delete(){
65 Connection conn = null;
66 PreparedStatement st = null;
67 ResultSet rs = null;
68 try{
69 conn = JdbcUtils.getConnection();
70 String sql = "delete from users where id=?";
71 st = conn.prepareStatement(sql);
72 st.setInt(1, 1);
73 int num = st.executeUpdate();
74 if(num>0){
75 System.out.println("删除成功！！");
76 }
77 }catch (Exception e) {
78 e.printStackTrace();
79 }finally{
80 JdbcUtils.release(conn, st, rs);
81 }
82 }
83
84 @Test
85 public void update(){
86 Connection conn = null;
87 PreparedStatement st = null;
88 ResultSet rs = null;
89 try{
90 conn = JdbcUtils.getConnection();
91 String sql = "update users set name=?,email=? where id=?";
92 st = conn.prepareStatement(sql);
93 st.setString(1, "gacl");
94 st.setString(2, "gacl@sina.com");
95 st.setInt(3, 2);
96 int num = st.executeUpdate();
97 if(num>0){
98 System.out.println("更新成功！！");
99 }
100 }catch (Exception e) {
101 e.printStackTrace();
102
103 }finally{
104 JdbcUtils.release(conn, st, rs);
105 }
106 }
107
108 @Test
109 public void find(){
110 Connection conn = null;
111 PreparedStatement st = null;
112 ResultSet rs = null;
113 try{
114 conn = JdbcUtils.getConnection();
115 String sql = "select * from users where id=?";
116 st = conn.prepareStatement(sql);
117 st.setInt(1, 1);
118 rs = st.executeQuery();
119 if(rs.next()){
120 System.out.println(rs.getString("name"));
121 }
122 }catch (Exception e) {
123
124 }finally{
125 JdbcUtils.release(conn, st, rs);
126 }
127 }
128 }以上就是使用JDBC对数据库进行CRUD的简单总结。
