oracle触发器将数据插入到另一个服务器的oracle数据库中

oracle触发器将数据插入到另一个服务器的oracle数据库中要用dblink实现两台服务器的数据共享。

oracle db_link 和触发器实现不同数据库表的同步

---创建dblink,dblink_test名称，（被同步数据库的a_test）ST10766用户名，ep密码，ass100连接字符串

create public database link dblink_test

connect to ST10766 identified by ep

using 'ass100';

---删除dblink

----drop public database link dblink_test;

----建立表

create table a_test (id int,name varchar(20),pass varchar(20))

select from a_test;

insert into a_test (id,name,pass) values (1,'zzn','shanshan')

insert into b_test (id,username,password) values('1','zxl','xiaolan')

----在目的数据库上，测试dblink，查询的是源数据库的表

select from a_test@dblink_orc10;

select from a_test;

----创建触发器

create or replace trigger a_b_test

after insert or update or delete

on a_test

for each row

begin

if deleting then

delete from b_test where id=:oldid;

end if;

if inserting then

insert into b_test(id,username,password) //b_test表的字段

values(:newid,:newname,:newpass); //a_test表的字段

end if;

if updating then

update b_test set username=:newname,password=:newpass where id=:oldid;

end if;

end a_b_test;

同步数据库自动化脚本

#!/bin/sh

read -p "Please keyin your ssh host:" -t 30 host_ipread -p "Please keyin your ssh user:" -t 30 usernameread -p "Please keyin your ssh pass:" -t 30 passwordread -p "Please keyin your sync table list,separated by spaces:" -t 30 table_listdatetime=`date +%Y%m%d%H%M%S`

src_file="/tmp/data_$datetimesql"

tar_file="/tmp/data_$datetimetargz"

mysqldump -h127001 -uroot -ppass database_name $table_list > $src_filetar czvf $tar_file $src_file

/expect_scpsh $host_ip $username $password $tar_fileexpect_scpsh代码

#!/tools/bin/expect

set timeout 10

set host [lindex $argv 0]

set username [lindex $argv 1]

set password [lindex $argv 2]

set src_file [lindex $argv 3]

#set dest_file [lindex $argv 4]

spawn scp $src_file $username@$host:/home/$usernameexpect {

"(yes/no)"

{

send "yes\n"

expect "assword:" { send "$password\n"}

}

"assword:"

{

send "$password\n"

}

}

expect "100%"

expect eof

1、配置ODBC数据源。

2、使用SQL函数进行连接。

对于1、配置数据源，配置完以后就可以编程 *** 作数据库了。

对于2、使用SQL函数进行连接，参考代码如下：

#include<windowsh>

#include<sqlh>

#include<sqlexth>

void main()

{

HENV henv; //环境句柄

HDBC hdbc; //数据源句柄

HSTMT hstmt; //执行语句句柄

unsigned char datasource[]="数据源名称"; //即源中设置的源名称

unsigned char user[]= "用户名"; //数据库的帐户名

unsigned char pwd[]= "密码"; //数据库的密码

unsigned char search[]="select xm from stu where xh=0";

SQLRETURN retcode; //记录各SQL函数的返回情况

// 分配环境句柄

retcode= SQLAllocEnv(&henv); // 等介于 SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL

, &henv);

// 设置ODBC环境版本号为30

retcode= SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void)SQL_OV_ODBC3, 0);

// 分配连接句柄

retcode= SQLAllocConnect(henv,&hdbc); // 等介于 SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);

//设置连接属性,登录超时为rgbValue秒（可以没有）

// SQLSetConnectAttr(hdbc, SQL_LOGIN_TIMEOUT, (SQLPOINTER)(rgbValue), 0);

//直接连接数据源

// 如果是windows身份验证，第二、三参数可以是

，也可以是任何字串

//SQL_NTS 即 "

retcode= SQLConnect(hdbc,datasource, SQL_NTS, user, SQL_NTS , pwd, SQL_NTS );

//分配语句句柄

retcode= SQLAllocStmt(hdbc,&hstmt); // 等介于 SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);

//直接执行查询语句

retcode=SQLExecDirect(hstmt,search,SQL_NTS);

//将数据缓冲区绑定数据库中的相应字段（i是查询结果集列号，queryData是绑定缓冲区，BUFF_LENGTH是缓冲区长度）

SQLBindCol(hstmt, i, SQL_C_CHAR, queryData[i-1], BUFF_LENGTH, 0);

//遍历结果集到相应缓冲区 queryData

SQLFetch(hstmt);

/

对遍历结果的相关 *** 作，如显示等

/

//注意释放顺序，否则会造成未知错误！

SQLFreeHandle(SQL_HANDLE_STMT, hstmt);

SQLDisconnect(hdbc);

SQLFreeHandle(SQL_HANDLE_DBC, hdbc);

SQLFreeHandle(SQL_HANDLE_ENV, henv);

}

以上就是关于oracle触发器将数据插入到另一个服务器的oracle数据库中全部的内容，包括:oracle触发器将数据插入到另一个服务器的oracle数据库中、MySQL的导出数据库的自动化脚本中怎么实现免人工输入密码、c语言怎样连接数据库等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！