Method BigQueryDatasource.query has a Cognitive Complexity of 49 (exceeds 20 allowed). Consider refactoring.

Open

func (td *BigQueryDatasource) query(ctx context.Context, query backend.DataQuery, req *backend.QueryDataRequest) backend.DataResponse {
    response := backend.DataResponse{}

    // Unmarshal the json into our queryModel
    var queryModel QueryModel

• Read up
  Read up

Function addSelectPart has a Cognitive Complexity of 34 (exceeds 5 allowed). Consider refactoring.

Open

  public addSelectPart(selectParts, item, subItem) {
    let partType = item.value;
    if (subItem && subItem.type) {
      partType = subItem.type;
    }

• Read up
  Read up

Function _buildDataPoints has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

  private static _buildDataPoints(results, timeIndex, metricIndex, valueIndexes) {
    const data = [];
    let targetName = '';
    let metricName = '';
    let i;

• Read up
  Read up

Function buildQuery has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

  public buildQuery() {
    let query = '';
    let outerQuery = '';
    query += '\n' + 'SELECT';
    query += '\n ' + this.buildTimeColumn();

• Read up
  Read up

Function buildGroupClause has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

  public buildGroupClause() {
    let query = '';
    let groupSection = '';
    for (let i = 0; i < this.target.group.length; i++) {
      const part = this.target.group[i];

• Read up
  Read up

Function testDatasource has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

  public async testDatasource() {
    let status = 'success';
    let message = 'Successfully queried the BigQuery API.';
    const defaultErrorMessage = 'Cannot connect to BigQuery API';
    if (!this.projectName) {

• Read up
  Read up

Function buildWhereClause has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

  public buildWhereClause() {
    let query = '', hasMacro = false, hasDateFilter = false;
    const conditions = _.map(this.target.where, (tag, index) => {
      switch (tag.type) {
        case 'macro':

• Read up
  Read up

Function _handleRecordFields has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

  private static _handleRecordFields(results, res) {
    for (const fl of results) {
      if (fl.type === 'RECORD') {
        for (const f of fl.fields) {
          if (f.type !== 'RECORD') {

• Read up
  Read up

Function buildValueColumn has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

  public buildValueColumn(column) {
    const columnName = _.find(column, (g: any) => g.type === 'column');
    let query = BigQueryQuery.quoteFiledName(columnName.params[0]);
    const aggregate = _.find(column, (g: any) => g.type === 'aggregate' || g.type === 'percentile');
    const windows = _.find(column, (g: any) => g.type === 'window' || g.type === 'moving_window');

• Read up
  Read up

Function buildHllOuterQuery has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

  public buildHllOuterQuery() {
    let query = 'time';
    let numOfColumns = 1;
    let hllInd = 0;
    if (this.hasMetricColumn()) {

• Read up
  Read up

Function transformAnnotationResponse has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

  public transformAnnotationResponse(options, data) {
    const table = data.data;
    let timeColumnIndex = -1;
    let textColumnIndex = -1;
    let tagsColumnIndex = -1;

• Read up
  Read up

Function parseTableFields has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

  public static parseTableFields(results, filter): IResultFormat[] {
    const fields: IResultFormat[] = [];
    if (!results || results.length === 0) {
      return fields;
    }

• Read up
  Read up

Method BigQueryDatasource.executeQuery has 16 return statements (exceeds 4 allowed).

Open

func (td *BigQueryDatasource) executeQuery(ctx context.Context, queryModel QueryModel, originalQuery backend.DataQuery, req *backend.QueryDataRequest) (*BigQueryResult, error) {
    if !queryModel.RawQuery {
        return nil, errors.New("alerting queries only support raw sql")
    }

Method BigQueryDatasource.executeQuery has a Cognitive Complexity of 27 (exceeds 20 allowed). Consider refactoring.

Open

func (td *BigQueryDatasource) executeQuery(ctx context.Context, queryModel QueryModel, originalQuery backend.DataQuery, req *backend.QueryDataRequest) (*BigQueryResult, error) {
    if !queryModel.RawQuery {
        return nil, errors.New("alerting queries only support raw sql")
    }

• Read up
  Read up

Function setUpQ has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

  private setUpQ(modOptions, options, query) {
    let [q, hasMacro, convertToUTC] = this.queryModel.expend_macros(modOptions);
    if (q) {
      q = this.setUpPartition(q, query.partitioned, query.partitionedField, modOptions, hasMacro, convertToUTC);
      q = BigQueryDatasource._updatePartition(q, modOptions, convertToUTC);

• Read up
  Read up

Method BigQueryDatasource.query has 9 return statements (exceeds 4 allowed).

Open

func (td *BigQueryDatasource) query(ctx context.Context, query backend.DataQuery, req *backend.QueryDataRequest) backend.DataResponse {
    response := backend.DataResponse{}

    // Unmarshal the json into our queryModel
    var queryModel QueryModel

Function _toTimeSeries has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  private static _toTimeSeries(results) {
    let timeIndex = -1;
    let metricIndex = -1;
    const valueIndexes = [];
    for (let i = 0; i < results.schema.fields.length; i++) {

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        if (fullStringId.toLowerCase().includes('.information_schema')) {
                            projectFound = splittedProject[0];
                        }

Function _FindTimeField has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  public static _FindTimeField(sql, timeFields) {
    const select = sql.search(/select/i);
    const from = sql.search(/from/i);
    const fields = sql.substring(select + 6, from);
    const splitFrom = fields.split(',');

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

            for (const ff of f.fields) {
              ff.name = fl.name + '.' + f.name + '.' + ff.name;
            }