J2EE进阶之JDBC简介十六

梦里梦外; 2024-02-18 14:18 19阅读 0赞

## **JDBC** ##

### 一、JDBC简介 ###

*  1、JDBC：Java Database Connectivity SUN推出的一套操作数据库的java规范，由接口组成
 *  2、JDBC和数据库驱动是什么关系：规范（接口）和实现的关系
 *  3、JDBC规范在：java.sql.*;javax.sql.*;

### 二、JDBC的编码步骤 ###

准备：拷贝数据库的驱动jar包（[下载][Link 1]）到classpath中。

*  1、注册驱动
 *  2、获取与数据库的链接
 *  3、创建代表SQL语句的对象
 *  4、执行SQL语句：CRUD
 *  5、如果是查询就会有结果集，遍历
 *  6、释放占用的资源

demo测试：

先创建一个wsj的数据库，然后创建用户表

create table users(
        id int primary key auto_increment,
        name varchar(40),
        password varchar(40),
        email varchar(60),
        birthday date
    )character set utf8 collate utf8_general_ci;
    
    insert into users(name,password,email,birthday) values('zs','123456','zs@sina.com','1980-12-04');
    insert into users(name,password,email,birthday) values('lisi','123456','lisi@sina.com','1981-12-04');
    insert into users(name,password,email,birthday) values('wangwu','123456','wangwu@sina.com','1979-12-04');

![kAG2fqq.jpg][]

然后写java代码：

1 package wsj;
      2 
      3 import java.sql.Connection;
      4 import java.sql.DriverManager;
      5 import java.sql.ResultSet;
      6 import java.sql.SQLException;
      7 import java.sql.Statement;
      8 
      9 import com.mysql.jdbc.Driver;
     10 
     11 /**
     12  * JDBC的编码步骤
     13  * @author Angus
     14  *
     15  */
     16 public class demo1 {
     17 
     18     public static void main(String[] args) throws Exception {
     19 //      - 1、注册驱动
     20         DriverManager.registerDriver(new Driver());
     21 //      - 2、获取与数据库的链接
     22         Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/wsj","root","root");
     23 //      System.out.println(conn.getClass().getName());//com.mysql.jdbc.Connection  检测是否连接成功
     24 //      - 3、创建代表SQL语句的对象
     25         Statement statement = conn.createStatement();
     26 //      - 4、执行SQL语句：CRUD
     27         ResultSet rs = statement.executeQuery("SELECT * FROM users;");
     28 //      - 5、如果是查询就会有结果集，遍历
     29         while(rs.next()){
     30             System.out.println("----------------------");
     31             System.out.println(rs.getObject("id"));
     32             System.out.println(rs.getObject("name"));
     33             System.out.println(rs.getObject("password"));
     34             System.out.println(rs.getObject("email"));
     35             System.out.println(rs.getObject("birthday"));
     36         }
     37 //      - 6、释放占用的资源
     38         rs.close();
     39         statement.close();
     40         conn.close();
     41 
     42     }
     43 
     44 }

结果：

![iKW4IRf.jpg][]

### 三、JDBC常用的接口或类 ###

#### 1：DriverManger ####

*  Jdbc程序中的DriverManager用于加载驱动，并创建与数据库的链接，这个API的常用方法：  
    　　DriverManager.registerDriver(new Driver())  
    　　DriverManager.getConnection(url, user, password)，
 *  注意：在实际开发中并不推荐采用registerDriver方法注册驱动。原因有二：  
    　　一、查看Driver的源代码可以看到，如果采用此种方式，会导致驱动程序注册两次，也就是在内存中会有两个Driver对象。  
    　　二、程序依赖mysql的api，脱离mysql的jar包，程序将无法编译，将来程序切换底层数据库将会非常麻烦。

推荐方式：Class.forName(“com.mysql.jdbc.Driver”);  
采用此种方式不会导致驱动对象在内存中重复出现，并且采用此种方式，程序仅仅只需要一个字符串，不需要依赖具体的驱动，使程序的灵活性更高。

#### 2：数据库URL ####

![Tq1rafE.jpg][]

#### 3：Connection ####

Jdbc程序中的Connection，它用于代表数据库的链接，Collection是数据库编程中最重要的一个对象，客户端与数据库所有交互都是通过connection对象完成的，这个对象的常用方法：

*  **createStatement()：创建向数据库发送sql的statement对象**。
 *  **prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象**。
 *  prepareCall(sql)：创建执行存储过程的callableStatement对象。
 *  setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
 *  commit() ：在链接上提交事务 。
 *  rollback() ：在此链接上回滚事务。

#### 4：Statement ####

Jdbc程序中的Statement对象用于向数据库发送SQL语句， Statement对象常用方法：

*  **executeQuery(String sql) ：用于向数据发送查询语句。**
 *  **executeUpdate(String sql)：用于向数据库发送insert、update或delete语句**
 *  **execute(String sql)：用于向数据库发送任意sql语句**
 *  addBatch(String sql) ：把多条sql语句放到一个批处理中。
 *  executeBatch()：向数据库发送一批sql语句执行。

#### 5：ResultSet ####

游标

*   boolean next():下移游标。返回有没有记录
 *   boolean previous():上移游标。返回有没有记录
 *   boolean absolute(int count):定位到某一行记录(第一行是1)。返回有没有记录
 *   void beforeFirst():把游标移动到第一条记录的前面。
 *   void afterLast():把游标移动到最后一条的后面

ResultSet既然用于封装执行结果的，所以该对象提供的都是用于获取数据的get方法：  
获取任意类型的数据  
　　\*\*getObject(int index)  
　　getObject(string columnName)\*\*  
获取指定类型的数据，(封装数据时方便)例如：  
　　\*\*getString(int index)  
　　getString(String columnName)\*\*

#### 6:释放资源 ####

*  Jdbc程序运行完后，切记要释放程序在运行过程中，创建的那些与数据库进行交互的对象，这些对象通常是**ResultSet, Statement和Connection**对象。
 *  特别是**Connection**对象，它是非常稀有的资源，用完后必须马上释放，如果**Connection**不能及时、正确的关闭，极易导致系统宕机。**Connection**的使用原则是尽量晚创建，尽量早的释放。
 *  为确保资源释放代码能运行，资源释放代码也一定要放在**finally**语句中。

demo测试：

1 package wsj;
      2 
      3 import java.sql.Connection;
      4 import java.sql.DriverManager;
      5 import java.sql.ResultSet;
      6 import java.sql.SQLException;
      7 import java.sql.Statement;
      8 import java.util.ArrayList;
      9 import java.util.List;
     10 
     11 import wsj.domain.User;
     12 
     13 import com.mysql.jdbc.Driver;
     14 
     15 /**
     16  * JDBC的编码步骤:改进版释放资源
     17  * @author Angus
     18  *
     19  */
     20 public class demo2 {
     21     public static void main(String[] args) {
     22         Connection conn = null;
     23         Statement stmt = null;
     24         ResultSet rs = null;
     25         
     26         try {
     27             Class.forName("com.mysql.jdbc.Driver");
     28             conn = DriverManager.getConnection("jdbc:mysql:///wsj","root","root");
     29             stmt = conn.createStatement();
     30             rs = stmt.executeQuery("select id,name,password,email,birthday from users");
     31             
     32             List<User> list = new ArrayList<User>();
     33             while(rs.next()){
     34                 User user = new User(rs.getInt("id"),
     35                         rs.getString("name"),
     36                         rs.getString("password"),
     37                         rs.getString("email"), 
     38                         rs.getDate("birthday"));
     39                 
     40                 list.add(user);
     41                 System.out.println(user);
     42             }
     43             
     44             
     45         } catch (Exception e) {
     46             e.printStackTrace();
     47         }finally{
     48             if(rs!=null){
     49                 try {
     50                     rs.close();
     51                 } catch (SQLException e) {
     52                     e.printStackTrace();
     53                 }
     54                 rs = null;
     55             }
     56             if(stmt!=null){
     57                 try {
     58                     stmt.close();
     59                 } catch (SQLException e) {
     60                     e.printStackTrace();
     61                 }
     62                 stmt = null;
     63             }
     64             if(conn!=null){
     65                 try {
     66                     conn.close();
     67                 } catch (SQLException e) {
     68                     e.printStackTrace();
     69                 }
     70                 conn = null;
     71             }
     72         }
     73     }
     74 }

常用数据类型转换表

![8X1PIW2.png][]

### 四、抽取一个JDBC的工具类和CRUD测试 ###

JDBCUtils.java

1 package wsj.utils;
      2 
      3 import java.sql.Connection;
      4 import java.sql.DriverManager;
      5 import java.sql.ResultSet;
      6 import java.sql.SQLException;
      7 import java.sql.Statement;
      8 import java.util.ResourceBundle;
      9 /**
     10  * JDBC工具类
     11  * @author Angus
     12  *
     13  */
     14 public class JDBCUtils {
     15     private static String driverClass;
     16     private static String url;
     17     private static String user;
     18     private static String password;
     19 
     20     static {
     21         // 初始化变量
     22         ResourceBundle rb = ResourceBundle.getBundle("dbinfo");
     23         driverClass = rb.getString("driverClass");
     24         url = rb.getString("url");
     25         user = rb.getString("user");
     26         password = rb.getString("password");
     27 
     28         try {
     29             Class.forName(driverClass);
     30         } catch (ClassNotFoundException e) {
     31             throw new ExceptionInInitializerError(e);
     32         }
     33     }
     34 
     35     /**
     36      * 获取数据库连接
     37      * 
     38      * @return
     39      * @throws SQLException
     40      */
     41     public static Connection getConnection() throws SQLException {
     42         Connection conn = DriverManager.getConnection(url, user, password);
     43         return conn;
     44 
     45     }
     46 
     47     /**
     48      * //释放占用的资源
     49      * 
     50      * @param rs
     51      * @param stmt
     52      * @param conn
     53      */
     54     public static void release(ResultSet rs, Statement stmt, Connection conn) {
     55         if (rs != null) {
     56             try {
     57                 rs.close();
     58             } catch (SQLException e) {
     59                 e.printStackTrace();
     60             }
     61             rs = null;
     62         }
     63         if (stmt != null) {
     64             try {
     65                 stmt.close();
     66             } catch (SQLException e) {
     67                 e.printStackTrace();
     68             }
     69             stmt = null;
     70         }
     71         if (conn != null) {
     72             try {
     73                 conn.close();
     74             } catch (SQLException e) {
     75                 e.printStackTrace();
     76             }
     77             conn = null;
     78         }
     79     }
     80 }

测试代码：

1 package wsj;
      2 
      3 import java.sql.Connection;
      4 import java.sql.ResultSet;
      5 import java.sql.SQLException;
      6 import java.sql.Statement;
      7 
      8 import org.junit.Test;
      9 
     10 import wsj.utils.JDBCUtils;
     11 
     12 /**
     13  * 对users表进行CRUD操作
     14  * @author Angus
     15  *
     16  */
     17 public class dmeo3 {
     18     
     19     private Connection conn;
     20     private Statement stmt;
     21     private ResultSet rs;
     22 
     23     @Test
     24     public void testAdd(){
     25         try {
     26             conn = JDBCUtils.getConnection();
     27             stmt = conn.createStatement();
     28             stmt.executeUpdate("insert into users (id,name,password,email,birthday) value(4,'杨彬彬','123','ybb@qq.com','1937-09-08')");
     29         } catch (SQLException e) {
     30             // TODO Auto-generated catch block
     31             e.printStackTrace();
     32         }finally{
     33             JDBCUtils.release(rs, stmt, conn);
     34         }
     35     }
     36     
     37     @Test
     38     public void testUpdate() {
     39         try{
     40             conn = JDBCUtils.getConnection();
     41             stmt = conn.createStatement();
     42             stmt.executeUpdate("update users set password='438' where id=4");
     43         }catch(Exception e){
     44             throw new RuntimeException(e);
     45         }finally{
     46             JDBCUtils.release(rs, stmt, conn);
     47         }
     48     }
     49     
     50     @Test
     51     public void testFind() {
     52         try{
     53             conn = JDBCUtils.getConnection();
     54             stmt = conn.createStatement();
     55             rs = stmt.executeQuery("select * from users where id=4");
     56             if(rs.next()){
     57                 System.out.println(rs.getString("name"));
     58             }
     59         }catch(Exception e){
     60             throw new RuntimeException(e);
     61         }finally{
     62             JDBCUtils.release(rs, stmt, conn);
     63         }
     64     }
     65     
     66     @Test
     67     public void testDelete() {
     68         try{
     69             conn = JDBCUtils.getConnection();
     70             stmt = conn.createStatement();
     71             stmt.executeUpdate("delete from users where id=4");
     72         }catch(Exception e){
     73             throw new RuntimeException(e);
     74         }finally{
     75             JDBCUtils.release(rs, stmt, conn);
     76         }
     77     }
     78 }

其中吧数据库信息抽取到属性配置文件中：

![fKz6srp.jpg][]

数据库操作截图

![3rdIISc.jpg][]

### 五PreparedStatement ###

PreperedStatement是Statement的孩子，它的实例对象可以通过调用Connection.preparedStatement()方法获得，相对于Statement对象而言：

*  PreperedStatement可以避免SQL注入的问题。
 *  Statement会使数据库频繁编译SQL，可能造成数据库缓冲区溢出。PreparedStatement 可对SQL进行预编译，从而提高数据库的执行效率 。
 *  并且PreperedStatement对于sql中的参数，允许使用占位符的形式进行替换，简化sql语句的编写。

[Link 1]: http://download.csdn.net/download/onceing/9926021
[kAG2fqq.jpg]: http://i.imgur.com/kAG2fqq.jpg
[iKW4IRf.jpg]: http://i.imgur.com/iKW4IRf.jpg
[Tq1rafE.jpg]: http://i.imgur.com/Tq1rafE.jpg
[8X1PIW2.png]: http://i.imgur.com/8X1PIW2.png
[fKz6srp.jpg]: http://i.imgur.com/fKz6srp.jpg
[3rdIISc.jpg]: http://i.imgur.com/3rdIISc.jpg