当前位置: 首页 > news >正文

JDBC的连接过程(超详细)

JDBC(Java Database Connectivity)是 Java 用于访问数据库的标准 API,它允许 Java 程序与各种不同类型的数据库进行交互, 其连接数据库的过程主要包含以下几个步骤:

1. 导入 JDBC 驱动依赖

在使用 JDBC 连接数据库之前,需要导入相应数据库的 JDBC 驱动。如果是使用 Maven 构建项目,以 MySQL 为例,在pom.xml文件中添加如下依赖:

<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.33</version> <!-- 根据实际需求选择版本 -->
</dependency>

2. 加载 JDBC 驱动

在 Java 代码中,需要加载数据库的 JDBC 驱动,让 Java 程序知道使用哪个驱动来连接数据库。使用Class.forName()方法加载驱动类,例如连接 MySQL 数据库

try {Class.forName("com.mysql.cj.jdbc.Driver");
} catch (ClassNotFoundException e) {e.printStackTrace();
}

3. 建立数据库连接

使用DriverManager.getConnection()方法来建立与数据库的连接,该方法需要传入数据库的 URL、用户名和密码。以下是不同数据库连接 URL 的示例:

  • MySQL
String url = "jdbc:mysql://localhost:3306/mydatabase?useSSL=false&serverTimezone=UTC";
String username = "root";
String password = "123456";
try (java.sql.Connection connection = DriverManager.getConnection(url, username, password)) {System.out.println("数据库连接成功");
} catch (java.sql.SQLException e) {e.printStackTrace();
}

jdbc:mysql://是 MySQL 的 JDBC URL 前缀,localhost是数据库主机地址,3306是端口号,mydatabase是数据库名,后面的参数用于配置连接属性,如关闭 SSL 验证和设置时区。

  • PostgreSQL
String url = "jdbc:postgresql://localhost:5432/mydatabase";
String username = "postgres";
String password = "123456";
try (java.sql.Connection connection = DriverManager.getConnection(url, username, password)) {System.out.println("数据库连接成功");
} catch (java.sql.SQLException e) {e.printStackTrace();
}

jdbc:postgresql://是 PostgreSQL 的 JDBC URL 前缀,5432是默认端口号。

  • Oracle
String url = "jdbc:oracle:thin:@localhost:1521:orcl";
String username = "scott";
String password = "tiger";
try (java.sql.Connection connection = DriverManager.getConnection(url, username, password)) {System.out.println("数据库连接成功");
} catch (java.sql.SQLException e) {e.printStackTrace();
}

jdbc:oracle:thin:是 Oracle 的 JDBC URL 前缀,1521是默认端口号,orcl是数据库实例名。

4. 创建 Statement 对象

连接建立后,需要创建StatementPreparedStatementCallableStatement对象,用于执行 SQL 语句

  • Statement:最基本的用于执行 SQL 语句的对象,适用于执行静态 SQL 语句,例如:
try (java.sql.Statement statement = connection.createStatement()) {// 执行SQL查询java.sql.ResultSet resultSet = statement.executeQuery("SELECT * FROM users");while (resultSet.next()) {System.out.println(resultSet.getString("username"));}
} catch (java.sql.SQLException e) {e.printStackTrace();
}
  • PreparedStatement:预编译 SQL 语句,能有效防止 SQL 注入攻击,并且性能更好,适用于执行动态 SQL 语句,例如:
String sql = "SELECT * FROM users WHERE username = ?";
try (java.sql.PreparedStatement preparedStatement = connection.prepareStatement(sql)) {preparedStatement.setString(1, "admin");java.sql.ResultSet resultSet = preparedStatement.executeQuery();while (resultSet.next()) {System.out.println(resultSet.getString("username"));}
} catch (java.sql.SQLException e) {e.printStackTrace();
}
  • CallableStatement:用于执行数据库中的存储过程,例如:
String sql = "{call get_user_count(?)}";
try (java.sql.CallableStatement callableStatement = connection.prepareCall(sql)) {callableStatement.registerOutParameter(1, java.sql.Types.INTEGER);callableStatement.execute();int count = callableStatement.getInt(1);System.out.println("用户数量: " + count);
} catch (java.sql.SQLException e) {e.printStackTrace();
}

5. 执行 SQL 语句

根据不同的需求,使用上述创建的对象执行 SQL 语句,如executeQuery()用于执行查询语句并返回结果集(ResultSet),executeUpdate()用于执行增删改操作并返回受影响的行数,execute()用于执行任意 SQL 语句并返回一个布尔值表示是否返回结果集。

6. 处理结果集(如果有)

当执行查询语句后,会得到一个ResultSet对象,通过调用ResultSet的方法(如getString()getInt()等)来获取查询结果集中的数据,并进行相应的处理。

7. 关闭资源

在完成数据库操作后,需要按照ResultSetStatement(或PreparedStatementCallableStatement)、Connection的顺序关闭资源,以释放数据库连接和其他相关资源,防止资源泄漏。示例代码如下:

java.sql.ResultSet resultSet = null;
java.sql.PreparedStatement preparedStatement = null;
try {// 执行操作...
} catch (java.sql.SQLException e) {e.printStackTrace();
} finally {if (resultSet != null) {try {resultSet.close();} catch (java.sql.SQLException e) {e.printStackTrace();}}if (preparedStatement != null) {try {preparedStatement.close();} catch (java.sql.SQLException e) {e.printStackTrace();}}if (connection != null) {try {connection.close();} catch (java.sql.SQLException e) {e.printStackTrace();}}
}

或者使用 Java 7 引入的try-with-resources语句,它会自动关闭实现了AutoCloseable接口的资源,简化代码编写:

try (java.sql.Connection connection = DriverManager.getConnection(url, username, password);java.sql.PreparedStatement preparedStatement = connection.prepareStatement(sql);java.sql.ResultSet resultSet = preparedStatement.executeQuery()) {// 处理结果集...
} catch (java.sql.SQLException e) {e.printStackTrace();
}

完美撒花~

http://www.xdnf.cn/news/1277191.html

相关文章:

  • 机器学习——标准化、归一化
  • 从零开始理解百度语音识别API的Python实现
  • nginx 反向代理传递原始域名
  • 前端开发中的常见问题与实战解决方案​
  • PostgreSQL 批量COPY导入优化参数配置
  • GC如何判断对象可以被回收?
  • SpringAI报错:com.github.victools.jsonschema.generator.AnnotationHelper
  • 《设计模式》UML类图
  • Java集合框架、Collection体系的单列集合
  • Elasticsearch QueryDSL 教程
  • Android APK 使用OpenGl 绘制三角形源码
  • Spring Boot 全局异常处理与日志监控实战
  • 智能体革命:网络安全人的角色重塑与突围指南
  • 井字游戏的强化学习
  • 复现论文《基于Retinex理论和深度学习的低照度图像增强算法研究》
  • CompletableFuture实现Excel 多个sheet页批量导出
  • 【模板】拓扑排序
  • 【嵌入式硬件实例】-555定时器PWM调光电路
  • 通过Certbot自动申请更新HTTPS网站的SSL证书
  • 字节:计算机存储单位
  • Spring Cloud系列—OpenFeign远程调用
  • 【东枫科技】FR3 可扩展测试平台,适用于 6G 研究与卫星通信,高达 1.6 GHz 的带宽
  • 【Html网页模板】炫酷科技风公司首页
  • 正确使用SQL Server中的Hint(10)—Hint简介与Hint分类及语法(1)
  • strace的常用案例
  • GPT-5与中国AI发展(DeepSeek R1视角)
  • FFmpeg实现音视频转码
  • QT的常用控件说明
  • 【从源码角度深度理解 Python 的垃圾回收机制】:第1课引用计数篇
  • C++高频知识点(二十)