Java 之 JDBC
1、認識JDBC
JDBC是用於在Java語言編程中與數據庫鏈接的API.JDBC是一個規範，它提供了一整套接口，容許以一種可移植的訪問底層數據庫API。使用JDBC驅動程序來訪問數據庫，並用於存儲數據到數據庫中.html
解釋上面兩幅圖：java
java應用程序經過JDBC API首先鏈接到JDBC Driver，這些JDBC驅動器都是由各大數據庫廠家針對JDBC提供的，咱們能夠在網上下載jar包來使用，而後經過JDBC驅動器就能鏈接到咱們的數據庫了。mysql
第一步 添加驅動git
1.在項目當中建立一個文件夾爲lib
2.把Mysql驅動包複製到該文件夾下
3.builder path 編譯路徑
複製代碼
第二步 鏈接到數據庫github
package con.meils.jdbc.conn;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ConnectionClass {
public static void main(String[] args) throws ClassNotFoundException, SQLException {
// TODO Auto-generated method stub
// 一、加載驅動
// 把com.mysql.jdbc.Driver這份字節碼加載進JVM
// 當一份字節碼加載進JVM的時候，就會執行字節碼文件中的靜態代碼塊
// 這裏加載該字節碼以後會實例化一個驅動器
Class.forName("com.mysql.jdbc.Driver");
// 二、鏈接
String url = "jdbc:mysql://localhost:3306/mytest";
String username = "root";
String password = "zjj19970517";
Connection connection = DriverManager.getConnection(url, username, password);
// 三、驗證鏈接
System.out.println(connection); // 若是有輸出，代表鏈接成功
}
}
複製代碼
第三步 操做數據庫建立表sql
package con.meils.jdbc.ddl;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class CreateTable {
public static void main(String[] args) throws Exception {
// TODO Auto-generated method stub
// 1\加載驅動
// 把com.mysql.jdbc.Driver這份字節碼加載進JVM
// 當一份字節碼加載進JVM的時候，就會執行字節碼文件中的靜態代碼塊
// 這裏加載該字節碼以後會實例化一個驅動器
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3306/jdbc_db";
String username = "root";
String password = "zjj19970517";
// 2\ 鏈接數據庫
Connection connection = DriverManager.getConnection(url, username, password);
// 3\建立sql語句
String sql = "create table stu (id int , name varchar(20), age int)";
// 4\執行sql語句
Statement st = connection.createStatement();
int row = st.executeUpdate(sql);
// 5\釋放
st.close();
connection.close();
}
}
複製代碼
爲何要釋放資源呢？數據庫
第四步 插入數據編程
package con.meils.jdbc.dml;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class InsertClass {
public static void main(String[] args) {
// TODO Auto-generated method stub
// ================ 插入數據 ================
Connection conn = null;
Statement st = null;
try {
// 一、加載驅動
Class.forName("com.mysql.jdbc.Driver");
// 二、建立鏈接
String url = "jdbc:mysql://localhost:3306/mytest";
String user = "root";
String password = "zjj19970517";
conn = DriverManager.getConnection(url, user, password);
// 三、建立sql語句
String sql = "insert into stu values(1, 'zjj', 20)";
st = conn.createStatement();
// 四、執行語句
int row = st.executeUpdate(sql);
System.out.println(row);
}catch (Exception e) {
e.printStackTrace();
} finally {
// 五、釋放
if(st!=null) {
try {
st.close();
}catch (Exception e) {
e.printStackTrace();
}
}
if(conn!=null) {
try {
conn.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
複製代碼
第五步 查詢操做數組
package con.meils.jdbc.dql;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class QueryClass {
public static void main(String[] args) throws SQLException, ClassNotFoundException {
// TODO Auto-generated method stub
// ================ 查詢數據 ================
// 1\加載驅動
// 把com.mysql.jdbc.Driver這份字節碼加載進JVM
// 當一份字節碼加載進JVM的時候，就會執行字節碼文件中的靜態代碼塊
// 這裏加載該字節碼以後會實例化一個驅動器
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3306/mytest";
String username = "root";
String password = "zjj19970517";
// 2\ 鏈接數據庫
Connection connection = DriverManager.getConnection(url, username, password);
// 3\建立sql語句
String sql = "select count(*) as total from stu"; // 查詢一共有幾行數據
// 4\執行sql語句
Statement st = connection.createStatement();
ResultSet rs = st.executeQuery(sql);
if(rs.next()) {
int count = rs.getInt("total");
System.out.println(count); // 1
}
// 5\釋放
st.close();
connection.close();
}
}
複製代碼
數據類型對照表：安全
上面咱們基本學會了如何與數據庫打交道，可是這樣使用存在許多的弊端，好比：每一步操做都進行一次數據庫鏈接，形成浪費，因此咱們在實際中要使用DAO思想來處理。
2、DAO設計
一、什麼是DAO
DAO（Data Access Object）數據存儲對象，介於業務邏輯層和持久層之間，實現持久化數據訪問。
不使用DAO的時候：
使用DAO的狀況：
3、ORM映射關係
4、Domain
一、認識domain
二、domain類
三、保存數據
四、獲取數據
5、DAO設計規範
案例
咱們能夠編寫一個DAO接口，定義了經常使用的數據庫操做方法，這時候咱們同時會鏈接多個數據庫，好比是mysql 和 oracle ，咱們能夠分別實現oracleDao和mysqlDao兩個類，不一樣類裏面定義不一樣的操做數據庫的代碼，實現的功能確實相同的。
因此面向接口編程是很重要的，也是一個很好的方式。
一、包命名規範
二、類命名規範
三、開發步驟
目錄以下
內容實現：
接口實現類的具體內容：
package com.meils.jdbc.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import com.meils.jdbc.dao.IStudentDao;
import com.meils.jdbc.domain.Student;
import com.meils.jdbc.utils.JdbcUtil;
/**
* 實現DAO接口的類
* @author apple
*
*/
public class StudentDaoImpl implements IStudentDao{
@Override
/**
* 存儲學生
* @param stu
*/
public void save(Student stu) {
// TODO Auto-generated method stub
Connection conn = null;
PreparedStatement ps = null;
try {
// 鏈接數據庫
conn = JdbcUtil.getConnection();
String sql = "insert into student (name, age) values (? , ?)";
// 建立預編譯
ps = conn.prepareStatement(sql);
ps.setString(1, stu.getName());
ps.setInt(2, stu.getAge());
// 執行更新
ps.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
JdbcUtil.close(conn, ps, null);
}
}
@Override
public void delete(int id) {
Connection conn = null;
PreparedStatement ps = null;
try {
// 鏈接數據庫
conn = JdbcUtil.getConnection();
String sql = "delete from student where id = ?";
// 建立預編譯
ps = conn.prepareStatement(sql);
ps.setInt(1, id);
// 執行更新
ps.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
JdbcUtil.close(conn, ps, null);
}
}
@Override
public void update(int id, Student stu) {
Connection conn = null;
PreparedStatement ps = null;
try {
conn = JdbcUtil.getConnection();
String sql = "update student set name=?, age=? where id = ? ";
ps = conn.prepareStatement(sql);
ps.setString(1, stu.getName());
ps.setInt(2, stu.getAge());
ps.setInt(3, id);
// 執行
ps.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
JdbcUtil.close(conn, ps, null);
}
}
@Override
public Student findOne(int id) {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = JdbcUtil.getConnection();
// sql語句
String sql = "select * from student where id = ?";
ps = conn.prepareStatement(sql);
ps.setInt(1, id);
// 執行
rs = ps.executeQuery();
if (rs.next()) {
// 保存數據
Student stu = new Student();
stu.setName(rs.getString("name"));
stu.setAge(rs.getInt("age"));
stu.setId(rs.getInt("id"));
return stu;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 銷燬
JdbcUtil.close(conn, ps, rs);
}
return null;
}
@Override
public List<Student> findAll() {
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try {
conn = JdbcUtil.getConnection();
st = conn.createStatement();
String sql = "select * from student ";
rs = st.executeQuery(sql);
List<Student> list = new ArrayList<Student>();
while (rs.next()) {
Student stu = new Student();
stu.setName(rs.getString("name"));
stu.setAge(rs.getInt("age"));
stu.setId(rs.getInt("id"));
list.add(stu);
}
return list;
} catch (Exception e) {
e.printStackTrace();
} finally {
JdbcUtil.close(conn, st, rs);
}
return null;
}
}
複製代碼
編寫測試類：
package com.meils.jdbc.dao.test;
import java.util.List;
import org.junit.Test;
import com.meils.jdbc.dao.IStudentDao;
import com.meils.jdbc.dao.impl.StudentDaoImpl;
import com.meils.jdbc.domain.Student;
/**
* StudentDao測試類
* @author apple
*/
public class StudentDaoTest {
public static void main(String[] args) {
// TODO Auto-generated method stub
}
@Test
public void save() {
Student stu = new Student();
stu.setName("張偉");
stu.setAge(21);
IStudentDao dao = new StudentDaoImpl();
dao.save(stu);
}
@Test
public void delete() {
IStudentDao dao = new StudentDaoImpl();
dao.delete(4);
}
@Test
public void update () {
Student stu = new Student();
stu.setName("mmmmm");
stu.setAge(16);
IStudentDao dao = new StudentDaoImpl();
dao.update(5, stu);
}
@Test
public void findOne() {
IStudentDao dao = new StudentDaoImpl();
Student stu = dao.findOne(5);
System.out.println(stu);
}
@Test
public void findAll() {
IStudentDao dao = new StudentDaoImpl();
List<Student> allStu = dao.findAll();
System.out.println(allStu);
}
}
複製代碼
JDBC工具類：
package com.meils.jdbc.utils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
/**
* JDBC 工具類
* @author apple
*
*/
public class JdbcUtil {
// 配置信息
public static String driverName = "com.mysql.jdbc.Driver";
public static String url = "jdbc:mysql://localhost:3306/mytest";
public static String userName = "root";
public static String password = "zjj19970517";
static {
try {
// 加載驅動，由於是在static塊中，因此只會加載一次
Class.forName(JdbcUtil.driverName);
}catch (Exception e) {
e.printStackTrace();
}
}
/**
* 鏈接數據庫
* @return 返回鏈接對象
*/
public static Connection getConnection() {
try {
return DriverManager.getConnection(JdbcUtil.url, JdbcUtil.userName, JdbcUtil.password);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 關閉鏈接，並釋放資源
* @param conn
* @param st
* @param rs
*/
public static void close(Connection conn, Statement st, ResultSet rs) {
if(conn!=null) {
try {
conn.close();
}catch(Exception e) {
e.printStackTrace();
}
}
if(st!=null) {
try {
st.close();
}catch(Exception e) {
e.printStackTrace();
}
}
if(rs!=null) {
try {
rs.close();
}catch(Exception e) {
e.printStackTrace();
}
}
}
}
複製代碼
三、DAO代碼重構
四、Statement接口
1 Statement 是父接口，PreparedStatement 和 CallableStatement 是子接口。
2 Statement 用於java應用程序與數據庫之間的傳送數據，好比傳送sql語句過去，到數據庫執行操做。
3 Statement 用於通用的訪問，使用靜態sql，其實並很差，容易SQL注入
4 PreparedStatement 用於預編譯模版SQL語句，能夠在運行的時候傳入參數
5 CallableStatement 訪問存儲過程的時候使用
複製代碼
五、預編譯語句
防止SQL注入：
六、經過DB類來操做數據庫
JDBC的另外一種封裝方法：
package com.meils.jdbc.db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class MysqlDB {
Connection conn = null; // 建立鏈接對象
Statement st = null; // 建立編譯語句對象
PreparedStatement ps = null; // 建立預編譯語句對象
ResultSet rs1 = null; // 結果集
// 配置信息
// 驅動名稱
private static final String driverName = "com.mysql.jdbc.Driver";
// 數據庫的地址
private static final String URL = "jdbc:mysql://localhost:3306/mytest";
// 數據庫登陸用戶名
private static final String userName = "root";
// 數據庫登陸密碼
private static final String pwd = "zjj19970517";
/**
* 鏈接數據庫
* @return
*/
public Connection getConnection() {
try {
Class.forName(driverName);
this.conn = DriverManager.getConnection(URL, userName, pwd);
System.out.println("鏈接成功");
return conn;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
// 構造函數
public MysqlDB() {
this.getConnection();
}
/**
* 查詢
* @param sql sql語句，完整的語句，查詢通常比較安全
* @return
*/
public ResultSet query(String sql) {
try {
this.st = this.conn.createStatement();
this.rs1 = this.st.executeQuery(sql);
return rs1;
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
/**
* 更新
* @param sql // 預編譯sql語句
* @param args // 參數數組
*/
public void update(String sql, String [] args) {
try {
this.ps = this.conn.prepareStatement(sql);
for (int i = 0 ; i < args.length ; i++) {
this.ps.setString(i+1, args[i]);
}
this.ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
this.close();
}
}
/**
* 刪除
* @param sql
* @return
*/
public int delete(String sql){
try {
this.st = this.conn.createStatement();
int num = this.st.executeUpdate(sql);
return num;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
this.close();
}
return 0;
}
/**
* 釋放資源
*/
public void close () {
try {
if(rs1!=null) {
rs1.close();
}
if(st!=null) {
st.close();
}
if(ps!=null) {
ps.close();
}
if(conn!=null) {
conn.close();
}
} catch (SQLException e) {
// TODO: handle exception
e.printStackTrace();
}
}
}
複製代碼
測試如下：
package com.meils.jdbc.db;
import java.sql.ResultSet;
import java.sql.SQLException;
public class Test {
public static void main(String[] args) {
// TODO Auto-generated method stub
// Conn();
delete();
}
// 測試鏈接
public static void Conn() {
MysqlDB m = new MysqlDB();
}
// 測試查詢
public static void queryTest() {
MysqlDB m = new MysqlDB();
String sql = "select * from student";
ResultSet result = m.query(sql);
System.out.println(result);
try {
while (result.next()) {
System.out.println(result.getString("name"));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
m.close();
}
}
// 更新
public static void update() {
MysqlDB m = new MysqlDB();
String sql = "update student set name = ? where id = ?";
String [] args = {"梅子111", "7"};
m.update(sql, args);
}
// 刪除
public static void delete() {
MysqlDB m = new MysqlDB();
String sql = "delete from student where id = 8";
System.out.println(m.delete(sql));
}
}
複製代碼
七、調用存儲過程
首先咱們熟悉一下存儲過程
// 新建存儲過程
DELIMITER //
create PROCEDURE getStudent1(in n varchar(20))
BEGIN
select * from student where name = n;
END //
DELIMITER ;
// 執行
call getStudent1('張錦傑');
複製代碼
package com.meils.jdbc.dao.test;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import com.meils.jdbc.domain.Student;
import com.meils.jdbc.utils.JdbcUtil;
public class ProductTest {
public static void main(String[] args) {
CallableStatement cstmt = null;
try {
//1.鏈接
Connection conn = JdbcUtil.getConnection();
//2.
CallableStatement cs = conn.prepareCall("{ call getStu(?)}");
//3.設置參數
cs.setString(1, "張錦傑");
//4.執行
ResultSet rs = cs.executeQuery();
if(rs.next()) {
Student stu = new Student();
stu.setId(rs.getInt("id"));
stu.setName(rs.getString("name"));
stu.setAge(rs.getInt("age"));
System.out.println(stu);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
複製代碼
帶有參數和輸出的存儲過程
// 帶有參數和輸出的存儲過程
DELIMITER //
CREATE PROCEDURE getName ( IN i INT, OUT n VARCHAR ( 50 ) ) BEGIN
SELECT NAME INTO
n
FROM
student
WHERE
id = i;
END // DELIMITER;
call getName(1, @name);
select @name;
複製代碼
package com.meils.jdbc.dao.test;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import com.meils.jdbc.domain.Student;
import com.meils.jdbc.utils.JdbcUtil;
public class ProductTest {
public static void main(String[] args) {
CallableStatement cstmt = null;
try {
//1.建立鏈接
Connection conn = JdbcUtil.getConnection();
//2.建立預編譯語句
CallableStatement cs = conn.prepareCall("{ call getName(?,?)}");
//3.設置參數
cs.setInt(1, 1);
//4.設置輸出參數
cs.registerOutParameter(2, Types.VARCHAR);
//5.執行
cs.execute();
//6.獲取到輸出的參數
String name = cs.getString(2);
System.out.println(name); // 張錦傑
} catch (Exception e) {
e.printStackTrace();
}
}
}
複製代碼
八、事物
首先在減小錢以前關閉自動提交事務，期間能夠進行多個操做，此時的事務提交必須手動了，須要使用conn.commit();。若是在中間發生了異常，那麼就進行回滾，釋放資源。
九、批處理
一般狀況下若是咱們想要一次性執行許多條sql語句，咱們都是一條執行完畢再執行下一條，當咱們使用了批處理以後，咱們就能夠一次性執行多條語句，話費的事件將大大縮短。
十、將文件存入數據庫
一般咱們不會這麼作的，由於數據庫的空間是很是寶貴的，文件較大，佔用的空間也較大，成本也就高了，假如咱們須要存文件，那麼就要選擇blob類型了，它是以二進制的形式來存取的，能夠存視頻、圖片、等多媒體信息。
首先須要設置數據庫中的字段類型爲blob。
複製代碼
存儲文件到數據庫：
將數據庫中的文件取出來：
十一、獲取自動生成的主鍵id
需求分析：
咱們可能回遇到這樣的情景，咱們首先註冊信息，填入用戶明和密碼後，註冊成功，此時的數據庫中的id是自動添加進去的，接下來回讓本身去完善本身的信息，這就要須要咱們剛纔建立的id了，那麼如何返回id給咱們下次使用呢？
兩種方式獲取：
1:
2:
相關文章
- 1. Java之JDBC（2）
- 2. Java 之 JDBC
- 3. Java 之 JDBC（二）
- 4. java之JDBC
- 5. JAVA EE之JDBC
- 6. Java之JDBC（1）
- 7. Java 之JDBC
- 8. java之jdbc使用
- 9. Java EE之JDBC技術
- 10. Java之JDBC初淺理解
- 更多相關文章...
- • SQLite - Java - SQLite教程
- • Java 中操作 R - R 語言教程
- • Java 8 Stream 教程
- • 互聯網組織的未來：剖析GitHub員工的任性之源
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. Java之JDBC（2）
- 2. Java 之 JDBC
- 3. Java 之 JDBC（二）
- 4. java之JDBC
- 5. JAVA EE之JDBC
- 6. Java之JDBC（1）
- 7. Java 之JDBC
- 8. java之jdbc使用
- 9. Java EE之JDBC技術
- 10. Java之JDBC初淺理解