Add RedshiftAdapter

lib/Connection.php

@@ -245,6 +245,10 @@ protected function __construct($info)
 			}
 			else
 				$host = "unix_socket=$info->host";
+			// PDO driver redshift == pgsql
+			if ($info->protocol == 'redshift') {
+				$info->protocol = 'pgsql';
+			}
 
 			$this->connection = new PDO("$info->protocol:$host;dbname=$info->db", $info->user, $info->pass, static::$PDO_OPTIONS);
 		} catch (PDOException $e) {

lib/adapters/PgsqlAdapter.php

@@ -6,7 +6,7 @@
 
 /**
  * Adapter for Postgres (not completed yet)
- * 
+ *
  * @package ActiveRecord
  */
 class PgsqlAdapter extends Connection
@@ -47,7 +47,7 @@ public function query_column_info($table)
         WHERE c.oid = pg_index.indrelid
         AND a.attnum = ANY (pg_index.indkey)
         AND pg_index.indisprimary = 't'
-      ) IS NOT NULL AS pk,      
+      ) IS NOT NULL AS pk,
       REGEXP_REPLACE(REGEXP_REPLACE(REGEXP_REPLACE((SELECT pg_attrdef.adsrc
         FROM pg_attrdef
         WHERE c.oid = pg_attrdef.adrelid
@@ -75,7 +75,7 @@ public function create_column(&$column)
 		$c->inflected_name	= Inflector::instance()->variablize($column['field']);
 		$c->name			= $column['field'];
 		$c->nullable		= ($column['not_nullable'] ? false : true);
-		$c->pk				= ($column['pk'] ? true : false);
+		$c->pk				= ($column['pk'] == 't');
 		$c->auto_increment	= false;
 
 		if (substr($column['type'],0,9) == 'timestamp')

lib/adapters/RedshiftAdapter.php

@@ -0,0 +1,56 @@
+<?php
+/**
+ * @package ActiveRecord
+ */
+namespace ActiveRecord;
+
+require_once __DIR__ . '/PgsqlAdapter.php';
+
+/**
+ * Adapter for Redshift postgres version < 8.0.2 (not completed yet)
+ *
+ * @package ActiveRecord
+ */
+class RedshiftAdapter extends PgsqlAdapter
+{
+	public function supports_sequences()
+	{
+		return false;
+	}
+
+	public function query_column_info($table)
+	{
+		$sql = <<<SQL
+SELECT
+	a.attname AS field,
+	a.attlen,
+	REPLACE(pg_catalog.format_type(a.atttypid, a.atttypmod), 'character varying', 'varchar') AS type,
+	a.attnotnull AS not_nullable,
+	(SELECT 't'
+		FROM pg_index
+		WHERE c.oid = pg_index.indrelid
+		AND a.attnum = ANY (
+		string_to_array(
+			textin(
+			int2vectorout(pg_index.indkey)
+			), ''
+		)
+		)
+		AND pg_index.indisprimary = 't'
+	) IS NOT NULL AS pk,
+	REGEXP_REPLACE(REGEXP_REPLACE(REGEXP_REPLACE((SELECT pg_attrdef.adsrc
+		FROM pg_attrdef
+		WHERE c.oid = pg_attrdef.adrelid
+		AND pg_attrdef.adnum=a.attnum
+	),'::[a-z_ ]+',''),'''$',''),'^''','') AS default
+FROM pg_attribute a, pg_class c, pg_type t
+WHERE c.relname = ?
+	AND a.attnum > 0
+	AND a.attrelid = c.oid
+	AND a.atttypid = t.oid
+ORDER BY a.attnum
+SQL;
+		$values = array($table);
+		return $this->query($sql,$values);
+	}
+}