用C++產(chǎn)生SQL*Loader各類(lèi)文件

目 前， 我 國(guó) 許 多 單 位MIS 系 統(tǒng) 建 立 在 微 機(jī)PC 或 基 于 Novell NetWare 局 域 網(wǎng) 環(huán) 境 中， 數(shù) 據(jù) 庫(kù) 和 開(kāi) 發(fā) 工 具 采 用 Foxpro 2.5 for DOS 或 Foxpro 2.5 for Windows, 以dbf 文 件 為 數(shù) 據(jù) 組 織 管 理 手 段， 隨 著 系 統(tǒng) 的 不 斷 擴(kuò) 大 和 實(shí) 際 應(yīng) 用 的 需 要， 不 少 單 位 已 開(kāi) 始 采 用 大 型 數(shù) 據(jù) 庫(kù)Oracle。 在MIS 從Foxpro 升 級(jí) 到 大 型 數(shù) 據(jù) 庫(kù)Oracle 過(guò) 程 中， 將Foxpro 的dbf 文 件 通 過(guò)Oracle 工 具SQL*Loader 加 載 到Oracle 數(shù) 據(jù) 庫(kù) 中 是 一 項(xiàng) 非 常 重 要 的 工 作。 一 般 用SQL*Loader 加 載 的 具 體 實(shí) 施 步 驟 是：

---- * 運(yùn) 行Foxpro, 打 開(kāi) 數(shù) 據(jù) 庫(kù)， 將dbf 文 件 拷 貝 為SDF 格 式 的 文 本 文 件

---- * 根 據(jù)dbf 文 件 結(jié) 構(gòu)， 產(chǎn) 生 建 立Oracle 表（CREATE TABLE） 的SQL 語(yǔ) 句

---- * 登 錄Oracle, 運(yùn) 行 產(chǎn) 生Oracle 表（CREATE TABLE） 的SQL 語(yǔ) 句

---- * 根 據(jù)dbf 文 件 結(jié) 構(gòu)， 產(chǎn) 生SQL*Loader 的 控 制 文 件

---- * 運(yùn) 行SQL*Loader ， 加 載 數(shù) 據(jù)

---- 用 手 工 方 法 產(chǎn) 生CREATE TABLE 的SQL 語(yǔ) 句， 特 別 是 產(chǎn) 生SQL*Loader 控 制 文 件 時(shí)，POSITION 起 始、 結(jié) 束 位 置 經(jīng) 常 弄 錯(cuò)， 當(dāng) 需 要 加 載 大 量 的 數(shù) 據(jù) 時(shí)， 不 但 煩 瑣， 而 且 效 率 比 較 低。 我 們 在 實(shí) 踐 中 利 用Borland C++ 5.0 編 制 了 一 個(gè)C++ 實(shí) 用 程 序load.cpp， 自 動(dòng) 產(chǎn) 生SQL*Loader 的 數(shù) 據(jù) 文 件、 控 制 文 件 和 產(chǎn) 生CREATE TABLE 的SQL 語(yǔ) 句。 運(yùn) 用load， 我 們 只 需：

---- * load < 數(shù) 據(jù) 庫(kù) 名 >

---- * 登 錄Oracle, 運(yùn) 行 產(chǎn) 生Oracle 表（CREATE TABLE） 的SQL 語(yǔ) 句

---- * 運(yùn) 行SQL*Loader ， 加 載 數(shù) 據(jù)

---- 在 實(shí) 踐 中， 我 們 通 過(guò) 這 種 方 法， 在 實(shí) 現(xiàn) 從Foxpro 到Oracle for Digital UNIX + 中 文Windows 95 的client/server 平 臺(tái) 的 數(shù) 據(jù) 加 載 過(guò) 程 中 提 高 了 效 率。

---- 2.Foxpro 中dbf 文 件 結(jié) 構(gòu)

---- dbf 文 件 由 文 件 頭 和 文 件 記 錄 組 成， 其 中 文 件 頭 又 由 數(shù) 據(jù) 庫(kù) 說(shuō) 明 和 字 段 說(shuō) 明 組 成。 數(shù) 據(jù) 庫(kù) 說(shuō) 明 由32 個(gè) 字 節(jié) 組 成， 各 字 節(jié) 含 義 見(jiàn) 表 一：

字 節(jié)
含 義
0
數(shù) 據(jù) 庫(kù) 文 件 標(biāo) 志 有 無(wú) 備 注 型 字 段（03H 無(wú)）
1-3
最 后 一 次 修 改 日 期
4-7
文 件 記 錄 數(shù)
8-9
文 件 頭 長(zhǎng) 度
10-11
記 錄 長(zhǎng) 度
12-31
未 用

---- 表 一

---- 字 段 說(shuō) 明 由 若 干 個(gè)32 字 節(jié) 組 成， 每32 字 節(jié) 說(shuō) 明 一 個(gè) 字 段， 各 字 節(jié) 含 義 見(jiàn) 表 二：

字 節(jié)
含 義
0-10
字 段 名
11
字 段 類(lèi) 型
12-15
該 字 段 在 文 件 首 記 錄 中 的 地 址
16
字 段 長(zhǎng) 度
17
小 數(shù) 位 數(shù)
18-31
未 用

---- 表 二

---- 文 件 記 錄 以ASCII 形 式 存 儲(chǔ)， 每 條 記 錄 以 空 格（20H） 開(kāi) 頭， 該 空 格 用 來(lái) 作 刪 除 標(biāo) 志 用。

---- 3. 建 立 對(duì) 應(yīng)Foxpro 的Oracle 表 的SQL 語(yǔ) 句

---- Foxpro 和Oracle 對(duì) 應(yīng) 的 數(shù) 據(jù) 類(lèi) 型 的 描 述 見(jiàn) 表 三：

Foxpro
Oracle
Character(n)
char(n) varchar2(n)
Number(n,m)
number(n-1,m) m< >0
number(n,m) m=0
Float(n,m)

Logical
char(1)
DATE
DATE

---- 三

---- 【 注】：

---- * 不 考 慮 完 整 性 約 束， 同 時(shí) 對(duì) 于TABLESPACE 及STORAGE 存 儲(chǔ) 參 數(shù) 取 缺 省 值。

---- * 對(duì) 于 數(shù) 字 型 字 段，n 表 示 數(shù) 字 的 寬 度， 在Foxpro 中 包 含 小 數(shù) 點(diǎn) 位 置， 而 在Oracle 中 不 包 含。

---- * 對(duì) 于Foxpro logical 型 字 段 類(lèi) 型， 由 于Oracle 中 沒(méi) 有 相 應(yīng) 的 邏 輯 型 變 量， 故 將 其 轉(zhuǎn) 換 為 字 符 類(lèi) 型。

---- * 暫 且 不 考 慮memo、general、picture 字 段 的 轉(zhuǎn) 換。

---- 4. SQL*Loader 控 制 文 件 的 建 立

---- 控 制 文 件 為SQL*Loader 的 核 心 文 件， 與Foxpro 字 段 對(duì) 應(yīng) 關(guān) 系 為 表 四： Foxpro 數(shù) 據(jù) 類(lèi) 型

---- 控 制 文 件 語(yǔ) 句 對(duì) 應(yīng) 的 格 式

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 下 編 制 的 產(chǎn) 生CREATE TABLE SQL 語(yǔ) 句 和 產(chǎn) 生SQL*Loader 數(shù) 據(jù) 文 件、 控 制 文 件 的 源 程 序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頭文件結(jié)構(gòu)
{ 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字段結(jié)構(gòu)
{ 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 ; //字段個(gè)數(shù)

for( i=0; i< field_num; i++)
{ fseek(fp,32*(i+1),SEEK_SET);
fread(&dbffield[i],sizeof(FIELD),1,fp); // 讀dbf結(jié)構(gòu)信息
}
// 產(chǎn) 生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 ) //整數(shù)型
fprintf(fout, "INTEGER EXTERNAL NULLIF %s = BLANKS",
dbffield[i].name);
else //實(shí)數(shù)型
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);

// 產(chǎn) 生CREATE TABEL. 的SQL 語(yǔ) 句
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': //數(shù)字型
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);

// 產(chǎn)生SQL*Loader數(shù)據(jù)文件
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記錄首字節(jié)(刪除標(biāo)志)
}
fclose(fout);
fclose(fp);

delete sqlload;
return 0 ;
}