使用JDBC連接操作數據庫

JDBC簡介

• Java數據庫連接(Java Database Connectivity，JDBC)，是一種用於執行SQL語句的Java API，它由一組用Java編程語言編寫的類和接口組成。
• JDBC提供了一種基准，據此可以構建更高級的工具和接口，使數據庫開發人員能夠編寫數據庫應用程序。
• 使用JDBC編寫的程序能夠自動地將SQL語句傳送給相應的數據庫管理系統。
• JDBC 是個"低級"接口，也就是說，它用於直接調用 SQL 命令。在這方面它的功能極佳，並比其它的數據庫連接 API 易於使用，但它同時也被設計為一種基礎接口，在它之上可以建立高級接口和工具。高級接口是"對用戶友好的"接口，它使用的是一種更易理解和更為方便的 API，這種API在幕后被轉換為諸如 JDBC 這樣的低級接口。
• JDBC擴展了Java的功能，由於Java語言本身的特點，使得JDBC具有簡單、健壯、安全、可移植、獲取方便等優勢。

JDBC中常用類和接口

接口/類	功能說明
DriverManager	數據庫驅動管理類，用於加載和卸載各種驅動程序，並建立於數據庫的連接
Connection	此接口用於連接數據庫
Statement	此接口用於執行SQL語句並將數據檢索到ResultSet中
ResultSet	結果集接口，提供檢索SQL語句返回數據的各種方法
PreparedStatement	此接口用於執行預編譯的SQL語句
CallableStatement	此接口用於執行SQL存儲過程的語句

 

JDBC開發步驟

• 注冊驅動
• 建立連接
• 創建statement
• 執行sql，得到ResultSet
• 查看結果
• 釋放資源

開發第一個JDBC程序

源碼

package com.jyroy.test;

import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.jyroy.util.JDBCUtil;

import java.sql.Connection;
import java.sql.Driver;

public class MainTest {

    public static void main(String[] args) {
        Connection connection = null;
        Statement st = null;
        ResultSet rs = null;
        
        try {
            //1.注冊驅動
            DriverManager.registerDriver(new com.mysql.jdbc.Driver());
            
            //2.建立連接
            //方法一  參數一：協議+訪問數據庫，參數二：用戶名，參數三：密碼
            connection = DriverManager.getConnection("jdbc:mysql://localhost/student", "root", "password");
            
            //方法二
//            DriverManager.getConnection("jdbc:msql://localhost/student?user=root&password=password");
            
            //3.創建statement，跟數據庫打交道一定需要這個對象
            st = connection.createStatement();
            
            //4.執行查詢
            String sql = "select * from stu";
            rs = st.executeQuery(sql);
            
            //5.遍歷查詢每一條記錄
            while(rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                int age = rs.getInt("age");
                
                System.out.println("id = " + id + "; name = " + name + "; age = " + age);
            }
             //進行資源釋放
            connection.close();
            st.close();
            rs.close();

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
    

結果

 

使用工具類

　　借助工具類來方便JDBC的操作

獲取數據庫連接

　　建立數據庫連接的類，里面封裝好實現數據庫連接的函數，方便調用實現數據庫連接

　　這里說兩個問題：

　　一：

　　這里多用了一個 Class.forName("com.mysql.jdbc.Driver"); 因為

　　在上面的例子中，Driver這個類里面有靜態代碼塊（java.sql.DriverManager.registerDriver(new Driver())），我們在new的時候一開始就加載了Driver類，相當於注冊了兩次驅動，為了避免這個情況，使用Class.forName("com.mysql.jdbc.Driver");來進行驅動的注冊。

　　二:

　　根據JDBC官方文檔，在JDBC5之后，Class.forName(); 的注冊驅動，官方已經幫我們實現了，我們不加載驅動（JDBC會自動識別使mysql還是oracl什么的，當然了，如果同時用了mysql和oracl就要寫上了，這個時候就沒法自動確定了），直接建立連接也是可以的，大家可以自己試一下把Class.forName();這句話注釋掉，也是可以完美運行的！

package com.jyroy.DBUtil;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DBUtil {

    private static Connection connection=null;
    
    static {
        try {
            //1.加載驅動程序
            Class.forName("com.mysql.jdbc.Driver");
            //2.獲得數據庫的連接
            connection = DriverManager.getConnection("jdbc:mysql://localhost/student", "root", "password");
            
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    //將獲得的數據庫與java的鏈接返回（返回的類型為Connection）
    public static Connection getConnection(){
        return connection;
    }
}

　　我們在MainTest中調用

connection = DBUtil.getConnection();

　　運行之后，同樣可以得到相同的查詢結果

 

進行資源釋放

　　上面的資源釋放，只是簡單的close掉了，更好的辦法釋放資源還是在finally語句塊中，因此重新編寫代碼，使用finally語句塊，我這里直接寫了一個工具類，讓代碼更清晰一點。

   　finally一般拿來做一些善后清理工作，當try塊里出現錯誤的話，會立即跳出try塊，找到匹配的錯誤，執行catch塊里的語句,此時，可能在try塊里打開的文件沒關閉，連接的網絡沒斷開，對這些浪費的內存就不能及時釋放回收,因此利用finally進行一些善后工作

package com.jyroy.util;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBCUtil {
    /*
     釋放資源
     */
    
    public static void release(Connection connection, Statement st, ResultSet rs) {
        closeConn(connection);
        closeRs(rs);
        closeSt(st);
    }
    
    private static void closeRs(ResultSet rs) {
        try {
            if(rs!=null) {
                rs.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            rs = null;
        }
    }
    
    private static void closeSt(Statement st) {
        try {
            if(st!=null) {
                st.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            st = null;
        }
    }
    
    private static void closeConn(Connection connection) {
        try {
            if(connection!=null) {
                connection.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            connection = null;
        }
    }
    
}

 

　　在MainTest類中進行使用

JDBCUtil.release(connection, st, rs);

 

數據庫的增刪查改

查詢

package com.jyroy.test;

import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.jyroy.DBUtil.DBUtil;
import com.jyroy.util.JDBCUtil;

import java.sql.Connection;
import java.sql.Driver;

public class MainTest {

    public static void main(String[] args) {
        
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        
        try {
            //1.獲取連接對象
            conn = DBUtil.getConnection();
            
            //2.根據連接對象，得到statement
            st = conn.createStatement();
            
            //3.執行查詢
            String sql = "select * from stu";
            rs = st.executeQuery(sql);
            
            //4.遍歷輸出結果
            while(rs.next()) {
                String name = rs.getString("name");
                int age = rs.getInt("age");
                
                System.out.println(name + " " + age);
            }
            
        } catch (SQLException e) {
            // TODO 自動生成的 catch 塊
            e.printStackTrace();
        }finally {
            JDBCUtil.release(conn, st, rs);
        }
    }
}

插入

@Test
    public void testInsert() {
        Connection conn = null;
        Statement st = null;
        
        try {
            //1.獲取連接對象
            conn = DBUtil.getConnection();
            
            //2.根據連接對象，得到statement
            st = conn.createStatement();
            
            //3.執行插入
            String sql = "insert into stu values(null, 'xiaoming', 12)";
            
            int result = st.executeUpdate(sql);
            
            //result表示影響的行數，大於0表示添加成功，否則失敗
            if(result > 0) {
                System.out.println("添加成功");
            }
            else {
                System.out.println("添加失敗");
            }
            
        } catch (SQLException e) {
            // TODO 自動生成的 catch 塊
            e.printStackTrace();
        }finally {
            JDBCUtil.release(conn, st);
        }
    }

刪除

@Test
    public void testDelete() {
        Connection conn = null;
        Statement st = null;
        
        try {
            //1.獲取連接對象
            conn = DBUtil.getConnection();
            
            //2.根據連接對象，得到statement
            st = conn.createStatement();
            
            //3.執行刪除
            String sql = "delete from stu where name = 'xiaoming'";
            
            int result = st.executeUpdate(sql);
            
            //result表示影響的行數，大於0表示添加成功，否則失敗
            if(result > 0) {
                System.out.println("刪除成功");
            }
            else {
                System.out.println("刪除失敗");
            }
            
        } catch (SQLException e) {
            // TODO 自動生成的 catch 塊
            e.printStackTrace();
        }finally {
            JDBCUtil.release(conn, st);
        }
    }

更新

@Test
    public void testUpdate() {
        Connection conn = null;
        Statement st = null;
        
        try {
            //1.獲取連接對象
            conn = DBUtil.getConnection();
            
            //2.根據連接對象，得到statement
            st = conn.createStatement();
            
            //3.執行更新
            String sql = "update stu set age = 11 where name = 'zhangsan'";
            
            int result = st.executeUpdate(sql);
            
            //result表示影響的行數，大於0表示添加成功，否則失敗
            if(result > 0) {
                System.out.println("更新成功");
            }
            else {
                System.out.println("更新失敗");
            }
            
        } catch (SQLException e) {
            // TODO 自動生成的 catch 塊
            e.printStackTrace();
        }finally {
            JDBCUtil.release(conn, st);
        }
    }