脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → JDBC连接数据库

如何使用JDBC连接数据库并执行SQL语句

 更新时间：2023年04月28日 11:12:57   作者：互联小助手  
JDBC是Java数据库连接的缩写，是Java程序与数据库进行交互的标准API。JDBC主要包括Java.sql和javax.sql两个包，通过DriverManager获取数据库连接对象Connection，并通过Statement或PreparedStatement执行SQL语句

1. JDBC入门

JDBC（Java Database Connectivity）是Java程序与数据库进行交互的一种标准接口，它提供了一种简单的方式来连接和操作数据库。在使用JDBC之前，需要先了解以下几个概念：

  • JDBC Driver：JDBC驱动程序是一个Java类，用于将Java应用程序与特定数据库管理系统（DBMS）连接。JDBC驱动程序分为四种类型：JDBC-ODBC桥接驱动程序、本地API驱动程序、网络协议驱动程序和本地协议驱动程序。
  • Connection：Connection是一个JDBC接口，用于连接到数据库。在Java程序中，通过Connection接口的实现类来实现与数据库的连接。
  • Statement：Statement是一个JDBC接口，用于向数据库发送SQL语句并执行它们。在Java程序中，通过Connection对象创建Statement对象。
  • ResultSet：ResultSet是一个JDBC接口，用于表示从数据库中检索到的结果集。ResultSet对象通过Statement对象的executeQuery()方法返回。

下面是一个简单的JDBC连接示例：

import java.sql.*;
public class JDBCDemo {
    public static void main(String[] args) {
        try {
            // 加载JDBC驱动程序
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 建立数据库连接
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "root", "password");
            // 执行SQL查询
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM users");
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getString(3));
            }
            // 关闭数据库连接
            rs.close();
            stmt.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

2. 抽取工具类

在实际开发中，我们通常会抽取出一个JDBC工具类来封装JDBC相关操作，以方便代码的重用和维护。下面是一个简单的JDBC工具类示例：

import java.sql.*;
public class JDBCUtils {
    private static final String URL = "jdbc:mysql://localhost:3306/mydb";
    private static final String USER = "root";
    private static final String PASSWORD = "password";
    static {
        try {
            // 加载JDBC驱动程序
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    public static Connection getConnection() {
        Connection conn = null;
        try {
            // 建立数据库连接
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    public static void release(ResultSet rs, Statement stmt, Connection conn) {
        try {
            if (rs != null) rs.close();
            if (stmt != null) stmt.close();
            if (conn != null) conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

3. Statement CRUD

Statement是JDBC中最基本的操作方式，它用于向数据库发送SQL语句并执行它们。下面是一个使用Statement进行CRUD操作的示例：

import java.sql.*;
public class StatementCRUD {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtils.getConnection();
            stmt = conn.createStatement();
            // 插入数据
            String sql = "INSERT INTO users (name, age) VALUES ('Tom', 18)";
            stmt.executeUpdate(sql);
            // 更新数据
            sql = "UPDATE users SET age = 20 WHERE name = 'Tom'";
            stmt.executeUpdate(sql);
            // 删除数据
            sql = "DELETE FROM users WHERE age = 20";
            stmt.executeUpdate(sql);
            // 查询数据
            sql = "SELECT * FROM users";
            rs = stmt.executeQuery(sql);
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getInt(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, stmt, conn);
        }
    }
}

4. 演练CRUD

下面是一个使用PreparedStatement进行CRUD操作的示例：

import java.sql.*;
public class PreparedStatementCRUD {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtils.getConnection();
            // 插入数据
            String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "Tom");
            pstmt.setInt(2, 18);
            pstmt.executeUpdate();
            // 更新数据
            sql = "UPDATE users SET age = ? WHERE name = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.setString(2, "Tom");
            pstmt.executeUpdate();
            // 删除数据
            sql = "DELETE FROM users WHERE age = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.executeUpdate();
            // 查询数据
            sql = "SELECT * FROM users";
            pstmt = conn.prepareStatement(sql);
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getInt(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, pstmt, conn);
        }
    }
}

5. Dao模式(声明与实现分开)

Dao（Data Access Object）模式是一种用于封装数据访问逻辑的设计模式。它将数据访问逻辑与业务逻辑分离开来，使得代码更易于维护和扩展。下面是一个使用Dao模式进行CRUD操作的示例：

import java.sql.*;
public class UserDAO {
    private static final String INSERT_SQL = "INSERT INTO users (name, age) VALUES (?, ?)";
    private static final String UPDATE_SQL = "UPDATE users SET age = ? WHERE name = ?";
    private static final String DELETE_SQL = "DELETE FROM users WHERE age = ?";
    private static final String SELECT_SQL = "SELECT * FROM users";
    public void insert(User user) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(INSERT_SQL);
            pstmt.setString(1, user.getName());
            pstmt.setInt(2, user.getAge());
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(null, pstmt, conn);
        }
    }
    public void update(User user) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(UPDATE_SQL);
            pstmt.setInt(1, user.getAge());
            pstmt.setString(2, user.getName());
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(null, pstmt, conn);
        }
    }
    public void delete(int age) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(DELETE_SQL);
            pstmt.setInt(1, age);
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(null, pstmt, conn);
        }
    }
    public List<User> selectAll() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        List<User> userList = new ArrayList<>();
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(SELECT_SQL);
            rs = pstmt.executeQuery();
            while (rs.next()) {
                User user = new User();
                user.setId(rs.getInt(1));
                user.setName(rs.getString(2));
                user.setAge(rs.getInt(3));
                userList.add(user);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, pstmt, conn);
        }
        return userList;
    }
}
public class User {
    private int id;
    private String name;
    private int age;
    // 省略getter、setter方法
}

6. PrepareStatement CRUD

PreparedStatement是一种预编译的Statement，它可以通过占位符的方式来替换SQL语句中的参数，避免了SQL注入的危险。下面是一个使用PreparedStatement进行CRUD操作的示例：

import java.sql.*;
public class PrepareStatementCRUD {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtils.getConnection();
            // 插入数据
            String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "Tom");
            pstmt.setInt(2, 18);
            pstmt.executeUpdate();
            // 更新数据
            sql = "UPDATE users SET age = ? WHERE name = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.setString(2, "Tom");
            pstmt.executeUpdate();
            // 删除数据
            sql = "DELETE FROM users WHERE age = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.executeUpdate();
            // 查询数据
            sql = "SELECT * FROM users";
            pstmt = conn.prepareStatement(sql);
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getInt(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, pstmt, conn);
        }
    }
}

以上就是关于JDBC入门、抽取工具类、Statement CRUD、演练CRUD、Dao模式（声明与实现分开）、PrepareStatement CRUD的详细介绍和代码示例。通过学习这些内容，可以让我们更好地掌握JDBC的使用和开发技巧，从而更好地应用到实际的项目中。

到此这篇关于如何使用JDBC连接数据库并执行SQL语句的文章就介绍到这了,更多相关JDBC连接数据库内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • 通过实例解析java8中的parallelStream

    通过实例解析java8中的parallelStream

    这篇文章主要介绍了通过实例解析java8中的parallelStream,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • Java Enum和String及int的相互转化示例

    Java Enum和String及int的相互转化示例

    这篇文章主要介绍了Java Enum和String及int的相互转化示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-06-06
  • Java实现读取Excel文件功能(EasyExcel初使用)

    Java实现读取Excel文件功能(EasyExcel初使用)

    EasyExcel是一款基于Java语言的开源Excel解析工具,可以帮助我们快速、高效地读取和写入Excel文件,这篇文章主要给大家介绍了关于Java实现读取Excel文件功能的相关资料,使用的是EasyExcel,需要的朋友可以参考下
    2024-07-07
  • 详解Java中的ThreadLocal

    详解Java中的ThreadLocal

    ThreadLocal是JDK包提供的，它提供线程本地变量，如果创建一个ThreadLocal变量，那么访问这个变量的每个线程都会有这个变量的一个副本，在实际多线程操作的时候，操作的是自己本地内存中的变量，从而规避了线程安全问题
    2021-06-06
  • springboot实现mock平台的示例代码

    springboot实现mock平台的示例代码

    本文主要介绍了springboot实现mock平台的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-06-06
  • Java集合去重导致的线上问题

    Java集合去重导致的线上问题

    这篇文章主要介绍了Java集合去重导致的线上问题，根据主题提出Set是怎样保证数据的唯一性的，为什么两种去重方式性能差距这么大的问题，下文解决思路需要的小伙伴可以参考一下
    2022-04-04
  • Java中的排序与内部比较器Compareable解析

    Java中的排序与内部比较器Compareable解析

    这篇文章主要介绍了Java中的排序与内部比较器Compareable解析,一般没有特殊要求时,直接调用(底层默认的升序排列)就可以得到想要的结果,所谓的 sort 方法排序底层都是基于这两种排序,故如果需要设计成所想要的排序就需要了解底层排序原理,需要的朋友可以参考下
    2023-11-11
  • 详解MyBatis Generator自动创建代码(dao,mapping,poji)

    详解MyBatis Generator自动创建代码(dao,mapping,poji)

    这篇文章主要介绍了详解MyBatis Generator自动创建代码(dao,mapping,poji)的相关资料,非常不错，具有参考借鉴价值，需要的朋友可以参考下
    2016-10-10
  • sublime编译器怎么运行java程序

    sublime编译器怎么运行java程序

    Sublime是一款强大的代码编辑器,它提供了丰富的功能和插件,可以帮助开发者提高代码的编写效率和质量,通过安装相关插件和进行简单配置,我们可以轻松地在Sublime中编译和运行Java代码,下面我们将详细介绍如何配置Sublime,使其能够高效地运行Java代码
    2024-06-06
  • 浅谈JAVA 责任链模式

    浅谈JAVA 责任链模式

    这篇文章主要介绍了JAVA 责任链模式的的相关资料，文中讲解非常细致，代码帮助大家更好的理解和学习，感兴趣的朋友可以了解下
    2020-06-06

最新评论