Java原生操作JDBC連接以及原理詳解

更新時(shí)間：2021年01月12日 11:13:37 作者：L_Sueno

這篇文章主要給大家介紹了關(guān)于Java原生操作JDBC連接以及原理的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

一、簡(jiǎn)介

JDBC全稱(chēng)又叫做Java DataBase Connectivity，也就是Java數(shù)據(jù)庫(kù)連接，說(shuō)白了就是用Java語(yǔ)言來(lái)操作數(shù)據(jù) 庫(kù)，提供統(tǒng)一API訪問(wèn)數(shù)據(jù)庫(kù)操作。

二、原理

JDBC主要是用于java連接數(shù)據(jù)庫(kù)的，能連接什么數(shù)據(jù)庫(kù)不固定，其實(shí)能連接很多種數(shù)據(jù)庫(kù)，而且一般來(lái)說(shuō)可以連接oracle和mysql，通常也是這兩種。但是既然JDBC能連接這么多的數(shù)據(jù)庫(kù)，開(kāi)發(fā)起來(lái)太麻煩了，于是sun公司那些人想出了一個(gè)辦法，我定義一套規(guī)范，大家都按照這個(gè)規(guī)范來(lái)，實(shí)現(xiàn)自己公司訪問(wèn)數(shù)據(jù)庫(kù)的實(shí)現(xiàn)。這套規(guī)范就是JDBC，遵循了JDBC規(guī)范的，可以訪問(wèn)自己數(shù)據(jù)庫(kù)的API被稱(chēng)之為數(shù)據(jù)庫(kù)驅(qū)動(dòng)。

三、數(shù)據(jù)庫(kù)操作

數(shù)據(jù)庫(kù)操作分為6個(gè)步驟（增、刪、改可跳過(guò)第5步，移步看第6步）：

1、首先，項(xiàng)目中檢查是否已導(dǎo)入mysql連接jar包，如：mysql-connector-java-5.1.6-bin.jar

2、使用反射注冊(cè)數(shù)據(jù)庫(kù)驅(qū)動(dòng)，Class.forName(name);

3、通過(guò)DriverManager.getConnection(url, username, password)構(gòu)造器獲取數(shù)據(jù)庫(kù)連接

4、通過(guò)Connection連接對(duì)象獲取數(shù)據(jù)庫(kù)操作對(duì)象PrepareStatement或者Statement

5、通過(guò)獲取的Statement對(duì)象執(zhí)行executeQuery()操作返回ResultSet結(jié)果集，需判斷是否為空

6、通過(guò)獲取的Statement對(duì)象執(zhí)行executeUpdate()操作返回受影響的行數(shù)，判斷是否成功標(biāo)識(shí)

7、釋放連接資源，關(guān)閉順序?yàn)椋篟esultSet -> PrepareStatement / Statement -> Connection

解釋說(shuō)明關(guān)鍵類(lèi)：

（1）DriverManager：該類(lèi)管理數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序。

（2）Connection：管理數(shù)據(jù)庫(kù)建立的連接。

（3）Statement：負(fù)責(zé)將要執(zhí)行的sql體提交到數(shù)據(jù)庫(kù)。

（4）ResultSet：執(zhí)行sql查詢(xún)語(yǔ)句返回的結(jié)果集。

（5）PreparedStatement：可以使用預(yù)編譯的SQL，防止SQL注入，而Statment只能使用靜態(tài)的SQL。

PreparedStatement 與 Statment 區(qū)別：

語(yǔ)法不同： PreparedStatement可以使用預(yù)編譯的sql，而Statment只能使用靜態(tài)的sql。

效率不同： PreparedStatement可以使用sql緩存區(qū)，效率比Statment高。

安全性不同： PreparedStatement可以有效防止sql注入，而Statment不能防止sql注入。

四、數(shù)據(jù)庫(kù)增、刪、改、查示例

工具類(lèi)（可做相對(duì)應(yīng)靈活替換）：

package com.bnd.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Objects;

/** 

* @author 作者 mbql: 

* @version 創(chuàng)建時(shí)間：2021年1月10日 下午5:14:16 

* 類(lèi)說(shuō)明 	JDBC操作數(shù)據(jù)庫(kù)工具類(lèi)

*/
public class JdbcUtils {
	
	private static final String driverName = "com.mysql.jdbc.Driver";		// 數(shù)據(jù)庫(kù)驅(qū)動(dòng)名稱(chēng)
	
	private static final String url = "jdbc:mysql://39.108.146.20:3307/jsp?useUnicode=true&characterEncoding=utf-8";	// 數(shù)據(jù)庫(kù)url
	
	private static final String userName = "root";			// 用戶(hù)名
	
	private static final String password = "123456";	 // 用戶(hù)密碼
	
	private static Connection conn = null;					// 數(shù)據(jù)庫(kù)連接對(duì)象
	
	private static PreparedStatement preparedStatement = null;	// 執(zhí)行操作對(duì)象
	
	static {
		
		try {
			Class.forName(driverName);		// 2、注冊(cè)數(shù)據(jù)庫(kù)驅(qū)動(dòng)
			conn = DriverManager.getConnection(url, userName, password);	// 3、獲取數(shù)據(jù)庫(kù)連接
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
	/**
	 * 查詢(xún)數(shù)據(jù)
	 * @return	返回查詢(xún)到結(jié)果
	 */
	public static ResultSet queryData() {
		ResultSet result = null;
		String sql = "select id, name, pwd from user";		// 定義預(yù)編譯SQL
		try {
			preparedStatement = conn.prepareStatement(sql);			// 4、執(zhí)行預(yù)編譯SQL操作
			result = preparedStatement.executeQuery();	// 5、執(zhí)行查詢(xún)操作
			while (result.next()) {
				int id = result.getInt(1);
				String name = result.getString(2);
				String pwd = result.getString(3);
				System.out.println("id：" + id + "--> name：" + name + "--> pwd：" + pwd);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、釋放資源
			close(conn, preparedStatement, result);
		}
		return result;
	}
	
	/**
	 * 添加數(shù)據(jù)
	 * @return	返回受影響行數(shù)
	 */
	public static int addData() {
		String sql = "insert into user(name,pwd) values(?, ?)";
		try {
			preparedStatement = conn.prepareStatement(sql);		// 4、執(zhí)行預(yù)編譯SQL操作
			preparedStatement.setString(1, "tom");
			preparedStatement.setString(2, "abc123");
			int count = preparedStatement.executeUpdate();			// 6、執(zhí)行添加操作
			if (count > 0) {
				return count;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、釋放資源
			close(conn, preparedStatement, null);
		}			
		return -1;
	}
	
	/**
	 * 更新數(shù)據(jù)
	 * @return	返回受影響行數(shù)
	 */
	public static int updateData() {
		String sql = "update user set name = ?, pwd = ? where id = ?";
		try {
			preparedStatement = conn.prepareStatement(sql);		// 4、執(zhí)行預(yù)編譯SQL操作
			preparedStatement.setString(1, "sueno");
			preparedStatement.setString(2, "qwe123");
			preparedStatement.setInt(3, 10);
			int count = preparedStatement.executeUpdate();			// 6、執(zhí)行添加操作
			if (count > 0) {
				return count;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、釋放資源
			close(conn, preparedStatement, null);
		}			
		return -1;
	}
	
	
	/**
	 * 刪除數(shù)據(jù)
	 * @return	返回受影響行數(shù)
	 */
	public static int deleteData() {
		String sql = "delete from user where id = ?";
		try {
			preparedStatement = conn.prepareStatement(sql);		// 4、執(zhí)行預(yù)編譯SQL操作
			preparedStatement.setInt(1, 11);
			int count = preparedStatement.executeUpdate();			// 6、執(zhí)行添加操作
			if (count > 0) {
				return count;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、釋放資源
			close(conn, preparedStatement, null);
		}			
		return -1;
	}
	
	/**
	 * 釋放資源
	 * @param conn	關(guān)閉數(shù)據(jù)庫(kù)連接
	 * @param statement	關(guān)閉數(shù)據(jù)庫(kù)操作對(duì)象
	 * @param rs	關(guān)閉結(jié)果集操作對(duì)象
	 */
	public static void close(Connection conn, Statement statement, ResultSet rs) {
		if (Objects.nonNull(rs)) {
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if (Objects.nonNull(statement)) {
			try {
				statement.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if (Objects.nonNull(conn)) {
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

測(cè)試類(lèi)：

package com.bnd.util;

import java.sql.ResultSet;

/** 

* @author 作者 mbql: 

* @version 創(chuàng)建時(shí)間：2021年1月10日 下午6:00:30 

* 類(lèi)說(shuō)明 

*/
public class TestJdbc {
	
	public static void main(String[] args) {
		// 獲取用戶(hù)數(shù)據(jù)
//		ResultSet rs = JdbcUtils.queryData();
//		System.out.println(rs);
		
		// 添加用戶(hù)數(shù)據(jù)
//		int count = JdbcUtils.addData();
//		if (count > 0) {
//			System.out.println("添加成功！");
//		}
		
		// 更新用戶(hù)數(shù)據(jù)
//		int count = JdbcUtils.updateData();
//		if (count > 0) {
//			System.out.println("更新成功！");
//		}
		
		// 刪除用戶(hù)數(shù)據(jù)
//		int count = JdbcUtils.deleteData();
//		if (count > 0) {
//			System.out.println("刪除成功！");
//		}
	}
}