encoding_test.dart

import 'dart:async';
import 'dart:convert';

import 'package:postgres/postgres.dart';
import 'package:postgres/src/types/text_codec.dart';
import 'package:postgres/src/types/type_registry.dart';
import 'package:test/test.dart';

import 'docker.dart';

void main() {
  withPostgresServer('Binary encoders with reversible tests', (server) {
    late Connection conn;

    Future expectReversible(
      String typeName,
      List values, {
      String? expectedDartType,
      bool skipNegative = false,
      Object negative = 'non-value',
    }) async {
      await conn
          .execute('CREATE TEMPORARY TABLE IF NOT EXISTS t (v $typeName)');

      for (final value in values) {
        final explicit = await conn.execute(
          Sql(r'SELECT $1',
              types: [TypeRegistry().resolveSubstitution(typeName)!]),
          parameters: [value],
        );
        if (value is! double || !value.isNaN) {
          expect(explicit.single.single, value);
        } else {
          expect((explicit.first.first as double).isNaN, true);
        }

        final named = await conn.execute(Sql.named('SELECT @v:$typeName'),
            parameters: {'v': value});
        if (value is! double || !value.isNaN) {
          expect(named.single.single, value);
        } else {
          expect((named.first.first as double).isNaN, true);
        }

        final inserted = await conn.execute(
            Sql.named('INSERT INTO t (v) VALUES (@v:$typeName) RETURNING v'),
            parameters: {'v': value});
        if (value is! double || !value.isNaN) {
          expect(inserted.first.first, equals(value));
        } else {
          expect((inserted.first.first as double).isNaN, true);
        }
      }

      if (!skipNegative) {
        try {
          await conn.execute(
              Sql.named('INSERT INTO t (v) VALUES (@v:$typeName)'),
              parameters: {'v': negative});
          fail('unreachable');
        } on FormatException catch (e) {
          expect(
              e.toString(),
              contains(expectedDartType == null
                  ? 'Expected: '
                  : 'Expected: $expectedDartType'));
        }
      }
    }

    setUp(() async {
      conn = await server.newConnection();
    });

    tearDown(() async {
      await conn.close();
    });

    test('bool', () async {
      await expectReversible(
        'boolean',
        [null, true, false],
        expectedDartType: 'bool',
      );
    });

    test('smallint', () async {
      await expectReversible(
        'int2',
        [null, -1, 0, 1],
        expectedDartType: 'int',
      );
    });

    test('integer', () async {
      await expectReversible(
        'int4',
        [null, -1, 0, 1],
        expectedDartType: 'int',
      );
    });

    test('serial', () async {
      await expectReversible(
        'serial4',
        [0, 1],
        expectedDartType: 'int',
      );
    });

    test('bigint', () async {
      await expectReversible(
        'int8',
        [null, -1, 0, 1, 999999999999],
        expectedDartType: 'int',
      );
    });

    test('bigserial', () async {
      await expectReversible(
        'serial8',
        [0, 1],
        expectedDartType: 'int',
      );
    });

    test('text', () async {
      await expectReversible(
        'text',
        [
          null,
          '',
          'foo',
          'foo\n',
          'foo\nbar;s',
        ],
        negative: 0,
        expectedDartType: 'String',
      );
    });

    test('real', () async {
      await expectReversible(
        'float4',
        [null, -1.0, 0.0, 1.0, double.nan],
        expectedDartType: 'double',
      );
    });

    test('double', () async {
      await expectReversible(
        'float8',
        [null, -1.0, 0.0, 1.0, double.negativeInfinity, double.infinity],
        expectedDartType: 'double',
      );
    });

    test('date', () async {
      await expectReversible(
        'date',
        [
          null,
          DateTime.utc(1920, 10, 1),
          DateTime.utc(2120, 10, 5),
          DateTime.utc(2016, 10, 1),
        ],
        expectedDartType: 'DateTime',
      );
    });

    test('dateArray', () async {
      await expectReversible(
        '_date',
        [
          null,
          <DateTime>[],
          [
            null,
            DateTime.utc(1920, 10, 1),
            DateTime.utc(2120, 10, 5),
            DateTime.utc(2016, 10, 1),
          ],
        ],
        expectedDartType: 'List<DateTime?>',
      );
    });

    test('timestamp', () async {
      await expectReversible(
        'timestamp',
        [
          null,
          DateTime.utc(1920, 10, 1),
          DateTime.utc(2120, 10, 5),
          DateTime.utc(2016, 10, 1),
        ],
        expectedDartType: 'DateTime',
      );
    });

    test('timestamptz', () async {
      await expectReversible(
        'timestamptz',
        [
          null,
          DateTime.utc(1920, 10, 1),
          DateTime.utc(2120, 10, 5),
          DateTime.utc(2016, 10, 1),
        ],
        expectedDartType: 'DateTime',
      );
    });

    test('interval', () async {
      await expectReversible(
        'interval',
        [
          null,
          Interval(microseconds: 12345678),
          Interval(days: 1, microseconds: 15),
          Interval(days: -1, months: 5),
        ],
        expectedDartType: 'Interval',
      );
    });

    test('numeric', () async {
      await expectReversible(
        'numeric',
        [
          null,
          '-123400000.20000',
          '-123400001.00002',
          '1000000000000000000000000000.0000000000000000000000000001',
          '3141592653589793238462643383279502.1618033988749894848204586834365638',
          '-3141592653589793238462643383279502.1618033988749894848204586834365638',
          '0',
          '0.0',
          '0.1',
          '0.0001',
          '0.00001',
          '0.000001',
          '0.000000001',
          '1.000000000',
          '1000.000000000',
          '10000.000000000',
          '100000000.00000000',
          'NaN',
        ],
        expectedDartType: 'String',
      );
    });

    test('jsonb', () async {
      await expectReversible(
        'jsonb',
        [
          null,
          'string',
          2,
          ['foo'],
          {
            'key': 'val',
            'key1': 1,
            'array': ['foo'],
          },
        ],
        skipNegative: true,
      );

      try {
        await conn.execute(Sql.named('INSERT INTO t (v) VALUES (@v:jsonb)'),
            parameters: {'v': DateTime.now()});
        fail('unreachable');
      } on JsonUnsupportedObjectError catch (_) {}
    });

    test('bytea', () async {
      await expectReversible(
        'bytea',
        [
          null,
          [0],
          [1, 2, 3, 4, 5],
          [255, 254, 253],
        ],
        expectedDartType: 'List<int>',
      );
    });

    test('uuid', () async {
      await expectReversible(
        'uuid',
        [
          null,
          '00000000-0000-0000-0000-000000000000',
          '12345678-abcd-efab-cdef-012345678901',
        ],
        negative: 0,
        expectedDartType: 'String',
      );
    });

    test('uuidArray', () async {
      await expectReversible(
        '_uuid',
        [
          null,
          <String>[],
          [
            null,
            '00000000-0000-0000-0000-000000000000',
            '12345678-abcd-efab-cdef-012345678901',
          ],
        ],
        expectedDartType: 'List<String?>',
      );
    });

    test('Invalid UUID encoding', () async {
      final invalids = [
        'z0000000-0000-0000-0000-000000000000',
        '0000000-0000-0000-0000-000000000000',
        '00000000-0000-0000-0000-000000000000f',
      ];

      await conn.execute('CREATE TEMPORARY TABLE IF NOT EXISTS t (v uuid)');

      for (final value in invalids) {
        try {
          await conn.execute(
              Sql.named('INSERT INTO t (v) VALUES (@v:uuid) RETURNING v'),
              parameters: {'v': value});
          fail('unreachable');
        } on FormatException catch (e) {
          expect(e.toString(), contains('Invalid UUID string'));
        }
      }
    });

    test('char', () async {
      await expectReversible(
        'char',
        [null, 'a'],
        negative: 0,
        expectedDartType: 'String',
      );
    });

    test('varchar', () async {
      await expectReversible(
        'varchar',
        [null, '', 'foo', 'foo\n', 'foo\nbar;s'],
        negative: 0,
        expectedDartType: 'String',
      );
    });

    test('json', () async {
      await expectReversible(
        'json',
        [
          null,
          'string',
          2,
          ['foo'],
          {
            'key': 'val',
            'key1': 1,
            'array': ['foo'],
          },
        ],
        skipNegative: true,
      );

      try {
        await conn.execute(Sql.named('INSERT INTO t (v) VALUES (@v:jsonb)'),
            parameters: {'v': DateTime.now()});
        fail('unreachable');
      } on JsonUnsupportedObjectError catch (_) {}

      try {
        await conn.execute(Sql.named('INSERT INTO t (v) VALUES (@v:json)'),
            parameters: {'v': DateTime.now()});
        fail('unreachable');
      } on JsonUnsupportedObjectError catch (_) {}
    });

    test('point', () async {
      await expectReversible(
        'point',
        [
          null,
          Point(0, 0),
          Point(100, 123.456),
          Point(0.001, -999),
        ],
        expectedDartType: 'Point',
      );
    });

    test('booleanArray', () async {
      await expectReversible(
        '_bool',
        [
          null,
          <bool>[],
          [null, false, true],
          [true],
        ],
        expectedDartType: 'List<bool?>',
      );
    });

    test('smallIntegerArray', () async {
      await expectReversible(
        '_int2',
        [
          null,
          <int>[],
          [null, -1, 0, 200],
          [-123],
        ],
        expectedDartType: 'List<int?>',
      );
    });

    test('integerArray', () async {
      await expectReversible(
        '_int4',
        [
          null,
          <int>[],
          [null, -1, 0, 200],
          [-123],
        ],
        expectedDartType: 'List<int?>',
      );
    });

    test('bigIntegerArray', () async {
      await expectReversible(
        '_int8',
        [
          null,
          <int>[],
          [null, -1, 0, 200],
          [-123],
        ],
        expectedDartType: 'List<int?>',
      );
    });

    test('timestampArray', () async {
      await expectReversible(
        '_timestamp',
        [
          null,
          <DateTime>[],
          [
            null,
            DateTime.utc(1970),
            DateTime.fromMicrosecondsSinceEpoch(12345678, isUtc: true),
            DateTime.timestamp()
          ],
        ],
        expectedDartType: 'List<DateTime?>',
      );
    });

    test('timestampTzArray', () async {
      await expectReversible(
        '_timestamptz',
        [
          null,
          <DateTime>[],
          [
            null,
            DateTime.utc(1970),
            DateTime.fromMicrosecondsSinceEpoch(12345678, isUtc: true),
            DateTime.timestamp()
          ],
        ],
        expectedDartType: 'List<DateTime?>',
      );
    });

    test('doubleArray', () async {
      await expectReversible(
        '_float8',
        [
          null,
          <double>[],
          [null, -123.0, 0.0, 1.0],
          [0.001, 45.678],
        ],
        expectedDartType: 'List<double?>',
      );
    });

    test('varCharArray', () async {
      await expectReversible(
        '_varchar',
        [
          null,
          <String>[],
          [null, '', 'foo', 'foo\n', 'foo\nbar;s'],
        ],
        negative: 0,
        expectedDartType: 'List<String?>',
      );
    });

    test('textArray', () async {
      await expectReversible(
        '_text',
        [
          null,
          <String>[],
          [null, '', 'foo', 'foo\n', 'foo\nbar;s'],
        ],
        negative: 0,
        expectedDartType: 'List<String?>',
      );
    });

    test('jsonbArray', () async {
      await expectReversible(
        '_jsonb',
        [
          null,
          [],
          ['', 'foo', 'foo\n', 'foo\nbar;s', 2, 0.1, true],
          [
            {'a': false},
            {},
            2,
            ['a'],
            {
              'a': ['b']
            }
          ],
        ],
        skipNegative: true,
      );

      try {
        await conn.execute(Sql.named('INSERT INTO t (v) VALUES (@v:_jsonb)'),
            parameters: {
              'v': [DateTime.now()]
            });
        fail('unreachable');
      } on JsonUnsupportedObjectError catch (_) {}
    });

    test('void', () async {
      final result = await conn.execute(Sql.named('SELECT NULL::void AS r'));
      expect(result.schema.columns.single.typeOid, TypeOid.voidType);

      expect(result, [
        [null]
      ]);

      await expectLater(
        () => conn.execute(
          Sql(r'SELECT $1 AS r', types: [Type.voidType]),
          parameters: [1],
        ),
        throwsArgumentError,
      );
    });

    test('regtype', () async {
      await expectReversible(
        'regtype',
        [null, Type.bigInteger, Type.voidType],
        skipNegative: true,
      );
    });

    test('issue #22', () async {
      // TODO: investigate
      // await conn.execute(Sql.named('SELECT TO_TIMESTAMP(@ts / 1000)'),
      //     parameters: {'ts': 1640556171599});
      await conn.execute(Sql.named('SELECT TO_TIMESTAMP(@ts:int8 / 1000)'),
          parameters: {'ts': 1640556171599});
    });

    test('time', () async {
      await expectReversible(
        'time',
        [
          null,
          Time(16, 0, 44, 0, 888),
          Time.fromMicroseconds(57644000888),
          Time(0, 0, 0, 0, 86400000000),
          Time(0),
        ],
        expectedDartType: 'Time',
      );
    });

    test('timeArray', () async {
      await expectReversible(
        '_time',
        [
          null,
          <Time>[],
          [
            null,
            Time(16, 0, 44, 0, 888),
            Time.fromMicroseconds(57644000888),
            Time(0, 0, 0, 0, 86400000000),
            Time(0),
          ],
        ],
        expectedDartType: 'List<Time?>',
      );
    });

    test('line', () async {
      await expectReversible(
        'line',
        [
          null,
          Line(1, 2, 3),
          Line(.0002, .000001, 100000),
        ],
        expectedDartType: 'Line',
      );
    });

    test('lseg', () async {
      await expectReversible(
        'lseg',
        [
          null,
          LineSegment(Point(1, 2), Point(3, 4)),
          LineSegment(Point(1, 2), Point(1, 2)),
        ],
        expectedDartType: 'LineSegment',
      );
    });

    test('box', () async {
      await expectReversible(
        'box',
        [
          null,
          Box(Point(1.23, 2), Point(3, 4)),
          // Check all box coordinate permutations are reordered correctly
          Box(Point(-1, 1), Point(1, -1)),
          Box(Point(1, -1), Point(-1, 1)),
          Box(Point(1, 1), Point(-1, -1)),
          Box(Point(-1, -1), Point(1, 1)),
          Box(Point(0, 0), Point(-1, 0)),
          Box(Point(0, 0), Point(0, 0)),
        ],
        expectedDartType: 'Box',
      );
    });

    test('polygon', () async {
      await expectReversible(
        'polygon',
        [
          null,
          Polygon([Point(0, 0)]),
          Polygon([Point(1, 2), Point(3, 4), Point(5, 6), Point(7, 8.2)]),
          Polygon([Point(1, 2), Point(3, 4), Point(5, 6), Point(-7, -8.2)]),
        ],
        expectedDartType: 'Polygon',
      );
    });

    test('path', () async {
      await expectReversible(
        'path',
        [
          null,
          Path([Point(0, 0)], open: false),
          Path([Point(1, 2), Point(3, 4), Point(5, 6), Point(7, 8.2)],
              open: true),
          Path([Point(1, 2), Point(3, 4), Point(5, 6), Point(-7, -8.2)],
              open: true),
        ],
        expectedDartType: 'Path',
      );
    });

    test('circle', () async {
      await expectReversible(
        'circle',
        [
          null,
          Circle(Point(0, 0), 0),
          Circle(Point(-1, 1), 1.234),
        ],
        expectedDartType: 'Circle',
      );
    });

    test('int4range', () async {
      await expectReversible(
        'int4range',
        [
          null,
          // normal ranges
          IntRange(4, 4, Bounds(Bound.inclusive, Bound.inclusive)),
          IntRange(4, 5, Bounds(Bound.inclusive, Bound.inclusive)),
          IntRange(4, 6, Bounds(Bound.exclusive, Bound.exclusive)),
          // partially unbounded ranges
          IntRange(null, 4, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(4, null, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(null, 4, Bounds(Bound.exclusive, Bound.inclusive)),
          IntRange(4, null, Bounds(Bound.exclusive, Bound.inclusive)),
          // unbounded ranges
          IntRange(null, null, Bounds(Bound.exclusive, Bound.inclusive)),
          IntRange(null, null, Bounds(Bound.exclusive, Bound.exclusive)),
          IntRange(null, null, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(null, null, Bounds(Bound.inclusive, Bound.inclusive)),
          // empty ranges
          IntRange(4, 4, Bounds(Bound.exclusive, Bound.exclusive)),
          IntRange(4, 4, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(4, 4, Bounds(Bound.exclusive, Bound.inclusive)),
          IntRange(4, 5, Bounds(Bound.exclusive, Bound.exclusive)),
        ],
        expectedDartType: 'IntRange',
      );
    });

    test('int8range', () async {
      await expectReversible(
        'int8range',
        [
          null,
          // normal ranges
          IntRange(4, 4, Bounds(Bound.inclusive, Bound.inclusive)),
          IntRange(4, 5, Bounds(Bound.inclusive, Bound.inclusive)),
          IntRange(4, 6, Bounds(Bound.exclusive, Bound.exclusive)),
          // partially unbounded ranges
          IntRange(null, 4, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(4, null, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(null, 4, Bounds(Bound.exclusive, Bound.inclusive)),
          IntRange(4, null, Bounds(Bound.exclusive, Bound.inclusive)),
          // unbounded ranges
          IntRange(null, null, Bounds(Bound.exclusive, Bound.inclusive)),
          IntRange(null, null, Bounds(Bound.exclusive, Bound.exclusive)),
          IntRange(null, null, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(null, null, Bounds(Bound.inclusive, Bound.inclusive)),
          // empty ranges
          IntRange(4, 4, Bounds(Bound.exclusive, Bound.exclusive)),
          IntRange(4, 4, Bounds(Bound.inclusive, Bound.exclusive)),
          IntRange(4, 4, Bounds(Bound.exclusive, Bound.inclusive)),
          IntRange(4, 5, Bounds(Bound.exclusive, Bound.exclusive)),
        ],
        expectedDartType: 'IntRange',
      );
    });

    test('daterange', () async {
      await expectReversible(
        'daterange',
        [
          null,
          // normal ranges
          DateRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4, 12),
              Bounds(Bound.inclusive, Bound.inclusive)),
          DateRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 5),
              Bounds(Bound.inclusive, Bound.inclusive)),
          DateRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 6),
              Bounds(Bound.exclusive, Bound.exclusive)),
          // partially unbounded ranges
          DateRange(null, DateTime.utc(2000, 4, 4),
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateRange(DateTime.utc(2000, 4, 4), null,
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateRange(null, DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.inclusive)),
          DateRange(DateTime.utc(2000, 4, 4), null,
              Bounds(Bound.exclusive, Bound.inclusive)),
          // unbounded ranges
          DateRange(null, null, Bounds(Bound.exclusive, Bound.inclusive)),
          DateRange(null, null, Bounds(Bound.exclusive, Bound.exclusive)),
          DateRange(null, null, Bounds(Bound.inclusive, Bound.exclusive)),
          DateRange(null, null, Bounds(Bound.inclusive, Bound.inclusive)),
          // empty ranges
          DateRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4, 12),
              Bounds(Bound.exclusive, Bound.exclusive)),
          DateRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.inclusive)),
          DateRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 5),
              Bounds(Bound.exclusive, Bound.exclusive)),
        ],
        expectedDartType: 'DateRange',
      );
    });

    test('tsrange', () async {
      await expectReversible(
        'tsrange',
        [
          null,
          // normal ranges
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4, 12),
              Bounds(Bound.inclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 5),
              Bounds(Bound.inclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 6),
              Bounds(Bound.exclusive, Bound.exclusive)),
          // partially unbounded ranges
          DateTimeRange(null, DateTime.utc(2000, 4, 4),
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), null,
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(null, DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), null,
              Bounds(Bound.exclusive, Bound.inclusive)),
          // unbounded ranges
          DateTimeRange(null, null, Bounds(Bound.exclusive, Bound.inclusive)),
          DateTimeRange(null, null, Bounds(Bound.exclusive, Bound.exclusive)),
          DateTimeRange(null, null, Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(null, null, Bounds(Bound.inclusive, Bound.inclusive)),
          // empty ranges
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.exclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 5),
              Bounds(Bound.exclusive, Bound.exclusive)),
        ],
        expectedDartType: 'DateTimeRange',
      );
    });

    test('tstzrange', () async {
      await expectReversible(
        'tstzrange',
        [
          null,
          // normal ranges
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4, 12),
              Bounds(Bound.inclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 5),
              Bounds(Bound.inclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 6),
              Bounds(Bound.exclusive, Bound.exclusive)),
          // partially unbounded ranges
          DateTimeRange(null, DateTime.utc(2000, 4, 4),
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), null,
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(null, DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), null,
              Bounds(Bound.exclusive, Bound.inclusive)),
          // unbounded ranges
          DateTimeRange(null, null, Bounds(Bound.exclusive, Bound.inclusive)),
          DateTimeRange(null, null, Bounds(Bound.exclusive, Bound.exclusive)),
          DateTimeRange(null, null, Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(null, null, Bounds(Bound.inclusive, Bound.inclusive)),
          // empty ranges
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.exclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.inclusive, Bound.exclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 4),
              Bounds(Bound.exclusive, Bound.inclusive)),
          DateTimeRange(DateTime.utc(2000, 4, 4), DateTime.utc(2000, 4, 5),
              Bounds(Bound.exclusive, Bound.exclusive)),
        ],
        expectedDartType: 'DateTimeRange',
      );
    });

    test('ambiguous nulls', () async {
      final statement =
          await conn.prepare(Sql.indexed('SELECT @1:json IS NULL'));

      // By default, null values in Dart are mapped to null values in SQL.
      expect(await statement.run([TypedValue<Object>(Type.json, null)]), [
        [true]
      ]);

      // For JSON types with have their own distinct null representation, we
      // can use that instead:
      expect(
          await statement
              .run([TypedValue<Object>(Type.json, null, isSqlNull: false)]),
          [
            [false]
          ]);
    });

    test("can't bind non-null Dart value as null", () async {
      await expectLater(
        () async => await conn.execute(
          Sql.indexed('SELECT @1'),
          parameters: [
            TypedValue(Type.json, {'hello': 'world'}, isSqlNull: true)
          ],
        ),
        throwsArgumentError,
      );
    });
  });

  group('Text encoders', () {
    final encoder = PostgresTextEncoder();

    test('Escape strings', () {
      //                                                       '   b   o    b   '
      expect(
          utf8.encode(encoder.convert('bob')), equals([39, 98, 111, 98, 39]));

      //                                                         '   b   o   \n   b   '
      expect(utf8.encode(encoder.convert('bo\nb')),
          equals([39, 98, 111, 10, 98, 39]));

      //                                                         '   b   o   \r   b   '
      expect(utf8.encode(encoder.convert('bo\rb')),
          equals([39, 98, 111, 13, 98, 39]));

      //                                                         '   b   o  \b   b   '
      expect(utf8.encode(encoder.convert('bo\bb')),
          equals([39, 98, 111, 8, 98, 39]));

      //                                                     '   '   '   '
      expect(utf8.encode(encoder.convert("'")), equals([39, 39, 39, 39]));

      //                                                      '   '   '   '   '   '
      expect(
          utf8.encode(encoder.convert("''")), equals([39, 39, 39, 39, 39, 39]));

      //                                                       '   '   '   '   '   '
      expect(
          utf8.encode(encoder.convert("''")), equals([39, 39, 39, 39, 39, 39]));

      //                                                       sp   E   '   \   \   '   '   '   '   '
      expect(utf8.encode(encoder.convert(r"\''")),
          equals([32, 69, 39, 92, 92, 39, 39, 39, 39, 39]));

      //                                                      sp   E   '   \   \   '   '   '
      expect(utf8.encode(encoder.convert(r"\'")),
          equals([32, 69, 39, 92, 92, 39, 39, 39]));
    });

    test('Encode DateTime', () {
      // Get users current timezone
      final tz = DateTime(2001, 2, 3).timeZoneOffset;
      final tzOffsetDelimiter = '${tz.isNegative ? '-' : '+'}'
          '${tz.abs().inHours.toString().padLeft(2, '0')}'
          ':${(tz.inSeconds % 60).toString().padLeft(2, '0')}';

      final pairs = {
        '2001-02-03T00:00:00.000$tzOffsetDelimiter':
            DateTime(2001, DateTime.february, 3),
        '2001-02-03T04:05:06.000$tzOffsetDelimiter':
            DateTime(2001, DateTime.february, 3, 4, 5, 6, 0),
        '2001-02-03T04:05:06.999$tzOffsetDelimiter':
            DateTime(2001, DateTime.february, 3, 4, 5, 6, 999),
        '0010-02-03T04:05:06.123$tzOffsetDelimiter BC':
            DateTime(-10, DateTime.february, 3, 4, 5, 6, 123),
        '0010-02-03T04:05:06.000$tzOffsetDelimiter BC':
            DateTime(-10, DateTime.february, 3, 4, 5, 6, 0),
        '012345-02-03T04:05:06.000$tzOffsetDelimiter BC':
            DateTime(-12345, DateTime.february, 3, 4, 5, 6, 0),
        '012345-02-03T04:05:06.000$tzOffsetDelimiter':
            DateTime(12345, DateTime.february, 3, 4, 5, 6, 0)
      };

      pairs.forEach((k, v) {
        expect(encoder.convert(v, escapeStrings: false), "'$k'");
      });
    });

    test('Encode Double', () {
      final pairs = {
        "'nan'": double.nan,
        "'infinity'": double.infinity,
        "'-infinity'": double.negativeInfinity,
        '1.7976931348623157e+308': double.maxFinite,
        '5e-324': double.minPositive,
        '-0.0': -0.0,
        '0.0': 0.0
      };

      pairs.forEach((k, v) {
        expect(encoder.convert(v, escapeStrings: false), k);
      });
    });

    test('Encode Int', () {
      expect(encoder.convert(1), '1');
      expect(encoder.convert(1234324323), '1234324323');