認識 JDBC

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

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

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

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

JDBC API

JDBC API主要用于與數(shù)據(jù)庫建立連接、執(zhí)行SQL語句、處理結(jié)果，其中核心類和接口如下：

• DriverManager：依據(jù)數(shù)據(jù)庫的不同，管理JDBC驅(qū)動
• Connection：負責(zé)連接數(shù)據(jù)庫并擔(dān)任傳送數(shù)據(jù)的任務(wù)
• Statement：由 Connection 產(chǎn)生、負責(zé)執(zhí)行SQL語句
• ResultSet:負責(zé)保存 Statement 執(zhí)行后所產(chǎn)生的查詢結(jié)果

JDBC 編碼模板

1、與數(shù)據(jù)庫建立連接并獲取連接

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

2、發(fā)送SQL語句，得到執(zhí)行結(jié)果

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

3、處理返回結(jié)果

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 數(shù)據(jù)庫

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

連接到MySQL數(shù)據(jù)庫

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數(shù)據(jù)庫用戶名String user="root";//MySQL數(shù)據(jù)庫的密碼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("連接關(guān)閉");} catch (SQLException e) {e.printStackTrace();}}} }

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

jdbc4.0不需要加載驅(qū)動

PreparedStatement 增刪改

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

先準備好數(shù)據(jù)庫 books

表 book

字段類型屬性

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

腳本也準備好了

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

PreparedStatement添加數(shù)據(jù)

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);//傳入?yún)?shù)pstmt.setString(1, "《java入門到改行》");pstmt.setFloat(2, 11.11f);int result=pstmt.executeUpdate();System.out.println("受影響行數(shù)："+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、連接字符串要修改數(shù)據(jù)庫名字為 books

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

2、插入數(shù)據(jù)庫的數(shù)據(jù)不能拼接而是要用 ? 代替

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

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

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

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

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

int result=pstmt.executeUpdate();

刪除數(shù)據(jù)

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);//傳入?yún)?shù) 要刪除idpstmt.setInt(1, 1);int result=pstmt.executeUpdate();System.out.println("受影響行數(shù)："+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();}}}} }

修改數(shù)據(jù)

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);//傳入?yún)?shù) 要刪除idpstmt.setString(1, "《MySQL從刪庫到跑路》");pstmt.setFloat(2, 16.66f);pstmt.setInt(3, 2);int result=pstmt.executeUpdate();System.out.println("受影響行數(shù)："+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();}}}} }

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

PreparedStatement 查詢數(shù)據(jù)

查詢數(shù)據(jù)需要用到 ResultSet 類保存返回的結(jié)果集，我們獲取數(shù)據(jù)要操作 ResultSet 獲取。

ResultSet 常用方法

方法名說明

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

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();}}}} }

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

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

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

轉(zhuǎn)載于:https://www.cnblogs.com/AIThink/p/9940542.html

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。