java資料庫開發之JDBC基礎使用方法及例項詳解
1.什麼是JDBC
JDBC是一種用於執行SQL語句的Java API,可以為多種關係資料庫提供統一訪問,它由一組用Java語言編寫的類和介面組成。JDBC提供了一種基準,據此可以構建更高階的工具和介面,使資料庫開發人員能夠編寫資料庫應用程式
JDBC 資料庫訪問規範
應用程式 <-> JDBC <-> MySQL驅動 <-> MySQL
<-> Oracle驅動 <-> Oracle
匯入jar包
載入驅動 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 配置引數 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 驅動 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); // 關閉連結 conn.close(); } }
所有的java.sql.Driver實現類,都提供了static程式碼塊,
塊內程式碼把自己註冊到DriverManager中
jdbc4.0之後 每個驅動jar包中,在META-INF/services目錄下提供了一個java.sql.Driver檔案
內容就是該介面的實現類名稱
2.JDBC完成增、刪、改、查
1、增、刪、改
// 傳送DML,DDL int Statement.executeUpdate(String sql);
程式碼示例
// 註冊 JDBC 驅動 Class.forName(JDBC_DRIVER); // 開啟連結 Connection conn = DriverManager.getConnection(DB_URL,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); // 關閉連結 conn.close();
2、查詢
ResultSet executeQuery(String querySql); boolean ResultSet.next(); // 獲取列資料 ResultSet.getString() ResultSet.getObject() ResultSet.getInt() ResultSet.getDouble()
行游標
beforeFirst <- 預設游標位置
first
last
AfterLast
// 開啟連結 Connection conn = DriverManager.getConnection(DB_URL,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); } // 關閉資源 ret.close(); statement.close(); conn.close();
3.JDBC之程式碼規範化
// 定義 try{ // 例項化 } finally{ // 關閉資源 }
4.結果集游標與元資料
JBDC主要的類
DriverManager Connection conn = DriverManager.getConnection(DB_URL,PASSWORD); Statement statement = conn.createStatement(); int executeUpdate(String sql) // 執行增、刪、改 ResultSet executeQuery(String sql) // 執行查詢 boolean execute(String sql) // 執行增、刪、改、查
ResultSet滾動結果集
一個二維表格,內部維護了一個行游標(遊標)
next() // 最常用
beforeFirst()
afterLast()
first()
last()
getRow()
absolute()
relative()
isBeforeFirst()
isAfterLast()
isFirst()
isLast()
元資料
// 元資料 ResultSetMetaData ResultSet.getMetaData() // 獲取結果集列數 int ResultSetMetaData.getColumnCount() // 獲取指定列的列名 String ResultSetMetaData.getColumnName(int colIndex)
5.結果集的特性(是否可滾動、是否敏感、是否可更新)
確定結果集特性
1、是否可滾動
2、是否敏感
3、是否可更新
// 不滾動,不敏感,不可更新 Statement createStatement() // 滾動支援 Statement createStatement(int resultSetType,int resultSetConcurrency) resultSetType: ResultSet.TYPE_FORWARD_ONLY // 不滾動 ResultSet.TYPE_SCROLL_INSENSITIVE // 滾動,不隨資料庫變化而變化 ResultSet.TYPE_SCROLL_SENSITIVE // 滾動,不隨資料庫變化而變化 resultSetConcurrency // 是否通過修改結果集二反向影響資料庫 ResultSet.CONCUR_READ_ONLY // 結果集只讀 ResultSet.CONCUR_UPDATABLE // 結果集可更新
6.PreparedStatement的用法
PreparedStatement是Statement子介面
1、防止SQL注入攻擊
2、提高程式碼可讀性,可維護性
3、提高效率
// 開啟連結 Connection conn = DriverManager.getConnection(DB_URL,PASSWORD); // 使用預處理查詢, 使用?佔位 String sql = "select * from student where sid = ?"; PreparedStatement statement = conn.prepareStatement(sql); // 為引數賦值 statement.setInt(1,1); // 獲取資料 ResultSet ret = statement.executeQuery(); while (ret.next()){ String name = ret.getString("sname"); System.out.println(name); } // 關閉資源 ret.close(); statement.close(); conn.close();
7.預處理的原理
伺服器工作:
(1)校驗:sql語句的語法
(2)編譯:為一個與函式相似的東西
(3)執行:呼叫函式
PreparedStatement
(1)先將sql發給資料庫,資料庫先進行校驗
(2)執行的時候只發送引數
8.mysql的預編譯功能預設是關閉的
prepare myfun from 'select * from student where sid = ?' set @uid=1 execute myfun using @uid
設定連線引數:
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; // 靜態程式碼塊只執行一次 static { // 初始化資料庫配置引數 try { InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream(dbconfig); prop = new Properties(); prop.load(in); } catch (IOException e) { throw new RuntimeException(e); } // 載入驅動 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
寫一個類,把訪問資料庫的程式碼封裝起來
DAO在資料庫與業務邏輯(service)之間
實體域,即操作的物件
DAO模式步驟
(1)提供一個DAO介面
(2)提供一個DAO介面的實現類
(3)在編寫一個DAO工廠,Service通過工廠來獲取DAO實現
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; // 靜態程式碼塊只執行一次 static { // 初始化資料庫配置引數 try { InputStream in = DaoFactory.class.getClassLoader().getResourceAsStream(dbconfig); prop = new Properties(); prop.load(in); } catch (IOException e) { throw new RuntimeException(e); } } /** * 返回一個UserDao的具體實現類 */ public static UserDao getUserDao() { String daoClassName = prop.getProperty("UserDaoClassName"); // 通過反射建立實現類的物件 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 物件關係對映 * @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()); // 執行 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); // 執行 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; // 靜態程式碼塊只執行一次 static { // 初始化資料庫配置引數 try { InputStream in = DaoFactory.class.getClassLoader().getResourceAsStream(dbconfig); prop = new Properties(); prop.load(in); } catch (IOException e) { throw new RuntimeException(e); } } /** * 返回一個UserDao的具體實現類 */ public static UserDao getUserDao() { String daoClassName = prop.getProperty("UserDaoClassName"); // 通過反射建立實現類的物件 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包下的時間型別之間的轉換
Data -> java.sql.Data
Time -> java.sql.Time
Timestamp -> java.sql.Timestamp
領域物件中所有屬性不能出現java.sql包內容
繼承關係
java.util.Date
-java.sql.Date
父類轉子類: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);
子類轉父類:sql.Date、Time、Timestamp -> util.Data
java.util.Date UtilDate = new java.sql.Date(System.currentTimeMillis());
13.大資料
可以將檔案存入MySQL
my.ini配置
max_allowed_packet=10485760
14.批處理
批處理只針對更新(增,刪,改)
一次向伺服器傳送多條sql語句
開啟批處理引數
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(); // 提交資料 long end = System.currentTimeMillis(); System.out.println(end - start); // 107 } }
結束語
本文主要講了java資料庫開發中JDBC基礎使用方法及例項
更多關於java資料庫開發之JDBC基礎使用方法及例項請檢視下面的相關連結