jdbc java数据库连接 5）CallableStatement 接口

 　　CallableStatement执行存储过程（也是预编译语言）

 

首先在sql中执行以下带有输入参数的代码：

      DELIMITER $
              CREATE PROCEDURE pro_findById(IN sid INT)
      BEGIN
              SELECT * FROM person WHERE id = sid;
      END $

那么，这条语句的存储过程代码就是

CALL pro_findById (？);

　　使用CallableStatement来执行:

    /**
      带有输入参数的存储语言
      sql中先运行
      DELIMITER $
              CREATE PROCEDURE pro_findById(IN sid INT)
      BEGIN
              SELECT * FROM person WHERE id = sid;
      END $
     */
    private static void testIn() {
        
        Connection conn = null;
        CallableStatement stsm = null;
        ResultSet rs = null;
    try{    
        //1：创建连接
        conn = Jdbcutil.getConnection();
        
        //2：准备sql语言（带有存储过程的预编译语言）
        String sql = "CALL pro_findById(?);";

        //3：执行预编译语言
        stsm = conn.prepareCall(sql);
        
        //4：设置参数
        stsm.setInt(1, 4);
        
        //5：发送参数，执行sql(注意：CallableStatement执行sql只有executeQuery()方法)
        //返回ResultSet对象
         rs = stsm.executeQuery();
        
        //6：遍历，打印出结果
    while(rs.next()){
        int id = rs.getInt("id");
        String name = rs.getString("name");
        String sex = rs.getString("sex");
        System.out.println(id+","+name+","+sex);
         }
         }
    catch(Exception e){
        e.printStackTrace();
        throw new RuntimeException(e);
    }
    //7：关闭连接
    finally{
        Jdbcutil.close(conn, stsm, rs);
    }
    
    }

在sql中执行带有输入参数和输出参数的代码：

DELIMITER $
CREATE PROCEDURE pro_findout(IN sid INT ,OUT sname VARCHAR(20))
BEGIN
    SELECT NAME INTO sname FROM person WHERE id = sid;
END $

这段代码的存储过程代码是：

CALL pro_findout(4,@NAME);
//预编译语言就是
//CALL pro_findout(?,?);

使用CallableStatement来执行：

/**
         带有输入，输出参数的存储语言
         DELIMITER $
            CREATE PROCEDURE pro_findout(IN sid INT ,OUT sname VARCHAR(20))
        BEGIN
            SELECT NAME INTO sname FROM person WHERE id = sid;
        END $
     */
    private static void InAndOut() {
        
        Connection conn = null;
        CallableStatement stsm = null;
        
        try{
            
            //1：创建连接
            conn = Jdbcutil.getConnection();
            
            //2：创建sql存储语言（预编译）
            String sql = "CALL pro_findout(?,?)";
            
            //3：执行sql预编译语言
            stsm = conn.prepareCall(sql);
            
            //4：设置参数
            /**
             * 第一个参数是输入参数
             * 第二个参数是存储过程中的输出参数的jdbc类型（这里是varchar()） 
             *                在sql.Types中寻找对应的类型
             */
            //4.1：第一个参数的设置
            stsm.setInt(1, 4);
            //4.2：第二个参数的设置
            stsm.registerOutParameter(2,java.sql.Types.VARCHAR);
            
            //5：发送参数，执行sql：这个返回的不是ResultSet对象
            stsm.executeQuery();
            
            /**
             * 6：得到输出参数的值
             *         根据索引值，也就是预编译sql语言中输出参数的位置
             */
            String result = stsm.getString(2);
            System.out.println(result);    
        }
        catch(Exception e){
            e.printStackTrace();
            throw new RuntimeException(e);
        }
            //7：关闭连接
        finally{
            Jdbcutil.close(conn, stsm);
        }
        

    }