ondrej-bouda / ivory

src/Ivory/Exception/ConnectionException.php

Indentation +13 added lines, -13 removed lines

@@ -12,19 +12,19 @@
  */
 class ConnectionException extends \RuntimeException
 {
-	/**
-	 * @param string|resource $message alternatively to the message, a connection handler may be given - the last error
-	 *                                   message on this connection is considered then
-	 * @param int $code
-	 * @param Exception $previous
-	 */
-	public function __construct($message = '', $code = 0, Exception $previous = null)
-	{
-		if (is_resource($message)) {
-			$message = pg_last_error($message);
-		}
+    /**
+     * @param string|resource $message alternatively to the message, a connection handler may be given - the last error
+     *                                   message on this connection is considered then
+     * @param int $code
+     * @param Exception $previous
+     */
+    public function __construct($message = '', $code = 0, Exception $previous = null)
+    {
+        if (is_resource($message)) {
+            $message = pg_last_error($message);
+        }
 
-		parent::__construct($message, $code, $previous);
-	}
+        parent::__construct($message, $code, $previous);
+    }
 
 }
\ No newline at end of file

src/Ivory/Result/QueryResult.php

Indentation +153 added lines, -153 removed lines

@@ -14,165 +14,165 @@
 
 class QueryResult extends Result implements IQueryResult
 {
-	use RelationMacros;
-
-	private $typeDictionary;
-	private $numRows;
-	private $populated = false;
-	/** @var Column[] */
-	private $columns;
-	/** @var int[] map: column name => offset of the first column of the name */
-	private $colNameMap;
-
-
-	/**
-	 * @param resource $resultHandler the result, with the internal pointer at the beginning
-	 * @param ITypeDictionary $typeDictionary
-	 * @param string|null $lastNotice last notice captured on the connection
-	 */
-	public function __construct($resultHandler, ITypeDictionary $typeDictionary, $lastNotice = null)
-	{
-		parent::__construct($resultHandler, $lastNotice);
-
-		$this->typeDictionary = $typeDictionary;
-
-		$this->numRows = $this->fetchNumRows();
-		$this->populate(); // not lazy - chances are, when the query was made, the caller will care about its results
-	}
-
-	private function fetchNumRows()
-	{
-		$numRows = pg_num_rows($this->handler);
-		if ($numRows >= 0 && $numRows !== null) { // NOTE: besides -1, pg_num_rows() might return NULL on error
-			return $numRows;
-		}
-		else {
-			throw new ResultException('Error retrieving number of rows of the result.');
-		}
-	}
+    use RelationMacros;
+
+    private $typeDictionary;
+    private $numRows;
+    private $populated = false;
+    /** @var Column[] */
+    private $columns;
+    /** @var int[] map: column name => offset of the first column of the name */
+    private $colNameMap;
+
+
+    /**
+     * @param resource $resultHandler the result, with the internal pointer at the beginning
+     * @param ITypeDictionary $typeDictionary
+     * @param string|null $lastNotice last notice captured on the connection
+     */
+    public function __construct($resultHandler, ITypeDictionary $typeDictionary, $lastNotice = null)
+    {
+        parent::__construct($resultHandler, $lastNotice);
+
+        $this->typeDictionary = $typeDictionary;
+
+        $this->numRows = $this->fetchNumRows();
+        $this->populate(); // not lazy - chances are, when the query was made, the caller will care about its results
+    }
+
+    private function fetchNumRows()
+    {
+        $numRows = pg_num_rows($this->handler);
+        if ($numRows >= 0 && $numRows !== null) { // NOTE: besides -1, pg_num_rows() might return NULL on error
+            return $numRows;
+        }
+        else {
+            throw new ResultException('Error retrieving number of rows of the result.');
+        }
+    }
 
 
     //region ICachingDataProcessor
 
-	public function populate()
-	{
-		if ($this->populated) {
-			return;
-		}
-
-		$numFields = pg_num_fields($this->handler);
-		if ($numFields < 0 || $numFields === null) {
-			throw new ResultException('Error retrieving number of fields of the result.');
-		}
-		$this->columns = [];
-		$this->colNameMap = [];
-		for ($i = 0; $i < $numFields; $i++) {
-			/* NOTE: pg_field_type() cannot be used for simplicity - multiple types of the same name might exist in
+    public function populate()
+    {
+        if ($this->populated) {
+            return;
+        }
+
+        $numFields = pg_num_fields($this->handler);
+        if ($numFields < 0 || $numFields === null) {
+            throw new ResultException('Error retrieving number of fields of the result.');
+        }
+        $this->columns = [];
+        $this->colNameMap = [];
+        for ($i = 0; $i < $numFields; $i++) {
+            /* NOTE: pg_field_type() cannot be used for simplicity - multiple types of the same name might exist in
 			 *       different schemas. Thus, the only reasonable way to recognize the types is using their OIDs,
 			 *       returned by pg_field_type_oid(). Up to some extreme cases, within a given database, the same OID
 			 *       will always refer to the same data type.
 			 */
-			$name = pg_field_name($this->handler, $i);
-			if ($name === false || $name === null) { // NOTE: besides false, pg_field_name() might return NULL on error
-				throw new ResultException("Error retrieving name of result column $i.");
-			}
-			if ($name == '?column?') {
-				$name = null;
-			}
-			$typeOid = pg_field_type_oid($this->handler, $i);
-			if ($typeOid === false || $typeOid === null) { // NOTE: besides false, pg_field_type_oid() might return NULL on error
-				throw new ResultException("Error retrieving type OID of result column $i.");
-			}
-			$type = $this->typeDictionary->requireTypeByOid($typeOid);
-
-			$this->columns[] = new Column($this, $i, $name, $type);
-
-			if ($name !== null && !isset($this->colNameMap[$name])) {
-				$this->colNameMap[$name] = $i;
-			}
-		}
-
-		$this->populated = true;
-	}
-
-	public function flush()
-	{
-		$this->populated = false;
-		$this->populate(); // re-initialize the internal data right away for the other methods not to call populate() over and over again
-	}
-
-	//endregion
-
-	//region IRelation
-
-	public function getColumns()
-	{
-		return $this->columns;
-	}
-
-	public function filter($decider)
-	{
-		return new FilteredRelation($this, $decider);
-	}
-
-	public function project($columns)
-	{
-		return new ProjectedRelation($this, $columns);
-	}
-
-	public function rename($renamePairs)
-	{
-		return new RenamedRelation($this, $renamePairs);
-	}
-
-	public function col($offsetOrNameOrEvaluator)
-	{
-		return $this->_colImpl($offsetOrNameOrEvaluator, $this->columns, $this->colNameMap, $this);
-	}
-
-	public function uniq($hasher = null, $comparator = null)
-	{
-		throw new NotImplementedException();
-	}
-
-	public function tuple($offset = 0)
-	{
-		if ($offset >= $this->numRows || $offset < -$this->numRows) {
-			throw new \OutOfBoundsException("Offset $offset is out of the result bounds [0,{$this->numRows})");
-		}
-
-		$effectiveOffset = ($offset >= 0 ? $offset : $this->numRows + $offset);
-
-		$rawData = pg_fetch_row($this->handler, $effectiveOffset);
-		if ($rawData === false || $rawData === null) {
-			throw new ResultException("Error fetching row at offset $offset");
-		}
-
-		$data = [];
-		foreach ($this->columns as $i => $col) {
-			$data[$i] = $col->getType()->parseValue($rawData[$i]);
-		}
-
-		return new Tuple($data, $this->columns, $this->colNameMap);
-	}
-
-	//endregion
-
-	//region \Countable
-
-	public function count()
-	{
-		return $this->numRows;
-	}
-
-	//endregion
-
-	//region \IteratorAggregate
-
-	public function getIterator()
-	{
-		return new RelationSeekableIterator($this);
-	}
-
-	//endregion
+            $name = pg_field_name($this->handler, $i);
+            if ($name === false || $name === null) { // NOTE: besides false, pg_field_name() might return NULL on error
+                throw new ResultException("Error retrieving name of result column $i.");
+            }
+            if ($name == '?column?') {
+                $name = null;
+            }
+            $typeOid = pg_field_type_oid($this->handler, $i);
+            if ($typeOid === false || $typeOid === null) { // NOTE: besides false, pg_field_type_oid() might return NULL on error
+                throw new ResultException("Error retrieving type OID of result column $i.");
+            }
+            $type = $this->typeDictionary->requireTypeByOid($typeOid);
+
+            $this->columns[] = new Column($this, $i, $name, $type);
+
+            if ($name !== null && !isset($this->colNameMap[$name])) {
+                $this->colNameMap[$name] = $i;
+            }
+        }
+
+        $this->populated = true;
+    }
+
+    public function flush()
+    {
+        $this->populated = false;
+        $this->populate(); // re-initialize the internal data right away for the other methods not to call populate() over and over again
+    }
+
+    //endregion
+
+    //region IRelation
+
+    public function getColumns()
+    {
+        return $this->columns;
+    }
+
+    public function filter($decider)
+    {
+        return new FilteredRelation($this, $decider);
+    }
+
+    public function project($columns)
+    {
+        return new ProjectedRelation($this, $columns);
+    }
+
+    public function rename($renamePairs)
+    {
+        return new RenamedRelation($this, $renamePairs);
+    }
+
+    public function col($offsetOrNameOrEvaluator)
+    {
+        return $this->_colImpl($offsetOrNameOrEvaluator, $this->columns, $this->colNameMap, $this);
+    }
+
+    public function uniq($hasher = null, $comparator = null)
+    {
+        throw new NotImplementedException();
+    }
+
+    public function tuple($offset = 0)
+    {
+        if ($offset >= $this->numRows || $offset < -$this->numRows) {
+            throw new \OutOfBoundsException("Offset $offset is out of the result bounds [0,{$this->numRows})");
+        }
+
+        $effectiveOffset = ($offset >= 0 ? $offset : $this->numRows + $offset);
+
+        $rawData = pg_fetch_row($this->handler, $effectiveOffset);
+        if ($rawData === false || $rawData === null) {
+            throw new ResultException("Error fetching row at offset $offset");
+        }
+
+        $data = [];
+        foreach ($this->columns as $i => $col) {
+            $data[$i] = $col->getType()->parseValue($rawData[$i]);
+        }
+
+        return new Tuple($data, $this->columns, $this->colNameMap);
+    }
+
+    //endregion
+
+    //region \Countable
+
+    public function count()
+    {
+        return $this->numRows;
+    }
+
+    //endregion
+
+    //region \IteratorAggregate
+
+    public function getIterator()
+    {
+        return new RelationSeekableIterator($this);
+    }
+
+    //endregion
 }

Braces +1 added lines, -2 removed lines

@@ -45,8 +45,7 @@
 		$numRows = pg_num_rows($this->handler);
 		if ($numRows >= 0 && $numRows !== null) { // NOTE: besides -1, pg_num_rows() might return NULL on error
 			return $numRows;
-		}
-		else {
+		} else {
 			throw new ResultException('Error retrieving number of rows of the result.');
 		}
 	}

src/Ivory/Result/CommandResult.php

Indentation +8 added lines, -8 removed lines

@@ -3,13 +3,13 @@
 
 class CommandResult extends Result implements ICommandResult
 {
-	public function __construct($resultHandler, $lastNotice = null)
-	{
-		parent::__construct($resultHandler, $lastNotice);
-	}
+    public function __construct($resultHandler, $lastNotice = null)
+    {
+        parent::__construct($resultHandler, $lastNotice);
+    }
 
-	public function getAffectedRows()
-	{
-		// TODO: Implement getAffectedRows() method.
-	}
+    public function getAffectedRows()
+    {
+        // TODO: Implement getAffectedRows() method.
+    }
 }

src/Ivory/Result/SqlStateClass.php

Indentation +46 added lines, -46 removed lines

@@ -9,50 +9,50 @@
  */
 class SqlStateClass
 {
-	const SUCCESSFUL_COMPLETION = '00';
-	const WARNING = '01';
-	/** No Data (this is also a warning class per the SQL standard) */
-	const NO_DATA = '02';
-	const SQL_STATEMENT_NOT_YET_COMPLETE = '03';
-	const CONNECTION_EXCEPTION = '08';
-	const TRIGGERED_ACTION_EXCEPTION = '09';
-	const FEATURE_NOT_SUPPORTED = '0A';
-	const INVALID_TRANSACTION_INITIATION = '0B';
-	const LOCATOR_EXCEPTION = '0F';
-	const INVALID_GRANTOR = '0L';
-	const INVALID_ROLE_SPECIFICATION = '0P';
-	const DIAGNOSTICS_EXCEPTION = '0Z';
-	const CASE_NOT_FOUND = '20';
-	const CARDINALITY_VIOLATION = '21';
-	const DATA_EXCEPTION = '22';
-	const INTEGRITY_CONSTRAINT_VIOLATION = '23';
-	const INVALID_CURSOR_STATE = '24';
-	const INVALID_TRANSACTION_STATE = '25';
-	const INVALID_SQL_STATEMENT_NAME = '26';
-	const TRIGGERED_DATA_CHANGE_VIOLATION = '27';
-	const INVALID_AUTHORIZATION_SPECIFICATION = '28';
-	const DEPENDENT_PRIVILEGE_DESCRIPTORS_STILL_EXIST = '2B';
-	const INVALID_TRANSACTION_TERMINATION = '2D';
-	const SQL_ROUTINE_EXCEPTION = '2F';
-	const INVALID_CURSOR_NAME = '34';
-	const EXTERNAL_ROUTINE_EXCEPTION = '38';
-	const EXTERNAL_ROUTINE_INVOCATION_EXCEPTION = '39';
-	const SAVEPOINT_EXCEPTION = '3B';
-	const INVALID_CATALOG_NAME = '3D';
-	const INVALID_SCHEMA_NAME = '3F';
-	const TRANSACTION_ROLLBACK = '40';
-	const SYNTAX_ERROR_OR_ACCESS_RULE_VIOLATION = '42';
-	const WITH_CHECK_OPTION_VIOLATION = '44';
-	const INSUFFICIENT_RESOURCES = '53';
-	const PROGRAM_LIMIT_EXCEEDED = '54';
-	const OBJECT_NOT_IN_PREREQUISITE_STATE = '55';
-	const OPERATOR_INTERVENTION = '57';
-	/* System Error (errors external to PostgreSQL itself) */
-	const SYSTEM_ERROR = '58';
-	const CONFIG_FILE_ERROR = 'F0';
-	/* Foreign Data Wrapper Error (SQL/MED) */
-	const FDW_ERROR = 'HV';
-	/* PL/pgSQL Error */
-	const PLPGSQL_ERROR = 'P0';
-	const INTERNAL_ERROR = 'XX';
+    const SUCCESSFUL_COMPLETION = '00';
+    const WARNING = '01';
+    /** No Data (this is also a warning class per the SQL standard) */
+    const NO_DATA = '02';
+    const SQL_STATEMENT_NOT_YET_COMPLETE = '03';
+    const CONNECTION_EXCEPTION = '08';
+    const TRIGGERED_ACTION_EXCEPTION = '09';
+    const FEATURE_NOT_SUPPORTED = '0A';
+    const INVALID_TRANSACTION_INITIATION = '0B';
+    const LOCATOR_EXCEPTION = '0F';
+    const INVALID_GRANTOR = '0L';
+    const INVALID_ROLE_SPECIFICATION = '0P';
+    const DIAGNOSTICS_EXCEPTION = '0Z';
+    const CASE_NOT_FOUND = '20';
+    const CARDINALITY_VIOLATION = '21';
+    const DATA_EXCEPTION = '22';
+    const INTEGRITY_CONSTRAINT_VIOLATION = '23';
+    const INVALID_CURSOR_STATE = '24';
+    const INVALID_TRANSACTION_STATE = '25';
+    const INVALID_SQL_STATEMENT_NAME = '26';
+    const TRIGGERED_DATA_CHANGE_VIOLATION = '27';
+    const INVALID_AUTHORIZATION_SPECIFICATION = '28';
+    const DEPENDENT_PRIVILEGE_DESCRIPTORS_STILL_EXIST = '2B';
+    const INVALID_TRANSACTION_TERMINATION = '2D';
+    const SQL_ROUTINE_EXCEPTION = '2F';
+    const INVALID_CURSOR_NAME = '34';
+    const EXTERNAL_ROUTINE_EXCEPTION = '38';
+    const EXTERNAL_ROUTINE_INVOCATION_EXCEPTION = '39';
+    const SAVEPOINT_EXCEPTION = '3B';
+    const INVALID_CATALOG_NAME = '3D';
+    const INVALID_SCHEMA_NAME = '3F';
+    const TRANSACTION_ROLLBACK = '40';
+    const SYNTAX_ERROR_OR_ACCESS_RULE_VIOLATION = '42';
+    const WITH_CHECK_OPTION_VIOLATION = '44';
+    const INSUFFICIENT_RESOURCES = '53';
+    const PROGRAM_LIMIT_EXCEEDED = '54';
+    const OBJECT_NOT_IN_PREREQUISITE_STATE = '55';
+    const OPERATOR_INTERVENTION = '57';
+    /* System Error (errors external to PostgreSQL itself) */
+    const SYSTEM_ERROR = '58';
+    const CONFIG_FILE_ERROR = 'F0';
+    /* Foreign Data Wrapper Error (SQL/MED) */
+    const FDW_ERROR = 'HV';
+    /* PL/pgSQL Error */
+    const PLPGSQL_ERROR = 'P0';
+    const INTERNAL_ERROR = 'XX';
 }

src/Ivory/Result/ICommandResult.php

Indentation +14 added lines, -14 removed lines

@@ -6,18 +6,18 @@
  */
 interface ICommandResult extends IResult
 {
-	/**
-	 * Returns the number of rows affected by the command, if relevant.
-	 *
-	 * The affected rows count is relevant for the following commands:
-	 * - `INSERT`: number of inserted rows;
-	 * - `UPDATE`: number of updated rows;
-	 * - `DELETE`: number of deleted rows;
-	 * - `CREATE TABLE AS`: number of rows inserted right away to the created table;
-	 * - `MOVE`: number of rows the cursor's position has been changed by;
-	 * - `COPY`: number of rows copied.
-	 *
-	 * @return int|null number of rows affected by the command, or <tt>null</tt> if irrelevant for the command
-	 */
-	function getAffectedRows();
+    /**
+     * Returns the number of rows affected by the command, if relevant.
+     *
+     * The affected rows count is relevant for the following commands:
+     * - `INSERT`: number of inserted rows;
+     * - `UPDATE`: number of updated rows;
+     * - `DELETE`: number of deleted rows;
+     * - `CREATE TABLE AS`: number of rows inserted right away to the created table;
+     * - `MOVE`: number of rows the cursor's position has been changed by;
+     * - `COPY`: number of rows copied.
+     *
+     * @return int|null number of rows affected by the command, or <tt>null</tt> if irrelevant for the command
+     */
+    function getAffectedRows();
 }

src/Ivory/Result/SqlState.php

Indentation +259 added lines, -259 removed lines

@@ -9,269 +9,269 @@
  */
 class SqlState
 {
-	const SUCCESSFUL_COMPLETION = '00000';
-	const WARNING = '01000';
-	const NULL_VALUE_ELIMINATED_IN_SET_FUNCTION = '01003';
-	const STRING_DATA_RIGHT_TRUNCATION_WARNING = '01004';
-	const PRIVILEGE_NOT_REVOKED = '01006';
-	const PRIVILEGE_NOT_GRANTED = '01007';
-	const IMPLICIT_ZERO_BIT_PADDING = '01008';
-	const DYNAMIC_RESULT_SETS_RETURNED = '0100C';
-	const DEPRECATED_FEATURE = '01P01';
-	const NO_DATA = '02000';
-	const NO_ADDITIONAL_DYNAMIC_RESULT_SETS_RETURNED = '02001';
-	const SQL_STATEMENT_NOT_YET_COMPLETE = '03000';
-	const CONNECTION_EXCEPTION = '08000';
-	const SQLCLIENT_UNABLE_TO_ESTABLISH_SQLCONNECTION = '08001';
-	const CONNECTION_DOES_NOT_EXIST = '08003';
-	const SQLSERVER_REJECTED_ESTABLISHMENT_OF_SQLCONNECTION = '08004';
-	const CONNECTION_FAILURE = '08006';
-	const TRANSACTION_RESOLUTION_UNKNOWN = '08007';
-	const PROTOCOL_VIOLATION = '08P01';
-	const TRIGGERED_ACTION_EXCEPTION = '09000';
-	const FEATURE_NOT_SUPPORTED = '0A000';
-	const INVALID_TRANSACTION_INITIATION = '0B000';
-	const LOCATOR_EXCEPTION = '0F000';
-	const INVALID_LOCATOR_SPECIFICATION = '0F001';
-	const INVALID_GRANTOR = '0L000';
-	const INVALID_GRANT_OPERATION = '0LP01';
-	const INVALID_ROLE_SPECIFICATION = '0P000';
-	const DIAGNOSTICS_EXCEPTION = '0Z000';
-	const STACKED_DIAGNOSTICS_ACCESSED_WITHOUT_ACTIVE_HANDLER = '0Z002';
-	const CASE_NOT_FOUND = '20000';
-	const CARDINALITY_VIOLATION = '21000';
-	const DATA_EXCEPTION = '22000';
-	const STRING_DATA_RIGHT_TRUNCATION_EXCEPTION = '22001';
-	const NULL_VALUE_NO_INDICATOR_PARAMETER = '22002';
-	const NUMERIC_VALUE_OUT_OF_RANGE = '22003';
-	const NULL_VALUE_NOT_ALLOWED = '22004';
-	const ERROR_IN_ASSIGNMENT = '22005';
-	const INVALID_DATETIME_FORMAT = '22007';
-	const DATETIME_FIELD_OVERFLOW = '22008';
-	const INVALID_TIME_ZONE_DISPLACEMENT_VALUE = '22009';
-	const ESCAPE_CHARACTER_CONFLICT = '2200B';
-	const INVALID_USE_OF_ESCAPE_CHARACTER = '2200C';
-	const INVALID_ESCAPE_OCTET = '2200D';
-	const ZERO_LENGTH_CHARACTER_STRING = '2200F';
-	const MOST_SPECIFIC_TYPE_MISMATCH = '2200G';
-	const NOT_AN_XML_DOCUMENT = '2200L';
-	const INVALID_XML_DOCUMENT = '2200M';
-	const INVALID_XML_CONTENT = '2200N';
-	const INVALID_XML_COMMENT = '2200S';
-	const INVALID_XML_PROCESSING_INSTRUCTION = '2200T';
-	const INVALID_INDICATOR_PARAMETER_VALUE = '22010';
-	const SUBSTRING_ERROR = '22011';
-	const DIVISION_BY_ZERO = '22012';
-	const INVALID_ARGUMENT_FOR_NTILE_FUNCTION = '22014';
-	const INTERVAL_FIELD_OVERFLOW = '22015';
-	const INVALID_ARGUMENT_FOR_NTH_VALUE_FUNCTION = '22016';
-	const INVALID_CHARACTER_VALUE_FOR_CAST = '22018';
-	const INVALID_ESCAPE_CHARACTER = '22019';
-	const INVALID_REGULAR_EXPRESSION = '2201B';
-	const INVALID_ARGUMENT_FOR_LOGARITHM = '2201E';
-	const INVALID_ARGUMENT_FOR_POWER_FUNCTION = '2201F';
-	const INVALID_ARGUMENT_FOR_WIDTH_BUCKET_FUNCTION = '2201G';
-	const INVALID_ROW_COUNT_IN_LIMIT_CLAUSE = '2201W';
-	const INVALID_ROW_COUNT_IN_RESULT_OFFSET_CLAUSE = '2201X';
-	const CHARACTER_NOT_IN_REPERTOIRE = '22021';
-	const INDICATOR_OVERFLOW = '22022';
-	const INVALID_PARAMETER_VALUE = '22023';
-	const UNTERMINATED_C_STRING = '22024';
-	const INVALID_ESCAPE_SEQUENCE = '22025';
-	const STRING_DATA_LENGTH_MISMATCH = '22026';
-	const TRIM_ERROR = '22027';
-	const ARRAY_SUBSCRIPT_ERROR = '2202E';
-	const FLOATING_POINT_EXCEPTION = '22P01';
-	const INVALID_TEXT_REPRESENTATION = '22P02';
-	const INVALID_BINARY_REPRESENTATION = '22P03';
-	const BAD_COPY_FILE_FORMAT = '22P04';
-	const UNTRANSLATABLE_CHARACTER = '22P05';
-	const NONSTANDARD_USE_OF_ESCAPE_CHARACTER = '22P06';
-	const INTEGRITY_CONSTRAINT_VIOLATION = '23000';
-	const RESTRICT_VIOLATION = '23001';
-	const NOT_NULL_VIOLATION = '23502';
-	const FOREIGN_KEY_VIOLATION = '23503';
-	const UNIQUE_VIOLATION = '23505';
-	const CHECK_VIOLATION = '23514';
-	const EXCLUSION_VIOLATION = '23P01';
-	const INVALID_CURSOR_STATE = '24000';
-	const INVALID_TRANSACTION_STATE = '25000';
-	const ACTIVE_SQL_TRANSACTION = '25001';
-	const BRANCH_TRANSACTION_ALREADY_ACTIVE = '25002';
-	const INAPPROPRIATE_ACCESS_MODE_FOR_BRANCH_TRANSACTION = '25003';
-	const INAPPROPRIATE_ISOLATION_LEVEL_FOR_BRANCH_TRANSACTION = '25004';
-	const NO_ACTIVE_SQL_TRANSACTION_FOR_BRANCH_TRANSACTION = '25005';
-	const READ_ONLY_SQL_TRANSACTION = '25006';
-	const SCHEMA_AND_DATA_STATEMENT_MIXING_NOT_SUPPORTED = '25007';
-	const HELD_CURSOR_REQUIRES_SAME_ISOLATION_LEVEL = '25008';
-	const NO_ACTIVE_SQL_TRANSACTION = '25P01';
-	const IN_FAILED_SQL_TRANSACTION = '25P02';
-	const INVALID_SQL_STATEMENT_NAME = '26000';
-	const TRIGGERED_DATA_CHANGE_VIOLATION = '27000';
-	const INVALID_AUTHORIZATION_SPECIFICATION = '28000';
-	const INVALID_PASSWORD = '28P01';
-	const DEPENDENT_PRIVILEGE_DESCRIPTORS_STILL_EXIST = '2B000';
-	const DEPENDENT_OBJECTS_STILL_EXIST = '2BP01';
-	const INVALID_TRANSACTION_TERMINATION = '2D000';
-	const SQL_ROUTINE_EXCEPTION = '2F000';
-	const MODIFYING_SQL_DATA_NOT_PERMITTED_BY_SQL_ROUTINE = '2F002';
-	const PROHIBITED_SQL_STATEMENT_ATTEMPTED_BY_SQL_ROUTINE = '2F003';
-	const READING_SQL_DATA_NOT_PERMITTED_BY_SQL_ROUTINE = '2F004';
-	const FUNCTION_EXECUTED_NO_RETURN_STATEMENT = '2F005';
-	const INVALID_CURSOR_NAME = '34000';
-	const EXTERNAL_ROUTINE_EXCEPTION = '38000';
-	const CONTAINING_SQL_NOT_PERMITTED = '38001';
-	const MODIFYING_SQL_DATA_NOT_PERMITTED_BY_EXTERNAL_ROUTINE = '38002';
-	const PROHIBITED_SQL_STATEMENT_ATTEMPTED_BY_EXTERNAL_ROUTINE = '38003';
-	const READING_SQL_DATA_NOT_PERMITTED_BY_EXTERNAL_ROUTINE = '38004';
-	const EXTERNAL_ROUTINE_INVOCATION_EXCEPTION = '39000';
-	const INVALID_SQLSTATE_RETURNED = '39001';
-	const NULL_VALUE_NOT_ALLOWED_IN_EXTERNAL_ROUTINE = '39004';
-	const TRIGGER_PROTOCOL_VIOLATED = '39P01';
-	const SRF_PROTOCOL_VIOLATED = '39P02';
-	const SAVEPOINT_EXCEPTION = '3B000';
-	const INVALID_SAVEPOINT_SPECIFICATION = '3B001';
-	const INVALID_CATALOG_NAME = '3D000';
-	const INVALID_SCHEMA_NAME = '3F000';
-	const TRANSACTION_ROLLBACK = '40000';
-	const SERIALIZATION_FAILURE = '40001';
-	const TRANSACTION_INTEGRITY_CONSTRAINT_VIOLATION = '40002';
-	const STATEMENT_COMPLETION_UNKNOWN = '40003';
-	const DEADLOCK_DETECTED = '40P01';
-	const SYNTAX_ERROR_OR_ACCESS_RULE_VIOLATION = '42000';
-	const INSUFFICIENT_PRIVILEGE = '42501';
-	const SYNTAX_ERROR = '42601';
-	const INVALID_NAME = '42602';
-	const INVALID_COLUMN_DEFINITION = '42611';
-	const NAME_TOO_LONG = '42622';
-	const DUPLICATE_COLUMN = '42701';
-	const AMBIGUOUS_COLUMN = '42702';
-	const UNDEFINED_COLUMN = '42703';
-	const UNDEFINED_OBJECT = '42704';
-	const DUPLICATE_OBJECT = '42710';
-	const DUPLICATE_ALIAS = '42712';
-	const DUPLICATE_FUNCTION = '42723';
-	const AMBIGUOUS_FUNCTION = '42725';
-	const GROUPING_ERROR = '42803';
-	const DATATYPE_MISMATCH = '42804';
-	const WRONG_OBJECT_TYPE = '42809';
-	const INVALID_FOREIGN_KEY = '42830';
-	const CANNOT_COERCE = '42846';
-	const UNDEFINED_FUNCTION = '42883';
-	const RESERVED_NAME = '42939';
-	const UNDEFINED_TABLE = '42P01';
-	const UNDEFINED_PARAMETER = '42P02';
-	const DUPLICATE_CURSOR = '42P03';
-	const DUPLICATE_DATABASE = '42P04';
-	const DUPLICATE_PREPARED_STATEMENT = '42P05';
-	const DUPLICATE_SCHEMA = '42P06';
-	const DUPLICATE_TABLE = '42P07';
-	const AMBIGUOUS_PARAMETER = '42P08';
-	const AMBIGUOUS_ALIAS = '42P09';
-	const INVALID_COLUMN_REFERENCE = '42P10';
-	const INVALID_CURSOR_DEFINITION = '42P11';
-	const INVALID_DATABASE_DEFINITION = '42P12';
-	const INVALID_FUNCTION_DEFINITION = '42P13';
-	const INVALID_PREPARED_STATEMENT_DEFINITION = '42P14';
-	const INVALID_SCHEMA_DEFINITION = '42P15';
-	const INVALID_TABLE_DEFINITION = '42P16';
-	const INVALID_OBJECT_DEFINITION = '42P17';
-	const INDETERMINATE_DATATYPE = '42P18';
-	const INVALID_RECURSION = '42P19';
-	const WINDOWING_ERROR = '42P20';
-	const COLLATION_MISMATCH = '42P21';
-	const INDETERMINATE_COLLATION = '42P22';
-	const WITH_CHECK_OPTION_VIOLATION = '44000';
-	const INSUFFICIENT_RESOURCES = '53000';
-	const DISK_FULL = '53100';
-	const OUT_OF_MEMORY = '53200';
-	const TOO_MANY_CONNECTIONS = '53300';
-	const CONFIGURATION_LIMIT_EXCEEDED = '53400';
-	const PROGRAM_LIMIT_EXCEEDED = '54000';
-	const STATEMENT_TOO_COMPLEX = '54001';
-	const TOO_MANY_COLUMNS = '54011';
-	const TOO_MANY_ARGUMENTS = '54023';
-	const OBJECT_NOT_IN_PREREQUISITE_STATE = '55000';
-	const OBJECT_IN_USE = '55006';
-	const CANT_CHANGE_RUNTIME_PARAM = '55P02';
-	const LOCK_NOT_AVAILABLE = '55P03';
-	const OPERATOR_INTERVENTION = '57000';
-	const QUERY_CANCELED = '57014';
-	const ADMIN_SHUTDOWN = '57P01';
-	const CRASH_SHUTDOWN = '57P02';
-	const CANNOT_CONNECT_NOW = '57P03';
-	const DATABASE_DROPPED = '57P04';
-	const SYSTEM_ERROR = '58000';
-	const IO_ERROR = '58030';
-	const UNDEFINED_FILE = '58P01';
-	const DUPLICATE_FILE = '58P02';
-	const CONFIG_FILE_ERROR = 'F0000';
-	const LOCK_FILE_EXISTS = 'F0001';
-	const FDW_ERROR = 'HV000';
-	const FDW_OUT_OF_MEMORY = 'HV001';
-	const FDW_DYNAMIC_PARAMETER_VALUE_NEEDED = 'HV002';
-	const FDW_INVALID_DATA_TYPE = 'HV004';
-	const FDW_COLUMN_NAME_NOT_FOUND = 'HV005';
-	const FDW_INVALID_DATA_TYPE_DESCRIPTORS = 'HV006';
-	const FDW_INVALID_COLUMN_NAME = 'HV007';
-	const FDW_INVALID_COLUMN_NUMBER = 'HV008';
-	const FDW_INVALID_USE_OF_NULL_POINTER = 'HV009';
-	const FDW_INVALID_STRING_FORMAT = 'HV00A';
-	const FDW_INVALID_HANDLE = 'HV00B';
-	const FDW_INVALID_OPTION_INDEX = 'HV00C';
-	const FDW_INVALID_OPTION_NAME = 'HV00D';
-	const FDW_OPTION_NAME_NOT_FOUND = 'HV00J';
-	const FDW_REPLY_HANDLE = 'HV00K';
-	const FDW_UNABLE_TO_CREATE_EXECUTION = 'HV00L';
-	const FDW_UNABLE_TO_CREATE_REPLY = 'HV00M';
-	const FDW_UNABLE_TO_ESTABLISH_CONNECTION = 'HV00N';
-	const FDW_NO_SCHEMAS = 'HV00P';
-	const FDW_SCHEMA_NOT_FOUND = 'HV00Q';
-	const FDW_TABLE_NOT_FOUND = 'HV00R';
-	const FDW_FUNCTION_SEQUENCE_ERROR = 'HV010';
-	const FDW_TOO_MANY_HANDLES = 'HV014';
-	const FDW_INCONSISTENT_DESCRIPTOR_INFORMATION = 'HV021';
-	const FDW_INVALID_ATTRIBUTE_VALUE = 'HV024';
-	const FDW_INVALID_STRING_LENGTH_OR_BUFFER_LENGTH = 'HV090';
-	const FDW_INVALID_DESCRIPTOR_FIELD_IDENTIFIER = 'HV091';
-	const PLPGSQL_ERROR = 'P0000';
-	const RAISE_EXCEPTION = 'P0001';
-	const NO_DATA_FOUND = 'P0002';
-	const TOO_MANY_ROWS = 'P0003';
-	const INTERNAL_ERROR = 'XX000';
-	const DATA_CORRUPTED = 'XX001';
-	const INDEX_CORRUPTED = 'XX002';
+    const SUCCESSFUL_COMPLETION = '00000';
+    const WARNING = '01000';
+    const NULL_VALUE_ELIMINATED_IN_SET_FUNCTION = '01003';
+    const STRING_DATA_RIGHT_TRUNCATION_WARNING = '01004';
+    const PRIVILEGE_NOT_REVOKED = '01006';
+    const PRIVILEGE_NOT_GRANTED = '01007';
+    const IMPLICIT_ZERO_BIT_PADDING = '01008';
+    const DYNAMIC_RESULT_SETS_RETURNED = '0100C';
+    const DEPRECATED_FEATURE = '01P01';
+    const NO_DATA = '02000';
+    const NO_ADDITIONAL_DYNAMIC_RESULT_SETS_RETURNED = '02001';
+    const SQL_STATEMENT_NOT_YET_COMPLETE = '03000';
+    const CONNECTION_EXCEPTION = '08000';
+    const SQLCLIENT_UNABLE_TO_ESTABLISH_SQLCONNECTION = '08001';
+    const CONNECTION_DOES_NOT_EXIST = '08003';
+    const SQLSERVER_REJECTED_ESTABLISHMENT_OF_SQLCONNECTION = '08004';
+    const CONNECTION_FAILURE = '08006';
+    const TRANSACTION_RESOLUTION_UNKNOWN = '08007';
+    const PROTOCOL_VIOLATION = '08P01';
+    const TRIGGERED_ACTION_EXCEPTION = '09000';
+    const FEATURE_NOT_SUPPORTED = '0A000';
+    const INVALID_TRANSACTION_INITIATION = '0B000';
+    const LOCATOR_EXCEPTION = '0F000';
+    const INVALID_LOCATOR_SPECIFICATION = '0F001';
+    const INVALID_GRANTOR = '0L000';
+    const INVALID_GRANT_OPERATION = '0LP01';
+    const INVALID_ROLE_SPECIFICATION = '0P000';
+    const DIAGNOSTICS_EXCEPTION = '0Z000';
+    const STACKED_DIAGNOSTICS_ACCESSED_WITHOUT_ACTIVE_HANDLER = '0Z002';
+    const CASE_NOT_FOUND = '20000';
+    const CARDINALITY_VIOLATION = '21000';
+    const DATA_EXCEPTION = '22000';
+    const STRING_DATA_RIGHT_TRUNCATION_EXCEPTION = '22001';
+    const NULL_VALUE_NO_INDICATOR_PARAMETER = '22002';
+    const NUMERIC_VALUE_OUT_OF_RANGE = '22003';
+    const NULL_VALUE_NOT_ALLOWED = '22004';
+    const ERROR_IN_ASSIGNMENT = '22005';
+    const INVALID_DATETIME_FORMAT = '22007';
+    const DATETIME_FIELD_OVERFLOW = '22008';
+    const INVALID_TIME_ZONE_DISPLACEMENT_VALUE = '22009';
+    const ESCAPE_CHARACTER_CONFLICT = '2200B';
+    const INVALID_USE_OF_ESCAPE_CHARACTER = '2200C';
+    const INVALID_ESCAPE_OCTET = '2200D';
+    const ZERO_LENGTH_CHARACTER_STRING = '2200F';
+    const MOST_SPECIFIC_TYPE_MISMATCH = '2200G';
+    const NOT_AN_XML_DOCUMENT = '2200L';
+    const INVALID_XML_DOCUMENT = '2200M';
+    const INVALID_XML_CONTENT = '2200N';
+    const INVALID_XML_COMMENT = '2200S';
+    const INVALID_XML_PROCESSING_INSTRUCTION = '2200T';
+    const INVALID_INDICATOR_PARAMETER_VALUE = '22010';
+    const SUBSTRING_ERROR = '22011';
+    const DIVISION_BY_ZERO = '22012';
+    const INVALID_ARGUMENT_FOR_NTILE_FUNCTION = '22014';
+    const INTERVAL_FIELD_OVERFLOW = '22015';
+    const INVALID_ARGUMENT_FOR_NTH_VALUE_FUNCTION = '22016';
+    const INVALID_CHARACTER_VALUE_FOR_CAST = '22018';
+    const INVALID_ESCAPE_CHARACTER = '22019';
+    const INVALID_REGULAR_EXPRESSION = '2201B';
+    const INVALID_ARGUMENT_FOR_LOGARITHM = '2201E';
+    const INVALID_ARGUMENT_FOR_POWER_FUNCTION = '2201F';
+    const INVALID_ARGUMENT_FOR_WIDTH_BUCKET_FUNCTION = '2201G';
+    const INVALID_ROW_COUNT_IN_LIMIT_CLAUSE = '2201W';
+    const INVALID_ROW_COUNT_IN_RESULT_OFFSET_CLAUSE = '2201X';
+    const CHARACTER_NOT_IN_REPERTOIRE = '22021';
+    const INDICATOR_OVERFLOW = '22022';
+    const INVALID_PARAMETER_VALUE = '22023';
+    const UNTERMINATED_C_STRING = '22024';
+    const INVALID_ESCAPE_SEQUENCE = '22025';
+    const STRING_DATA_LENGTH_MISMATCH = '22026';
+    const TRIM_ERROR = '22027';
+    const ARRAY_SUBSCRIPT_ERROR = '2202E';
+    const FLOATING_POINT_EXCEPTION = '22P01';
+    const INVALID_TEXT_REPRESENTATION = '22P02';
+    const INVALID_BINARY_REPRESENTATION = '22P03';
+    const BAD_COPY_FILE_FORMAT = '22P04';
+    const UNTRANSLATABLE_CHARACTER = '22P05';
+    const NONSTANDARD_USE_OF_ESCAPE_CHARACTER = '22P06';
+    const INTEGRITY_CONSTRAINT_VIOLATION = '23000';
+    const RESTRICT_VIOLATION = '23001';
+    const NOT_NULL_VIOLATION = '23502';
+    const FOREIGN_KEY_VIOLATION = '23503';
+    const UNIQUE_VIOLATION = '23505';
+    const CHECK_VIOLATION = '23514';
+    const EXCLUSION_VIOLATION = '23P01';
+    const INVALID_CURSOR_STATE = '24000';
+    const INVALID_TRANSACTION_STATE = '25000';
+    const ACTIVE_SQL_TRANSACTION = '25001';
+    const BRANCH_TRANSACTION_ALREADY_ACTIVE = '25002';
+    const INAPPROPRIATE_ACCESS_MODE_FOR_BRANCH_TRANSACTION = '25003';
+    const INAPPROPRIATE_ISOLATION_LEVEL_FOR_BRANCH_TRANSACTION = '25004';
+    const NO_ACTIVE_SQL_TRANSACTION_FOR_BRANCH_TRANSACTION = '25005';
+    const READ_ONLY_SQL_TRANSACTION = '25006';
+    const SCHEMA_AND_DATA_STATEMENT_MIXING_NOT_SUPPORTED = '25007';
+    const HELD_CURSOR_REQUIRES_SAME_ISOLATION_LEVEL = '25008';
+    const NO_ACTIVE_SQL_TRANSACTION = '25P01';
+    const IN_FAILED_SQL_TRANSACTION = '25P02';
+    const INVALID_SQL_STATEMENT_NAME = '26000';
+    const TRIGGERED_DATA_CHANGE_VIOLATION = '27000';
+    const INVALID_AUTHORIZATION_SPECIFICATION = '28000';
+    const INVALID_PASSWORD = '28P01';
+    const DEPENDENT_PRIVILEGE_DESCRIPTORS_STILL_EXIST = '2B000';
+    const DEPENDENT_OBJECTS_STILL_EXIST = '2BP01';
+    const INVALID_TRANSACTION_TERMINATION = '2D000';
+    const SQL_ROUTINE_EXCEPTION = '2F000';
+    const MODIFYING_SQL_DATA_NOT_PERMITTED_BY_SQL_ROUTINE = '2F002';
+    const PROHIBITED_SQL_STATEMENT_ATTEMPTED_BY_SQL_ROUTINE = '2F003';
+    const READING_SQL_DATA_NOT_PERMITTED_BY_SQL_ROUTINE = '2F004';
+    const FUNCTION_EXECUTED_NO_RETURN_STATEMENT = '2F005';
+    const INVALID_CURSOR_NAME = '34000';
+    const EXTERNAL_ROUTINE_EXCEPTION = '38000';
+    const CONTAINING_SQL_NOT_PERMITTED = '38001';
+    const MODIFYING_SQL_DATA_NOT_PERMITTED_BY_EXTERNAL_ROUTINE = '38002';
+    const PROHIBITED_SQL_STATEMENT_ATTEMPTED_BY_EXTERNAL_ROUTINE = '38003';
+    const READING_SQL_DATA_NOT_PERMITTED_BY_EXTERNAL_ROUTINE = '38004';
+    const EXTERNAL_ROUTINE_INVOCATION_EXCEPTION = '39000';
+    const INVALID_SQLSTATE_RETURNED = '39001';
+    const NULL_VALUE_NOT_ALLOWED_IN_EXTERNAL_ROUTINE = '39004';
+    const TRIGGER_PROTOCOL_VIOLATED = '39P01';
+    const SRF_PROTOCOL_VIOLATED = '39P02';
+    const SAVEPOINT_EXCEPTION = '3B000';
+    const INVALID_SAVEPOINT_SPECIFICATION = '3B001';
+    const INVALID_CATALOG_NAME = '3D000';
+    const INVALID_SCHEMA_NAME = '3F000';
+    const TRANSACTION_ROLLBACK = '40000';
+    const SERIALIZATION_FAILURE = '40001';
+    const TRANSACTION_INTEGRITY_CONSTRAINT_VIOLATION = '40002';
+    const STATEMENT_COMPLETION_UNKNOWN = '40003';
+    const DEADLOCK_DETECTED = '40P01';
+    const SYNTAX_ERROR_OR_ACCESS_RULE_VIOLATION = '42000';
+    const INSUFFICIENT_PRIVILEGE = '42501';
+    const SYNTAX_ERROR = '42601';
+    const INVALID_NAME = '42602';
+    const INVALID_COLUMN_DEFINITION = '42611';
+    const NAME_TOO_LONG = '42622';
+    const DUPLICATE_COLUMN = '42701';
+    const AMBIGUOUS_COLUMN = '42702';
+    const UNDEFINED_COLUMN = '42703';
+    const UNDEFINED_OBJECT = '42704';
+    const DUPLICATE_OBJECT = '42710';
+    const DUPLICATE_ALIAS = '42712';
+    const DUPLICATE_FUNCTION = '42723';
+    const AMBIGUOUS_FUNCTION = '42725';
+    const GROUPING_ERROR = '42803';
+    const DATATYPE_MISMATCH = '42804';
+    const WRONG_OBJECT_TYPE = '42809';
+    const INVALID_FOREIGN_KEY = '42830';
+    const CANNOT_COERCE = '42846';
+    const UNDEFINED_FUNCTION = '42883';
+    const RESERVED_NAME = '42939';
+    const UNDEFINED_TABLE = '42P01';
+    const UNDEFINED_PARAMETER = '42P02';
+    const DUPLICATE_CURSOR = '42P03';
+    const DUPLICATE_DATABASE = '42P04';
+    const DUPLICATE_PREPARED_STATEMENT = '42P05';
+    const DUPLICATE_SCHEMA = '42P06';
+    const DUPLICATE_TABLE = '42P07';
+    const AMBIGUOUS_PARAMETER = '42P08';
+    const AMBIGUOUS_ALIAS = '42P09';
+    const INVALID_COLUMN_REFERENCE = '42P10';
+    const INVALID_CURSOR_DEFINITION = '42P11';
+    const INVALID_DATABASE_DEFINITION = '42P12';
+    const INVALID_FUNCTION_DEFINITION = '42P13';
+    const INVALID_PREPARED_STATEMENT_DEFINITION = '42P14';
+    const INVALID_SCHEMA_DEFINITION = '42P15';
+    const INVALID_TABLE_DEFINITION = '42P16';
+    const INVALID_OBJECT_DEFINITION = '42P17';
+    const INDETERMINATE_DATATYPE = '42P18';
+    const INVALID_RECURSION = '42P19';
+    const WINDOWING_ERROR = '42P20';
+    const COLLATION_MISMATCH = '42P21';
+    const INDETERMINATE_COLLATION = '42P22';
+    const WITH_CHECK_OPTION_VIOLATION = '44000';
+    const INSUFFICIENT_RESOURCES = '53000';
+    const DISK_FULL = '53100';
+    const OUT_OF_MEMORY = '53200';
+    const TOO_MANY_CONNECTIONS = '53300';
+    const CONFIGURATION_LIMIT_EXCEEDED = '53400';
+    const PROGRAM_LIMIT_EXCEEDED = '54000';
+    const STATEMENT_TOO_COMPLEX = '54001';
+    const TOO_MANY_COLUMNS = '54011';
+    const TOO_MANY_ARGUMENTS = '54023';
+    const OBJECT_NOT_IN_PREREQUISITE_STATE = '55000';
+    const OBJECT_IN_USE = '55006';
+    const CANT_CHANGE_RUNTIME_PARAM = '55P02';
+    const LOCK_NOT_AVAILABLE = '55P03';
+    const OPERATOR_INTERVENTION = '57000';
+    const QUERY_CANCELED = '57014';
+    const ADMIN_SHUTDOWN = '57P01';
+    const CRASH_SHUTDOWN = '57P02';
+    const CANNOT_CONNECT_NOW = '57P03';
+    const DATABASE_DROPPED = '57P04';
+    const SYSTEM_ERROR = '58000';
+    const IO_ERROR = '58030';
+    const UNDEFINED_FILE = '58P01';
+    const DUPLICATE_FILE = '58P02';
+    const CONFIG_FILE_ERROR = 'F0000';
+    const LOCK_FILE_EXISTS = 'F0001';
+    const FDW_ERROR = 'HV000';
+    const FDW_OUT_OF_MEMORY = 'HV001';
+    const FDW_DYNAMIC_PARAMETER_VALUE_NEEDED = 'HV002';
+    const FDW_INVALID_DATA_TYPE = 'HV004';
+    const FDW_COLUMN_NAME_NOT_FOUND = 'HV005';
+    const FDW_INVALID_DATA_TYPE_DESCRIPTORS = 'HV006';
+    const FDW_INVALID_COLUMN_NAME = 'HV007';
+    const FDW_INVALID_COLUMN_NUMBER = 'HV008';
+    const FDW_INVALID_USE_OF_NULL_POINTER = 'HV009';
+    const FDW_INVALID_STRING_FORMAT = 'HV00A';
+    const FDW_INVALID_HANDLE = 'HV00B';
+    const FDW_INVALID_OPTION_INDEX = 'HV00C';
+    const FDW_INVALID_OPTION_NAME = 'HV00D';
+    const FDW_OPTION_NAME_NOT_FOUND = 'HV00J';
+    const FDW_REPLY_HANDLE = 'HV00K';
+    const FDW_UNABLE_TO_CREATE_EXECUTION = 'HV00L';
+    const FDW_UNABLE_TO_CREATE_REPLY = 'HV00M';
+    const FDW_UNABLE_TO_ESTABLISH_CONNECTION = 'HV00N';
+    const FDW_NO_SCHEMAS = 'HV00P';
+    const FDW_SCHEMA_NOT_FOUND = 'HV00Q';
+    const FDW_TABLE_NOT_FOUND = 'HV00R';
+    const FDW_FUNCTION_SEQUENCE_ERROR = 'HV010';
+    const FDW_TOO_MANY_HANDLES = 'HV014';
+    const FDW_INCONSISTENT_DESCRIPTOR_INFORMATION = 'HV021';
+    const FDW_INVALID_ATTRIBUTE_VALUE = 'HV024';
+    const FDW_INVALID_STRING_LENGTH_OR_BUFFER_LENGTH = 'HV090';
+    const FDW_INVALID_DESCRIPTOR_FIELD_IDENTIFIER = 'HV091';
+    const PLPGSQL_ERROR = 'P0000';
+    const RAISE_EXCEPTION = 'P0001';
+    const NO_DATA_FOUND = 'P0002';
+    const TOO_MANY_ROWS = 'P0003';
+    const INTERNAL_ERROR = 'XX000';
+    const DATA_CORRUPTED = 'XX001';
+    const INDEX_CORRUPTED = 'XX002';
 
 
-	private $code;
+    private $code;
 
-	/**
-	 * @param string $code SQL STATE code; one of {@link SqlState} constants
-	 * @return SqlState
-	 */
-	public static function fromCode($code)
-	{
-		return new SqlState($code);
-	}
+    /**
+     * @param string $code SQL STATE code; one of {@link SqlState} constants
+     * @return SqlState
+     */
+    public static function fromCode($code)
+    {
+        return new SqlState($code);
+    }
 
-	private function __construct($code)
-	{
-		$this->code = $code;
-	}
+    private function __construct($code)
+    {
+        $this->code = $code;
+    }
 
-	/**
-	 * @return string the SQL STATE code; one of {@link SqlState} constants
-	 */
-	public function getCode()
-	{
-		return $this->code;
-	}
+    /**
+     * @return string the SQL STATE code; one of {@link SqlState} constants
+     */
+    public function getCode()
+    {
+        return $this->code;
+    }
 
-	/**
-	 * @return string the class of the SQL STATE; one of {@link SqlStateClass} constants
-	 */
-	public function getClass()
-	{
-		return substr($this->code, 0, 2);
-	}
+    /**
+     * @return string the class of the SQL STATE; one of {@link SqlStateClass} constants
+     */
+    public function getClass()
+    {
+        return substr($this->code, 0, 2);
+    }
 }

src/Ivory/Result/CopyOutResult.php

Indentation +14 added lines, -14 removed lines

@@ -5,21 +5,21 @@
 
 class CopyOutResult extends Result implements ICopyOutResult
 {
-	private $connHandler;
+    private $connHandler;
 
-	public function __construct($connHandler, $resultHandler, $lastNotice = null)
-	{
-		parent::__construct($resultHandler, $lastNotice);
+    public function __construct($connHandler, $resultHandler, $lastNotice = null)
+    {
+        parent::__construct($resultHandler, $lastNotice);
 
-		$this->connHandler = $connHandler;
-	}
+        $this->connHandler = $connHandler;
+    }
 
-	public function end()
-	{
-		$res = pg_end_copy($this->connHandler);
-		if ($res === false) {
-			throw new ConnectionException('Error ending copying data from the database server.');
-			// TODO: try to squeeze the client to get some useful information; maybe trap errors issued by pg_end_copy()?
-		}
-	}
+    public function end()
+    {
+        $res = pg_end_copy($this->connHandler);
+        if ($res === false) {
+            throw new ConnectionException('Error ending copying data from the database server.');
+            // TODO: try to squeeze the client to get some useful information; maybe trap errors issued by pg_end_copy()?
+        }
+    }
 }

src/Ivory/Result/IResult.php

Indentation +27 added lines, -27 removed lines

@@ -6,32 +6,32 @@
  */
 interface IResult
 {
-	/**
-	 * Returns the last notice emitted for this result.
-	 *
-	 * Note some notices might be swallowed - see the notes below. A notice is returned by this method only if it is
-	 * sure it was emitted for this result.
-	 *
-	 * Unfortunately, on PHP 5.6, it seems the PostgreSQL client library is pretty limited:
-	 * - there is no other way of getting notices of successful statements than using pg_last_notice() (except
-	 *   pg_trace(), which would write the frontend/backend communication to a file - then, the file would have to be
-	 *   read and truncated, which would result in quite some overhead);
-	 * - yet, it only reports the last notice - thus, none but the last notice of a single successful statement can be
-	 *   caught by any means;
-	 * - there is no clearing mechanism, thus, successful statement emitting the same notice as the previous statement
-	 *   is indistinguishable from a statement emitting nothing; moreover, statements with no notice do not clear the
-	 *   notice returned by pg_last_notice(); last but not least, it is connection-wide, thus, notion of last received
-	 *   notice must be kept on the whole connection, and a notice found out by get_last_notice() should only be
-	 *   reported if different from the last one.
-	 *
-	 * @return string|null notice emitted for this result, or <tt>null</tt> if no notice was emitted or it was
-	 *                       indistinguishable from previous notices
-	 */
-	function getLastNotice();
+    /**
+     * Returns the last notice emitted for this result.
+     *
+     * Note some notices might be swallowed - see the notes below. A notice is returned by this method only if it is
+     * sure it was emitted for this result.
+     *
+     * Unfortunately, on PHP 5.6, it seems the PostgreSQL client library is pretty limited:
+     * - there is no other way of getting notices of successful statements than using pg_last_notice() (except
+     *   pg_trace(), which would write the frontend/backend communication to a file - then, the file would have to be
+     *   read and truncated, which would result in quite some overhead);
+     * - yet, it only reports the last notice - thus, none but the last notice of a single successful statement can be
+     *   caught by any means;
+     * - there is no clearing mechanism, thus, successful statement emitting the same notice as the previous statement
+     *   is indistinguishable from a statement emitting nothing; moreover, statements with no notice do not clear the
+     *   notice returned by pg_last_notice(); last but not least, it is connection-wide, thus, notion of last received
+     *   notice must be kept on the whole connection, and a notice found out by get_last_notice() should only be
+     *   reported if different from the last one.
+     *
+     * @return string|null notice emitted for this result, or <tt>null</tt> if no notice was emitted or it was
+     *                       indistinguishable from previous notices
+     */
+    function getLastNotice();
 
-	/**
-	 * @return string the command tag, e.g., <tt>SELECT 2</tt> or <tt>CREATE FUNCTION</tt>
-	 * @see http://www.postgresql.org/docs/9.4/static/protocol-message-formats.html
-	 */
-	function getCommandTag();
+    /**
+     * @return string the command tag, e.g., <tt>SELECT 2</tt> or <tt>CREATE FUNCTION</tt>
+     * @see http://www.postgresql.org/docs/9.4/static/protocol-message-formats.html
+     */
+    function getCommandTag();
 }

src/Ivory/Result/CopyInResult.php

Indentation +23 added lines, -23 removed lines

@@ -5,32 +5,32 @@
 
 class CopyInResult extends Result implements ICopyInResult
 {
-	private $connHandler;
+    private $connHandler;
 
-	public function __construct($connHandler, $resultHandler, $lastNotice = null)
-	{
-		parent::__construct($resultHandler, $lastNotice);
+    public function __construct($connHandler, $resultHandler, $lastNotice = null)
+    {
+        parent::__construct($resultHandler, $lastNotice);
 
-		$this->connHandler = $connHandler;
-	}
+        $this->connHandler = $connHandler;
+    }
 
-	public function putLine($line)
-	{
-		$res = pg_put_line($this->connHandler, $line);
-		if ($res === false) {
-			throw new ConnectionException('Error sending data to the database server.');
-			// TODO: try to squeeze the client to get some useful information; maybe trap errors issued by pg_end_copy()?
-		}
-	}
+    public function putLine($line)
+    {
+        $res = pg_put_line($this->connHandler, $line);
+        if ($res === false) {
+            throw new ConnectionException('Error sending data to the database server.');
+            // TODO: try to squeeze the client to get some useful information; maybe trap errors issued by pg_end_copy()?
+        }
+    }
 
-	public function end()
-	{
-		$this->putLine("\\.\n");
+    public function end()
+    {
+        $this->putLine("\\.\n");
 
-		$res = pg_end_copy($this->connHandler);
-		if ($res === false) {
-			throw new ConnectionException('Error ending copying data to the database server.');
-			// TODO: try to squeeze the client to get some useful information; maybe trap errors issued by pg_end_copy()?
-		}
-	}
+        $res = pg_end_copy($this->connHandler);
+        if ($res === false) {
+            throw new ConnectionException('Error ending copying data to the database server.');
+            // TODO: try to squeeze the client to get some useful information; maybe trap errors issued by pg_end_copy()?
+        }
+    }
 }