视频1 视频21 视频41 视频61 视频文章1 视频文章21 视频文章41 视频文章61 推荐1 推荐3 推荐5 推荐7 推荐9 推荐11 推荐13 推荐15 推荐17 推荐19 推荐21 推荐23 推荐25 推荐27 推荐29 推荐31 推荐33 推荐35 推荐37 推荐39 推荐41 推荐43 推荐45 推荐47 推荐49 关键词1 关键词101 关键词201 关键词301 关键词401 关键词501 关键词601 关键词701 关键词801 关键词901 关键词1001 关键词1101 关键词1201 关键词1301 关键词1401 关键词1501 关键词1601 关键词1701 关键词1801 关键词1901 视频扩展1 视频扩展6 视频扩展11 视频扩展16 文章1 文章201 文章401 文章601 文章801 文章1001 资讯1 资讯501 资讯1001 资讯1501 标签1 标签501 标签1001 关键词1 关键词501 关键词1001 关键词1501 专题2001
FORM程序中Oracle与Access表的导入和导出
2020-11-09 08:13:39 责编:小采
文档

问题: 如何在FORM的 程序 中实现Oracle与Access表之间的 导入 和 导出 。 解答: 准备工作: 1.安装OCA。运行Developer的安装盘,选择自定义安装,选择Oracle Open Client Adapter for ODBC安装。 2.在数据源(ODBC)中添加DSN。控制面板-管理工具-数据源(ODB

    问题:如何在FORM的程序中实现Oracle与Access表之间的导入和导出。

解答:

准备工作:

1.安装OCA。运行Developer的安装盘,选择自定义安装,选择Oracle Open Client Adapter for ODBC安装。

2.在数据源(ODBC)中添加DSN。控制面板->管理工具->数据源(ODBC),选择“用户DSN”,添加要进行操作的Access的文件。在“高级”选项里,填上“登录名称”和“密码”(很重要,在程序中会用到)。

下面以实际例子来说明:

假设在Oracle中和Access中都有一个student表,表中字段相同(name char(10) ,age number(2)),在准备工作2中的“数据源名”为test,“登录名称”和“密码”都为user。

下面为从Oracle导出到Access的procedure:

引用片段:

PROCEDURE oracle_to_access IS

connection_id EXEC_SQL.ConnType;

action_cursor EXEC_SQL.CursType;

ignore PLS_INTEGER;

t_name student.name%type;

t_age student.age%type;

cursor temp_cursor is select * from student;

BEGIN

connection_id:= EXEC_SQL.OPEN_CONNECTION('user/user@odbc:test');

action_cursor := EXEC_SQL.OPEN_CURSOR(connection_id);

EXEC_SQL.PARSE(connection_id, action_cursor,'delete * from student');

ignore := EXEC_SQL.EXECUTE(connection_id, action_cursor);

EXEC_SQL.CLOSE_CURSOR(connection_id,action_cursor);

open temp_cursor;

export_count := 0;

action_cursor := EXEC_SQL.OPEN_CURSOR(connection_id);

EXEC_SQL.PARSE(connection_id, action_cursor,'INSERT INTO student(name,age) values(:1,:2)');

loop

fetch temp_cursor into t_name,t_age;

exit when temp_cursor%notfound;

EXEC_SQL.BIND_VARIABLE(connection_id,action_cursor, ':1', t_name);

EXEC_SQL.BIND_VARIABLE(connection_id,action_cursor, ':2', t_age);

ignore := EXEC_SQL.EXECUTE(connection_id, action_cursor);

end loop;

close temp_cursor;

EXEC_SQL.PARSE(connection_id, action_cursor,'commit');

ignore := EXEC_SQL.EXECUTE(connection_id,action_cursor);

EXEC_SQL.CLOSE_CURSOR(connection_id,action_cursor);

EXEC_SQL.CLOSE_CONNECTION(connection_id);

EXCEPTION

WHEN EXEC_SQL.PACKAGE_ERROR THEN

IF EXEC_SQL.LAST_ERROR_CODE(connection_id) != 0 THEN

message('数据导出至ACCESS失败: ' || TO_CHAR(EXEC_SQL.LAST_ERROR_CODE(connection_id)) || ': ' || EXEC_SQL.LAST_ERROR_MESG(connection_id));

END IF;

IF EXEC_SQL.IS_CONNECTED(connection_id) THEN

IF EXEC_SQL.IS_OPEN(connection_id,action_cursor) THEN

EXEC_SQL.CLOSE_CURSOR(connection_id,action_cursor);

END IF;

EXEC_SQL.CLOSE_CONNECTION(connection_id);

END IF;

END;

下面为从Access导出到Oracles的procedure:

PROCEDURE Access_to_oracle IS

connection_id EXEC_SQL.ConnType;

action_cursor EXEC_SQL.CursType;

ignore PLS_INTEGER;

t_name student.name%type;

t_age student.age%type;

BEGIN

connection_id := EXEC_SQL.OPEN_CONNECTION('user/user@odbc:test');

action_cursor := EXEC_SQL.OPEN_CURSOR(connection_id);

delete from student;

EXEC_SQL.PARSE(connection_id, action_cursor,'select name,age from student');

ignore := EXEC_SQL.EXECUTE(connection_id, action_cursor);

exec_sql.define_column(connection_id,action_cursor,1,t_name,10);

exec_sql.define_column(connection_id,action_cursor,2,t_age);

ignore := EXEC_SQL.EXECUTE(connection_id, action_cursor);

while(exec_sql.fetch_rows(connection_id,action_cursor)>0)

loop

exec_sql.column_value(connection_id,action_cursor,1,t_name);

exec_sql.column_value(connection_id,action_cursor,2,t_age);

insert into test(name,age) values(t_name,t_age);

end loop;

commit;

EXEC_SQL.CLOSE_CURSOR(connection_id,action_cursor);

EXEC_SQL.CLOSE_CONNECTION(connection_id);

EXCEPTION

WHEN EXEC_SQL.PACKAGE_ERROR THEN

IF EXEC_SQL.LAST_ERROR_CODE(connection_id) != 0 THEN

message('数据导入至ORACLE失败: ' || TO_CHAR(EXEC_SQL.LAST_ERROR_CODE(connection_id)) || ': ' || EXEC_SQL.LAST_ERROR_MESG(connection_id));

END IF;

IF EXEC_SQL.IS_CONNECTED(connection_id) THEN

IF EXEC_SQL.IS_OPEN(connection_id,action_cursor) THEN

EXEC_SQL.CLOSE_CURSOR(connection_id,action_cursor);

END IF;

EXEC_SQL.CLOSE_CONNECTION(connection_id);

END IF;

END;

注意:EXEC_SQL.BIND_VARIABLE中绑定的变量只能是以下三种类型:NUMBER,DATE,VARCHAR2。对于Access中的“是/否”的布尔型变量,可以用NUMBER类型的1和0来表示。如果Access中的表名或者字段名中有空格,在写SQL语句的时候可以用双引号把表名或者字段名包括起来,如:本例中如果Access中表名为student detail,字段名分别为student name和student age,那插入数据的SQL语句为:insert into “student detail”(“student name”,”student age”) values(:1,:2)。

下载本文
显示全文
专题