oracle 调用 java 程序连 sqlserver2005 1 、在 oracle 的 sys-sysdba 下登陆 写一个 java source 程序链接 sqlserver2005 : create or replace and compile java source named test as import java.sql.connection; import java.sql.drivermanager; import
oracle调用java程序连sqlserver2005
1、在oracle的sys-sysdba下登陆
写一个java source程序链接sqlserver2005:
create or replace and compile java source named test as
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
public class excutesql1
{
public static string entry(string str1,string str2) {
string drivername = com.microsoft.sqlserver.jdbc.sqlserverdriver;
// 加载jdbc驱动
string a = 0;
string dburl = jdbc:sqlserver://localhost:1433;databasename=wb; // 链接数据库服务和驱动sample
string username = sa; // 用户名
string userpwd = giap; // 密码
connection dbconn;
try {
a = 1;
class.forname(drivername);
dbconn = drivermanager.getconnection(dburl, username, userpwd);
string sql = insert into ry_jbxx (rybh,xm) values (' + str1
+ ',' + str2 + ');
preparedstatement pstmt = dbconn.preparestatement(sql);
pstmt.addbatch();
pstmt.executebatch();
a = 2;
} catch (exception e) {
e.printstacktrace();
a = error;
}
return a;
}
}
(注:java程序可以用loadjava的方式load到oracle中,也可以利用plsql写java source)
2、在oracle的sys-sysdba下登陆
用loadjava将sqlserver2005驱动load到oracle,在dos下执行:
loadjava -u sys/giap@zhxtdb -r -v sqljdbc.jar
测试链接是否成功:
写一个函数:
create or replace function insert2(a varchar2, b varchar2) return varchar2 as
language java name 'excutesql1.entry(java.lang.string,java.lang.string) return java.long.string';
测试链接!~
(注:一定要在sysdba下执行)
sqlserver2005测试数据库:
create table [dbo].[msg](
[tel] [varchar](50) not null,
[msg] [varchar](50) null
)
3、测试成功后在普通用户(giapzhxt)下建表:
create table msg
(
tel varchar2(20),
msg varchar2(200)
)
tablespace giapdata
pctfree 10
initrans 1
maxtrans 255
storage
(
initial 64k
minextents 1
maxextents unlimited
);
4、在oracle的sys-sysdba下登陆
new一个存储过程
create or replace procedure insertsqlserver2005(a varchar2, b varchar2) as
language java name 'excutesql1.entry(java.lang.string,java.lang.string)';
在sys-sysdba下登陆new一个普通用户(giapzhxt)下表的触发器来执行存储过程:
create or replace trigger tri_zhxt_msg
after insert on giapzhxt.msg
for each row
begin
insertsqlserver2005(:new.tel,:new.msg);
end tri_zhxt_msg;
实现:oracle中的表通过java程序向sqlserver2005表中写数据!~