JDBC学习

Posted Apollospotato

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了JDBC学习相关的知识，希望对你有一定的参考价值。

JDBC学习

1. 概述

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

1.1 加载驱动包:

<!-- 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 连接池

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

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

7.2 C3P0连接池

导入jar包

<!-- 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;
		}
	}
}

以上是关于JDBC学习的主要内容，如果未能解决你的问题，请参考以下文章

面试常用的代码片段

mysql jdbc源码分析片段 和 Tomcat's JDBC Pool

IOS开发－OC学习－常用功能代码片段整理

java SpringRetry学习的代码片段

python 机器学习有用的代码片段

JDBC操作数据库之查询数据