当前位置： 移动技术网 > IT编程>开发语言>Java > 详解Java的JDBC API的存储过程与SQL转义语法的使用

详解Java的JDBC API的存储过程与SQL转义语法的使用

2019年07月22日  | 移动技术网IT编程  | 我要评论

正如一个connection对象创建statement和preparedstatement对象，它也创造了callablestatement对象这将被用来执行调用数据库存储过程。

创建callablestatement对象：
假设，需要执行以下oracle存储过程：

create or replace procedure getempname 
  (emp_id in number, emp_first out varchar) as
begin
  select first into emp_first
  from employees
  where id = emp_id;
end;

注意: 上面已经写过oracle存储过程，但我们正在使用mysql数据库，写相同的存储过程对于mysql如下，以emp数据库中创建它：

delimiter $$

drop procedure if exists `emp`.`getempname` $$
create procedure `emp`.`getempname` 
  (in emp_id int, out emp_first varchar(255))
begin
  select first into emp_first
  from employees
  where id = emp_id;
end $$

delimiter ;

三种类型的参数有：in，out和inout。preparedstatement对象只使用in参数。 callablestatement对象可以使用所有的三个。

这里是每个定义：

  • in：它的值是在创建sql语句时未知的参数。将值绑定到setxxx（）方法的参数。
  • out：其值是由它返回的sql语句提供的参数。你从out参数的getxxx（）方法检索值。
  • inout：同时提供输入和输出值的参数。绑定setxxx（）方法的变量，并与getxxx（）方法检索值。

下面的代码片段显示了如何使用该connection.preparecall（）方法实例化基于上述存储过程callablestatement对象：

callablestatement cstmt = null;
try {
  string sql = "{call getempname (?, ?)}";
  cstmt = conn.preparecall (sql);
  . . .
}
catch (sqlexception e) {
  . . .
}
finally {
  . . .
}

string变量的sql表示存储过程，使用参数占位符。

使用callablestatement对象是使用preparedstatement对象。必须将值绑定到所有的参数执行该语句之前，否则将收到一个sqlexception。

如果有in参数，只要按照适用于preparedstatement对象相同的规则和技巧;使用对应于要绑定java数据类型的setxxx（）方法。

当使用out和inout参数就必须采用额外callablestatement方法的registeroutparameter（）。registeroutparameter（）方法jdbc数据类型绑定到数据类型的存储过程返回。

一旦调用存储过程，用getxxx（）方法的输出参数检索值。这种方法投射sql类型的值检索到java数据类型。

关闭callablestatement 对象：
正如关闭其他statement对象，出于同样的原因，也应该关闭callablestatement对象。

close（）方法简单的调用将完成这项工作。如果关闭了connection对象首先它会关闭callablestatement对象为好。然而，应该始终明确关闭的callablestatement对象，以确保正确的清除。

callablestatement cstmt = null;
try {
  string sql = "{call getempname (?, ?)}";
  cstmt = conn.preparecall (sql);
  . . .
}
catch (sqlexception e) {
  . . .
}
finally {
  cstmt.close();
}

ps：callablestatement对象实例
下面是利用callablestatement连同下列getempname()的mysql存储过程的例子：

请确定已经在emp数据库中创建该存储过程。可以使用mysql查询浏览器来完成它。

delimiter $$

drop procedure if exists `emp`.`getempname` $$
create procedure `emp`.`getempname` 
  (in emp_id int, out emp_first varchar(255))
begin
  select first into emp_first
  from employees
  where id = emp_id;
end $$

delimiter ;

基于对环境和数据库安装在前面的章节中进行，这个范例程式码已被写入。

复制下面的例子中jdbcexample.java，编译并运行，如下所示：

//step 1. import required packages
import java.sql.*;

public class jdbcexample {
  // jdbc driver name and database url
  static final string jdbc_driver = "com.mysql.jdbc.driver"; 
  static final string db_url = "jdbc:mysql://localhost/emp";

  // database credentials
  static final string user = "username";
  static final string pass = "password";
  
  public static void main(string[] args) {
  connection conn = null;
  callablestatement stmt = null;
  try{
   //step 2: register jdbc driver
   class.forname("com.mysql.jdbc.driver");

   //step 3: open a connection
   system.out.println("connecting to database...");
   conn = drivermanager.getconnection(db_url,user,pass);

   //step 4: execute a query
   system.out.println("creating statement...");
   string sql = "{call getempname (?, ?)}";
   stmt = conn.preparecall(sql);
   
   //bind in parameter first, then bind out parameter
   int empid = 102;
   stmt.setint(1, empid); // this would set id as 102
   // because second parameter is out so register it
   stmt.registeroutparameter(2, java.sql.types.varchar);
   
   //use execute method to run stored procedure.
   system.out.println("executing stored procedure..." );
   stmt.execute();

   //retrieve employee name with getxxx method
   string empname = stmt.getstring(2);
   system.out.println("emp name with id:" + 
        empid + " is " + empname);
   stmt.close();
   conn.close();
  }catch(sqlexception se){
   //handle errors for jdbc
   se.printstacktrace();
  }catch(exception e){
   //handle errors for class.forname
   e.printstacktrace();
  }finally{
   //finally block used to close resources
   try{
     if(stmt!=null)
      stmt.close();
   }catch(sqlexception se2){
   }// nothing we can do
   try{
     if(conn!=null)
      conn.close();
   }catch(sqlexception se){
     se.printstacktrace();
   }//end finally try
  }//end try
  system.out.println("goodbye!");
}//end main
}//end jdbcexample

现在编译上面的例子如下：

c:>javac jdbcexample.java

当运行jdbcexample，它会产生以下结果：

c:>java jdbcexample

connecting to database...
creating statement...
executing stored procedure...
emp name with id:102 is zaid
goodbye!

jdbc的sql转义语法：
转义语法使能够使用通过使用标准的jdbc方法和属性，无法使用数据库的某些特性的灵活性。

一般的sql转义语法格式如下：

{keyword 'parameters'}

这里有以下这些，会发现非常有用的，而这样做的jdbc编程的转义序列：

d, t, ts 关键字:
他们帮助确定日期，时间和时间戳记文字。如所知，没有两个数据库管理系统是基于时间和日期的方式相同。此转义语法告诉驱动程序呈现在目标数据库的格式，日期或时间。实现例子：

{d 'yyyy-mm-dd'}

其中yyyy=年，mm =月，dd =日。使用这种语法 {d '2009-09-03'}是2009年3月9日。

下面是一个简单的例子说明如何插入日期表：

//create a statement object
stmt = conn.createstatement();
//insert data ==> id, first name, last name, dob
string sql="insert into students values" +
       "(100,'zara','ali', {d '2001-12-16'})";

stmt.executeupdate(sql);

同样，可以使用以下两种语法之一，无论是 t 或 ts：

{t 'hh:mm:ss'}

其中hh=小时，mm=分，ss=秒。使用此语法 {t '13:30:29'}是下午1点三十分29秒.

{ts 'yyyy-mm-dd hh:mm:ss'}

这是上述两种语法 'd' 和  't' 来表示时间戳结合语法。

escape 关键字:
该关键字标识like子句中使用的转义字符。有用使用sql通配符％，其中匹配零个或多个字符时。例如：

string sql = "select symbol from mathsymbols
       where symbol like '\%' {escape ''}";
stmt.execute(sql);

如果使用反斜杠字符（）作为转义字符，还必须使用两个反斜杠字符在java字符串字面，因为反斜杠也是一个java转义字符。

fn 关键字:
此关键字代表在dbms中使用标量函数。例如，可以使用sql length函数计算ge字符串的长度：

{fn length('hello world')}

这将返回11，字符串 'hello world'的长度。.

call 关键字:
此关键字是用来调用存储过程。例如，对于一个存储过程，需要一个in参数，请使用以下语法：

{call my_procedure(?)};

对于一个存储过程，需要一个in参数并返回一个out参数，使用下面的语法：

{? = call my_procedure(?)};

oj 关键字:
此关键字用来表示外部联接。其语法如下：

{oj outer-join}

外连接表={left| right| full}外连接{表|外连接}的搜索条件。例如：

string sql = "select employees 
       from {oj thistable right
       outer join thattable on id = '100'}";
stmt.execute(sql);

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网