JDBC学习

程序员文章站 2022-06-26 13:20:47

JDBC学习 "1. 概述" "2. 相关接口" "3. 连接数据库" "4. 资源释放" "5. 工具类抽取" "6. 数据操作" "7. 数据库连接池" 1. 概述 JDBC是Java连接数据库的一个API。它允许用户访问任何形式的表格数据，尤其是存储在关系数据库中的数据。 1.1 加载驱动包: ......

JDBC学习

1. 概述
2. 相关接口
3. 连接数据库
4. 资源释放
5. 工具类抽取
6. 数据操作
7. 数据库连接池

1. 概述

JDBC是Java连接数据库的一个API。它允许用户访问任何形式的表格数据，尤其是存储在关系数据库中的数据。

1.1 加载驱动包:

手动加载:
jar包下载地址为： https://dev.mysql.com/downloads/connector/j/
通过maven添加依赖：
在pom.xml中dependencies标签内中添加如下代码即可。

<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>6.0.6</version>
</dependency>

1.2 执行流程：

连接数据源，如：数据库。
为数据库传递查询和更新指令。
处理数据库响应并返回的结果。

2. 相关接口

2.1 DriverManager

作用:

注册驱动：实际开发中利用反射获取驱动实例
获得连接：使用getConnection()方法获得数据库连接

Connection getConnection(String url, String username, String password);
/** url写法：jdbc:mysql://localhost:3306/dbname
*   jdbc: 协议
*   mysql: 子协议
*   localhost: 主机名
*   3306: 默认端口号
*   dbname: 数据库名字
*   默认url简写: jdbc:mysql:///dbname 
*/
// username: 数据库连接账号
// password：数据库连接密码

2.2 Connection

作用:

创建执行SQL语句对象：

// 1. 执行SQL语句，有SQL注入漏洞
Statement createStatement()
// 2. 预编译SQL语句，解决SQL注入漏洞
PreparedStatement prepareStatement(String sql)
// 3. 执行SQL中存储过程
CallableStatement prepareCall(String sql)

进行事务管理

// 设置事务是否自动提交
setAutoCommit(boolean autoCommit)
// 事务提交
commit()
// 事务回滚
rollback()

2.3 Statement

作用

执行SQL

// 执行SQl，执行select语句后返回true，否则返回false
boolean execute(String sql)
// 执行SQL中的select语句，并将结果封装
ResultSet executeQuery(String sql)
// 执行SQL中的insert/update/delete语句，返回受影响行数
int executeUpdate(String sql)

执行批处理
批处理一次最好不要大于500条

// 添加到批处理
addBatch(String sql)
// 执行批处理
executeBatch()
// 清空批处理
clearBatch()

2.4 ResultSet

结果集：即查询语句(select)语句查询结果的封装

作用

获取查询到的结果

// 使用 next() 验证是否有下一个数据，有则返回true
rs.next()
// 使用 getXXX() 获取数据
rs.getInt("id")
rs.getString()
// 获取通用数据使用 getObject()
rs.getObject()

3. 连接数据库

3.1 加载驱动程序：

// 通过反射获得驱动，driverClass代表驱动类名
Class.forName(driverClass)
// 加载MySql驱动
Class.forName("com.mysql.jdbc.Driver")
// 加载Oracle驱动
Class.forName("oracle.jdbc.driver.OracleDriver")

3.2 获得数据库连接：

// 获得本地默认数据库
DriverManager.getConnection(jdbc:mysql://localhost:3306/dbname, root, root);

4. 资源释放

由于Connection对象是非常稀有的资源，用完之后应该立马释放。如果不能及时，正确的关闭容易导致系统宕机。Connection使用原则是尽量晚创建，尽量早释放。
ResultSet、Statement 使用完后也需要及时的释放

// 使用close()方法释放资源
if(rs!= null){
	try {
		rs.close();
	} catch (SQLException e) {
		e.printStackTrace();
	}
	    rs = null;
	}
// 	PreparedStatement/Connection 同理释放

5. 工具类抽取

由于注册驱动、获得连接以及资源释放都是重复操作。可以将这这些代码抽取到一个工具类中，可以提高代码重用。同时也可以将一些数据库参数配置信息写到一个配置文件中。

5.1 配置文件

# 文件名：jdbc.properties
driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql:///dbname
username=root
password=root

5.2 工具类

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

//JDBC的工具类
public class JDBCUtils {
	private static final String driverClass;
	private static final String url;
	private static final String username;
	private static final String password;
	
	static{
		// 加载属性文件并解析：
		Properties props = new Properties();
		// 使用类的加载器的方式进行获取：
		InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
		try {
			props.load(is);
		} catch (IOException e) {
			e.printStackTrace();
		}
		driverClass = props.getProperty("driverClass");
		url = props.getProperty("url");
		username = props.getProperty("username");
		password = props.getProperty("password");
	}

	/**
	 * 注册驱动的方法
	 * @throws ClassNotFoundException 
	 */
	public static void loadDriver() throws ClassNotFoundException{
		Class.forName(driverClass);
	}
	
	/**
	 * 获得连接的方法:
	 * @throws SQLException 
	 */
	public static Connection getConnection() throws Exception{
		loadDriver();
		Connection conn = DriverManager.getConnection(url, username, password);
		return conn;
	}
	
	/**
	 * 资源释放方法1
	 */
	public static void release(PreparedStatement pstmt,Connection conn){
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
	/**
	 * 资源释放方法2
	 */
	public static void release(ResultSet rs,PreparedStatement pstmt,Connection conn){
		if(rs!= null){
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			rs = null;
		}
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
}

6. 数据操作

即增删改查（CRUD）操作，一般使用PreparedStatement来避免SQL注入漏洞。下面操作使用工具类获取数据库连接。

6.1 增加数据

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 导入工具类
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
    public void insert(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		try{
			// 获得连接:
			conn = JDBCUtils.getConnection();
			// 编写SQL:
			String sql = "insert into user values (null,?,?,?)";
			// 预处理SQL:
			pstmt = conn.prepareStatement(sql);
			// 设置参数的值:
			pstmt.setString(1, "hahaha");
			pstmt.setString(2, "12345");
			pstmt.setString(3, "小明");
			// 执行SQL:
			int num = pstmt.executeUpdate();
			if(num > 0){
				System.out.println("保存成功！");
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			// 释放资源
			JDBCUtils.release(pstmt, conn);
		}
    }
}

6.2 修改数据

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 导入工具类
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
     public void update(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		try{
			// 获得连接:
			conn = JDBCUtils.getConnection();
			// 编写SQL:
			String sql = "update user set username = ?,password = ?,name = ? where uid = ?";
			// 预编译SQL:
			pstmt = conn.prepareStatement(sql);
			// 设置参数:
			pstmt.setString(1, "hahaha");
			pstmt.setString(2, "123456");
			pstmt.setString(3, "小六");
			pstmt.setInt(4, 6);
			// 执行SQL:
			int num = pstmt.executeUpdate();
			if(num > 0){
				System.out.println("修改成功！");
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(pstmt, conn);
		}
     }
}

6.3 删除数据

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 导入工具类
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
     public void delete(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		try{
			// 获得连接:
			conn = JDBCUtils.getConnection();
			// 编写SQL：
			String sql = "delete from user where uid = ?";
			// 预编译SQL:
			pstmt = conn.prepareStatement(sql);
			// 设置参数:
			pstmt.setInt(1, 6);
			// 执行SQL:
			int num = pstmt.executeUpdate();
			if(num > 0){
				System.out.println("删除成功！");
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(pstmt, conn);
		}
     }
}

6.4 查询数据

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
// 导入工具类
import com.test.jdbc.utils.JDBCUtils; 
public class JDBCTest {
    // 查询一条
     public static void selectOne(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try{
			// 获得连接:
			conn = JDBCUtils.getConnection();
			// 编写SQL：
			String sql = "select * from user where uid = ?";
			// 预编译SQL:
			pstmt = conn.prepareStatement(sql);
			// 设置参数:
			pstmt.setObject(1, 3);
			// 执行SQL:
			rs = pstmt.executeQuery();
			// 判断结果集:
			if(rs.next()){
				System.out.println(rs.getInt("uid")+"  "+rs.getString("username")+"  "+rs.getString("password")+"  "+rs.getString("name"));
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(rs, pstmt, conn);
		}
     }
     
    // 查询全部
    public static void selectAll(){
        Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try{
			// 获得连接:
			conn = JDBCUtils.getConnection();
			// 编写SQL:
			String sql = "select * from user";
			// 预编译SQL:
			pstmt = conn.prepareStatement(sql);
			// 设置参数
			// 执行SQL:
			rs = pstmt.executeQuery();
			while(rs.next()){
				System.out.println(rs.getInt("uid")+"  "+rs.getString("username")+"  "+rs.getString("password")+"  "+rs.getString("name"));
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			JDBCUtils.release(rs, pstmt, conn);
		}
    }
}

7. 数据库连接池

7.1 连接池

连接池是创建和管理一个连接的缓冲池技术，这些连接准备好被任何需要他们的线程使用。

应用程序直接获得连接的缺点：用户每次请求都需要向数据库获得连接，而数据库创建连接通常需要消耗相对较大的资源，创建时间也较长。这样极大的浪费数据库的资源，并且极易造成数据库服务器内存溢出。
使用连接池：用户请求的连接直接从连接池中获取，使用完毕后再放回连接池。只需维持较少的连接就可以满足大量用户需求。

JDBC学习

7.2 C3P0连接池

导入jar包

手动导入：
下载地址：https://sourceforge.net/projects/c3p0/
maven导入

<!-- https://mvnrepository.com/artifact/c3p0/c3p0 -->
<dependency>
    <groupId>c3p0</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.1.2</version>
</dependency>

使用方法

添加配置文件

# 文件名 c3p0-config.xml
<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>

  <default-config>
    <property name="driverClass">com.mysql.jdbc.Driver</property>
	<property name="jdbcUrl">jdbc:mysql:///dbname</property>
	<property name="user">root</property>
	<property name="password">abc</property>
	// 初始化线程池
	<property name="initialPoolSize">5</property>
	// 设置最大线程池大小
	<property name="maxPoolSize">20</property>
  </default-config>
  
</c3p0-config>

使用C3P0编写工具类

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JDBCUtils2 {
    // 初始化连接池
	private static final ComboPooledDataSource dataSource = new ComboPooledDataSource();
	
	/**
	 * 获得连接的方法:
	 * @throws SQLException 
	 */
	public static Connection getConnection() throws Exception{
		Connection conn = dataSource.getConnection();
		return conn;
	}
	
	/**
	 * 资源释放方法1
	 */
	public static void release(PreparedStatement pstmt,Connection conn){
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
	/**
	 * 资源释放方法2
	 */
	public static void release(ResultSet rs,PreparedStatement pstmt,Connection conn){
		if(rs!= null){
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			rs = null;
		}
		if(pstmt != null){
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			pstmt = null;
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
}

上一篇：为什么说赵云是一位颇为特殊的人物？他为什么能与即位开国将领并列青史？

下一篇： RestTemplate 使用

JDBC学习

JDBC学习

1. 概述

1.1 加载驱动包:

1.2 执行流程：

2. 相关接口

2.1 DriverManager

作用:

2.2 Connection

作用:

2.3 Statement

作用

2.4 ResultSet

作用

3. 连接数据库

3.1 加载驱动程序：

3.2 获得数据库连接：

4. 资源释放

5. 工具类抽取

5.1 配置文件

5.2 工具类

6. 数据操作

6.1 增加数据

6.2 修改数据

6.3 删除数据

6.4 查询数据

7. 数据库连接池

7.1 连接池

7.2 C3P0连接池

导入jar包

使用方法

学习强国app怎么进入在家上学网课直播入口?

Linux shell脚本全面学习入门

详解ASP.NET Core MVC 源码学习：Routing 路由

JDBC连接Access数据库的几种方式介绍

javaweb介绍代码（jdbc连接数据库5个步骤）

java到哪里学习（史上最强Java学习路线图）

python学习 流程控制语句详解

Python深入学习之对象的属性

Java语言Consistent Hash算法学习笔记（代码示例）

Python深入学习之闭包

python学习流程控制语句详解