protected void applyCommonOptions()

in client/migrationx/migrationx-transformer/src/main/java/com/aliyun/dataworks/migrationx/transformer/core/sqoop/BaseSqoopTool.java [864:959]
79 lines of code
20 McCabe index (conditional complexity)

    protected void applyCommonOptions(CommandLine in, SqoopOptions out)
        throws InvalidOptionsException {

        // common options.
        if (in.hasOption(VERBOSE_ARG)) {
            // Immediately switch into DEBUG logging.
            out.setVerbose(true);
            LOG.debug("Enabled debug logging.");
        }

        if (in.hasOption(HELP_ARG)) {
            ToolOptions toolOpts = new ToolOptions();
            configureOptions(toolOpts);
            printHelp(toolOpts);
            throw new InvalidOptionsException("");
        }

        if (in.hasOption(TEMP_ROOTDIR_ARG)) {
            out.setTempRootDir(in.getOptionValue(TEMP_ROOTDIR_ARG));
        }

        if (in.hasOption(CONNECT_STRING_ARG)) {
            out.setConnectString(in.getOptionValue(CONNECT_STRING_ARG));
        }

        if (in.hasOption(CONN_MANAGER_CLASS_NAME)) {
            out.setConnManagerClassName(in.getOptionValue(CONN_MANAGER_CLASS_NAME));
        }

        if (in.hasOption(CONNECT_PARAM_FILE)) {
            File paramFile = new File(in.getOptionValue(CONNECT_PARAM_FILE));
            if (!paramFile.exists()) {
                throw new InvalidOptionsException(
                    "Specified connection parameter file not found: " + paramFile);
            }
            InputStream inStream = null;
            Properties connectionParams = new Properties();
            try {
                inStream = new FileInputStream(
                    new File(in.getOptionValue(CONNECT_PARAM_FILE)));
                connectionParams.load(inStream);
            } catch (IOException ex) {
                LOG.warn("Failed to load connection parameter file", ex);
                throw new InvalidOptionsException(
                    "Error while loading connection parameter file: "
                        + ex.getMessage());
            } finally {
                if (inStream != null) {
                    try {
                        inStream.close();
                    } catch (IOException ex) {
                        LOG.warn("Failed to close input stream", ex);
                    }
                }
            }
            LOG.debug("Loaded connection parameters: " + connectionParams);
            out.setConnectionParams(connectionParams);
        }

        if (in.hasOption(NULL_STRING)) {
            out.setNullStringValue(in.getOptionValue(NULL_STRING));
        }

        if (in.hasOption(INPUT_NULL_STRING)) {
            out.setInNullStringValue(in.getOptionValue(INPUT_NULL_STRING));
        }

        if (in.hasOption(NULL_NON_STRING)) {
            out.setNullNonStringValue(in.getOptionValue(NULL_NON_STRING));
        }

        if (in.hasOption(INPUT_NULL_NON_STRING)) {
            out.setInNullNonStringValue(in.getOptionValue(INPUT_NULL_NON_STRING));
        }

        if (in.hasOption(DRIVER_ARG)) {
            out.setDriverClassName(in.getOptionValue(DRIVER_ARG));
        }

        if (in.hasOption(SKIP_DISTCACHE_ARG)) {
            LOG.debug("Disabling dist cache");
            out.setSkipDistCache(true);
        }

        applyCredentialsOptions(in, out);

        if (in.hasOption(HADOOP_MAPRED_HOME_ARG)) {
            out.setHadoopMapRedHome(in.getOptionValue(HADOOP_MAPRED_HOME_ARG));
            // Only consider HADOOP_HOME if HADOOP_MAPRED_HOME is not set
        } else if (in.hasOption(HADOOP_HOME_ARG)) {
            out.setHadoopMapRedHome(in.getOptionValue(HADOOP_HOME_ARG));
        }
        if (in.hasOption(RELAXED_ISOLATION)) {
            out.setRelaxedIsolation(true);
        }
    }