認識 JDBC

JDBC (Java DataBase Connectivity) 是 Java 數據庫連接技術的簡稱，用于連接常用數據庫。

Sun 公司提供了 JDBC API ，供程序員調用接口和類，集成在 java.sql 和 javax.sql 包中。

Sun 公司還提供了 DriverManager 類用來管理各種不同的JDBC驅動。

不同數據庫廠商提供各自的JDBC驅動，所以我們想要連接數據庫除了要了解 JDBC API 還需要下載各數據庫廠商的驅動 jar 包。

JDBC API

JDBC API主要用于與數據庫建立連接、執行SQL語句、處理結果，其中核心類和接口如下：

• DriverManager：依據數據庫的不同，管理JDBC驅動
• Connection：負責連接數據庫并擔任傳送數據的任務
• Statement：由 Connection 產生、負責執行SQL語句
• ResultSet:負責保存 Statement 執行后所產生的查詢結果

JDBC 編碼模板

1、與數據庫建立連接并獲取連接

Connection connection=DriverManager.getConnection(URL,數據庫用戶名,密碼);

2、發送SQL語句，得到執行結果

Statement stmt=connection.createStatement(); ResultSet rs=stmt.executeQuery(SQL語句);

3、處理返回結果

while(rs.next()){int a=rs.getInt("a");String b=rs.getString("b");Date d=rs.getDate("d");…… }

4、釋放資源

rs.close(); stmt.close(); connection.close();

使用 JDBC 連接到 MySQL 數據庫

本例適合已經會使用 MySQL 數據庫的同學，首先我們下載 JDBC 的驅動 jar 包。這個網址提供了 MySQL 各種語言連接數據庫的驅動 https://www.mysql.com/products/connector/,MySQL Connector / J 8.0與從MySQL 5.5開始的所有MySQL版本兼容。
8.0下載地址
下載完成后解壓，后將jar添加依賴到項目中。

連接到MySQL數據庫

import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException;public class DemoConnectMySQL {public static void main(String[] args) {//連接MySQL的URLString url="jdbc:mysql://localhost:3306/mysql?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";//MySQL數據庫用戶名String user="root";//MySQL數據庫的密碼String password="1234";Connection connection=null;try {connection=DriverManager.getConnection(url, user, password);System.out.println("連接成功");} catch (SQLException e) {e.printStackTrace();}finally {try {connection.close();System.out.println("連接關閉");} catch (SQLException e) {e.printStackTrace();}}} }

url指定數據庫的連接字符串，格式為：
jdbc:數據庫://ip或域名:端口號?參數&參數……
這里的參數 useUnicode=true 使用Unicode字符，characterEncoding=utf8 設置編碼防止中文亂碼，serverTimezone=UTC 設置時區，useSSL=false 不使用SSL

jdbc4.0不需要加載驅動

PreparedStatement 增刪改

PreparedStatement 繼承了 Statement 接口，表示預編譯的 SQL 語句對象，SQL 語句被預編譯并存儲在 PreparedStatement 對象中，可以使用此對象多次高效地執行該語句。(還避免了 SQL 注入的隱患)

先準備好數據庫 books

表 book

字段類型屬性

id	整數	主鍵,自增
bName	字符串	非空
price	小數	非空

腳本也準備好了

#創建數據庫 CREATE DATABASE books; USE books; #創建表 CREATE TABLE book ( id INT primary key auto_increment, bName VARCHAR ( 255 ) NOT NULL, price FLOAT NOT NULL );

PreparedStatement添加數據

import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException;public class TestInsert {public static void main(String[] args) {Connection connection=null;PreparedStatement pstmt=null;String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";String user="root";String password="1234";try {connection=DriverManager.getConnection(url,user,password);//sql語句String sql="insert into book(bName,price) values (?,?)";pstmt=connection.prepareStatement(sql);//傳入參數pstmt.setString(1, "《java入門到改行》");pstmt.setFloat(2, 11.11f);int result=pstmt.executeUpdate();System.out.println("受影響行數："+result);} catch (SQLException e) {e.printStackTrace();}finally {if (pstmt!=null) {try {pstmt.close();} catch (SQLException e) {e.printStackTrace();}}if (connection!=null) {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}} }

說明：

1、連接字符串要修改數據庫名字為 books

String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";

2、插入數據庫的數據不能拼接而是要用 ? 代替

String sql="insert into book(bName,price) values (?,?)";

3、? 代替的參數要通過 set類型(位置,值) 傳入

pstmt.setString(1, "《java入門到改行》"); pstmt.setFloat(2, 11.11f);

pstmt.setXxx()的位置從 1 開始！

4、增刪改的SQL語句都使用這個方法，返回受影響行數

int result=pstmt.executeUpdate();

刪除數據

import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException;public class TestDelete {public static void main(String[] args) {Connection connection=null;PreparedStatement pstmt=null;String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";String user="root";String password="1234";try {connection=DriverManager.getConnection(url,user,password);//sql語句String sql="delete from book where id=?";pstmt=connection.prepareStatement(sql);//傳入參數 要刪除idpstmt.setInt(1, 1);int result=pstmt.executeUpdate();System.out.println("受影響行數："+result);} catch (SQLException e) {e.printStackTrace();}finally {if (pstmt!=null) {try {pstmt.close();} catch (SQLException e) {e.printStackTrace();}}if (connection!=null) {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}} }

修改數據

import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException;public class TestUpdate {public static void main(String[] args) {Connection connection=null;PreparedStatement pstmt=null;String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";String user="root";String password="1234";try {connection=DriverManager.getConnection(url,user,password);//sql語句String sql="update book set bName=?,price=? where id=?";pstmt=connection.prepareStatement(sql);//傳入參數 要刪除idpstmt.setString(1, "《MySQL從刪庫到跑路》");pstmt.setFloat(2, 16.66f);pstmt.setInt(3, 2);int result=pstmt.executeUpdate();System.out.println("受影響行數："+result);} catch (SQLException e) {e.printStackTrace();}finally {if (pstmt!=null) {try {pstmt.close();} catch (SQLException e) {e.printStackTrace();}}if (connection!=null) {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}} }

增、刪、改操作的寫法都一樣，都調用 executeUpdate() 方法返回一個受影響行數，唯一不同的 SQL語句。

PreparedStatement 查詢數據

查詢數據需要用到 ResultSet 類保存返回的結果集，我們獲取數據要操作 ResultSet 獲取。

ResultSet 常用方法

方法名說明

boolean next()	將游標從當前位置向下移動一行
void close()	關閉 ResultSet 對象
int getInt(int colIndex)	以int形式獲取結果集當前行指定列號值
int getInt(String colLabel)	以int形式獲取結果集當前行指定列名值
float getFloat(String colLabel)	以float形式獲取結果集當前行指定列名值
String getString(String colLabel)	以 String 形式獲取結果集當前行指定列名值

import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;public class TestSelect {public static void main(String[] args) {Connection connection=null;PreparedStatement pstmt=null;ResultSet rs=null;String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";String user="root";String password="1234";try {connection=DriverManager.getConnection(url,user,password);//sql語句String sql="select bName,price,id from book where id=?";pstmt=connection.prepareStatement(sql);//傳入查詢條件pstmt.setInt(1, 2);rs=pstmt.executeQuery();while(rs.next()) {//通過列名獲取列的值int id=rs.getInt("id");//通過位置獲取列的值String bName=rs.getString(1);float price=rs.getFloat("price");System.out.println(id+" "+bName+" "+price);}} catch (SQLException e) {e.printStackTrace();}finally {if(rs!=null) {try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if (pstmt!=null) {try {pstmt.close();} catch (SQLException e) {e.printStackTrace();}}if (connection!=null) {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}} }

關閉對象時注意關閉的順序，后使用的先關閉：rs.close()->pstmt.close()->connection.close()

ResultSet 對象存在一個光標，光標所指行為當前行。想要獲取列的數據需要先指向一行，所以要先指定 next() 方法用于指向一行，如果沒有數據next()方法返回false，有數據返回true。

使用 getXxx() 方法獲取列的數據時建議寫列名，這樣好識別

轉載于:https://www.cnblogs.com/AIThink/p/9940542.html

總結

以上是生活随笔為你收集整理的Java入门系列-26-JDBC的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。