connection)) { return true; } $config = array( "host" => $this->connectionData->getHost(), "port" => $this->connectionData->getPort(), "dbname" => $this->connectionData->getProperty('database', 'public'), "user" => $this->connectionData->getLogin(), "password" => $this->connectionData->getPassword() ); $connectionString = array(); foreach($config as $key => $val) { if (!empty($val)) { $connectionString[] = "$key=$val"; } } $this->connection = @pg_connect(implode(" ", $connectionString), PGSQL_CONNECT_FORCE_NEW); if (!$this->connection) { $this->lastError = "Failed to connect to Database"; $this->connection = NULL; return false; } pg_set_client_encoding($this->connection, $this->connectionData->getProperty('encoding', 'UTF-8')); return true; } public function disconnect() { if(is_null($this->connection)) return; @pg_close($this->connection); } public function getLastError(): string { $lastError = parent::getLastError(); if (empty($lastError)) { $lastError = trim(pg_last_error($this->connection) . " " . pg_last_error($this->connection)); } return $lastError; } protected function execute($query, $values = NULL, $returnValues = false) { $this->lastError = ""; $stmt_name = uniqid(); $pgParams = array(); if (!is_null($values)) { foreach($values as $value) { $paramType = Parameter::parseType($value); switch($paramType) { case Parameter::TYPE_DATE: $value = $value->format("Y-m-d"); break; case Parameter::TYPE_TIME: $value = $value->format("H:i:s"); break; case Parameter::TYPE_DATE_TIME: $value = $value->format("Y-m-d H:i:s"); break; case Parameter::TYPE_ARRAY: $value = json_encode($value); break; default: break; } $pgParams[] = $value; } } $stmt = @pg_prepare($this->connection, $stmt_name, $query); if ($stmt === FALSE) { return false; } $result = @pg_execute($this->connection, $stmt_name, $pgParams); if ($result === FALSE) { return false; } if ($returnValues) { $rows = pg_fetch_all($result); if ($rows === FALSE) { if (empty(trim($this->getLastError()))) { $rows = array(); } } return $rows; } else { return true; } } public function getOnDuplicateStrategy(?Strategy $strategy, &$params): ?string { if (!is_null($strategy)) { if ($strategy instanceof UpdateStrategy) { $updateValues = array(); foreach($strategy->getValues() as $key => $value) { $leftColumn = $this->columnName($key); if ($value instanceof Column) { $columnName = $this->columnName($value->getName()); $updateValues[] = "$leftColumn=EXCLUDED.$columnName"; } else if ($value instanceof Add) { $columnName = $this->columnName($value->getColumn()); $operator = $value->getOperator(); $value = $value->getValue(); $updateValues[] = "$leftColumn=$columnName$operator" . $this->addValue($value, $params); } else { $updateValues[] = "$leftColumn=" . $this->addValue($value, $parameters); } } $conflictingColumns = $this->columnName($strategy->getConflictingColumns()); $updateValues = implode(",", $updateValues); return " ON CONFLICT ($conflictingColumns) DO UPDATE SET $updateValues"; } else { $strategyClass = get_class($strategy); $this->lastError = "ON DUPLICATE Strategy $strategyClass is not supported yet."; return null; } } else { return ""; } } public function getReturning(?string $columns): string { return $columns ? (" RETURNING " . $this->columnName($columns)) : ""; } public function executeQuery(Query $query, bool $fetchResult = false) { return parent::executeQuery($query, $fetchResult || ($query instanceof Insert && !empty($query->getReturning()))); } protected function fetchReturning($res, string $returningCol) { $this->lastInsertId = $res[0][$returningCol]; } // UGLY but.. what should i do? private function createEnum(EnumColumn $enumColumn, string $typeName): string { $values = array(); foreach($enumColumn->getValues() as $value) { $values[] = $this->getValueDefinition($value); } $values = implode(",", $values); $query = "DO $$ BEGIN CREATE TYPE \"$typeName\" AS ENUM ($values); EXCEPTION WHEN duplicate_object THEN null; END $$;"; return $this->execute($query); } public function getColumnType(Column $column): ?string { if ($column instanceof StringColumn) { $maxSize = $column->getMaxSize(); if ($maxSize) { return "VARCHAR($maxSize)"; } else { return "TEXT"; } } else if($column instanceof SerialColumn) { return "SERIAL"; } else if($column instanceof IntColumn) { return "INTEGER"; } else if($column instanceof DateTimeColumn) { return "TIMESTAMP"; } else if($column instanceof EnumColumn) { $typeName = $column->getName(); if(!endsWith($typeName, "_type")) { $typeName = "${typeName}_type"; } return $typeName; } else if($column instanceof BoolColumn) { return "BOOLEAN"; } else if($column instanceof JsonColumn) { return "JSON"; } else { $this->lastError = "Unsupported Column Type: " . get_class($column); return NULL; } } public function getColumnDefinition($column): ?string { $columnName = $this->columnName($column->getName()); $type = $this->getColumnType($column); if (!$type) { return null; } else if ($column instanceof EnumColumn) { if (!$this->createEnum($column, $type)) { return null; } } $notNull = $column->notNull() ? " NOT NULL" : ""; $defaultValue = ""; if (!is_null($column->getDefaultValue()) || !$column->notNull()) { $defaultValue = " DEFAULT " . $this->getValueDefinition($column->getDefaultValue()); } return "$columnName $type$notNull$defaultValue"; } protected function getValueDefinition($value) { if (is_numeric($value)) { return $value; } else if(is_bool($value)) { return $value ? "TRUE" : "FALSE"; } else if(is_null($value)) { return "NULL"; } else if ($value instanceof Keyword) { return $value->getValue(); } else if ($value instanceof CurrentTimeStamp) { return "CURRENT_TIMESTAMP"; } else { $str = str_replace("'", "''", $value); return "'$str'"; } } public function addValue($val, &$params = NULL) { if ($val instanceof Keyword) { return $val->getValue(); } else if ($val instanceof CurrentTable) { return "TG_TABLE_NAME"; } else if ($val instanceof CurrentColumn) { return "NEW." . $this->columnName($val->getName()); } else if ($val instanceof Column) { return $this->columnName($val->getName()); } else if ($val instanceof Expression) { return $this->createExpression($val, $params); } else { $params[] = is_bool($val) ? ($val ? "TRUE" : "FALSE") : $val; return '$' . count($params); } } public function tableName($table): string { if (is_array($table)) { $tables = array(); foreach($table as $t) $tables[] = $this->tableName($t); return implode(",", $tables); } else { return "\"$table\""; } } public function columnName($col): string { if ($col instanceof KeyWord) { return $col->getValue(); } elseif(is_array($col)) { $columns = array(); foreach($col as $c) $columns[] = $this->columnName($c); return implode(",", $columns); } else { if (($index = strrpos($col, ".")) !== FALSE) { $tableName = $this->tableName(substr($col, 0, $index)); $columnName = $this->columnName(substr($col, $index + 1)); return "$tableName.$columnName"; } else if(($index = stripos($col, " as ")) !== FALSE) { $columnName = $this->columnName(trim(substr($col, 0, $index))); $alias = $this->columnName(trim(substr($col, $index + 4))); return "$columnName as $alias"; } else { return "\"$col\""; } } } public function getStatus() { $version = pg_version($this->connection)["client"] ?? "??"; $status = pg_connection_status($this->connection); static $statusTexts = array( PGSQL_CONNECTION_OK => "PGSQL_CONNECTION_OK", PGSQL_CONNECTION_BAD => "PGSQL_CONNECTION_BAD", ); return ($statusTexts[$status] ?? "Unknown") . " (v$version)"; } protected function buildCondition($condition, &$params) { if($condition instanceof CondRegex) { $left = $condition->getLeftExp(); $right = $condition->getRightExp(); $left = ($left instanceof Column) ? $this->columnName($left->getName()) : $this->addValue($left, $params); $right = ($right instanceof Column) ? $this->columnName($right->getName()) : $this->addValue($right, $params); return $left . " ~ " . $right; } else { return parent::buildCondition($condition, $params); } } private function createTriggerProcedure(string $name, array $statements) { $params = []; $query = "CREATE OR REPLACE FUNCTION $name() RETURNS TRIGGER AS \$table\$ BEGIN "; foreach($statements as $stmt) { if ($stmt instanceof Keyword) { $query .= $stmt->getValue() . ";"; } else { $query .= $stmt->build($this, $params) . ";"; } } $query .= "END;"; $query .= "\$table\$ LANGUAGE plpgsql;"; var_dump($query); var_dump($params); return $this->execute($query, $params); } public function createTriggerBody(CreateTrigger $trigger): ?string { $procName = $this->tableName($trigger->getProcedure()->getName()); return "EXECUTE PROCEDURE $procName()"; } public function getProcedureHead(CreateProcedure $procedure): ?string { $name = $this->tableName($procedure->getName()); $returns = $procedure->getReturns() ?? ""; $paramDefs = []; if (!($procedure->getReturns() instanceof Trigger)) { foreach ($procedure->getParameters() as $parameter) { $paramDefs[] = $parameter->getName() . " " . $this->getColumnType($parameter); } } $paramDefs = implode(",", $paramDefs); if ($returns) { if ($returns instanceof Column) { $returns = " RETURNS " . $this->getColumnType($returns); } else if ($returns instanceof Keyword) { $returns = " RETURNS " . $returns->getValue(); } } return "CREATE OR REPLACE FUNCTION $name($paramDefs)$returns AS $$"; } public function getProcedureTail(): string { return "$$ LANGUAGE plpgsql;"; } public function getProcedureBody(CreateProcedure $procedure): string { $statements = parent::getProcedureBody($procedure); if ($procedure->getReturns() instanceof Trigger) { $statements .= "RETURN NEW;"; } return $statements; } protected function buildUnsafe(Query $statement): string { $params = []; $query = $statement->build($params); foreach ($params as $index => $value) { $value = $this->getUnsafeValue($value); $query = preg_replace("\$$index", $value, $query, 1); } return $query; } protected function createExpression(Expression $exp, array &$params) { if ($exp instanceof DateAdd || $exp instanceof DateSub) { $lhs = $this->addValue($exp->getLHS(), $params); $rhs = $this->addValue($exp->getRHS(), $params); $unit = $exp->getUnit(); if ($exp->getRHS() instanceof Column) { $rhs = "$rhs * INTERVAL '1 $unit'"; } else { $rhs = "$rhs $unit"; } $operator = ($exp instanceof DateAdd ? "+" : "-"); return "$lhs $operator $rhs"; } else if ($exp instanceof CurrentTimeStamp) { return "CURRENT_TIMESTAMP"; } else { return parent::createExpression($exp, $params); } } }