DB2的API编程问题...(基于DB2数据库的应用开发研究)

x521

请教下关于DB2的API编程.
要求我用数据处理API：EXPORT（凋出数据）、IMPORT（调入数据）、LOAD（调入数据）三个函数实现数据的整块调入调出.

这个题目怎么做......谢大家帮我看看..
还有想我想问下谁有 关于<DB2通用数据库API开发人员指南>的电子书.提供下再.....非常感谢....

大梦

老大,直接看db2自带的例子就能搞定的!

就在你的实例目录下面的sqllib\samples\c或是cli下面应该都有,自己找下!

或在那个管理API里面也有函数头的描述

x521

大梦大哥 ..可以帮下 弄弄吗?这个我没用弄过.一点头绪都没有.....


     谢    了...

Law

db2 v8 load API,db2load810封装的例子程序，核心函数是调用db2的db2Load(..),db2load 主要是初始化参数很麻烦

1. 
   
2. int db2load810(char *sTabName, char *sSourceFile,char *sColDel,char *sLoadMegFile)
   
3. {
   
4.         char dataFileName[256];
   
5.         char msgFileName[128];
   
6.         struct sqldcol dataDescriptor;
   
7.         char actionString[256];
   
8. 
   
9.         db2LoadStruct loadParms;
   
10.         char pActionString[128];
    
11.         char pFileTypeModString[128];
    
12.         sqlu_media_list loadMediaList;
    
13.         sqlu_location_entry inputLocationEntry;
    
14.         db2LoadIn loadInfoIn;
    
15.         db2LoadOut loadInfoOut;
    
16.         db2PartLoadIn partLoadInfoIn;
    
17.         db2PartLoadOut partLoadInfoOut;
    
18.         db2LoadNodeList partitioningDbPartNums;
    
19.         db2Uint16 mode;
    
20.         db2Uint16 isolatePartErrs;
    
21.         
    
22. 
    
23. 
    
24. 
    
25.         sprintf(dataFileName,"%s",sSourceFile);
    
26.         sprintf(msgFileName,"%s",sLoadMegFile);
    
27.         sprintf(pFileTypeModString,"%s coldel%s ","ANYORDER ",sColDel);
    
28.         printf("%s\n",sTabName);
    
29.         sprintf(pActionString," insert into  %s",sTabName);
    
30.         printf("%s\n",pActionString);
    
31.        
    
32.         printf("\n--------------------------------------------------------\n");
    
33.         printf("\nUSE THE DB2 API:\n");
    
34.         printf("  db2Load -- Load\n");
    
35.         printf("TO LOAD DATA TO A PARTITIONED DATABASE TABLE.\n");
    
36.         memset(&loadParms, '\0', sizeof(db2LoadStruct));
    
37. 
    
38.         /* Set up the list of input source files. We are using just one */
    
39.         /* which will be called "tbload.DEL"                            */
    
40.         loadParms.piSourceList = &loadMediaList;
    
41.         loadParms.piSourceList->media_type = SQLU_SERVER_LOCATION;
    
42.         loadParms.piSourceList->sessions = 1;
    
43.         loadParms.piSourceList->target.location = &inputLocationEntry;
    
44.         strcpy(loadParms.piSourceList->target.location->location_entry, dataFileName);
    
45. 
    
46.         /* Set up the load action string to "INSERT INTO TABLE1" */
    
47.         loadParms.piActionString = (struct sqlchar*)malloc(sizeof(short) + strlen(pActionString) + 1);
    
48.         strcpy(loadParms.piActionString->data, pActionString);
    
49.         loadParms.piActionString->length = strlen(pActionString);
    
50. 
    
51.         /* Set the file type to DEL (i.e., an ASCII delimited file) */
    
52.         loadParms.piFileType = (char*)SQL_DEL;
    
53. 
    
54.         /* Specify the ANYORDER file type modifier which indicates to the  */
    
55.         /* load utility that it is not necessary to load the rows of data  */
    
56.         /* into the table in the same order they appear in the input file. */
    
57.         /* This can result in better load performance and permits the use  */
    
58.         /* of multiple partitioning agents as well.                        */
    
59.         loadParms.piFileTypeMod = (struct sqlchar*)malloc(sizeof(short) + strlen(pFileTypeModString) + 1);
    
60.         strcpy(loadParms.piFileTypeMod->data, pFileTypeModString);
    
61.         loadParms.piFileTypeMod->length = strlen(pFileTypeModString);
    
62. 
    
63.         /* Set up the name that will serve as a prefix for the  */
    
64.         /* message files retrieved from each partition that is  */
    
65.         /* participating in the load operation.                 */
    
66.         loadParms.piLocalMsgFileName = msgFileName;
    
67. 
    
68.         /* Set up and initialize the load input structure */
    
69.         memset(&loadInfoIn, '\0', sizeof(db2LoadIn));
    
70.         loadInfoIn.iNonrecoverable = SQLU_NON_RECOVERABLE_LOAD;
    
71.         loadInfoIn.iIndexingMode = SQLU_INX_AUTOSELECT;
    
72.         loadInfoIn.iAccessLevel = SQLU_ALLOW_NO_ACCESS;
    
73.         loadInfoIn.iLockWithForce = SQLU_NO_FORCE;
    
74.         loadInfoIn.iCheckPending = SQLU_CHECK_PENDING_CASCADE_DEFERRED;
    
75.         loadInfoIn.iRestartphase = ' ';
    
76.         loadInfoIn.iStatsOpt = SQLU_STATS_NONE;
    
77.         loadParms.piLoadInfoIn = (db2LoadIn*) &loadInfoIn;
    
78. 
    
79.         /* Set up and initialize the load output structure */
    
80.         memset(&loadInfoOut, '\0', sizeof(db2LoadOut));
    
81.         loadParms.poLoadInfoOut = (db2LoadOut*) &loadInfoOut;
    
82. 
    
83.         /* Set up the callerac to indicate this is an initial load operation */
    
84.         loadParms.iCallerAction = SQLU_INITIAL;
    
85. 
    
86.         /**********************************************************************
    
87.          * Set up the partitioning load input structure.
    
88.          *
    
89.          * NOTE: A value of NULL for any field in this structure will
    
90.          *       result in the default value for the option being used.
    
91.          *
    
92.          *       It is recommended that callers zero out the entire structure
    
93.          *       and then set up only those parameters that have non-default
    
94.          *       values.
    
95.          **********************************************************************/
    
96.         memset(&partLoadInfoIn, '\0', sizeof(db2PartLoadIn));
    
97. 
    
98.         /* Set the mode to PARTITION_AND_LOAD -- this is the default value */
    
99.         /* but we do it anyway just to show how it would be set up for     */
    
100.         /* non-default values                                              */
     
101.         mode = DB2LOAD_PARTITION_AND_LOAD;
     
102.         partLoadInfoIn.piMode = &mode;
     
103. 
     
104.         /* By setting piOutputNodes to NULL we are indicating that we      */
     
105.         /* want loading to take place on all nodes the table is defined    */
     
106.         /* on.  Again, this is the default value, but we do it anyway for  */
     
107.         /* instructional purposes.                                         */
     
108.         partLoadInfoIn.piOutputNodes = NULL;
     
109. 
     
110.         /* Set up the piPartitioningNodes parameter to indicate that       */
     
111.         /* we want a partitioning agent on node 0.  We will just show      */
     
112.         /* how to do this in a comment.  For the real code we will use the */
     
113.         /* the default value, NULL, which will indicate to LOAD that it    */
     
114.         /* should try to select the best node(s) for partitioning.         */
     
115. 
     
116.         /* partitioningDbPartNums.iNumNodes = 1;
     
117.         partitioningDbPartNums.piNodeList =
     
118.         (SQL_PDB_NODE_TYPE *)malloc(1 * sizeof(SQL_PDB_NODE_TYPE));
     
119.         partitioningDbPartNums.piNodeList[0] = 0;
     
120.         partLoadInfoIn.piPartitioningNodes = &partitioningDbPartNums; */
     
121. 
     
122.         partLoadInfoIn.piPartitioningNodes = NULL;
     
123. 
     
124.         /* Set up the error isolation mode to SETUP_AND_LOAD_ERRS */
     
125.         isolatePartErrs = DB2LOAD_SETUP_AND_LOAD_ERRS;
     
126.         partLoadInfoIn.piIsolatePartErrs = &isolatePartErrs;
     
127. 
     
128.         loadParms.piPartLoadInfoIn = &partLoadInfoIn;
     
129. 
     
130.         /**********************************************************************
     
131.          * Set up the partitioned load output structure
     
132.          **********************************************************************/
     
133.         memset(&partLoadInfoOut, '\0', sizeof(db2PartLoadOut));
     
134. 
     
135.         /* Reserve space for 100 agent info entries. In general, setting */
     
136.         /* iMaxAgentInfoEntries to 3 * <number of nodes> in cluster      */
     
137.         /* should be sufficient.                                         */
     
138.         partLoadInfoOut.iMaxAgentInfoEntries = 100;
     
139.         partLoadInfoOut.poAgentInfoList = (db2LoadAgentInfo*)malloc(sizeof(db2LoadAgentInfo) *100);
     
140. 
     
141.         loadParms.poPartLoadInfoOut = &partLoadInfoOut;
     
142. 
     
143.         /*********************************************************************
     
144.          * Call the db2Load API
     
145.          *********************************************************************/
     
146.         printf("\n  Load data.\n");
     
147.         printf("    client destination file name: %s\n", dataFileName);
     
148.         printf("    action                      : %s\n", pActionString);
     
149.         printf("    client message file name    : %s\n", msgFileName);
     
150. 
     
151.         db2Load(db2Version810,  &loadParms,  &sqlca);
     
152. 
     
153.         /* Display and warnings or errors */
     
154.         if (sqlca.sqlcode != 0)
     
155.         {
     
156.                 printf("\nThe following error is expected for non-partitioned");
     
157.                 printf(" database environments.\n");
     
158.                 SqlInfoPrint("table -- load", &sqlca, __LINE__, __FILE__);
     
159.         }
     
160.         else
     
161.         {
     
162.                 /* Display a partition-level summary of the load operation */
     
163.                 PrintLoadSummary(loadParms.poLoadInfoOut, loadParms.poPartLoadInfoOut,  &sqlca);
     
164.         }
     
165.         if (loadParms.piActionString != NULL)
     
166.         {
     
167.                 free(loadParms.piActionString);
     
168.                 loadParms.piActionString = NULL;
     
169.         }
     
170. 
     
171.         if (loadParms.piFileTypeMod != NULL)
     
172.         {
     
173.                 free(loadParms.piFileTypeMod);
     
174.                 loadParms.piFileTypeMod = NULL;
     
175.         }
     
176. 
     
177.         if (partitioningDbPartNums.piNodeList != NULL)
     
178.         {
     
179.                 free(partitioningDbPartNums.piNodeList);
     
180.                 loadParms.piFileTypeMod = NULL;
     
181.         }
     
182. 
     
183.         if (partLoadInfoOut.poAgentInfoList != NULL)
     
184.         {
     
185.                 free(partLoadInfoOut.poAgentInfoList);
     
186.                 partLoadInfoOut.poAgentInfoList = NULL;
     
187.         }
     
188. }
     
189. 
     
190. 
     

复制代码

[ 本帖最后由 Law 于 2007-5-18 17:50 编辑 ]

goooole

学习了