work/entitycopy/main.cpp

Go to the documentation of this file.

#include <dcl/Config.h>
 
#ifdef __WINNT__
#include <windows.h>
#endif
 
#include <locale.h>
 
#include <dcl/FileWriter.h>
#include <dcl/Arguments.h>
#include <dcl/DateTime.h>
 
#include "main.h"
#include "EntityCopy.h"
#include "Version.h"
 
#if __DCL_HAVE_THIS_FILE__
#undef __THIS_FILE__
static const char_t __UNUSED__ __THIS_FILE__[] = __T("entitycopy/main.cpp");
#endif
 
__DCL_BEGIN_NAMESPACE
 
static Arguments::Option __options__[] =
{
    { L"verbose",   L'v', NULL,         0,  L"Produce verbose output" },
    { NULL,         0,    NULL,         0,  L"The following options should be grouped together:" },
    { L"source",    L's', L"STRING",    0,  L"Source database connection."
        "\n\t\t\t    DRIVER=DCLFirebird; USER=MT100;PASSWORD=pass;SERVER=g02u24kn2/32055;DATABASE=MT100"
        "\n\t\t\t    DRIVER=DCLOracle;   USER=MT100;PASSWORD=pass;DATABASE=g01r08od21:1521/AL32UTF8" },
    { L"destination", L'd', L"STRING",  0,  L"Destination database connection."
        "\n\t\t\t    DRIVER=DCLInterBase;USER=MT100;PASSWORD=pass;SERVER=n0317ud70p/3050;DATABASE=MT100"
        "\n\t\t\t    DRIVER=DCLInformix; USER=MT100;PASSWORD=pass;SERVER=informix02;DATABASE=MT100"
        "\n\t\t\t    DRIVER=DCLMariaDB;  USER=MT100;PASSWORD=pass;SERVER=g02u24kn2;PORT=32011;DATABASE=MT100"       
        "\n\t\t\t    DRIVER=DCLPostgreSQL;USER=MT100;PASSWORD=pass;SERVER=g02u24kn2;PORT=32017;DATABASE=MT100"
        "\n\t\t\t    DRIVER=DCLSQLCipher;DATABASE=MT100.sqlcipher;KEY=key"
        "\n\t\t\t    DRIVER=DCLSQLite3;  DATABASE=MT100.sqlite3"
        "\n\t\t\t    DRIVER={ODBC Driver 18 for SQL Server};Server=g02u24kn2,31433;Database=MT100;UID=MT100;PWD=pass" },
    { L"entities",  L'e',   L"STRING",  0,  L"Entity configuration list."
        "\n\t\t\t    Blank(all) or S1;S2;S3(c1,cn);S4(s1,sn)=D4(d1,dn); ..." },
    { L"truncate",  L'c',   NULL,       0,  L"Truncate table and insert" },
    { L"rows",      L'r',   L"NUMBER",  0,  L"Rows per transaction." },
    { L"i4-precision", L'4', L"NUMBER", 0,  L"32bits integer precision for decimal. default is 10" },
    { L"i8-precision", L'8', L"NUMBER", 0,  L"64bits integer precision for decimal, default is 19" },
    { L"dry-run",   L'n',   NULL,       0,  L"perform a trial run with no changes made" },
    { NULL }
};
 
MainArguments::MainArguments(Writer& _output, Writer& _errout)
    : Arguments(
        _output, _errout,
        L"entitycopy " DCL_ENTITY_COPY_VERSION_STRING,
        L"daejung@gowoonsoft.com, gowoonsoft.com@gmail.com",
        NULL,
        L"Copy Database Tables",
        __options__
    )
{
    __dryrun = false;
    __verbose = false;
    __truncate = false;
    __rows = -1;
    __i4precision = 10;
    __i8precision = 19;
}
 
String MainArguments::toString() const
{
    StringBuilder sb;
    sb.append(value0())
        .append(L" --verbose=").append(String::valueOf(__verbose))
        .append(L" --source=").append(__source)
        .append(L" --destination=").append(__destination)
        .append(L" --entities=").append(__entities)
        .append(L" --truncate=").append(String::valueOf(__truncate))
        .append(L" --rows=").append(String::valueOf(__rows))
        .append(L" --i4-precision=").append(String::valueOf(__i4precision))
        .append(L" --i8-precision=").append(String::valueOf(__i8precision))
        .append(L" --dry-run=").append(String::valueOf(__dryrun))
        .append(L" values[").append(values().toString())
        .append(L"]");
 
    return sb;
}
 
void MainArguments::onOption(int _key, const String& _arg)
    __DCL_THROWS1(Exception*)
{
    switch (_key) {
        case L'v':
            __verbose = true;
            break;
        case L's':
            __source = _arg;
            break;
        case L'd':
            __destination = _arg;
            break;
        case L'e':
            __entities = _arg;
            break;
        case L'c':
            __truncate = true;
            break;
        case L'r':
            __rows = Int32::parse(_arg.data());
            break;
        case L'4':
            __i4precision = Int32::parse(_arg.data(), 10, __i4precision);
            break;
        case L'8':
            __i8precision = Int32::parse(_arg.data(), 10, __i8precision);
            break;
        case L'n':
            __dryrun = true;
            break;
    }
}
 
String MainArguments::onValidate()
{
    if (__source.isEmpty() || __destination.isEmpty()) {
        return L"option '--source' and '--destination' must both be provided";
    }
    return Arguments::onValidate();
}
 
void __main(const MainArguments& _args)
{
    String srcDriver;
    String dstDriver;
 
    size_t first = _args.source().search(L"DRIVER *=", true);
    if (first != (size_t)-1) {
        srcDriver = _args.source().substring(L"DRIVER *= *[^;]+", true);
        if (srcDriver.isEmpty()) {
            srcDriver = _args.source().substring(first);
        }
        if (!srcDriver.isEmpty()) {
            if (srcDriver.indexOf(L'{') != (size_t)-1) {
                srcDriver = L"DCLODBC";
            }
            else {
                srcDriver = srcDriver.substring(srcDriver.indexOf(L'=') + 1).trim();
            }
        }
    }
 
    first = _args.destination().search(L"DRIVER *=", true);
    if (first != (size_t)-1) {
        dstDriver = _args.destination().substring(L"DRIVER *= *[^;]+", true);
        if (dstDriver.isEmpty()) {
            dstDriver = _args.destination().substring(first);
        }
        if (!dstDriver.isEmpty()) {
            if (dstDriver.indexOf(L'{') != (size_t)-1) {
                dstDriver = L"DCLODBC";
            }
            else {
                dstDriver = dstDriver.substring(dstDriver.indexOf(L'=') + 1).trim();
            }
        }
    }
 
    if (srcDriver.isEmpty() || dstDriver.isEmpty()) {
        _args.errout() << _args.value0() << L": option '--source' or '--destination' is invalid"
            << endl << _args.tryUsage() << endl;
        return;
    }
 
    EntityCopy copy(_args, srcDriver, dstDriver);
    if (copy.initialize()) {
        copy.doIt();
    }
}
 
__DCL_END_NAMESPACE
 
__DCL_USING_NAMESPACE
 
int main(int _argc, char* _argv[])
{
    // std::locale::global(std::locale(""));
    setlocale(LC_ALL, "");
 
    __DCL_INITIALIZE
    {
        FileWriter output(STDOUT_HANDLE);
        FileWriter errout(STDERR_HANDLE);
#ifdef __DCL_DEBUG
        DCLDebugSetGlobalReport(&errout);
#endif
        MainArguments args(output, errout);
        if (args.parse(_argc, _argv, false)) {
            String sep(L'=', 80);
            DateTime start = DateTime::getCurrentLocalTime();
            output << L"Start [" << start.toString()
                << L"]" << endl;
            if (args.verbose()) {
                output << L"      [" << args.toString() << L"]" << endl;
            }
            output << sep << endl;
 
            try {
                __main(args);
            }
            catch (Exception* e) {
                errout << e->toStringAll() << endl;
                e->destroy();
            }
 
            DateTime finish = DateTime::getCurrentLocalTime();
            output << sep << endl
                << L"Finish [" << finish.toString()
                << L" " << (finish - start).toString()
                << L"]" << endl;
        }
#ifdef __DCL_DEBUG
#if __DCL_HAVE_ALLOC_DEBUG
        DCLDebugDumpGlobalMemoryLeak(DCL_ALLOC_DUMP_ALL, &errout);
#endif
        DCLDebugSetGlobalReport(NULL);
#endif      // __DCL_DEBUG
    }
    __DCL_CLEANUP
 
    return 0;
}
 
#ifdef __WINNT_NEW_DELETE_OVERRIDE
#undef new
__WINNT_NEW_DELETE_OVERRIDE
#endif