使用JDBC操作存储过程,jdbc操作存储过程
使用JDBC操作存储过程,可以借助于一个借口CallableStatement实现。
此时调用存储过程的sql语句为:{call procedure_name [(arg1),(arg2)]}
而CallableStatement可以通过数据库连接对象的prepareCall()方法获得
例如:
conn.prepareCall(sql);
如果此时的存储过程有输出参数,可以通过他的registerOutParameter()方法将输出参数注册为JDBC类型。例如:
registerOutParameter(int parameterIndex,int sqlType)
下面看一个统计学生人数示例,首先看数据库中的记录:
不难看出学生表中公有七条记录。
下面写一个存储过程统计学生表中的人数。
create or replace procedure getStudentCount(v_student out number) is begin select count(*) into v_student from student; end getStudentCount;
然后测试一下这个存储过程:
declare v_count number; begin getstudentCount(v_count); dbms_output.put_line(v_count); end;
输出结果为7。存储过程没有问题。
然后在看如何使用JDBC调用存储过程。
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ProcedureDemo {
public static void main(String[] args) {
Connection conn = null;
int studentCount = 0;
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:ORCL",
"myhr", "myhr");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
String sql = "{call getStudentCount(?)}";
try {
CallableStatement proc = conn.prepareCall(sql);
proc.registerOutParameter(1, java.sql.Types.INTEGER);
proc.execute();
studentCount = proc.getInt(1);
} catch (SQLException e) {
e.printStackTrace();
}
System.out.println(studentCount);
}
}
这时在控制台输出7,证明调用存储过程成功。
那说明sun的驱动比SQLServerDriver的兼容性好啊
你要用jdbc,就得按标准的jdbc来跑,execute就够了,别用executeQuery……
JDBC连接数据库
•创建一个以JDBC连接数据库的程序,包含7个步骤:
1、加载JDBC驱动程序:
在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),
这通过java.lang.Class类的静态方法forName(String className)实现。
例如:
try{
//加载MySql的驱动类
Class.forName("com.mysql.jdbc.Driver") ;
}catch(ClassNotFoundException e){
System.out.println("找不到驱动程序类 ,加载驱动失败!");
e.printStackTrace() ;
}
成功加载后,会将Driver类的实例注册到DriverManager类中。
2、提供JDBC连接的URL
•连接URL定义了连接数据库时的协议、子协议、数据源标识。
•书写形式:协议:子协议:数据源标识
协议:在JDBC中总是以jdbc开始 子协议:是桥连接的驱动程序或是数据库管理系统名称。
数据源标识:标记找到数据库来源的地址与连接端口。
例如:
(MySql的连接URL)
jdbc:mysql: //localhost:3306/test?useUnicode=true&characterEncoding=gbk ;
useUnicode=true:
表示使用Unicode字符集。如果characterEncoding设置为 gb2312或GBK,本参数必须设置为true 。characterEncoding=gbk:字符编码方式。
3、创建数据库的连接
•要连接数据库,需要向java.sql.DriverManager请求并获得Connection对象, 该对象就代表一个数据库的连接。
•使用DriverManager的getConnectin(String url , String username , String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和 密码来获得。
例如: //连接MySql数据库,用户名和密码都是root
String url = "jdbc:mysql://localhost:3306/test" ;
String username = "root" ;
String password = "root" ;
try{
Connection con = DriverManager.getConnection(url , username , password ) ;
}catch(SQLException ......余下全文>>