Db_Pgsql

Complexity

Total Complexity

20

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	connect()	0	25	6
A	fetch_assoc()	0	2	1
A	query()	0	12	4
A	last_query_error()	0	2	1
A	num_rows()	0	2	1
A	init()	0	8	1
A	affected_rows()	0	2	1
A	escape_string()	0	6	2
A	last_error()	0	2	1
A	close()	0	2	1
A	fetch_result()	0	2	1

<?php
class Db_Pgsql implements IDb {
    private $link;
    private $last_error;

    public function connect($host, $user, $pass, $db, $port) {
        $string = "dbname=$db user=$user";

        if ($pass) {
            $string .= " password=$pass";
        }

        if ($host) {
            $string .= " host=$host";
        }

        if (is_numeric($port) && $port > 0) {
            $string = "$string port=".$port;
        }

        $this->link = pg_connect($string);

        if (!$this->link) {
            print("Unable to connect to database (as $user to $host, database $db):".pg_last_error());
            exit(102);

Using exit here is not recommended.

        }

        $this->init();

        return $this->link;
    }

    public function escape_string($s, $strip_tags = true) {
        if ($strip_tags) {
            $s = strip_tags($s);
        }

        return pg_escape_string($s);

The call to pg_escape_string() has too few arguments starting with data.

    }

    public function query($query, $die_on_error = true) {
        $result = @pg_query($this->link, $query);

        if (!$result) {

$result is of type resource, thus it always evaluated to false.

            $this->last_error = @pg_last_error($this->link);

            @pg_query($this->link, "ROLLBACK");

It seems like you do not handle an error condition for pg_query(). This can introduce security issues, and is generally not recommended.

            $query = htmlspecialchars($query); // just in case
            user_error("query $query failed: ".($this->link ? $this->last_error : "No connection"),
                $die_on_error ? E_USER_ERROR : E_USER_WARNING);
        }
        return $result;
    }

    public function fetch_assoc($result) {
        return pg_fetch_assoc($result);
    }


    public function num_rows($result) {
        return pg_num_rows($result);
    }

    public function fetch_result($result, $row, $param) {
        return pg_fetch_result($result, $row, $param);
    }

    public function close() {
        return pg_close($this->link);
    }

    public function affected_rows($result) {
        return pg_affected_rows($result);
    }

    public function last_error() {
        return pg_last_error($this->link);
    }

    public function last_query_error() {
        return $this->last_error;
    }

    public function init() {
        $this->query("set client_encoding = 'UTF-8'");
        pg_set_client_encoding("UNICODE");

The call to pg_set_client_encoding() has too few arguments starting with encoding.

'UNICODE' of type string is incompatible with the type resource expected by parameter $connection of pg_set_client_encoding().

        $this->query("set datestyle = 'ISO, european'");
        $this->query("set TIME ZONE 0");
        $this->query("set cpu_tuple_cost = 0.5");

        return true;
    }
}