使用JDBC CallableStatements执行存储过程

时间  2019-11-18
标签 使用 jdbc callablestatements 执行 存储 过程 栏目 Java 繁體版
原文   原文链接

使用JDBC CallableStatements执行存储过程java

实验目的：掌握jdbc callableStatements 的执行过程。mysql

实验内容：掌握jdbc callableStatements 的执行过程。web

实验过程：sql

CallableStatement的全部超级接口为PreparedStatement、Statement、Wrapper。其中继承自PreparedStatement接口。CallableStatement主要是调用数据库中的存储过程。在使用CallableStatement时能够接收存储过程的返回值。CallableStatement对象为全部的DBMS提供了一种标准的形式去调用数据库中已存在的存储过程。对数据库中存储过程的调用是CallableStatement对象所含的内容。有两种形式：1：形式带结果参数；2：形式不带结果参数。结果参数是一种输出参数(存储过程当中的输出OUT参数)，是存储过程的返回值。两种形式都有带有数量可变的输入、输出、输入和输出的参数。用问号作占位符。数据库

       形式带结果参数语法格式：{ ? = call 存储过程名[(?, ?, ?, ...)]};app

       形式不带结果参数语法格式：{ call 存储过程名[(?, ?, ?, ...)]};PS方括号里面的内容无关紧要。ide

       CallableStatement接口中经常使用的方法。测试

       1：getInt(int parameterIndex)、getInt(String parameterName)、还有getString、getBigDecimal、getString、getDate、getURL等等都相似和PreparedStatement与Statement中的用法相似。this

       2：registerOutParameter(int parameterIndex, int sqlType):按顺序位置parameterIndex将OUT参数注册为JDBC类型sqlType。spa

       3：wasNull():查询最后一个读取的OUT参数是否为SQL Null。等等还有不少方法，感兴趣的读者能够自行查阅JDK API文档。

      讲解了那么多，不如一个例子来的痛快。下面经过一个例子让读者更清楚的看到CallableStatement的用法。

       首先在原先的t_employee表中添加表示干了多少年的tyear字段。

alter table t_employee add tyear int;

在数据库中编写存储过程统计指定id的userName的人，输出一下他一共赚了多少钱。

      JDBC代码：

 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
package com.panli.dbutil;
/**
 * 链接数据库
 */
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
  
public class DbUtil {
    //数据库驱动名字
    private static String jdbcName = "com.mysql.jdbc.Driver";
    //数据库协议地址
    private static String dbUrl = "jdbc:mysql://localhost:3306/db_user";
    //数据库用户名
    private static String dbUser = "root";
    //数据库密码
    private static String dbPassword = "123456";
     
     
    /**
     * 获取链接
     * @return
     * @throws Exception
     */
    public static Connection getCon() throws Exception{
        Class.forName(jdbcName);
        Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
        return conn;
    }
     
    /**
     * 关闭链接
     * @param stmt
     * @param conn
     * @throws Exception
     */
    public static void close(Statement stmt,Connection conn) throws Exception{
        if(stmt!=null){
            stmt.close();
            if(conn!=null){
                conn.close();
            }
        }
    }
     
    /**
     * 关闭链接
     * @param cstmt
     * @param conn
     * @throws Exception
     */
    public static void close(CallableStatement cstmt, Connection conn) throws Exception{
        if(cstmt!=null){
            cstmt.close();
            if(conn!=null){
                conn.close();
            }
        }
    }
     
     
    /**
     * 关闭链接
     * @param pstmt
     * @param conn
     * @throws SQLException
     */
    public static void close(PreparedStatement pstmt, Connection conn) throws SQLException{
        if(pstmt!=null){
            pstmt.close();
            if(conn!=null){
                conn.close();
            }
        }
    }
     
     
    /**
     * 重载关闭方法
     * @param pstmt
     * @param conn
     * @throws Exception
     */
    public void close(ResultSet rs,PreparedStatement pstmt, Connection conn) throws Exception{
        if(rs!=null){
            rs.close();
            if(pstmt!=null){
                pstmt.close();
                if(conn!=null){
                    conn.close();
                }
                 
            }
        }
         
    }
}
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package com.panli.model;
  
import java.io.File;
  
/**
 * model包下的cemployee类,对每一个字段进行建模
 * @author Peter
 *
 */
public class CEmployee {
    private int id;
    private String userName;
    private double salary;
    private String job;
    private int jobTypeId;
    private File context;
    private File pic;
    private double counts;
    /**
     * 默认的构造方法
     */
    public CEmployee() {
        super();
        // TODO Auto-generated constructor stub
    }
     
    /**
     * 带一个参数的构造方法
     * @param id
     */
    public CEmployee(int id) {
        super();
        this.id = id;
    }
     
    /**
     * 两个参数的构造方法
     * @param counts
     * @param userNames
     */
    public CEmployee(double counts, String userName) {
        // TODO Auto-generated constructor stub
        this.counts = counts;
        this.userName = userName;
    }
  
    /**
     * 重写toString()方法
     */
    @Override
    public String toString(){
        return userName+"一共赚了"+counts+"钱";
    }
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getUserName() {
        return userName;
    }
    public void setUserName(String userName) {
        this.userName = userName;
    }
    public double getSalary() {
        return salary;
    }
    public void setSalary(double salary) {
        this.salary = salary;
    }
    public String getJob() {
        return job;
    }
    public void setJob(String job) {
        this.job = job;
    }
    public int getJobTypeId() {
        return jobTypeId;
    }
    public void setJobTypeId(int jobTypeId) {
        this.jobTypeId = jobTypeId;
    }
  
    public File getContext() {
        return context;
    }
  
    public void setContext(File context) {
        this.context = context;
    }
  
    public File getPic() {
        return pic;
    }
  
    public void setPic(File pic) {
        this.pic = pic;
    }
  
    public double getCounts() {
        return counts;
    }
  
    public void setCounts(double counts) {
        this.counts = counts;
    }
     
}
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
package com.panli.dao;
  
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.Types;
import java.util.ArrayList;
import java.util.List;
  
import com.panli.dbutil.DbUtil;
import com.panli.model.CEmployee;
  
public class CountsEmployeeDao {
    private static DbUtil dbUtil = new DbUtil();
    /**
     * 调用存储过程获得指定ID用户的一共赚了多少钱
     * @param employee
     * @return
     * @throws Exception
     */
    public static List getCountsById(CEmployee cemployee)throws Exception{
        List list = new ArrayList();
        Connection conn = dbUtil.getCon();
        String sql = "{call pro_getCountById(?, ?, ?)}";
        CallableStatement cstmt = conn.prepareCall(sql);
        cstmt.setInt(1, cemployee.getId());
        cstmt.registerOutParameter(2, Types.DOUBLE);
        cstmt.registerOutParameter(3, Types.VARCHAR);
        cstmt.execute();
        double counts = cstmt.getDouble("counts");
        String userNames = cstmt.getString("userNames");
        CEmployee emp = new CEmployee(counts, userNames);
        list.add(emp);
        dbUtil.close(cstmt, conn);
        return list;
    }
    /**
     * 作测试的主方法
     * @param args
     */
    public static void main(String[] args)throws Exception {
         
        CEmployee cemployee = new CEmployee(1);
        List list = getCountsById(cemployee);
        for(CEmployee cemp: list){
            System.out.println(cemp);
        }
    }
}

建立的存储过程为：

 
1
2
3
4
5
6
7
8
9
10
11
delimiter &&
create procedure pro_getCountById(in tid int, out counts double, out userNames varchar(20))
begin
  select salary*tyear into counts from t_employee where id = tid;
  select userName into userNames from t_employee where id = tid;
end
&&
  
测试：
call pro_getCountById(1, @counts, @userNames);
select @counts, @userNames;

 

1
alter table t_employee add tyear int ;

---恢复内容结束---

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程