欢迎 👍点赞 ➕关注 ❤️收藏 💬评论
目录
🌟一、什么是JDBC？
JDBC（Java Data Base Connectivity，Java数据库连接）是Java程序和数据库之间的桥梁，也就是Java语言操作数据库的标准API，他提供了一套用于执行SQL语句的Java接口。JDBC的主要作用就是：与数据库连接、发送SQL语句和处理数据库执行结果。
🌟二、JDBC编程的步骤
✨使用步骤
1.加载数据库厂商的驱动包
2.建立连接，用户名，密码
3.创建Statement
4.发送要执行的SQL语句
5.接收返回结果并显示（结果集,受影响的行数）
6.释放资源和关闭连接
✨DriverManger
💫定义
DriverManger是JDBC中的一个核心类，位于java.sql包下，他负责管理数据库驱动程序，并为客户端程序提供获取数据库连接的方法。它就像一个“驱动管理器”，协调不同数据库驱动与应用程序之间的交互。
💫DriverManger的主要功能
- 注册数据驱动：管理 已加载的数据；
- 获取数据库连接：根据连接信息（URL、用户名、密码）返回合适的Connection对象；
- 处理驱动程序之间的竞争：当多个驱动可以连接到同一URL时，选择最合适的驱动。
URL表示统一资源定位符，是互联网上用来指定一个位置、文件或者资源的标准方式。
💫DriverManger的核心方法
getConnection（）
| 核心方法 | 功能 |
| getConnection（String url） | 通过URL获取连接 |
| getConnection（String url，String user，String password） | 通过URL、用户名和密码获取连接 |
| getConnection（String url，Properties info） | 通过URL和包含连接属性的Properties对象获取连接 |
| registerDriver（Driver driver） | 注册驱动（一般不用手动调用） |
| deregisterDriver（Driver driver） | 注销驱动 |
| gerDrivers（） | 获取所有已注册的驱动 |
💫使用
import java.sql.*;
import java.text.MessageFormat;
import java.util.Scanner;
public class Demo1 {
public static void main(String[] args) {
//声明数据库操作的相关对象
//数据库连接对象
Connection connection=null;
//执行静态SQL对象，但是SQL注入可能会出现一些问题
Statement statement= null;
//对静态SQL的解决方法，预处理
PreparedStatement preparedStatement=null;
//查询结果集对象
ResultSet resultSet=null;
try{
//1，加载数据厂商提供的驱动：加载数据库提供的jdbc驱动类，注册到DriverManger中
Class.forName("com.mysql.cj.jdbc.Driver");
//2.获取数据库连接--相当于在数据库中写use java2；
//数据库连接URL格式：jdbc：mysql：//服务器地址：端口/数据库？参数名=值[&参数名=值]
connection= DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/java2?characterEncoding=utf8" +
"&allowPublicKeyRetrieval=true&useSSL=false", "root", "123456");
//3.创建Statement对象：Statement用于像数据库发送SQL语句
statement = connection.createStatement();
//4.定义SQL语句并执行
System.out.println("请输入学生姓名：");
Scanner scanner =new Scanner(System.in);
//接收用户输入
String name=scanner.next();
String sql="select id,name,class_id from students where name='"+name+"'";
//5.执行SQL，获取查询结果
//executeQuery用于执行select语句，返回结果集
resultSet=statement.executeQuery(sql);
//6.对结果集进行遍历获取结果
//有返回true，没有返回false
while(resultSet.next()){
long id=resultSet.getLong(1);//获取第一列字段的值
String Stuname=resultSet.getString(2);//获取第二列字段的值
long class_id=resultSet.getLong(3);//获取第三列字段的值
System.out.println(MessageFormat.format("学生id={0}，姓名={1}，班级={2}",id,name,class_id));
}
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}finally{// 释放资源（从后往前释放）,关闭连接
if(resultSet!=null){
try{
resultSet.close();
}catch (SQLException e){
e.printStackTrace();
}
}
if(statement!=null){
try {
statement.close();
}catch (SQLException e){
e.printStackTrace();
}
}
if(connection!=null){
try {
connection.close();
}catch (SQLException e){
e.printStackTrace();
}
}
}
}
}✨DataSource
💥定义
是Java数据库连接（JDBC）的一个接口，用于获取数据库连接，可方便数据库连接资源，实现连接池等高级功能。
💥使用
import com.mysql.cj.jdbc.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.*;
import java.text.MessageFormat;
import java.util.Scanner;
public class Demo {
public static void main(String[] args) {
//定义MySQL数据源对象
MysqlDataSource mysqlDataSource=new MysqlDataSource();
//MySQL驱动直连
//数据库连接
mysqlDataSource.setURL("jdbc:mysql://127.0.0.1:3306/java2?characterEncoding=utf8");
mysqlDataSource.setUser("root");
mysqlDataSource.setPassword("123456");
//定义jdbc数据源对象
DataSource dataSource=mysqlDataSource;
Connection connection=null;
//预处理
PreparedStatement statement=null;
//查询结果集对象
ResultSet resultSet=null;
try{
//1.获取数据库连接
connection= dataSource.getConnection();
//2.创建Statement对象：Statement用于像数据库发送SQL语句
//定义SQL语句并执行
String sql="select id,name,class_id from students where name=?";
statement = connection.prepareStatement(sql);
//3.接收用户输入
System.out.println("请输入学生姓名：");
Scanner scanner =new Scanner(System.in);
String name=scanner.next();
// 用真实值替换占位符
statement.setString(1,name);
//4..执行SQL，获取查询结果
//executeQuery用于执行select语句，返回结果集
resultSet=statement.executeQuery(sql);
//5.对结果集进行遍历获取结果
//有返回true，没有返回false
while(resultSet.next()){
long id=resultSet.getLong(1);//获取第一列字段的值
String Stuname=resultSet.getString(2);//获取第二列字段的值
long class_id=resultSet.getLong(3);//获取第三列字段的值
System.out.println(MessageFormat.format("学生id={0}，姓名={1}，班级={2}",id,name,class_id));
}
} catch (SQLException e) {
e.printStackTrace();
} finally{// 释放资源（从后往前释放）,关闭连接
if(resultSet!=null){
try{
resultSet.close();
}catch (SQLException e){
e.printStackTrace();
}
}
if(statement!=null){
try {
statement.close();
}catch (SQLException e){
e.printStackTrace();
}
}
if(connection!=null){
try {
connection.close();
}catch (SQLException e){
e.printStackTrace();
}
}
}
}
}💥代码优化
封装
import com.mysql.cj.jdbc.MysqlDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Random;
public class DB {
//数据源
private static DataSource dataSource=null;
//数据库连接串
private static final String url="jdbc:mysql://127.0.0.1:3306/java2?characterEncoding=utf8";
//用户
private static String user="root";
//密码
private static String password="123456";
//当类加载到JVM时，执行数据源的初始化
static {
MysqlDataSource mysqlDataSource = new MysqlDataSource();
mysqlDataSource.setURL(url);
mysqlDataSource.setUser(user);
mysqlDataSource.setPassword(password);
dataSource = mysqlDataSource;
}
public static void close(ResultSet resultSet, Statement statement, Connection connection){
if(resultSet!=null){
try{
resultSet.close();
}catch (SQLException e){
e.printStackTrace();
}
}
if(statement!=null){
try {
statement.close();
}catch (SQLException e){
e.printStackTrace();
}
}
if(connection!=null){
try {
connection.close();
}catch (SQLException e){
e.printStackTrace();
}
}
}
//构造方法私有化，防止new这个对象
private DB(){};
//获取数据连接
public static Connection getConnection() throws SQLException{
return dataSource.getConnection();
}
}
使用jdbc插入数据
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class Demo3{
//插入数据
public static void main(String[] args) {
Connection connection=null;
PreparedStatement statement=null;
//插入数据，不用获得结果集，要影响行数即可
try{
//获取数据库
connection=DB.getConnection();
//定义SQL
String sql="insert into students(id,name,class_id) values(?,?,?)";
//定义SQL预处理对象
statement = connection.prepareStatement(sql);
//接收用户参数
Scanner scanner = new Scanner(System.in);
System.out.println("请输入id");
Long id= Long.valueOf(scanner.next());
System.out.println("请输入姓名");
String name= scanner.next();
System.out.println("请输入班级");
Long class_id= Long.valueOf(scanner.next());
//用真实数据代替占位符
statement.setLong(1,id);
statement.setString(2,name);
statement.setLong(3,class_id);
//获取结果，影响的行数
//executeUpdate执行返回结果是一个整形，通常用于insert、delete、update
int row=statement.executeUpdate();
//判断
if(row==1){
System.out.println("插入成功");
}else{
System.out.println("插入失败");
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
//关闭连接，释放资源
DB.close(null,statement,connection);
}
}
}✨DriverManger和DataSource的区别
- DriverManger每次调用都会初始化一个新的连接，导致资源浪费；
- DataSource使用连接池的技术，一个连接可以重复使用，用DataDource替代DriverManger.getConnection（）直连方式，更直接，灵活。