如何使用JAVA异步执行存储过程

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;

public class AsyncStoredProcedureExample {
    public static void main(String[] args) {
        // 数据库连接信息
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";

        try {
            // 创建数据库连接
            Connection connection = DriverManager.getConnection(url, username, password);

            // 创建CallableStatement对象
            CallableStatement callableStatement = connection.prepareCall("{call my_stored_procedure(?, ?)}");

            // 设置输入参数
            callableStatement.setInt(1, 123);

            // 注册输出参数
            callableStatement.registerOutParameter(2, java.sql.Types.VARCHAR);

            // 异步执行存储过程
            callableStatement.executeAsync();

            // 获取输出参数
            String outputParameter = callableStatement.getString(2);
            System.out.println("Output parameter: " + outputParameter);

            // 处理存储过程的结果
            ResultSet resultSet = callableStatement.getResultSet();
            while (resultSet.next()) {
                // 处理每一行结果
            }

            // 关闭数据库连接和相关资源
            resultSet.close();
            callableStatement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}