public InternalJdbcConnectionOptions build()

in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/options/InternalJdbcConnectionOptions.java [201:225]

24 lines of code
4 McCabe index (conditional complexity)


        public InternalJdbcConnectionOptions build() {
            checkNotNull(dbURL, "No dbURL supplied.");
            checkNotNull(tableName, "No tableName supplied.");
            if (this.dialect == null) {
                if (classLoader == null) {
                    classLoader = Thread.currentThread().getContextClassLoader();
                }
                this.dialect = JdbcFactoryLoader.loadDialect(dbURL, classLoader, compatibleMode);
            }
            if (this.driverName == null) {
                Optional<String> optional = dialect.defaultDriverName();
                this.driverName =
                        optional.orElseThrow(
                                () -> new NullPointerException("No driverName supplied."));
            }

            return new InternalJdbcConnectionOptions(
                    dialect.appendDefaultUrlProperties(dbURL),
                    tableName,
                    driverName,
                    dialect,
                    parallelism,
                    connectionCheckTimeoutSeconds,
                    properties);
        }