用C++发生QL*Loader种种文件

副标题#e#

1.媒介

今朝，我国很多单元MIS系统成立在微机PC或基于NovellNetWare局域网情况中，数据库和开拓东西回收Foxpro2.5 for DOS或Foxpro 2.5 for Windows,以dbf文件为数据组织打点手段，跟着系统的不绝扩大和实际应用的需要，不少单元已开始回收大型数据库Oracle。在MIS从Foxpro进级到大型数据库Oracle进程中，将Foxpro的dbf文件通过Oracle东西SQL*Loader加载到Oracle数据库中是一项很是重要的事情。一般用SQL*Loader加载的详细实施步调是：

* 运行Foxpro,打开数据库，将dbf文件拷贝为SDF名目标文本文件

* 按照dbf文件布局，发生成立Oracle表（CREATETABLE）的SQL语句

* 登录Oracle,运行发生Oracle表（CREATETABLE）的SQL语句

* 按照dbf文件布局，发生SQL*Loader的节制文件

* 运行SQL*Loader，加载数据

用手工要领发生CREATETABLE的SQL语句，出格是发生SQL*Loader节制文件时，POSITION起始、竣事位置常常弄错，当需要加载大量的数据时，

不单啰嗦，并且效率较量低。我们在实践中操作BorlandC++5.0体例了一个C++实用措施load.cpp，自动发生SQL*Loader的数据文件、节制文件和产

生CREATETABLE的SQL语句。运用load，我们只需：

* load<数据库名>

* 登录Oracle,运行发生Oracle表（CREATETABLE）的SQL语句

* 运行SQL*Loader，加载数据

在实践中，我们通过这种要领，在实现从Foxpro到OracleforDigitalUNIX+中文Windows95的client/server平台的数据加载进程中提高了效率。

2.Foxpro中dbf文件布局

dbf文件由文件头和文件记录构成，个中文件头又由数据库说明和字段说明构成。数据库说明由32个字节构成，各字节寄义如下：

字节　　寄义　 

0　　　数据库文件符号有无备注型字段（03H无）

1-3　　最后一次修他日期

4-7　　文件记录数

8-9　　文件头长度

10-11　记录长度

12-31　未用

字段说明由若干个32字节构成，每32字节说明一个字段，各字节寄义如下：

字节　　寄义

0-10　　字段名

11　　　字段范例

12-15　 该字段在文件首记录中的地点

16　　　字段长度

17　　　小数位数

18-31　 未用

文件记录以ASCII形式存储，每笔记录以空格（20H）开头，该空格用来作删除符号用。

三

【注】：

* 不思量完整性约束，同时对付TABLESPACE及STORAGE存储参数取缺省值。

* 对付数字型字段，n暗示数字的宽度，在Foxpro中包括小数点位置，而在Oracle中不包括。

* 对付Foxprological型字段范例，由于Oracle中没有相应的逻辑型变量，故将其转换为字符范例。

* 暂且不思量memo、general、picture字段的转换。

#p#副标题#e#

4.SQL*Loader节制文件的成立

节制文件为SQL*Loader的焦点文件，与Foxpro字段对应干系为表四：Foxpro数据范例

节制文件语句对应的名目

Character(n)

CHAR

Number(n,m)

Float(n,m)

DECIMAL EXTERNAL NULLIF < field > = BLANKS　（m< >0）

INTEGER EXTERNAL NULLIF < field > = BLANKS　 （ m=0）

Logical

CHAR

DATE

DATE　"YYYYMMDD"　NULLIF < field > = BLANKS

四

以 下 是 用Borland C++ 5.0 在 中 文Windows 95 下 编 制 的 产 生CREATE TABLE SQL 语 句 和 产 生SQL*Loader 数 据 文 件、 控 制

文 件 的 源 程 序load.cpp。

#include < stdio.h >
#include < stdlib.h >
#include < iostream.h >
#include < fstream.h >
#include < string.h >
#include < math.h >
#define MAX_ROW_LENGTH 1200
#define MAX_FIELD_NUMBER 30
typedef struct head　　　　 // dbf头文件布局
{ unsigned char mask ;
unsigned char date[3] ;
unsigned long record_num;
unsigned short int head_length;
unsigned short int field_length ;
} HEAD ;
typedef struct field　　　　 // dbf字段布局
{ unsigned char name[11];
unsigned char type ;
unsigned long　add;
unsigned char length;
unsigned char dec ;
} FIELD ;
int main(int argc,char **argv)
{ char buf[MAX_ROW_LENGTH],dbf[40],*sqlload;
unsigned int i,field_num;
HEAD　*dbfhead ;
FIELD dbffield[MAX_FIELD_NUMBER];
FILE *fout, *fp;
if (argc!=2)
{ cout < < "Usage : load dbfile" < < endl ;
return -1;
}
sqlload = new char(40);
dbfhead = new HEAD;
strcpy(buf,"");
strcpy(dbf,argv[1]);
strcat(dbf,".dbf");
if ((fp=fopen(dbf,"rb")) == NULL)
{ cout < < "Cannot open file " < < dbf < < endl;
return -1 ;
}
fseek(fp,0,SEEK_SET);
fread(dbfhead,sizeof(HEAD),1,fp);　　 // 读dbf头文件信息
field_num = (dbfhead- >head_length-1)/32 -1 ;　　　//字段个数
for( i=0; i< field_num; i++)
{ fseek(fp,32*(i+1),SEEK_SET);
fread(&dbffield[i],sizeof(FIELD),1,fp);　// 读dbf布局信息
}
// 产 生SQL*Loader 控 制 文 件
strcpy(sqlload,argv[1]);
strcat(sqlload,".ctl");
if ((fout=fopen(sqlload,"w")) == NULL)
{ cout < < "Cannot open file " < < sqlload < < endl;
return -1 ;
}
fprintf(fout,"LOAD DATA\n");
fprintf(fout,"INFILE '%s.txt'\n", argv[1]);
fprintf(fout,"INTO TABLE %s (\n", argv[1]);
for(i=0;i< field_num;++i)
{ fprintf(fout, "%11s　POSITION(%d:%d)", dbffield[i].name,
 dbffield[i].add, dbffield[i].add + dbffield[i].length -1 );
switch (dbffield[i].type)
{ case 'C':
case 'L':　　　　　　　　　　　　　　// 字符型/ 逻辑型
fprintf(fout, "　CHAR");
break ;
case 'N':
if (dbffield[i].dec == 0 )　　　　 //整数型
fprintf(fout, "INTEGER EXTERNAL NULLIF %s = BLANKS",
dbffield[i].name);
else　　　　　　　　　　　　　　　 //实数型
fprintf(fout, "　DECIMAL EXTERNAL NULLIF %s =BLANKS",
dbffield[i].name );
break;
case 'D':　　　　　　　　　　　　　　//日期型
fprintf(fout, "　DATE 'YYYYMMDD' NULLIF %s = BLANKS",
dbffield[i].name);
break;
default:
break;
}
if(i< field_num -1)
fprintf(fout, ",\n") ;
}
fprintf(fout, ")\n");
fclose(fout);
// 产 生CREATE TABEL. 的SQL 语 句
strcpy(sqlload,argv[1]);
strcat(sqlload,".sql");
if ((fout=fopen(sqlload,"w")) == NULL)
{ cout < < "Cannot open file " < < sqlload < < endl;
return -1 ;
}
fprintf(fout, "create table %s (\n", argv[1]);
for(i=0;i< field_num;i++)
{ fprintf(fout,"%11s",dbffield[i].name);
switch (dbffield[i].type)
{ case 'C':　　//字符型
fprintf(fout, "　CHAR(%d)",dbffield[i].length);
break;
case 'L':　　//逻辑型
fprintf(fout, "　CHAR(1)");
break;
case 'N':　　//数字型
if (dbffield[i].dec==0)
fprintf(fout,"　NUMBER(%d)", dbffield[i].length) ;
else
fprintf(fout, " NUMBER(%d,%d)",
dbffield[i].length-1, dbffield[i].dec);
break;
case 'D':　　// 日 期 型
fprintf(fout, "　DATE");;
break;
default:
break;
}
if (i< field_num - 1)
fprintf(fout,　",\n");
}
fprintf(fout,　")\n");
fclose(fout);
// 发生SQL*Loader数据文件
strcpy(sqlload,argv[1]);
strcat(sqlload,".txt");
if((fout=fopen(sqlload,"w")) == NULL)
{ cout < < "Cannot open file " < < sqlload < < endl;
return -1 ;
}
fseek(fp,dbfhead- >head_length,SEEK_SET);
for(i=0;i< dbfhead- >record_num;i++)
{ fread(buf,dbfhead- >field_length,1,fp);
buf[dbfhead- >field_length] ='\0';
fprintf(fout,"%s\n", buf+1);　//skip记录首字节(删除符号)
}
fclose(fout);
fclose(fp);
delete sqlload;
return 0 ;
}