/******************************************************************************
**
** Source File Name = expsamp.sqc
**
** Licensed Materials - Property of IBM
**
** (C) COPYRIGHT International Business Machines Corp. 1995, 2000
** All Rights Reserved.
**
** US Government Users Restricted Rights - Use, duplication or
** disclosure restricted by GSA ADP Schedule Contract with IBM Corp.
**
**
** PURPOSE :
** This program is an example of how APIs are implemented in order to
** export and import tables and table data to a DRDA database.
** The order of the program is as follows:
** - export a table to an IXF file format
** - import the IXF file to a DB2 DRDA database table
** This program needs the embedded SQL calls in order to connect to
** an existing database, then to create a temporary table to work with.
**
** For DRDA database imports, the data file format MUST be of the IXF
** form. The IMPORT command must be issued an "INSERT" statement.
**
** EXTERNAL DEPENDENCIES :
** - Ensure existence of database for precompile purposes.
** - Precompile with the SQL precompiler (PREP in DB2)
** - Bind to a database (BIND in DB2)
** - Compile and link with the IBM Cset++ compiler (AIX and OS/2)
** or the Microsoft Visual C++ compiler (Windows)
** or the compiler supported on your platform.
**
** For more information about these samples see the README file.
**
** For more information on programming in C, see the:
** - "Programming in C and C++" section of the Application Development Guide
** For more information on Building C Applications, see the:
** - "Building C Applications" section of the Application Building Guide.
**
** For more information on the SQL language see the SQL Reference.
**
*****************************************************************************
** !!!!! NOTE !!!!!
** the proper node and database need to be available in order for this to
** work with a DRDA datbase.
** However, if you wish to EXPORT and IMPORT between the SAMPLE database
** and some other database, that already exists, this program will work
** appropriately.
*****************************************************************************
**
** STRUCTURES USED :
** sqldcol
** sqlchar
** sqluexpt_out
** sqluimp_in
** sqluimp_out
** sqlca
**
** APIs USED :
** IMPORT TO sqluimpr
** EXPORT sqluexpr
**
** FUNCTIONS DECLARED :
** 'C' COMPILER LIBRARY :
** stdio.h - printf
** string.h - fgets, strncpy
**
** DBMS LIBRARY :
** sqlenv.h - see "APIs USED" above
**
** OTHER :
** internal :
** list_dcs : Displays a directory of databases
**
** external :
** check_error : Checks for SQLCODE error, and prints out any
** [in UTIL.C] related information available.
**
** EXTERNAL DEPENDANCIES :
** - Ensure existence of database (SAMPLE) for precompile purposes.
** - Precompile with the SQL precompiler (PREP in DB2)
** - Bind to a database (BIND in DB2)
** - Compile and link with "xlc" compiler.
**
*******************************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sqlenv.h>
#include <sqlutil.h>
#ifndef DB2MAC
#include <malloc.h>
#endif
#include "utilemb.h"
#define STMTLEN 80
EXEC SQL INCLUDE SQLCA;
int main (int argc, char *argv[]) {
short int callerAction = 0;
struct sqldcol columnData;
struct sqlchar *columnStringPointer;
struct sqluexpt_out outputInfo;
struct sqluimpt_in impInput;
struct sqluimpt_out impOutput;
char datafile[] = "EXPTABL1.IXF";
char datafile2[] = "EXPTABL2.IXF";
char statement[STMTLEN] = "select * from staff";
char impStatement[STMTLEN] = "create into impstaff";
char statement2[STMTLEN] = "select * from org";
char impStatement2[STMTLEN] = "create into imporg";
char msgfile_x[] = "EXPMSG.TXT";
char msgfile_m[] = "IMPMSG.TXT";
char fileFormat[] = "IXF";
EXEC SQL BEGIN DECLARE SECTION;
char username[9];
char passwd[19];
char database[9];
char sqlStatement[256];
EXEC SQL END DECLARE SECTION;
if (argc < 6) {
printf ("\nUSAGE: expsamp username passwd DRDA_database DRDA_username "
"DRDA_passwd\n\n");
return 1;
}
/* need to preset the size of structure field and counts */
outputInfo.sizeOfStruct = SQLUEXPT_OUT_SIZE;
impInput.sizeOfStruct = SQLUIMPT_IN_SIZE;
impOutput.sizeOfStruct = SQLUIMPT_OUT_SIZE;
impInput.restartcnt = impInput.commitcnt = 0;
/******************************************************************\
* need to allocate the proper amount of space for the SQL statment *
\******************************************************************/
columnStringPointer = (struct sqlchar *)malloc(STMTLEN
+ sizeof (struct sqlchar));
/* DELimited format can not have specified names, therefore the
column method is 'D'efault */
columnData.dcolmeth = 'D';
strcpy (username, argv[1]);
strcpy (passwd, argv[2]);
printf ("Connecting to SAMPLE database\n");
/* CONNECTing to the 'sample' database */
EXEC SQL CONNECT TO sample USER :username USING :passwd;
EMB_SQL_CHECK("CONNECT TO database");
columnStringPointer->length = strlen(statement);
strncpy (columnStringPointer->data, statement, strlen(statement));
printf ("Exporting STAFF table into file '%s'\n", datafile);
/*******************\
* EXPORT API called *
\*******************/
sqluexpr (datafile, NULL, NULL, &columnData, columnStringPointer,
fileFormat, NULL, msgfile_x, 0, &outputInfo, NULL, &sqlca);
EMB_SQL_CHECK("exporting table");
printf ("Rows exported %d\n", outputInfo.rowsExported);
columnStringPointer->length = strlen(statement2);
strncpy (columnStringPointer->data, statement2, strlen(statement2));
printf ("Exporting ORG table into file '%s'\n", datafile2);
/*******************\
* EXPORT API called *
\*******************/
sqluexpr (datafile2, NULL, NULL, &columnData, columnStringPointer,
fileFormat, NULL, msgfile_x, 0, &outputInfo, NULL, &sqlca);
EMB_SQL_CHECK("exporting table");
printf ("Rows exported %d\n", outputInfo.rowsExported);
strcpy (database, argv[3]);
strcpy (username, argv[4]);
strcpy (passwd, argv[5]);
printf ("Connect to DRDA database\n");
EXEC SQL CONNECT TO :database USER :username USING :passwd;
EMB_SQL_CHECK("CONNECT TO DRDA DATABASE");
columnStringPointer->length = strlen(impStatement);
strncpy (columnStringPointer->data, impStatement, strlen(impStatement));
printf ("Importing the file '%s' into 'impstaff'\n", datafile);
/*******************\
* IMPORT API called *
\*******************/
sqluimpr (datafile, NULL, &columnData, columnStringPointer, fileFormat,
NULL, msgfile_m, 0, &impInput, &impOutput, NULL, NULL, &sqlca);
EMB_SQL_CHECK("importing table");
printf ("rows imported %d\nnumber of rows committed %d\n",
impOutput.rowsInserted, impOutput.rowsCommitted);
columnStringPointer->length = strlen(impStatement2);
strncpy (columnStringPointer->data, impStatement2, strlen(impStatement2));
printf ("importing the file '%s' into 'imporg'\n", datafile2);
/*******************\
* IMPORT API called *
\*******************/
sqluimpr (datafile2, NULL, &columnData, columnStringPointer, fileFormat,
NULL, msgfile_m, 0, &impInput, &impOutput, NULL, NULL, &sqlca);
EMB_SQL_CHECK("importing table");
printf ("rows imported %d\nnumber of rows committed %d\n",
impOutput.rowsInserted, impOutput.rowsCommitted);
free (columnStringPointer);
/* drop the tables and index */
strcpy (sqlStatement, "drop table impstaff");
EXEC SQL EXECUTE IMMEDIATE :sqlStatement;
strcpy (sqlStatement, "drop table imporg");
EXEC SQL EXECUTE IMMEDIATE :sqlStatement;
strcpy (sqlStatement, "drop index SAMPLE.TESTIND");
EXEC SQL EXECUTE IMMEDIATE :sqlStatement;
EXEC SQL COMMIT;
EMB_SQL_CHECK("COMMIT the DROP TABLE");
EXEC SQL CONNECT RESET;
EMB_SQL_CHECK("CONNECT RESET");
return 0;
}
/* end of program : expsamp.sqc */