JDBC入门

迷南。 2023-10-10 19:32 13阅读 0赞

JDBC，Java数据库连接，是Java语言中与关系型数据库连接的一种API规范。它可以让Java程序通过标准的SQL语句来与数据库进行交互、操作数据。

本篇文章将带您进入JDBC的世界，让您了解JDBC的一些基本概念和操作。我们将以MySQL数据库为例进行操作。

1.  JDBC的基本使用

首先，需要下载MySQL JDBC驱动并引入到项目中。我们可以从Maven仓库中获取最新的版本，或者直接从MySQL官网下载。

代码中，我们需要先加载驱动：

Class.forName("com.mysql.cj.jdbc.Driver");

然后，通过DriverManager来获取连接：

String url = "jdbc:mysql://localhost:3306/test";
    String user = "root";
    String password = "123456";
    Connection conn = DriverManager.getConnection(url, user, password);

其中，url是数据库的连接地址，user和password是连接数据库的用户名和密码。

接下来，我们就可以执行SQL语句了：

Statement stmt = conn.createStatement();
    ResultSet rs = stmt.executeQuery("SELECT * FROM user");
    while (rs.next()) {
        
        int id = rs.getInt("id");
        String name = rs.getString("name");
        int age = rs.getInt("age");
        System.out.println("id:" + id + ", name:" + name + ", age:" + age);
    }

上面代码中，我们使用Statement对象执行了一条查询语句，并通过ResultSet对象读取查询结果。

最后，不要忘记在程序结束后关闭连接和释放资源：

rs.close();
    stmt.close();
    conn.close();

1.  PreparedStatement的使用

在使用Statement时，我们拼接SQL语句时容易出现拼写错误、SQL注入等问题。而使用PreparedStatement对象可以有效避免这些问题。

PreparedStatement的使用方式类似于Statement，但它是预编译的语句，可以在执行之前预先进行编译。这样可以提高程序的效率，并且防止SQL注入。

下面是PreparedStatement的使用示例：

PreparedStatement stmt = conn.prepareStatement("SELECT * FROM user WHERE id = ?");
    stmt.setInt(1, id);
    ResultSet rs = stmt.executeQuery();

上面代码中，我们使用?占位符代替查询参数，然后使用setXXX()方法设置参数。

1.  批量操作

在实际开发中，我们经常需要批量插入或更新数据。JDBC可以使用Batch操作来实现这个功能。

下面是一个批量插入的示例：

PreparedStatement stmt = conn.prepareStatement("INSERT INTO user (name, age) VALUES (?, ?)");
    for (int i = 0; i < 1000; i++) {
        
        stmt.setString(1, "user" + i);
        stmt.setInt(2, i);
        stmt.addBatch();
    }
    stmt.executeBatch();

上面代码中，我们使用PreparedStatement对象将插入语句设置为批量操作，然后循环添加要插入的数据，并使用addBatch()来将操作加入批量中。最后通过executeBatch()来执行批量操作。

1.  事务处理

事务是指一系列对数据进行的操作，这些操作要么全部提交成功，要么全部失败回滚。

JDBC中通过Connection对象来进行事务处理。下面是一个事务处理的示例：

Connection conn = ...;
    try {
        
        // 关闭自动提交，开启事务
        conn.setAutoCommit(false);
    
        PreparedStatement stmt1 = conn.prepareStatement("UPDATE account SET balance = balance - ? WHERE user_id = ?");
        stmt1.setInt(1, 100);
        stmt1.setInt(2, 1);
        stmt1.executeUpdate();
    
        PreparedStatement stmt2 = conn.prepareStatement("UPDATE account SET balance = balance + ? WHERE user_id = ?");
        stmt2.setInt(1, 100);
        stmt2.setInt(2, 2);
        stmt2.executeUpdate();
    
        // 提交事务并启用自动提交
        conn.commit();
        conn.setAutoCommit(true);
    } catch (SQLException e) {
        
        // 出现异常回滚事务
        conn.rollback();
    } finally {
        
        conn.close();
    }

上面代码中，我们通过关闭自动提交并开启事务，然后依次执行两个UPDATE操作，如果其中一个操作出现异常，就回滚事务，否则提交事务。

1.  ResultSet的使用

ResultSet对象是JDBC中用来表示查询结果的类。我们可以通过ResultSet对象获取查询结果中的单行或多行数据。

下面是ResultSet的使用示例：

PreparedStatement stmt = conn.prepareStatement("SELECT * FROM user");
    ResultSet rs = stmt.executeQuery();
    while (rs.next()) {
        
        int id = rs.getInt("id");
        String name = rs.getString("name");
        int age = rs.getInt("age");
        System.out.println("id:" + id + ", name:" + name + ", age:" + age);
    }

上面代码中，我们使用PreparedStatement对象执行查询语句，然后通过ResultSet对象读取查询结果。读取操作使用的是next()方法，每次读取一行数据，并将指针指向下一行。

1.  总结

JDBC是Java与关系型数据库连接的一种API规范，我们可以使用JDBC来进行数据库的连接、操作和管理。本篇文章主要介绍了JDBC的基本使用、PreparedStatement的使用、批量操作、事务处理和ResultSet的使用等内容。希望本文对JDBC初学者有所帮助。