服务热线:13616026886

技术文档 欢迎使用技术文档,我们为你提供从新手到专业开发者的所有资源,你也可以通过它日益精进

位置:首页 > 技术文档 > 数据库技术 > Oracle技术 > Oracle开发 > 查看文档

实例讲解oracle到sql server主键的迁移

【赛迪网-it技术报道】这篇论坛文章(赛迪网技术社区)主要介绍了oracle数据库到sql server数据库主键的迁移过程,具体内容请参考下文。

由于项目需要要将以前oracle的数据库转化为sql server,今天利用sql server的dtd进行数据库的迁移,但导入以后发现只导入了表结构和数据,而表的一些主键约束都没导过来,感觉很郁闷,而手头又没有好的迁移工具,如erwin,所以动手写了个小工具,基本实现了主键的转移,主要代码如下:

主要控件:

adoconnorcale: tadoconnection; //连接oracle

adoconnsqlserver: tadoconnection; //连接sql server

o1: tadoquery; //连接oracle

s1: tadoquery; //连接sql server

s2: tadoquery; //连接sql server

progressbar1: tprogressbar; //进度条

memo1: tmemo; //显示出错信息

edtserver: tedit; //服务器

edtdatabase: tedit; //数据库名称

edtuser: tedit; //用户名

edtpass: tedit; //口令

button1: tbutton; //执行按钮

//常量

const

oraconnstr='provider=msdaora.1;data source=%s;user id=%s;password=%s;persist security info=true';

sqlconnstr='provider=sqloledb.1;data source=%s;initial catalog=%s;user id=%s;password=%s;persist security info=false';

在执行前先进行oracle和sql server数据库的连接。

连接oracle:

adoconnorcale.connectionstring :=format(oraconnstr,[trim(edtdatabase.text),

trim(edtuser.text),trim(edtpass.text)]);

try

adoconnorcale.open;

msgbox('oracle数据库连接成功!');

except

msgbox('oracle数据库连接失败!');

end;

连接sql server:

adoconnsqlserver.connectionstring :=format(sqlconnstr,[trim(edtserver.text),

trim(edtdatabase.text),trim(edtuser.text),trim(edtpass.text)]);

try

adoconnsqlserver.open;

msgbox('sql server数据库连接成功!')

except

msgbox('sql server数据库连接失败!');

end;

主要执行代码,比较乱,没有整理,不过实现功能就行了。

procedure tform1.button1click(sender: tobject);

var

i:integer;

fieldn, tablen, fieldm,aa:string;

begin

if not adoconnorcale.connected then

begin

msgbox('请先连接oracle数据库!');

exit;

end;

if not adoconnsqlserver.connected then

begin

msgbox('请先连接sql server数据库!');

exit;

end;

screen.cursor :=crhourglass;

try

o1.close;

o1.sql.clear;

//取oracle表用户budget的所有主键约束信息

o1.sql.text :=' select a.constraint_name,a.constraint_type,a.table_name, b.column_name,b.position '+

' from user_constraints a,user_cons_columns b where a.constraint_name=b.constraint_name '+

' and a.table_name=b.table_name and constraint_type=''p'' and a.owner=b.owner '+

' and lower(a.owner)=''budget'' order by a.table_name,b.position ';

o1.open;

tablen:='';

o1.first;

progressbar1.max:=o1.recordcount;

progressbar1.min:=0;

progressbar1.step:=1;

progressbar1.visible :=true;

for i:=0 to o1.recordcount -1 do

begin

s2.close;

s2.sql.clear;

//判断sql server表是否存在当前的字段信息

s2.sql.text:='select a.name as tanme, b.* from sysobjects a inner join '+

' syscolumns b on a.id = b.id '+

' where (a.xtype = ''u'') and (a.name = '''+o1.fieldbyname('table_name').asstring+''''+

') and b.name= '''+o1.fieldbyname('column_name').asstring+''''+

' order by b.id';

s2.open;

//不存在,输出表明和字段名

if s2.recordcount<=0 then

begin

memo1.text:=memo1.text+#13+'表:'''+o1.fieldbyname('table_name').asstring+''''+

' 字段:'''+o1.fieldbyname('column_name').asstring+''' 不存在!';

o1.next;

tablen:='';

fieldn:='';

continue;

end;

//是当前表,循环读取主键信息

if (tablen='') or (tablen= o1.fieldbyname('table_name').asstring) then

begin

fieldn:=fieldn+'['+o1.fieldbyname('column_name').asstring+'],';//表明相同或初试时

tablen:= o1.fieldbyname('table_name').asstring;

end

else

begin

with s1 do

begin

try

//取sql server表的主键信息

close;

sql.clear;

sql.text:='select * from information_schema.key_column_usage where table_name='''+tablen+'''';

open;

first;

aa:=fieldbyname('constraint_name').asstring;

//如果该主键在sql表中已存在,删除该主键信息,重建该表主键

if recordcount>0 then

begin

sql.clear;

sql.text:='alter table '+tablen+' drop constraint '+aa; //删除主键

execsql;

end;

sql.clear; //column_name

sql.text:='alter table '+tablen+' with nocheck add '+

' constraint [pk_'+tablen+'] primary key nonclustered '+

' ( '+ copy(fieldn,1,length(fieldn)-1)+

' )';

execsql;

fieldn:='['+o1.fieldbyname('column_name').asstring+'],';

tablen:= o1.fieldbyname('table_name').asstring;

except

memo1.text :=memo1.text+'表: '+tablen+' 字段: '+fieldn+' 导入出错!';

exit;

end;

end;

end;

progressbar1.stepit;

application.processmessages;

o1.next;

end;

msgbox('导入完成!');

finally

screen.cursor :=crdefault;

progressbar1.visible :=false;

end;

end;

扫描关注微信公众号