Drop support for PostgreSQL 9.1

PostgreSQL version 9.1 is no longer supported by the upstream, and it's
not worth the maintenance overhead.

Author: elprans

.travis.yml

@@ -39,16 +39,6 @@ matrix:
 
         # Do quick test runs for each supported version of PostgreSQL
         # minus the latest.
-        - os: linux
-          dist: precise
-          sudo: false
-          language: python
-          python: "3.5"
-          services: postgresql
-          env: BUILD=quicktests PGVERSION=9.1
-          addons:
-              postgresql: '9.1'
-
         - os: linux
           dist: trusty
           sudo: false

README.rst

@@ -17,7 +17,7 @@ framework.  You can read more about asyncpg in an introductory
 `blog post <http://magic.io/blog/asyncpg-1m-rows-from-postgres-to-python/>`_.
 
 asyncpg requires Python 3.5 or later and is supported for PostgreSQL
-versions 9.1 to 9.6.
+versions 9.2 to 9.6.
 
 
 Documentation

asyncpg/connection.py

@@ -80,10 +80,7 @@ def __init__(self, protocol, transport, loop,
         self._server_caps = _detect_server_capabilities(
             self._server_version, settings)
 
-        if self._server_version < (9, 2):
-            self._intro_query = introspection.INTRO_LOOKUP_TYPES_91
-        else:
-            self._intro_query = introspection.INTRO_LOOKUP_TYPES
+        self._intro_query = introspection.INTRO_LOOKUP_TYPES
 
         self._reset_query = None
         self._proxy = None

asyncpg/introspection.py

@@ -134,124 +134,6 @@
 '''.format(typeinfo=_TYPEINFO)
 
 
-# Prior to 9.2 PostgreSQL did not have range types.
-_TYPEINFO_91 = '''\
-    (
-        SELECT
-            t.oid                           AS oid,
-            ns.nspname                      AS ns,
-            t.typname                       AS name,
-            t.typtype                       AS kind,
-            (CASE WHEN t.typtype = 'd' THEN
-                (WITH RECURSIVE typebases(oid, depth) AS (
-                    SELECT
-                        t2.typbasetype      AS oid,
-                        0                   AS depth
-                    FROM
-                        pg_type t2
-                    WHERE
-                        t2.oid = t.oid
-
-                    UNION ALL
-
-                    SELECT
-                        t2.typbasetype      AS oid,
-                        tb.depth + 1        AS depth
-                    FROM
-                        pg_type t2,
-                        typebases tb
-                    WHERE
-                       tb.oid = t2.oid
-                       AND t2.typbasetype != 0
-               ) SELECT oid FROM typebases ORDER BY depth DESC LIMIT 1)
-
-               ELSE NULL
-            END)                            AS basetype,
-            t.typreceive::oid != 0 AND t.typsend::oid != 0
-                                            AS has_bin_io,
-            t.typelem                       AS elemtype,
-            elem_t.typdelim                 AS elemdelim,
-            NULL::oid                       AS range_subtype,
-            elem_t.typreceive::oid != 0 AND
-                elem_t.typsend::oid != 0
-                                            AS elem_has_bin_io,
-            (CASE WHEN t.typtype = 'c' THEN
-                (SELECT
-                    array_agg(ia.atttypid ORDER BY ia.attnum)
-                FROM
-                    pg_attribute ia
-                    INNER JOIN pg_class c
-                        ON (ia.attrelid = c.oid)
-                WHERE
-                    ia.attnum > 0 AND NOT ia.attisdropped
-                    AND c.reltype = t.oid)
-
-                ELSE NULL
-            END)                            AS attrtypoids,
-            (CASE WHEN t.typtype = 'c' THEN
-                (SELECT
-                    array_agg(ia.attname::text ORDER BY ia.attnum)
-                FROM
-                    pg_attribute ia
-                    INNER JOIN pg_class c
-                        ON (ia.attrelid = c.oid)
-                WHERE
-                    ia.attnum > 0 AND NOT ia.attisdropped
-                    AND c.reltype = t.oid)
-
-                ELSE NULL
-            END)                            AS attrnames
-        FROM
-            pg_catalog.pg_type AS t
-            INNER JOIN pg_catalog.pg_namespace ns ON (
-                ns.oid = t.typnamespace)
-            LEFT JOIN pg_type elem_t ON (
-                t.typlen = -1 AND
-                t.typelem != 0 AND
-                t.typelem = elem_t.oid
-            )
-    )
-'''
-
-INTRO_LOOKUP_TYPES_91 = '''\
-WITH RECURSIVE typeinfo_tree(
-    oid, ns, name, kind, basetype, has_bin_io, elemtype, elemdelim,
-    range_subtype, elem_has_bin_io, attrtypoids, attrnames, depth)
-AS (
-
-    SELECT
-        ti.oid, ti.ns, ti.name, ti.kind, ti.basetype, ti.has_bin_io,
-        ti.elemtype, ti.elemdelim, ti.range_subtype, ti.elem_has_bin_io,
-        ti.attrtypoids, ti.attrnames, 0
-    FROM
-        {typeinfo} AS ti
-    WHERE
-        ti.oid = any($1::oid[])
-
-    UNION ALL
-
-    SELECT
-        ti.oid, ti.ns, ti.name, ti.kind, ti.basetype, ti.has_bin_io,
-        ti.elemtype, ti.elemdelim, ti.range_subtype, ti.elem_has_bin_io,
-        ti.attrtypoids, ti.attrnames, tt.depth + 1
-    FROM
-        {typeinfo} ti,
-        typeinfo_tree tt
-    WHERE
-        (tt.elemtype IS NOT NULL AND ti.oid = tt.elemtype)
-        OR (tt.attrtypoids IS NOT NULL AND ti.oid = any(tt.attrtypoids))
-        OR (tt.range_subtype IS NOT NULL AND ti.oid = tt.range_subtype)
-)
-
-SELECT DISTINCT
-    *
-FROM
-    typeinfo_tree
-ORDER BY
-    depth DESC
-'''.format(typeinfo=_TYPEINFO_91)
-
-
 TYPE_BY_NAME = '''\
 SELECT
     t.oid,

tests/test_codecs.py

@@ -214,7 +214,7 @@ def _timezone(offset):
     ('json', 'json', [
         '[1, 2, 3, 4]',
         '{"a": [1, 2], "b": 0}'
-    ], (9, 2)),
+    ]),
     ('jsonb', 'jsonb', [
         '[1, 2, 3, 4]',
         '{"a": [1, 2], "b": 0}'
@@ -744,10 +744,6 @@ async def test_domains(self):
     async def test_range_types(self):
         """Test encoding/decoding of range types."""
 
-        if self.server_version < (9, 2):
-            raise unittest.SkipTest(
-                'PostgreSQL servers < 9.2 do not support range types.')
-
         cases = [
             ('int4range', [
                 [(1, 9), asyncpg.Range(1, 10)],