influxdb/ui/spec/influxql/astToStringSpec.js

import InfluxQL from 'src/influxql'

describe('influxql astToString', () => {
  it('simple query', () => {
    const ast = InfluxQL({
      fields: [
        {
          column: {
            expr: 'binary',
            op: '+',
            lhs: {
              expr: 'literal',
              val: '1',
              type: 'integer',
            },
            rhs: {
              expr: 'reference',
              val: 'A',
            },
          },
        },
      ],
      sources: [
        {
          database: '',
          retentionPolicy: '',
          name: 'howdy',
          type: 'measurement',
        },
      ],
    })

    const expected = `SELECT 1 + "A" FROM "howdy"`
    const actual = ast.toString()

    // console.log(actual)

    expect(actual).to.equal(expected)
  })

  it('simple query w/ multiple sources', () => {
    const ast = InfluxQL({
      fields: [
        {
          column: {
            expr: 'binary',
            op: '+',
            lhs: {
              expr: 'literal',
              val: '1',
              type: 'integer',
            },
            rhs: {
              expr: 'reference',
              val: 'A',
            },
          },
        },
      ],
      sources: [
        {
          database: '',
          retentionPolicy: '',
          name: 'howdy',
          type: 'measurement',
        },
        {
          database: 'telegraf',
          retentionPolicy: 'autogen',
          name: 'doody',
          type: 'measurement',
        },
      ],
    })

    const expected = `SELECT 1 + "A" FROM "howdy", "telegraf"."autogen"."doody"`
    const actual = ast.toString()

    // console.log('actual  ', actual)
    // console.log('expected', expected)

    expect(actual).to.equal(expected)
  })

  it('query with AS', () => {
    const ast = InfluxQL({
      fields: [
        {
          alias: 'B',
          column: {
            expr: 'binary',
            op: '+',
            lhs: {
              expr: 'literal',
              val: '1',
              type: 'integer',
            },
            rhs: {
              expr: 'reference',
              val: 'A',
            },
          },
        },
      ],
      sources: [
        {
          database: '',
          retentionPolicy: '',
          name: 'howdy',
          type: 'measurement',
        },
      ],
    })

    const expected = `SELECT 1 + "A" AS "B" FROM "howdy"`
    const actual = ast.toString()

    // console.log(actual)

    expect(actual).to.equal(expected)
  })

  it('query with 2x func', () => {
    const ast = InfluxQL({
      fields: [
        {
          column: {
            expr: 'binary',
            op: '/',
            lhs: {
              expr: 'call',
              name: 'derivative',
              args: [
                {
                  expr: 'reference',
                  val: 'field1',
                },
                {
                  expr: 'literal',
                  val: '1h',
                  type: 'duration',
                },
              ],
            },
            rhs: {
              expr: 'call',
              name: 'derivative',
              args: [
                {
                  expr: 'reference',
                  val: 'field2',
                },
                {
                  expr: 'literal',
                  val: '1h',
                  type: 'duration',
                },
              ],
            },
          },
        },
      ],
      sources: [
        {
          database: '',
          retentionPolicy: '',
          name: 'myseries',
          type: 'measurement',
        },
      ],
    })

    const expected = `SELECT derivative("field1", 1h) / derivative("field2", 1h) FROM "myseries"`
    const actual = ast.toString()

    // console.log('actual', actual)
    // console.log('expected', expected)

    expect(actual).to.equal(expected)
  })

  it('query with where and groupby', () => {
    const ast = InfluxQL({
      condition: {
        expr: 'binary',
        op: 'AND',
        lhs: {
          expr: 'binary',
          op: 'AND',
          lhs: {
            expr: 'binary',
            op: '=~',
            lhs: {
              expr: 'reference',
              val: 'cluster_id',
            },
            rhs: {
              expr: 'literal',
              val: '/^23/',
              type: 'regex',
            },
          },
          rhs: {
            expr: 'binary',
            op: '=',
            lhs: {
              expr: 'reference',
              val: 'host',
            },
            rhs: {
              expr: 'literal',
              val: 'prod-2ccccc04-us-east-1-data-3',
              type: 'string',
            },
          },
        },
        rhs: {
          expr: 'binary',
          op: '\u003e',
          lhs: {
            expr: 'reference',
            val: 'time',
          },
          rhs: {
            expr: 'binary',
            op: '-',
            lhs: {
              expr: 'call',
              name: 'now',
            },
            rhs: {
              expr: 'literal',
              val: '15m',
              type: 'duration',
            },
          },
        },
      },
      fields: [
        {
          alias: 'max_cpus',
          column: {
            expr: 'call',
            name: 'max',
            args: [
              {
                expr: 'reference',
                val: 'n_cpus',
              },
            ],
          },
        },
        {
          column: {
            expr: 'call',
            name: 'non_negative_derivative',
            args: [
              {
                expr: 'call',
                name: 'median',
                args: [
                  {
                    expr: 'reference',
                    val: 'n_users',
                  },
                ],
              },
              {
                expr: 'literal',
                val: '5m',
                type: 'duration',
              },
            ],
          },
        },
      ],
      groupBy: {
        time: {
          interval: '15m',
          offset: '10s',
        },
        tags: ['host', 'tag_x'],
        fill: '10',
      },
      sources: [
        {
          database: '',
          retentionPolicy: '',
          name: 'system',
          type: 'measurement',
        },
      ],
    })

    const expected =
      'SELECT max("n_cpus") AS "max_cpus", non_negative_derivative(median("n_users"), 5m) FROM "system" WHERE "cluster_id" =~ /^23/ AND "host" = \'prod-2ccccc04-us-east-1-data-3\' AND time > now() - 15m GROUP BY time(15m, 10s),host,tag_x fill(10)'
    const actual = ast.toString()

    // console.log('actual  ', actual)
    // console.log('expected', expected)

    expect(actual).to.equal(expected)
  })

  it('query with orderby and limit', () => {
    const ast = InfluxQL({
      condition: {
        expr: 'binary',
        op: 'AND',
        lhs: {
          expr: 'binary',
          op: '=',
          lhs: {
            expr: 'reference',
            val: 'host',
          },
          rhs: {
            expr: 'literal',
            val: 'hosta.influxdb.org',
            type: 'string',
          },
        },
        rhs: {
          expr: 'binary',
          op: '\u003e',
          lhs: {
            expr: 'reference',
            val: 'time',
          },
          rhs: {
            expr: 'literal',
            val: '2017-02-07T01:43:02.245407693Z',
            type: 'string',
          },
        },
      },
      fields: [
        {
          column: {
            expr: 'call',
            name: 'mean',
            args: [
              {
                expr: 'reference',
                val: 'field1',
              },
            ],
          },
        },
        {
          column: {
            expr: 'call',
            name: 'sum',
            args: [
              {
                expr: 'reference',
                val: 'field2',
              },
            ],
          },
        },
        {
          alias: 'field_x',
          column: {
            expr: 'call',
            name: 'count',
            args: [
              {
                expr: 'reference',
                val: 'field3',
              },
            ],
          },
        },
      ],
      groupBy: {
        time: {
          interval: '10h',
        },
      },
      limits: {
        limit: 20,
        offset: 10,
      },
      orderbys: [
        {
          name: 'time',
          order: 'descending',
        },
      ],
      sources: [
        {
          database: '',
          retentionPolicy: '',
          name: 'myseries',
          type: 'measurement',
        },
      ],
    })

    const expected = `SELECT mean("field1"), sum("field2"), count("field3") AS "field_x" FROM "myseries" WHERE "host" = 'hosta.influxdb.org' AND time > '2017-02-07T01:43:02.245407693Z' GROUP BY time(10h) ORDER BY time DESC LIMIT 20 OFFSET 10`
    const actual = ast.toString()

    // console.log('actual  ', actual)
    // console.log('expected', expected)

    expect(actual).to.equal(expected)
  })
})