java數(shù)據(jù)庫開發(fā)之JDBC基礎(chǔ)使用方法及實例詳解
1.什么是JDBC
JDBC是一種用于執(zhí)行SQL語句的Java API,可以為多種關(guān)系數(shù)據(jù)庫提供統(tǒng)一訪問,它由一組用Java語言編寫的類和接口組成。JDBC提供了一種基準,據(jù)此可以構(gòu)建更高級的工具和接口,使數(shù)據(jù)庫開發(fā)人員能夠編寫數(shù)據(jù)庫應用程序
JDBC 數(shù)據(jù)庫訪問規(guī)范
應用程序 <-> JDBC <-> MySQL驅(qū)動 <-> MySQL
<-> Oracle驅(qū)動 <-> Oracle
導入jar包
加載驅(qū)動 Class.forName(‘類名')
給出url、username、password
使用DriverManager類得到Connection類
maven導入依賴
<dependencies> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.18</version> </dependency> </dependencies>
連接示例
import java.sql.Connection; import java.sql.DriverManager; class Demo { // MySQL >= 8.0 配置參數(shù) private static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver"; private static final String DB_URL = "jdbc:mysql://localhost:3306/data"; private static final String USER = "root"; private static final String PASSWORD = "123456"; public static void main(String[] args) throws Exception { // 注冊 JDBC 驅(qū)動 Class.forName(JDBC_DRIVER); // 等效于 // com.mysql.cj.jdbc.Driver driver = new com.mysql.cj.jdbc.Driver(); // DriverManager.registerDriver(driver); // 打開鏈接 Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD); // 關(guān)閉鏈接 conn.close(); } }
所有的java.sql.Driver實現(xiàn)類,都提供了static代碼塊,
塊內(nèi)代碼把自己注冊到DriverManager中
jdbc4.0之后 每個驅(qū)動jar包中,在META-INF/services目錄下提供了一個java.sql.Driver文件
內(nèi)容就是該接口的實現(xiàn)類名稱
2.JDBC完成增、刪、改、查
1、增、刪、改
// 發(fā)送DML, DDL int Statement.executeUpdate(String sql);
代碼示例
// 注冊 JDBC 驅(qū)動 Class.forName(JDBC_DRIVER); // 打開鏈接 Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD); Statement statement = conn.createStatement(); // 增刪改 // String sql = "insert into student(sname) values('陸小鳳')"; // String sql = "update student set sname='花無缺' where sid=4"; String sql = "delete from student where sid=4"; int ret = statement.executeUpdate(sql); System.out.println(ret); // 關(guān)閉鏈接 conn.close();
2、查詢
ResultSet executeQuery(String querySql); boolean ResultSet.next(); // 獲取列數(shù)據(jù) ResultSet.getString() ResultSet.getObject() ResultSet.getInt() ResultSet.getDouble()
行光標
beforeFirst <- 默認光標位置
first
last
AfterLast
// 打開鏈接 Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD); Statement statement = conn.createStatement(); // 查詢 String sql = "select * from student"; ResultSet ret = statement.executeQuery(sql); while (ret.next()){ // 通過列序號獲取 int uid = ret.getInt(1); // 通過列名稱獲取 String name = ret.getString("sname"); System.out.println(uid + ", " + name); } // 關(guān)閉資源 ret.close(); statement.close(); conn.close();
3.JDBC之代碼規(guī)范化
// 定義 try{ // 實例化 } finally{ // 關(guān)閉資源 }
4.結(jié)果集光標與元數(shù)據(jù)
JBDC主要的類
DriverManager Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD); Statement statement = conn.createStatement(); int executeUpdate(String sql) // 執(zhí)行增、刪、改 ResultSet executeQuery(String sql) // 執(zhí)行查詢 boolean execute(String sql) // 執(zhí)行增、刪、改、查
ResultSet滾動結(jié)果集
一個二維表格,內(nèi)部維護了一個行光標(游標)
next() // 最常用
beforeFirst()
afterLast()
first()
last()
getRow()
absolute()
relative()
isBeforeFirst()
isAfterLast()
isFirst()
isLast()
元數(shù)據(jù)
// 元數(shù)據(jù) ResultSetMetaData ResultSet.getMetaData() // 獲取結(jié)果集列數(shù) int ResultSetMetaData.getColumnCount() // 獲取指定列的列名 String ResultSetMetaData.getColumnName(int colIndex)
5.結(jié)果集的特性(是否可滾動、是否敏感、是否可更新)
確定結(jié)果集特性
1、是否可滾動
2、是否敏感
3、是否可更新
// 不滾動, 不敏感,不可更新 Statement createStatement() // 滾動支持 Statement createStatement(int resultSetType, int resultSetConcurrency) resultSetType: ResultSet.TYPE_FORWARD_ONLY // 不滾動 ResultSet.TYPE_SCROLL_INSENSITIVE // 滾動,不隨數(shù)據(jù)庫變化而變化 ResultSet.TYPE_SCROLL_SENSITIVE // 滾動,不隨數(shù)據(jù)庫變化而變化 resultSetConcurrency // 是否通過修改結(jié)果集二反向影響數(shù)據(jù)庫 ResultSet.CONCUR_READ_ONLY // 結(jié)果集只讀 ResultSet.CONCUR_UPDATABLE // 結(jié)果集可更新
6.PreparedStatement的用法
PreparedStatement是Statement子接口
1、防止SQL注入攻擊
2、提高代碼可讀性,可維護性
3、提高效率
// 打開鏈接 Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD); // 使用預處理查詢, 使用?占位 String sql = "select * from student where sid = ?"; PreparedStatement statement = conn.prepareStatement(sql); // 為參數(shù)賦值 statement.setInt(1, 1); // 獲取數(shù)據(jù) ResultSet ret = statement.executeQuery(); while (ret.next()){ String name = ret.getString("sname"); System.out.println(name); } // 關(guān)閉資源 ret.close(); statement.close(); conn.close();
7.預處理的原理
服務器工作:
(1)校驗:sql語句的語法
(2)編譯:為一個與函數(shù)相似的東西
(3)執(zhí)行:調(diào)用函數(shù)
PreparedStatement
(1)先將sql發(fā)給數(shù)據(jù)庫,數(shù)據(jù)庫先進行校驗
(2)執(zhí)行的時候只發(fā)送參數(shù)
8.mysql的預編譯功能默認是關(guān)閉的
prepare myfun from 'select * from student where sid = ?' set @uid=1 execute myfun using @uid
設置連接參數(shù):
useServerPrepStmts=true
cachePrepStmts=true
DB_URL = "jdbc:mysql://localhost:3306/data?useServerPrepStmts=true&cachePrepStmts=true";
9.JdbcUtils1.0小工具
JdbcUtils.java
package util; import java.io.IOException; import java.io.InputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.Properties; public class JdbcUtils { // 配置文件路徑 private static String dbconfig = "dbconfig.properties"; private static Properties prop = null; // 靜態(tài)代碼塊只執(zhí)行一次 static { // 初始化數(shù)據(jù)庫配置參數(shù) try { InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream(dbconfig); prop = new Properties(); prop.load(in); } catch (IOException e) { throw new RuntimeException(e); } // 加載驅(qū)動 try{ Class.forName(prop.getProperty("driver")); } catch (ClassNotFoundException e) { throw new RuntimeException(e); } } public static Connection getConnection() throws SQLException { return DriverManager.getConnection( prop.getProperty("url"), prop.getProperty("username"), prop.getProperty("password") ); } public static void main(String[] args) throws SQLException { Connection conn = getConnection(); System.out.println(conn); } }
dbconfig.properties
driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/data
username=root
password=123456
10.面向接口編程
DAO模式
data access object
寫一個類,把訪問數(shù)據(jù)庫的代碼封裝起來
DAO在數(shù)據(jù)庫與業(yè)務邏輯(service)之間
實體域,即操作的對象
DAO模式步驟
(1)提供一個DAO接口
(2)提供一個DAO接口的實現(xiàn)類
(3)在編寫一個DAO工廠,Service通過工廠來獲取DAO實現(xiàn)
daoconfig.properties
UserDaoClassName=UserDaoImpl
UserDao.java
public interface UserDao { }
UserDaoImpl.java
public class UserDaoImpl implements UserDao{ }
DaoFactory.java
import java.io.IOException; import java.io.InputStream; import java.util.Properties; public class DaoFactory { // 配置文件路徑 private static String dbconfig = "daoconfig.properties"; private static Properties prop = null; // 靜態(tài)代碼塊只執(zhí)行一次 static { // 初始化數(shù)據(jù)庫配置參數(shù) try { InputStream in = DaoFactory.class.getClassLoader().getResourceAsStream(dbconfig); prop = new Properties(); prop.load(in); } catch (IOException e) { throw new RuntimeException(e); } } /** * 返回一個UserDao的具體實現(xiàn)類 */ public static UserDao getUserDao() { String daoClassName = prop.getProperty("UserDaoClassName"); // 通過反射創(chuàng)建實現(xiàn)類的對象 try { Class Clazz = Class.forName(daoClassName); return (UserDao) Clazz.newInstance(); } catch (Exception e) { throw new RuntimeException(e); } } }
11.修改案例,其中dao層為jdbc
User.java
public class User { private String username; private int age; public String getUsername() { return username; } public int getAge() { return age; } public void setUsername(String username) { this.username = username; } public void setAge(int age) { this.age = age; } @Override public String toString() { return "User{" + "username='" + username + '\'' + ", age=" + age + '}'; } }
daoconfig.properties
UserDaoClassName=UserDaoImpl
UserDao.java
public interface UserDao { public void addUser(User user); public User getUserByUsername(String username); }
UserDaoImpl.java
import util.JdbcUtils; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; /** * create table user( * id int primary key auto_increment, * username varchar(50), * age int * ) */ public class UserDaoImpl implements UserDao { /** * ORM 對象關(guān)系映射 * @param user */ @Override public void addUser(User user) { Connection conn = null; PreparedStatement statement = null; try { // 得到連接 conn = JdbcUtils.getConnection(); String sql = "insert into user(username, age) values(?, ?)"; // 準備模板 statement = conn.prepareStatement(sql); // 賦值 statement.setString(1, user.getUsername()); statement.setInt(2, user.getAge()); // 執(zhí)行 statement.executeUpdate(); } catch (Exception e) { throw new RuntimeException(e); } finally { try { if (statement != null) { statement.close(); } if (conn != null) { conn.close(); } } catch (SQLException e) { } } } @Override public User getUserByUsername(String username) { Connection conn = null; PreparedStatement statement = null; try { // 得到連接 conn = JdbcUtils.getConnection(); String sql = "select * from user where username = ? limit 1"; // 準備模板 statement = conn.prepareStatement(sql); // 賦值 statement.setString(1, username); // 執(zhí)行 ResultSet resultSet = statement.executeQuery(); if(resultSet.next()){ User user = new User(); user.setUsername(resultSet.getString("username")); user.setAge(resultSet.getInt("age")); return user; } else{ return null; } } catch (Exception e) { throw new RuntimeException(e); } finally { try { if (statement != null) { statement.close(); } if (conn != null) { conn.close(); } } catch (SQLException e) { } } } }
DaoFactory.java
import java.io.IOException; import java.io.InputStream; import java.util.Properties; public class DaoFactory { // 配置文件路徑 private static String dbconfig = "daoconfig.properties"; private static Properties prop = null; // 靜態(tài)代碼塊只執(zhí)行一次 static { // 初始化數(shù)據(jù)庫配置參數(shù) try { InputStream in = DaoFactory.class.getClassLoader().getResourceAsStream(dbconfig); prop = new Properties(); prop.load(in); } catch (IOException e) { throw new RuntimeException(e); } } /** * 返回一個UserDao的具體實現(xiàn)類 */ public static UserDao getUserDao() { String daoClassName = prop.getProperty("UserDaoClassName"); // 通過反射創(chuàng)建實現(xiàn)類的對象 try { Class Clazz = Class.forName(daoClassName); return (UserDao) Clazz.newInstance(); } catch (Exception e) { throw new RuntimeException(e); } } }
Service.java
// 添加測試 UserDao userDao = DaoFactory.getUserDao(); User user = new User(); user.setUsername("小明"); user.setAge(23); userDao.addUser(user); // 查詢測試 User user1 = userDao.getUserByUsername("小明"); System.out.println(user1);
12.util包下的Date與sql包下的時間類型之間的轉(zhuǎn)換
Data -> java.sql.Data
Time -> java.sql.Time
Timestamp -> java.sql.Timestamp
領(lǐng)域?qū)ο笾兴袑傩圆荒艹霈F(xiàn)java.sql包內(nèi)容
繼承關(guān)系
java.util.Date
-java.sql.Date
父類轉(zhuǎn)子類:util.Data -> sql.Date、Time、Timestamp
java.util.Date UtilDate = new java.util.Date(); long longDate = UtilDate.getTime(); java.sql.Date sqlData = new java.sql.Date(longDate);
子類轉(zhuǎn)父類:sql.Date、Time、Timestamp -> util.Data
java.util.Date UtilDate = new java.sql.Date(System.currentTimeMillis());
13.大數(shù)據(jù)
可以將文件存入MySQL
my.ini配置
max_allowed_packet=10485760
14.批處理
批處理只針對更新(增,刪,改)
一次向服務器發(fā)送多條sql語句
開啟批處理參數(shù)
rewriteBatchedStatements=true
dbconfig.properties
driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/data?rewriteBatchedStatements=true
username=root
password=123456
import util.JdbcUtils; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; class Demo { public static void main(String[] args) throws SQLException { Connection conn = JdbcUtils.getConnection(); String sql = "insert into user(username)values(?)"; PreparedStatement statement = conn.prepareStatement(sql); for(int i=0; i<10000; i++){ statement.setString(1, "name" + i); statement.addBatch(); // 裝箱 } long start = System.currentTimeMillis(); statement.executeBatch(); // 提交數(shù)據(jù) long end = System.currentTimeMillis(); System.out.println(end - start); // 107 } }
結(jié)束語
本文主要講了java數(shù)據(jù)庫開發(fā)中JDBC基礎(chǔ)使用方法及實例
更多關(guān)于java數(shù)據(jù)庫開發(fā)之JDBC基礎(chǔ)使用方法及實例請查看下面的相關(guān)鏈接
- Java基礎(chǔ)之JDBC的數(shù)據(jù)庫連接與基本操作
- java使用JDBC連接數(shù)據(jù)庫的五種方式(IDEA版)
- Java連接 JDBC基礎(chǔ)知識(操作數(shù)據(jù)庫:增刪改查)
- Java 數(shù)據(jù)庫連接(JDBC)的相關(guān)總結(jié)
- Java 如何使用JDBC連接數(shù)據(jù)庫
- 詳解Java數(shù)據(jù)庫連接JDBC基礎(chǔ)知識(操作數(shù)據(jù)庫:增刪改查)
- Java如果通過jdbc操作連接oracle數(shù)據(jù)庫
- Java連接數(shù)據(jù)庫JDBC技術(shù)之prepareStatement的詳細介紹
- Java之jdbc連接mysql數(shù)據(jù)庫的方法步驟詳解
- java數(shù)據(jù)庫開發(fā)之JDBC的完整封裝兼容多種數(shù)據(jù)庫
- Java基礎(chǔ)開發(fā)之JDBC操作數(shù)據(jù)庫增刪改查,分頁查詢實例詳解
- Java JDBC連接數(shù)據(jù)庫常見操作總結(jié)
- Java使用JDBC連接postgresql數(shù)據(jù)庫示例
- Java實現(xiàn)JDBC連接數(shù)據(jù)庫簡單案例
- java使用jdbc連接數(shù)據(jù)庫簡單實例
- Java使用jdbc連接MySQL數(shù)據(jù)庫實例分析
- Java基于JDBC連接數(shù)據(jù)庫及顯示數(shù)據(jù)操作示例
- 詳細說明關(guān)于Java的數(shù)據(jù)庫連接(JDBC)
相關(guān)文章
基于Java反射技術(shù)實現(xiàn)簡單IOC容器
這篇文章主要介紹了基于Java反射技術(shù)實現(xiàn)簡單IOC容器,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-07-07基于Java代碼實現(xiàn)數(shù)字在數(shù)組中出現(xiàn)次數(shù)超過一半
這篇文章主要介紹了基于Java代碼實現(xiàn)數(shù)字在數(shù)組中出現(xiàn)次數(shù)超過一半的相關(guān)資料,需要的朋友可以參考下2016-02-02SpringBoot配置文件方式,在線yml文件轉(zhuǎn)properties
這篇文章主要介紹了SpringBoot配置文件方式,在線yml文件轉(zhuǎn)properties,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-07-07springboot程序啟動慢-未配置hostname的解決
這篇文章主要介紹了springboot程序啟動慢-未配置hostname的解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-08-08