`
hyz301
  • 浏览: 376061 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

statement、prepareStatement、callableStatement的使用

    博客分类：
  • JDBC
 
阅读更多

       CallableStatement 对象为所有的DBMS 提供了一种以标准形式调用已储存过程的方法。已储 存过程储存在数据库中。对已储存过程的调用是 CallableStatement对象所含的内容。这种调用是 用一种换码语法来写的，有两种形式：一种形式带结果参，另一种形式不带结果参数。结果参数是 一种输出 (OUT) 参数，是已储存过程的返回值。两种形式都可带有数量可变的输入（IN 参数）、 输出（OUT 参数）或输入和输出（INOUT 参数）的参数。问号将用作参数的占位符。

1.带？参数的使用prepareStatement。这也是使用最多的。

 

public void addCategory(Category category) {
		String sql = "insert into category values(seque_cid.nextval,?,?)";
		PreparedStatement pstmt = null;
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, category.getCname());
			pstmt.setString(2, category.getCdesc());
			pstmt.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			//关闭
				if(pstmt!=null){
					try {
						pstmt.close();
					} catch (SQLException e) {
						e.printStackTrace();
					}
				}
				if(conn!=null){
					try {
						conn.close();
					} catch (SQLException e) {
						e.printStackTrace();
					}
				}
		}
		
	}

 2.不带参数，例如查所用，不需要到任何参数。使用statement。

 

 

	public List<Category> getAllCategorys() {
		List<Category>list = new ArrayList<Category>();
		String sql = "select * from category ";
		Category c = null;
		Statement stmt = null;
		ResultSet rs = null;
		try {
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				c = new Category();
				c.setCid(rs.getInt(1));
				c.setCname(rs.getString(2));
				c.setCdesc(rs.getString(3));
				list.add(c);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			//关闭
			if(rs!=null){
				try {
					rs.close();
				} catch (SQLException e) {
					
					e.printStackTrace();
				}
			}
			if(stmt!=null){
				try {
					stmt.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}
		return list;
	}

 3.调用存储过程的CallableStatement。

 

特别注意，存储过程的输出参数需要先进行注册。

public void callProcedure() {
		String sql = "{call proce_bigger(?,?,?,?)}";
		CallableStatement cstmt = null;
		try {
			cstmt = conn.prepareCall(sql);
			cstmt.setInt(1, 10);
			cstmt.setInt(2, 13);
			cstmt.registerOutParameter(3, Types.INTEGER);
			cstmt.registerOutParameter(4, Types.INTEGER);
			cstmt.setInt(4, 6);
			cstmt.executeUpdate();
			System.out.println(cstmt.getInt(3));
			System.out.println(cstmt.getInt(4));
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			//关闭
			if(cstmt!=null){
				try {
					cstmt.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if(conn!=null){
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}
		
	}

 1  使用不带参数的存储过程 

 

public static void executeStoredProcedure(Connection con) {
		try {
			CallableStatementcstmt = con
					.prepareCall("{calldbo.GetContactFormalNames}");
			ResultSetrs = cstmt.executeQuery();
			while (rs.next()) {
				System.out.println(rs.getString("FormalName"));
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			rs.close();
			cstmt.close();
		}
	}
 

 

2 使用带有输入参数的存储过程 

 

public static void executeStoredProcedure(Connection con) {
		try {
			CallableStatementcstmt = con
					.prepareCall("{call dbo.uspGetEmployeeManagers(?)}");
			cstmt.setInt(1, 50);
			ResultSetrs = cstmt.executeQuery();
			while (rs.next()) {
				System.out.println("EMPLOYEE:");
				System.out.println(rs.getString("LastName") + ", "
						+ rs.getString("FirstName"));
				System.out.println("MANAGER:");
				System.out.println(rs.getString("ManagerLastName") + ", "
						+ rs.getString("ManagerFirstName"));
				System.out.println();
			}
		}

		catch (Exception e) {
			e.printStackTrace();
		} finally {
			rs.close();
			cstmt.close();
		}
	}
 

 

3 使用带有输出参数的存储过程 

 

public static void executeStoredProcedure(Connection con) {
		try {
			CallableStatementcstmt = con
					.prepareCall("{call dbo.GetImmediateManager(?, ?)}");
			cstmt.setInt(1, 5);
			cstmt.registerOutParameter(2, java.sql.Types.INTEGER);
			cstmt.execute();
			System.out.println("MANAGER ID: " + cstmt.getInt(2));
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
 

 

4 使用带有返回状态的存储过程（目前测试状态返回只能是int类型） 

作为示例，在 SQL Server 2005 AdventureWorks 示例数据库中创建以下存储过程： 

 

CREATE PROCEDURE CheckContactCity      @cityNameCHAR(50)ASBEGIN      IF ((SELECT COUNT(*)      FROM Person.Address      WHERE City = @cityName) > 1)      RETURN 1ELSE      RETURN 0END
 

 

 

public static void executeStoredProcedure(Connection con) {
		try {
			CallableStatementcstmt = con
					.prepareCall("{? = call dbo.CheckContactCity(?)}");
			cstmt.registerOutParameter(1, java.sql.Types.INTEGER);
			cstmt.setString(2, "Atlanta");
			cstmt.execute();
			System.out.println("RETURN STATUS: " + cstmt.getInt(1));
		}
		
		catch (Exception e) {
			e.printStackTrace();
		}finally{
			cstmt.close(); 
		}
	}
 

 

注：在sql中执行该存储过程的方法： declare @c int 

exec @c=CheckContactCity 'Atlanta' print @c 

5 使用带有更新记数的存储过程 

作为示例，在 SQL Server 2005 AdventureWorks 示例数据库中创建以下表和存储过程： 

CREATE TABLE TestTable       (Col1 int IDENTITY,         Col2 varchar(50),         Col3 int);  
CREATE PROCEDURE UpdateTestTable 
      @Col2 varchar(50),       @Col3 int AS BEGIN 
      UPDATE TestTable 
      SET Col2 = @Col2, Col3 = @Col3 END;

 

public static void executeUpdateStoredProcedure(Connection con) {
		try {
			CallableStatementcstmt = con
					.prepareCall("{call dbo.UpdateTestTable(?, ?)}");
			cstmt.setString(1, "A");
			cstmt.setInt(2, 100);
			cstmt.execute();
			int count = cstmt.getUpdateCount();
			System.out.println("ROWS AFFECTED: " + count);
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			cstmt.close();  
		}
	}

 

  

附加说明 

 

JDBC调用存储过程: CallableStatement 

在Java里面调用存储过程，写法那是相当的固定： Class.forName(.... 

Connection conn = DriverManager.getConnection(.... /** 

*p是要调用的存储过程的名字，存储过程的4个参数，用4个？号占位符代替 *其余地方写法固定 */ 

CallableStatementcstmt = conn.prepareCall("{call p(?,?,?,?)}"); /** 

*告诉JDBC，这些个参数，哪些是输出参数，输出参数的类型用java.sql.Types来指定 

*下面的意思是，第3个？和第4个？是输出参数，类型是INTEGER的 *Types后面具体写什么类型，得看你的存储过程参数怎么定义的 

*/ 

cstmt.registerOutParameter(3, Types.INTEGER); cstmt.registerOutParameter(4, Types.INTEGER); /** 

*在我这里第1个？和第2个？是输入参数，第3个是输出参数，第4个既输入又输出 

*下面是设置他们的值,第一个设为3，第二个设为4，第4个设置为5 *没设第3个，因为它是输出参数 */ 

cstmt.setInt(1, 3); cstmt.setInt(2, 4); cstmt.setInt(4, 5); //执行 

cstmt.execute(); 

//把第3个参数的值当成int类型拿出来 int three = cstmt.getInt(3); System.out.println(three); 

//把第4个参数的值当成int类型拿出来 int four = cstmt.getInt(4); System.out.println(four); 

//用完别忘给人家关了，后开的先关 cstmt.close(); conn.close(); 

JDBC调用存储过程，掌握这一个程序足够了. 

以下是上面程序使用的存储过程的代码，我用的是Oracle数据库，不过不论是什么数据库，对于你 

的程序，JDBC这一端写法都是一样的. create or replace procedure p 

            (v_a in number,v_bnumber,v_ret out number,v_temp in out number) is begin 

           if(v_a>v_b) then v_ret := v_a;            else v_ret := v_b; 

           end if; v_temp := v_temp + 1; end;

 

分享到：
| UML 构造型
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    JDBC-Student.rar_callablestatement_dbtoobject_java 学员 管理 系统_jdbc

    2. **PrepareStatement**：PrepareStatement主要用于预编译SQL语句，它允许我们在执行多次SQL操作时只需要编译一次，从而提高效率。在学员管理系统的增删改查操作中，我们可以看到PrepareStatement如何动态设置参数...

    java数据库连接Statement

    PreparedStatement pstmt = con.prepareStatement("INSERT INTO Table1 (a, b) VALUES (?, ?)"); pstmt.setInt(1, 1); pstmt.setString(2, "value"); pstmt.executeUpdate(); ``` ### CallableStatement `...

    JDBC技术使用标准的 SQL 语言对数据库表中的数据进行访问，以及增删查改

    例如，`createStatement()`用于创建Statement对象，`prepareStatement()`用于创建PreparedStatement对象，它们分别用于执行无参数和有参数的SQL语句。 3. Statement：Statement接口用于执行静态SQL语句，返回结果集...

    JDBC常考知识点，常用api

    - `prepareStatement(String sql)`：返回一个PreparedStatement对象，用于执行预编译的SQL语句，支持参数绑定，提高效率并减少SQL注入风险。 - `prepareCall(String sql)`：返回CallableStatement对象，用于调用...

    Java的数据库连接编程 .pdf

    PreparedStatement pstmt = conn.prepareStatement(sql); // 设置参数 pstmt.setString(1, "John Doe"); // 执行查询 ResultSet rs = pstmt.executeQuery(); // 处理结果集 while (rs.next()) { System....

    DM7程序员手册.pdf

    #### 5.6 Statement/PrepareStatement/CallableStatement 分别介绍了Statement、PreparedStatement和CallableStatement的使用方法。 #### 5.7 ResultSet 讲解了如何使用ResultSet处理查询结果。 #### 5.8 流与大...

    JDBC学习文档

    5. **创建带有类型、并发性和保持性的PreparedStatement**：`PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)` - **用途**：创建一个带...

    JDBC执行SQL操作.docx

    PreparedStatement pstmt = con.prepareStatement(sql); pstmt.setString(1, "男"); ResultSet rs = pstmt.executeQuery(); ``` 3. CallableStatement：用于调用数据库的存储过程。例如： ```java String call = "...

    dm7程序员手册

    在此章节，程序员可以学习到JDBC的介绍、基本示例、DMJDBC特性、DMJDBC扩展、建立JDBC连接以及使用Statement/PrepareStatement/CallableStatement等对象。另外，还介绍了如何处理ResultSet、流与大对象、元数据以及...

    01_传智播客JDBC_jdbc的理论概述

    - 创建Statement或PreparedStatement对象：根据需求选择合适的对象，例如`conn.createStatement()`或`conn.prepareStatement(sql)`。 - 执行SQL语句：调用Statement的executeQuery()或executeUpdate()方法。 - 处理...

    java连接odbc

    * `PreparedStatement` 对象：用于执行参数化的 SQL 语句，可以使用 `Connection.prepareStatement(String sql)` 方法创建，例如： ```java PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM users...

    Java使用Jdbc连接Oracle执行简单查询操作示例

    stmt = conn.prepareStatement(sql); stmt.setString(1, "pek"); res = stmt.executeQuery(); ... } ``` 四、总结 本文详细分析了Java使用Jdbc连接Oracle数据库并执行简单查询操作的过程，并提供了一个简单的...

    java之jdbc项目文件

    PreparedStatement pstmt = conn.prepareStatement("INSERT INTO employees VALUES (?, ?)"); pstmt.setString(1, "John Doe"); pstmt.setInt(2, 30); pstmt.executeUpdate(); ``` 5. **处理结果集ResultSet**...

    Java高级教程课件 java数据库教程 JDBC教程 4-jdbc编程(2)（共5页）.pptx

    PreparedStatement pStmt = conn.prepareStatement("insert into emp (empno, ename) values(?, ?)"); pStmt.setInt(1, employeeNo); pStmt.setString(2, employeeName); pStmt.executeUpdate(); ``` 2. ...

    Java中jdbc jar包

    PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1, 1); ResultSet rs = pstmt.executeQuery(); while (rs.next()) { System.out.println(rs.getString("username")); } rs.close(); ...

    JDBC使用技巧

    PreparedStatement ps = conn.prepareStatement("INSERT INTO dept2 VALUES (?, ?, ?)"); ps.setInt(1, deptno); ps.setString(2, dname); ps.setString(3, loc); ps.execute(); ``` 2. **调用存储过程**： ...

    Java访问数据库.pdf

    PreparedStatement pstmt = con.prepareStatement("{call dbo.uspGetEmployeeManagers(?)}"); pstmt.setInt(1, 50); ResultSet rs = pstmt.executeQuery(); ``` - **仅输出参数**： ```java ...

    JDBC数据库连接测试

    PreparedStatement pstmt = conn.prepareStatement(sql); // 设置参数 pstmt.setString(1, "John"); pstmt.setString(2, "john@example.com"); // 执行SQL int rowsAffected = pstmt.executeUpdate(); // 关闭...

    JDBC连接数据库JDBC连接数据库.ppt

    PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1, 10); pstmt.setString(2, "John Doe"); pstmt.executeUpdate(); ``` 3. **CallableStatement对象**：用于调用数据库中的存储过程。...

    java业务层框架开发ibatis(java源码)

    public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException { return null;} public CallableStatement prepareCall...

Magicbox
Global site tag (gtag.js) - Google Analytics