Java JDBC(Java Database Connectivity)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,高可用系列 2核4GB
云数据库 RDS PostgreSQL,高可用系列 2核4GB
简介: Java JDBC(Java Database Connectivity)

Java JDBC(Java Database Connectivity)是用于在Java应用程序中与数据库进行交互的API。它提供了一种标准方法来访问各种类型的数据库,如MySQL、PostgreSQL、Oracle等。通过JDBC,开发人员可以执行SQL查询、更新和管理数据库,以实现数据持久化和检索。

 

JDBC编程基础

 

1. 加载数据库驱动程序

 

在使用JDBC之前,首先需要加载适当的数据库驱动程序。不同的数据库厂商提供了不同的驱动程序,例如com.mysql.cj.jdbc.Driver用于MySQL数据库。加载驱动程序的步骤如下:

 

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

 

2. 建立数据库连接

 

一旦加载了数据库驱动程序,就可以通过DriverManager建立数据库连接。连接字符串url包含了主机名、端口号和数据库名称,username和password则是用于认证的凭证。

 

```java
String url = "jdbc:mysql://localhost:3306/mydatabase";
String username = "root";
String password = "password";
 
Connection connection = null;
try {
    connection = DriverManager.getConnection(url, username, password);
} catch (SQLException e) {
    e.printStackTrace();
}
```

 

3. 创建和执行SQL语句

 

通过Connection对象,可以创建Statement或PreparedStatement对象,然后执行SQL语句。Statement主要用于执行静态SQL语句,而PreparedStatement则用于执行带参数的动态SQL语句。

 

```java
// 使用Statement执行静态SQL查询
Statement statement = null;
ResultSet resultSet = null;
try {
    statement = connection.createStatement();
    resultSet = statement.executeQuery("SELECT * FROM users");
 
    while (resultSet.next()) {
        String name = resultSet.getString("name");
        int age = resultSet.getInt("age");
        System.out.println("Name: " + name + ", Age: " + age);
    }
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    try {
        if (resultSet != null) resultSet.close();
        if (statement != null) statement.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
 
// 使用PreparedStatement执行带参数的SQL插入操作
String insertSQL = "INSERT INTO users (name, age) VALUES (?, ?)";
PreparedStatement preparedStatement = null;
try {
    preparedStatement = connection.prepareStatement(insertSQL);
    preparedStatement.setString(1, "Alice");
    preparedStatement.setInt(2, 25);
    preparedStatement.executeUpdate();
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    try {
        if (preparedStatement != null) preparedStatement.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
```

 

4. 处理结果集

 

执行查询后,可以通过ResultSet对象处理查询结果。ResultSet对象表示数据库结果集,包含了通过查询返回的数据。可以使用ResultSet的各种get方法来获取列值。

 

```java
while (resultSet.next()) {
    String name = resultSet.getString("name");
    int age = resultSet.getInt("age");
    System.out.println("Name: " + name + ", Age: " + age);
}
```

 

5. 事务管理

 

在实际应用中,经常需要使用事务来确保数据的一致性。JDBC支持手动事务管理,可以通过Connection对象的`setAutoCommit(false)`方法关闭自动提交模式,然后通过`commit()`和`rollback()`方法来控制事务。

 

```java
try {
    connection.setAutoCommit(false);
 
    String updateSQL1 = "UPDATE accounts SET balance = balance - ? WHERE id = ?";
    PreparedStatement pstmt1 = connection.prepareStatement(updateSQL1);
    pstmt1.setDouble(1, 100);
    pstmt1.setInt(2, 1);
    pstmt1.executeUpdate();
 
    String updateSQL2 = "UPDATE accounts SET balance = balance + ? WHERE id = ?";
    PreparedStatement pstmt2 = connection.prepareStatement(updateSQL2);
    pstmt2.setDouble(1, 100);
    pstmt2.setInt(2, 2);
    pstmt2.executeUpdate();
 
    connection.commit();
} catch (SQLException e) {
    try {
        connection.rollback();
    } catch (SQLException ex) {
        ex.printStackTrace();
    }
    e.printStackTrace();
} finally {
    try {
        connection.setAutoCommit(true);
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
```

 

6. 关闭连接

 

最后,记得关闭连接,释放资源。未关闭的连接可能会导致资源泄漏,从而影响系统性能。

 

```java
try {
    if (resultSet != null) resultSet.close();
    if (statement != null) statement.close();
    if (connection != null) connection.close();
} catch (SQLException e) {
    e.printStackTrace();
}
```

 

完整示例代码

 

以下是一个完整的Java JDBC示例,展示了如何连接到数据库、执行查询、更新记录,并处理结果集。

 

```java
import java.sql.*;
 
public class JdbcExample {
    public static void main(String[] args) {
        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;
        PreparedStatement preparedStatement = null;
 
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://localhost:3306/mydatabase";
            String username = "root";
            String password = "password";
 
            connection = DriverManager.getConnection(url, username, password);
            statement = connection.createStatement();
            resultSet = statement.executeQuery("SELECT * FROM users");
 
            while (resultSet.next()) {
                String name = resultSet.getString("name");
                int age = resultSet.getInt("age");
                System.out.println("Name: " + name + ", Age: " + age);
            }
 
            String insertSQL = "INSERT INTO users (name, age) VALUES (?, ?)";
            preparedStatement = connection.prepareStatement(insertSQL);
            preparedStatement.setString(1, "Bob");
            preparedStatement.setInt(2, 30);
            preparedStatement.executeUpdate();
 
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (resultSet != null) resultSet.close();
                if (statement != null) statement.close();
                if (preparedStatement != null) preparedStatement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}
```

 

以上代码展示了从数据库连接到执行查询、插入数据,再到关闭连接的完整流程。在实际项目中,还需要考虑更多的异常处理、日志记录、性能优化等方面。JDBC作为Java与数据库交互的基础技术,是每个Java开发人员必须掌握的重要技能。

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
目录
相关文章
|
6月前
|
SQL Java 中间件
【YashanDB知识库】yasdb jdbc驱动集成BeetISQL中间件,业务(java)报autoAssignKey failure异常
在BeetISQL 2.13.8版本中,客户使用batch insert向yashandb表插入数据并尝试获取自动生成的sequence id时,出现类型转换异常。原因是beetlsql在prepareStatement时未指定返回列,导致yashan JDBC驱动返回rowid(字符串),与Java Bean中的数字类型tid不匹配。此问题影响业务流程,使无法正确获取sequence id。解决方法包括:1) 在batchInsert时不返回自动生成的sequence id;2) 升级至BeetISQL 3,其已修正该问题。
【YashanDB知识库】yasdb jdbc驱动集成BeetISQL中间件,业务(java)报autoAssignKey failure异常
|
Java 关系型数据库 数据库连接
JDBC:Java与数据库的“黄金搭档”,为何它如此重要?
JDBC:Java与数据库的“黄金搭档”,为何它如此重要?
104 8
|
Java 数据库连接 API
JDBC:Java数据库连接的“黑科技”大揭秘
JDBC:Java数据库连接的“黑科技”大揭秘
82 7
|
SQL Java 数据库连接
为何JDBC是Java开发者的“心头好”?原因竟然这么简单!
为何JDBC是Java开发者的“心头好”?原因竟然这么简单!
89 3
|
6月前
|
SQL druid Oracle
【YashanDB知识库】yasdb jdbc驱动集成druid连接池,业务(java)日志中有token IDENTIFIER start异常
客户Java日志中出现异常,影响Druid的merge SQL功能(将SQL字面量替换为绑定变量以统计性能),但不影响正常业务流程。原因是Druid在merge SQL时传入null作为dbType,导致无法解析递归查询中的`start`关键字。
|
9月前
|
Java 数据库连接 数据库
springboot java.lang.ClassNotFoundException: dm.jdbc.driver.DmDriver应该如何解决
通过上述步骤,可以有效解决Spring Boot项目中遇到的 `java.lang.ClassNotFoundException: dm.jdbc.driver.DmDriver`问题。确保在项目中正确添加达梦数据库的JDBC驱动依赖,并在配置文件中正确配置数据源信息,是解决此问题的关键。通过这些方法,可以确保Spring Boot项目能够正确连接达梦数据库并正常运行。
1718 31
|
8月前
|
SQL Java 关系型数据库
使用 JDBC 实现 Java 数据库操作
JDBC(Java Database Connectivity)是 Java 提供的数据库访问技术,允许通过 SQL 语句与数据库交互。本文详细介绍了 JDBC 的使用方法,包括环境准备、编程步骤和完整示例。
769 7
|
8月前
|
SQL Java 数据库连接
【潜意识Java】Java中JDBC过时方法的替代方案以及JDBC为什么过时详细分析
本文介绍了JDBC中一些常见过时方法及其替代方案。
158 5
|
SQL Java 关系型数据库
【前端学java】JDBC快速入门
【8月更文挑战第12天】JDBC快速入门
124 2
【前端学java】JDBC快速入门
|
Java 数据库连接 网络安全
JDBC数据库编程(java实训报告)
这篇文章是关于JDBC数据库编程的实训报告,涵盖了实验要求、实验环境、实验内容和总结。文中详细介绍了如何使用Java JDBC技术连接数据库,并进行增删改查等基本操作。实验内容包括建立数据库连接、查询、添加、删除和修改数据,每个部分都提供了相应的Java代码示例和操作测试结果截图。作者在总结中分享了在实验过程中遇到的问题和解决方案,以及对Java与数据库连接操作的掌握情况。
JDBC数据库编程(java实训报告)

热门文章

最新文章