Java中调用数据库存储过程的示例代码

2025-06-27 17:50
文章标签 java 代码 数据库 过程 调用 存储 示例

本文主要是介绍Java中调用数据库存储过程的示例代码，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《Java中调用数据库存储过程的示例代码》本文介绍Java通过JDBC调用数据库存储过程的方法,涵盖参数类型、执行步骤及数据库差异,需注意异常处理与资源管理,以优化性能并实现复杂业务逻辑,感兴趣的朋友...

存储过程（Stored Procedure）是一组为了完成特定功能的SQL语句集，经编译后存储在数据库中。Java应用程序可以通过JDBC调用这些存储过程，实现复杂的业务逻辑。本文将详细介绍如何在Java中调用数据库的存储过程，包括传递参数和获取返回结果，并提供丰富的示例代码。

一、存储过程概述

存储过程具有以下优点：

  1. 提高性能：存储过程只需要编译一次，以后每次执行都不需要重新编译，提高了执行效率。
  2. 减少网络流量：存储过程在数据库服务器上执行，只需要将结果返回给客户端，减少了网络传输的数据量。
  3. 增强安全性：可以通过存储过程控制对数据库的访问，只允许用户执行特定的存储过程，而不是直接访问表。
  4. 复用性强：存储过程可以被多个应用程序共享和复用。

存储过程的参数类型有三种：

  • IN参数：输入参数，用于向存储过程传递值。
  • OUT参数：输出参数，用于从存储过程返回值。
  • INOUT参数：输入输出参数，既可以传递值给存储过程，也可以从存储过程返回值。

二、Java调用存储过程的基本步骤

在Java中调用存储过程主要通过CallableStatement接口实现，基本步骤如下：

  1. 获取数据库连接：通过DriverManager.getConnection()方法获取数据库连接。
  2. 准备调用存储过程的SQL语句：使用{call 存储过程名(参数1, 参数2, ...)}格式。
  3. 创建CallableStatement对象：通过Connection.prepareCall()方法创建。
  4. 设置输入参数：如果存储过程有输入参数，使用setXxx()方法设置。
  5. 注册输出参数：如果存储过程有输出参数，使用registerOutParameter()方法注册。
  6. 执行存储过程：使用execute()或executeQuery()或executeUpdate()方法执行。
  7. 获取输出参数的值：如果存储过程有输出参数，使用getXxx()方法获取。
  8. 处理结果集：如果存储过程返回结果集，遍历结果集获取数据。
  9. 关闭资源：关闭CallableStatement和Connection。

三、Java调用存储过程示例

下面通过具体示例演示如何在Java中调用不同类型的存储过程。

1. 无参数存储过程

存储过程定义（MySQL）：

DELIMITER $$
CREATE PROCEDURE GetAllEmployees()
BEGIN
    SELECT * FROM employees;
END$$
DELIMITER ;

Java调用代码：

import java.sql.*;
public class CallStoredProcedureNoParams {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/company";
        String username = "root";
        String password = "password";
        try (Connection conn = DriverManager.getConnection(url, username, password);
             // 创建调用存储过程的语句
             CallableStatement cstmt = conn.prepareCall("{call GetAllEmployees()}")) {
            // 执行存储过程
            ResultSet rs = cstmt.executeQuery();
            // 处理结果集
            while (rs.next()) {
                System.out.println("ID: " + rs.getInt("id") + 
                                   ", Name: " + rs.getString("name") + 
                                   ", Department: " + rs.getString("department"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

2. 带IN参数的存储过程

存储过程定义（MySQL）：

DELIMITER $$
CREATE PROCEDURE GetEmployeeByDepartment(IN dept VARCHAR(50))
BEGIN
    SELECT * FROM employees WHERE department = dept;
END$$
DELIMITER ;

Java调用代码：

import java.sql.*;
public class CallStoredProcedureWithINParam {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/company";
        String username = "root";
        String password = "password";
        try (Connection conn = DriverManager.getConnection(url, username, password);
             // 创建调用存储过程的语句
             CallableStatement cstmt = conn.prepareCall("{call GetEmployeeByDepartment(?)}")) {
            // 设置输入参数
            cstmt.setString(1, "IT");
            // 执行存储过程
            ResultSet rs = cstmt.executeQuery();
            // 处理结果集
            while (rs.next()) {
                System.out.println("ID: " + rs.getInt("id") + 
                                   ", Name: " + rs.getString("name") + 
                                   ", Department: " + rs.getString("department"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

3. 带OUT参数的存储过程

存储过程定义（MySQL）：

DELIMITER $$
CREATE PROCEDURE GetEmployeeCount(OUT count INT)
BEGIN
    SELECT COUNT(*) INTO count FROM employees;
END$$
DELIMITER ;

Java调用代码：

import java.sql.*;
public class CallStoredProcedureWithOUTParam {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/company";
        String username = "root";
        String password = "password";
        try (Connection conn = DriverManager.getConnection(url, username, password);
             // 创建调用存储过程的语句
             CallableStatement cstmt = conn.prepareCall("{call GetEmployeeCount(?)}")) {
            // 注册输出参数
            cstmt.registerOutParameter(1, Types.INTEGER);
            // 执行存储过程
            cstmt.execute();
            // 获取输出参数的值
            int count = cstmt.getInt(1);
            System.out.println("员工总数: " + count);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

4. 带INOUT参数的存储过程

存储过程定义（MySQL）：

DELIMITER $$
CREATE PROCEDURE IncrementSalary(INOUT salary DOUBLE, IN percentage INT)
BEGIN
    SET salary = salary * (1 + percentage/100.0);
END$$
DELIMITER ;

Java调用代码：

import java.sql.*;
public class CallStoredProcedureWithINOUTParam {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/company";
        String username = "root";
        String password = "password";
        try (Connection conn = DriverManager.getConnection(url, username, password);
             // 创建调用存储过程的语句
             CallableStatement cstmt = conn.prepareCall("{call IncrementSalary(?, ?)}")) {
            // 设置输入参数
            cstmt.setDouble(1, 5000.0);  // 初始工资
            cstmt.setInt(2, 10);        // 加薪百分比
            // 注册输出参数
            cstmt.registerOutParameter(1, Types.DOUBLE);
            // 执行存储过程
            cstmt.execute();
            // 获取输出参数的值
            double newSalary = cstmt.getDouble(1);
            System.out.println("加薪后的工资: " + newSalary);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

5. 带返回结果集和输出参数的存储过程

存储过程定义（MySQL）：

DELIMITER $$
CREATE PROCEDURE GetEmployeesAndCount(OUT count INT)
BEGIN
    SELECT * FROM employees;
    SELECT COUNT(*) INTO count FROM employees;
END$$
DELIMITER ;

Java调用代码：

import java.sql.*;
pubwww.chinasem.cnlic clajavascriptss CallStoredProcedureWithResultSetAndOUTParam {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/company";
        String username = "root";
        String password = "password";
        try (Connection conn = DriverManager.getConnection(url, username, password);
             // 创建调用存储过程的语句
             CallableStatement cstmt = conn.prepareCall("{call GetEmployeesAndCount(?)}")) {
            // 注册输出参数
            cstmt.registerOutParameter(1, Types.INTEGER);
            // 执行存储过程
            boolean hasResultSet = cstmt.execute();
            // 处理结果集
            if (hasResultSet) {
                try (ResultSet rs = cstmt.getResultSet()) {
                    System.out.println("员工列表:");
                    while (rs.next()) {
                        System.out.println("ID: " + rs.getInt("id") + 
                                           ", Name: " + rs.getString("name") + 
                                           ", Department: " + rs.getString("department"));
                    }
                }
            }
            // 移动到下一个结果（输出参数）
            while (cstmt.getMoreResults()) {
                // 处理可能的其他结果集
            }
            // 获取输出参数的值
            int count = cstmt.getInt(1);
            System.out.printChina编程ln("员工总数: " + count);
        } catch (SQLException e) {
            e.printStackTrace();
 python       }
    }
}

四、不同数据库的存储过程调用差异

虽然JDBC提供了统一的API来调用存储过程，但不同数据库的存储过程语法和调用方式可能存在差异。

1. MySQL

MySQL使用CREATE PROCEDURE语句创建存储过程，调用时使用{call 存储过程名(参数)}语法。

2. Oracle

Oracle使用CREATE OR REPLACE PROCEDURE语句创建存储过程，调用时语法与MySQL类似，但参数类型可能不同。

Oracle存储过程示例：

CREATE OR REPLACE PROCEDURE GetEmployeeCount(emp_count OUT NUMBER)
IS
BEGIN
    SELECT COUNT(*) INTO emp_count FROM employees;
END;

Java调用Oracle存储过程：

try (Connection conn = DriverManager.getConnection(url, username, password);
     CallableStatement cstmt = conn.prepareCall("{call GetEmployeeCount(?)}")) {
    // 注册输出参数（Oracle使用Types.NUMERIC）
    cstmt.registerOutParameter(1, Types.NUMERIC);
    // 执行存储过程
    cstmt.execute();
    // 获取输出参数的值
    int count = cstmt.getInt(1);
    System.out.println("员工总数: " + count);
} catch (SQLException e) {
    e.printStackTrace();
}

3. SQL Server

SQL Server使用CREATE PROCEDURE语句创建存储过程，调用时可以使用EXEC 存储过程名 参数语法，也可以使用标准的JDBC语法。

SQL Server存储过程示例：

CREATE PROCEDURE GetEmployeeByDepartment
    @dept VARCHAR(50)
AS
BEGIN
    SELECT * FROM employees WHERE department = @dept;
END

Java调用SQL Server存储过程：

try (Connection conn = DriverManager.getConnection(url, username, password);
     CallableStatement cstmt = conn.prepareCall("{call GetEmployeeByDepartment(?)}")) {
    // 设置输入参数
    cstmt.setString(1, "IT");
    // 执行存储过程
    ResultSet rs = cstmt.executeQuery();
    // 处理结果集
    while (rs.next()) {
        System.out.println("ID: " + rs.getInt("id") + 
                           ", Name: " + rs.getString("name") + 
                           ", Department: " + rs.getString("department"));
    }
} catch (SQLException e) {
    e.printStackTrace();
}

五、异常处理和资源管理

在调用存储过程时，需要注意异常处理和资源管理，避免资源泄漏。

Connection conn = null;
CallableStatement cstmt = null;
ResultSet rs = null;
try {
    // 获取数据库连接
    conn = DriverManager.getConnection(url, username, password);
    // 创建调用存储过程的语句
    cstmt = conn.prepareCall("{call 存储过程名(参数)}");
    // 设置参数和执行存储过程
    // ...
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    // 关闭资源，注意顺序
    try {
        if (rs != null) rs.close();
        if (cstmt != null) cstmt.close();
        if (conn != null) conn.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}

或者使用Java 7引入的try-with-resources语句自动关闭资源：

try (Connection conn = DriverManager.getConnection(url, username, password);
     CallableStatement cstmt = conn.prepareCall("{call 存储过程名(参数)}")) {
    // 设置参数和执行存储过程
    // ...
} catch (SQLException e) {
    e.printStackTrace();
}

六、存储过程调用的性能考虑

  1. 缓存存储过程：大多数JDBC驱动会自动缓存存储过程的执行计划，可以通过设置连接参数来控制缓存大小。

  2. 批量操作：如果需要多次调用同一个存储过程，可以考虑使用批量操作来提高性能。

  3. 避免过度使用存储过程：虽然存储过程有很多优点，但并不是所有情况都适合使用。对于简单的查询，直接使用SQL可能更高效。

  4. 优化存储过程：确保存储过程本身已经经过优化，避免在存储过程中执行复杂的逻辑。

七、总结

通过JDBC调用数据库存储过程是Java与数据库交互的重要方式，它允许我们利用数据库的强大功能来实现复杂的业务逻辑。本文介绍了Java调用存储过程的基本步骤和示例，包括无参数、带IN参数、带OUT参数、带INOUT参数以及带结果集和输出参数的存储过程调用方法。

主要关键点：

  1. 使用CallableStatement接口调用存储过程
  2. 使用setXxx()方法设置输入参数
  3. 使用registerOutParameter()方法注册输出参数
  4. 使用getXxx()方法获取输出参数的值
  5. 处理存储过程返回的结果集
  6. 注意不同数据库的存储过程语法差异
  7. 做好异常处理和资源管理

在实际项目中，可以根据业务需求选择合适的存储过程调用方式，并结合数据库特性进行优化，以提高应用程序的性能和可维护性。

到此这篇关于Java中调用数据库存储过程的文章就介绍到这了,更多相关java调用存储过程内容请搜索China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程China编程(www.chinasem.cn)！

这篇关于Java中调用数据库存储过程的示例代码的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1155236。

相关文章

一篇文章彻底搞懂macOS如何决定java环境

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面：本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一：使用 which命令方法二：使用 Java_home工具（Apple 官方推荐）那问题来了，
阅读更多...
Java HashMap的底层实现原理深度解析

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述：HashMap的宏观结构二、核心数据结构解析1. 数组（桶数组）2. 链表节点（Node
阅读更多...
Java AOP面向切面编程的概念和实现方式

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点（如日志、事务）与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么？二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关
阅读更多...
详解SpringBoot+Ehcache使用示例

详解SpringBoot+Ehcache使用示例

《详解SpringBoot+Ehcache使用示例》本文介绍了SpringBoot中配置Ehcache、自定义get/set方式,并实际使用缓存的过程,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录摘要概念内存与磁盘持久化存储：配置灵活性：编码示例引入依赖：配置ehcache.XML文件：配置
阅读更多...
Java 虚拟线程的创建与使用深度解析

Java 虚拟线程的创建与使用深度解析

《Java虚拟线程的创建与使用深度解析》虚拟线程是Java19中以预览特性形式引入,Java21起正式发布的轻量级线程,本文给大家介绍Java虚拟线程的创建与使用,感兴趣的朋友一起看看吧... 目录一、虚拟线程简介1.1 什么是虚拟线程？1.2 为什么需要虚拟线程？二、虚拟线程与平台线程对比代码对比示例：三
阅读更多...
Java中的.close()举例详解

Java中的.close()举例详解

《Java中的.close()举例详解》.close()方法只适用于通过window.open()打开的弹出窗口,对于浏览器的主窗口,如果没有得到用户允许是不能关闭的,：本文主要介绍Java中的.... 目录当你遇到以下三种情况时，一定要记得使用 .close()：用法作用举例如何判断代码中的 input
阅读更多...
Redis中Hash从使用过程到原理说明

Redis中Hash从使用过程到原理说明

《Redis中Hash从使用过程到原理说明》RedisHash结构用于存储字段-值对,适合对象数据,支持HSET、HGET等命令,采用ziplist或hashtable编码,通过渐进式rehash优化... 目录一、开篇：Hash就像超市的货架二、Hash的基本使用1. 常用命令示例2. Java操作示例三
阅读更多...
Redis中Set结构使用过程与原理说明

Redis中Set结构使用过程与原理说明

《Redis中Set结构使用过程与原理说明》本文解析了RedisSet数据结构,涵盖其基本操作（如添加、查找）、集合运算（交并差）、底层实现（intset与hashtable自动切换机制）、典型应用场... 目录开篇：从购物车到Redis Set一、Redis Set的基本操作1.1 编程常用命令1.2 集
阅读更多...
Linux下利用select实现串口数据读取过程

Linux下利用select实现串口数据读取过程

《Linux下利用select实现串口数据读取过程》文章介绍Linux中使用select、poll或epoll实现串口数据读取,通过I/O多路复用机制在数据到达时触发读取,避免持续轮询,示例代码展示设... 目录示例代码（使用select实现）代码解释总结在 linux 系统里，我们可以借助 select、
阅读更多...
Spring Gateway动态路由实现方案

Spring Gateway动态路由实现方案

《SpringGateway动态路由实现方案》本文主要介绍了SpringGateway动态路由实现方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随... 目录前沿何为路由RouteDefinitionRouteLocator工作流程动态路由实现尾巴前沿S
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2