문법

SQLRETURN SQL_API
TBExport(SQLINTEGER versionNumber, TBExportStruct *pParamStruct,
         struct sqlca *pSqlca);

파라미터

반환 코드

예제

#include "tbutil.h"

#define DNS_NAME  "DEFAULT"
#define USER_NAME "SYS"
#define PWD       "tibero"

int main(int argc, char *argv[]) {
    SQLRETURN      rc = SQL_SUCCESS;
    SQLINTEGER     versionNumber = 1;
    SQLCHAR        dataFileName[256];
    SQLCHAR        actionString[256];
    SQLCHAR        msgFileName[256];
    SQLCHAR        fieldTerm[5];
    SQLCHAR        lineTerm[5];
    SQLCHAR        enclStart[5];
    SQLCHAR        enclEnd[5];

    struct sqlca   ca           = {"\0", 0, 0, {0, "\0"}, "\0",
                                   {0, 0, 0, 0, 0, 0}, "\0", "\0"};
    TBExportStruct exportStruct = {NULL, 0, NULL, NULL, NULL, 0, NULL,
                                   0, NULL, NULL};
    TBExportIn     exportIn     = {{NULL, 0, NULL, 0, NULL, 0, NULL, 0, NULL, 0}};
    TBExportOut    exportOut    = {0};

    rc= TBConnect((SQLCHAR *)DNS_NAME, (SQLCHAR *)USER_NAME, (SQLCHAR *)PWD, &ca);
    
    if (rc != SQL_SUCCESS) return -1;

    strcpy((char *)dataFileName, "./all_tables.dat");
    strcpy((char *)actionString, "select * from all_tables");
    strcpy((char *)msgFileName, "./all_tables.log");
    strcpy((char *)fieldTerm, ",");
    strcpy((char *)lineTerm, "\n");
    strcpy((char *)enclStart, "\"");
    strcpy((char *)enclEnd, "\"");

    /* setting data file name */
    exportStruct.piDataFileName   = dataFileName;
    exportStruct.iDataFileNameLen = strlen((char *)dataFileName);

    /* setting action String */
    exportStruct.piActionString = calloc(1, sizeof(sqlstr));
    exportStruct.piActionString->data   = actionString;
    exportStruct.piActionString->length = strlen((char *)actionString);

    /* setting file type */
    exportStruct.iFileType = SQL_DEL;

    /* setting message file name */
    exportStruct.piMsgFileName   = msgFileName;
    exportStruct.iMsgFileNameLen = strlen((char *)msgFileName);

    /* setting field term, line term etc.. */
    exportIn.iMeta.fieldTerm    = fieldTerm;
    exportIn.iMeta.fieldTermLen = strlen((char *)fieldTerm);
    exportIn.iMeta.lineTerm     = lineTerm;
    exportIn.iMeta.lineTermLen  = strlen((char *)lineTerm);
    exportIn.iMeta.enclStart    = enclStart;
    exportIn.iMeta.enclStartLen = strlen((char *)enclStart);
    exportIn.iMeta.enclEnd      = enclEnd;
    exportIn.iMeta.enclEndLen   = strlen((char *)enclEnd);

    /* setting export input, output information */
    exportStruct.piExportInfoIn  = &exportIn;
    exportStruct.poExportInfoOut = &exportOut;

    /* setting file type */
    rc = TBExport(versionNumber, &exportStruct, &ca);
    if (rc != SQL_SUCCESS) return -1;

    /* disconnect */
    rc= TBDisconnect((SQLCHAR *)DNS_NAME, &ca);
    if (rc != SQL_SUCCESS) return -1;

    return 1;
}

문법

SQLRETURN SQL_API TBImport(SQLINTEGER versionNumber,
                           TBImportStruct *pParamStruct,
                           struct sqlca *pSqlca);

파라미터

반환 코드

예제

#include "tbutil.h"

#define DNS_NAME  "DEFAULT"
#define USER_NAME "SYS"
#define PWD       "tibero"

int main(int argc, char *argv[]) {
 SQLRETURN      rc = SQL_SUCCESS;
 SQLINTEGER     versionNumber = 1;
 SQLCHAR        dataFileName[256];
 SQLCHAR        actionString[256];
 SQLCHAR        msgFileName[256];
 SQLCHAR        badFileName[256];
 SQLCHAR        fieldTerm[5];
 SQLCHAR        lineTerm[5];
 SQLCHAR        enclStart[5];
 SQLCHAR        enclEnd[5];
 SQLCHAR        escape[5];

 struct sqlca   ca           = {"\0", 0, 0, {0, "\0"}, "\0",
                               {0, 0, 0, 0, 0, 0}, "\0", "\0"};
 TBImportStruct importStruct = {NULL, 0, NULL, NULL, NULL, 0, NULL,
                                0, NULL, 0, 0, NULL, NULL};
 TBImportIn     importIn     = {{NULL, 0, NULL, 0, NULL, 0, NULL, 0, NULL, 0},
                                0, 0, 0, 0};
 TBImportOut    importOut    = {0, 0, 0, 0, 0, 0};

 rc= TBConnect((SQLCHAR *)DNS_NAME, (SQLCHAR *)USER_NAME, (SQLCHAR *)PWD, &ca);
 if (rc != SQL_SUCCESS) return -1;

 strcpy((char *)actionString, "LOAD DATA "
                            "APPEND "
                            "INTO TABLE DEPT "
                            "MULTI INSERT INDEXES "
                            "(position, deptno, dname CONSTANT \"co dep\", loc)");
 strcpy((char *)dataFileName, "./test.dat");
 strcpy((char *)msgFileName, "./test.log");
 strcpy((char *)badFileName, "./test.bad");
 strcpy((char *)fieldTerm,   ",b");
 strcpy((char *)lineTerm,    "abbb\n");
 strcpy((char *)enclStart,   "{$");
 strcpy((char *)enclEnd,     "$}");
 strcpy((char *)escape,      "XX");

 /* setting data file name */
 importStruct.piDataFileName   = dataFileName;
 importStruct.iDataFileNameLen = strlen((char *)dataFileName);

 /* setting action String */
 importStruct.piActionString = calloc(1, sizeof(sqlstr));
 importStruct.piActionString->data   = actionString;
 importStruct.piActionString->length = strlen((char *)actionString);

 /* setting file type */
 importStruct.iFileType = SQL_DEL;

 /* setting message file name */
 importStruct.piMsgFileName   = msgFileName;
 importStruct.iMsgFileNameLen = strlen((char *)msgFileName);

 /* setting bad data file name */
 importStruct.piBadFileName   = badFileName;
 importStruct.iBadFileNameLen = strlen((char *)badFileName);

 /* turn on DPL mode */
 importStruct.iDPL            = 2;

 /* setting field term, line term etc.. */
 importIn.iMeta.fieldTerm    = fieldTerm;
 importIn.iMeta.fieldTermLen = strlen((char *)fieldTerm);
 importIn.iMeta.lineTerm     = lineTerm;
 importIn.iMeta.lineTermLen  = strlen((char *)lineTerm);
 importIn.iMeta.enclStart    = enclStart;
 importIn.iMeta.enclStartLen = strlen((char *)enclStart);
 importIn.iMeta.enclEnd      = enclEnd;
 importIn.iMeta.enclEndLen   = strlen((char *)enclEnd);
 importIn.iMeta.escape       = escape;
 importIn.iMeta.escapeLen    = strlen((char *)escape);

 importIn.iRowcount          = 0;
 importIn.iSkipcount         = 0;
 importIn.iCommitcount       = 2;
 importIn.iErrorcount        = 50;

 /* setting export input, output information */
 importStruct.piImportInfoIn  = &importIn;
 importStruct.poImportInfoOut = &importOut;

 /* setting file type */
 rc = TBImport(versionNumber, &importStruct, &ca);
 if (rc != SQL_SUCCESS) return -1;    

   fprintf(stdout, "oRowsRead[%ld]", importOut.oRowsRead);
   fprintf(stdout, "oRowsSkipped[%ld]", importOut.oRowsSkipped);
   fprintf(stdout, "oRowsInserted[%ld]", importOut.oRowsInserted);
   fprintf(stdout, "oRowsUpdated[%ld]", importOut.oRowsUpdated);
   fprintf(stdout, "oRowsRejected[%ld]", importOut.oRowsRejected);
   fprintf(stdout, "oRowsCommitted[%ld]", importOut.oRowsCommitted);

   /* disconnect */
   rc= TBDisconnect((SQLCHAR *)DNS_NAME, &ca);
   if (rc != SQL_SUCCESS) return -1;

   return 1;
}