private void initConfig()

in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/dialect/GenericDatabaseDialect.java [77:102]

21 lines of code
1 McCabe index (conditional complexity)


    private void initConfig(Properties config, String dbType) {
        // connection info
        this.dbType = dbType;
        this.jdbcUrl = config.getProperty(JdbcStorageConfigConstants.STORAGE_JDBC_URL, null);
        this.userName = config.getProperty(JdbcStorageConfigConstants.STORAGE_JDBC_USER, null);
        this.password = config.getProperty(JdbcStorageConfigConstants.STORAGE_JDBC_PASSWORD, null);
        Assert.notNull(jdbcUrl, "Configuration jdbc url cannot be empty");
        Assert.notNull(userName, "Configuration jdbc userName cannot be empty");
        Assert.notNull(password, "Configuration jdbc password cannot be empty");

        this.maxConnectionAttempts =
            Integer.parseInt(config.getProperty(JdbcStorageConfigConstants.MAX_CONNECTIONS_ATTEMPTS,
                JdbcStorageConfigConstants.MAX_CONNECTIONS_ATTEMPTS_DEFAULT));
        this.connectionRetryBackoff = Long.parseLong(config.getProperty(JdbcStorageConfigConstants.CONNECTION_RETRY_BACKOFF,
            JdbcStorageConfigConstants.CONNECTION_RETRY_BACKOFF_DEFAULT));

        // Storage db and tables
        String database = config.getProperty(JdbcStorageConfigConstants.STORAGE_JDBC_DATABASE_NAME,
            JdbcStorageConfigConstants.DATABASE_DEFAULT);
        String schemaName = config.getProperty(JdbcStorageConfigConstants.STORAGE_JDBC_SCHEMA_NAME,
            null);
        String tableName = config.getProperty(JdbcStorageConfigConstants.STORAGE_JDBC_TABLE_NAME,
            JdbcStorageConfigConstants.TABLE_NAME_DEFAULT);

        this.tableId = new TableId(tableName, database, schemaName);
    }