Add CockroachDB

Author: theory

Changes

@@ -1,6 +1,7 @@
 Revision history for Perl extension URI::db.
 
 0.20
+      - Added URI::cockroach.
 
 0.19  2018-07-19T15:15:04Z
       - Added URI::snowflake.

lib/URI/cockroach.pm

@@ -0,0 +1,16 @@
+package URI::cockroach;
+use base 'URI::_db';
+our $VERSION = '0.20';
+
+sub default_port { 26257 }
+sub dbi_driver   { 'Pg' }
+sub canonical_engine { 'cockroach' }
+
+sub _dbi_param_map {
+    my $self = shift;
+    return (
+        [ host   => scalar $self->host   ],
+        [ port   => scalar $self->port ],
+        [ dbname => scalar $self->dbname ],
+    );
+}

lib/URI/cockroachdb.pm

@@ -0,0 +1,3 @@
+package URI::cockroachdb;
+use base 'URI::cockroach';
+our $VERSION = '0.20';

t/dbi.t

@@ -418,6 +418,36 @@ for my $spec (
         dbi => [ [Server => 'foo'], [Port => 123], [Database => 'try'] ],
         qry => [ foo => 1, foo => 2, lol => 'yes', Driver => 'Snowflaker' ],
     },
+    {
+        uri => 'db:cockroach:',
+        dsn => 'dbi:Pg:port=26257',
+        dbi => [ [host => undef], [port => 26257], [dbname => undef] ],
+        qry => [],
+    },
+    {
+        uri => 'db:cockroach://xxx:5432',
+        dsn => 'dbi:Pg:host=xxx;port=5432',
+        dbi => [ [host => 'xxx'], [port => 5432], [dbname => undef] ],
+        qry => [],
+    },
+    {
+        uri => 'db:cockroach://foo:123/try?foo=1&foo=2&lol=yes',
+        dsn => 'dbi:Pg:host=foo;port=123;dbname=try;foo=1;foo=2;lol=yes',
+        dbi => [ [host => 'foo'], [port => 123], [dbname => 'try'] ],
+        qry => [ foo => 1, foo => 2, lol => 'yes' ],
+    },
+    {
+        uri => 'db:cockroachdb:',
+        dsn => 'dbi:Pg:port=26257',
+        dbi => [ [host => undef], [port => 26257], [dbname => undef] ],
+        qry => [],
+    },
+    {
+        uri => 'db:cockroachdb://foo:123/try?foo=1&foo=2&lol=yes',
+        dsn => 'dbi:Pg:host=foo;port=123;dbname=try;foo=1;foo=2;lol=yes',
+        dbi => [ [host => 'foo'], [port => 123], [dbname => 'try'] ],
+        qry => [ foo => 1, foo => 2, lol => 'yes' ],
+    },
 ) {
     my $uri = $spec->{uri};
     ok my $u = URI->new($uri), "URI $uri";

t/engines.t

@@ -7,48 +7,50 @@ use URI;
 use URI::QueryParam;
 
 for my $spec (
-    [ db         => undef,  undef      ],
-    [ unknown    => undef,  undef      ],
-    [ postgresql => 5432,  'pg'        ],
-    [ postgres   => 5432,  'pg'        ],
-    [ pgsql      => 5432,  'pg'        ],
-    [ pg         => 5432,  'pg'        ],
-    [ pgxc       => 5432,  'pg'        ],
-    [ postgresxc => 5432,  'pg'        ],
-    [ redshift   => 5432,  'pg'        ],
-    [ mysql      => 3306,  'mysql'     ],
-    [ mariadb    => 3306,  'mysql'     ],
-    [ maria      => 3306,  'mysql'     ],
-    [ sqlite     => undef, 'sqlite'    ],
-    [ sqlite3    => undef, 'sqlite'    ],
-    [ oracle     => 1521,  'oracle'    ],
-    [ cubrid     => 33000, 'cubrid'    ], # ?
-    [ firebird   => 3050,  'firebird'  ],
-    [ mssql      => 1433,  'mssql'     ],
-    [ sqlserver  => 1433,  'mssql'     ],
-    [ db2        => 50000, 'db2'       ], # ?
-    [ ingres     => 1524,  'ingres'    ],
-    [ sybase     => 2638,  'sybase'    ],
-    [ informix   => 1526,  'informix'  ], # ?
-    [ teradata   => 1025,  'teradata'  ],
-    [ interbase  => 3050,  'interbase' ],
-    [ unify      => 27117, 'unify'     ], # ?
-    [ mongodb    => 27017, 'mongodb'   ],
-    [ mongo      => 27017, 'mongodb'   ],
-    [ monetdb    => 50000, 'monetdb'   ], # ?
-    [ monet      => 50000, 'monetdb'   ], # ?
-    [ maxdb      => 7673,  'maxdb'     ], # ?
-    [ max        => 7673,  'maxdb'     ], # ?
-    [ impala     => 21000, 'impala'    ],
-    [ couchdb    => 5984,  'couchdb'   ],
-    [ couch      => 5984,  'couchdb'   ],
-    [ hive       => 10000, 'hive'      ],
-    [ cassandra  => 9160,  'cassandra' ],
-    [ derby      => 1527,  'derby'     ],
-    [ vertica    => 5433,  'vertica'   ],
-    [ ldapdb     => undef, 'ldapdb'    ],
-    [ exasol     => 8563,  'exasol'    ],
-    [ snowflake  => 443,   'snowflake' ],
+    [ db          => undef, undef       ],
+    [ unknown     => undef, undef       ],
+    [ postgresql  => 5432,  'pg'        ],
+    [ postgres    => 5432,  'pg'        ],
+    [ pgsql       => 5432,  'pg'        ],
+    [ pg          => 5432,  'pg'        ],
+    [ pgxc        => 5432,  'pg'        ],
+    [ postgresxc  => 5432,  'pg'        ],
+    [ redshift    => 5432,  'pg'        ],
+    [ mysql       => 3306,  'mysql'     ],
+    [ mariadb     => 3306,  'mysql'     ],
+    [ maria       => 3306,  'mysql'     ],
+    [ sqlite      => undef, 'sqlite'    ],
+    [ sqlite3     => undef, 'sqlite'    ],
+    [ oracle      => 1521,  'oracle'    ],
+    [ cubrid      => 33000, 'cubrid'    ], # ?
+    [ firebird    => 3050,  'firebird'  ],
+    [ mssql       => 1433,  'mssql'     ],
+    [ sqlserver   => 1433,  'mssql'     ],
+    [ db2         => 50000, 'db2'       ], # ?
+    [ ingres      => 1524,  'ingres'    ],
+    [ sybase      => 2638,  'sybase'    ],
+    [ informix    => 1526,  'informix'  ], # ?
+    [ teradata    => 1025,  'teradata'  ],
+    [ interbase   => 3050,  'interbase' ],
+    [ unify       => 27117, 'unify'     ], # ?
+    [ mongodb     => 27017, 'mongodb'   ],
+    [ mongo       => 27017, 'mongodb'   ],
+    [ monetdb     => 50000, 'monetdb'   ], # ?
+    [ monet       => 50000, 'monetdb'   ], # ?
+    [ maxdb       => 7673,  'maxdb'     ], # ?
+    [ max         => 7673,  'maxdb'     ], # ?
+    [ impala      => 21000, 'impala'    ],
+    [ couchdb     => 5984,  'couchdb'   ],
+    [ couch       => 5984,  'couchdb'   ],
+    [ hive        => 10000, 'hive'      ],
+    [ cassandra   => 9160,  'cassandra' ],
+    [ derby       => 1527,  'derby'     ],
+    [ vertica     => 5433,  'vertica'   ],
+    [ ldapdb      => undef, 'ldapdb'    ],
+    [ exasol      => 8563,  'exasol'    ],
+    [ snowflake   => 443,   'snowflake' ],
+    [ cockroach   => 26257, 'cockroach' ],
+    [ cockroachdb => 26257, 'cockroach' ],
 ) {
     my ($engine, $port, $canon) = @{ $spec };
     my $prefix = "db:$engine";