1 files changed, 73 insertions, 0 deletions
diff --git a/codebase/connector/db_postgre.php b/codebase/connector/db_postgre.php
new file mode 100644
index 0000000..a7d1598
--- /dev/null
+++ b/codebase/connector/db_postgre.php
@@ -0,0 +1,73 @@
+<?php
+/*
+	@author dhtmlx.com
+	@license GPL, see license.txt
+*/
+require_once("db_common.php");
+/*! Implementation of DataWrapper for PostgreSQL
+**/
+class PostgreDBDataWrapper extends DBDataWrapper{
+	public function query($sql){
+		LogMaster::log($sql);
+		
+		$res=pg_query($this->connection,$sql);
+		if ($res===false) throw new Exception("Postgre - sql execution failed\n".pg_last_error($this->connection));
+		
+		return $res;
+	}
+	
+	protected function select_query($select,$from,$where,$sort,$start,$count){
+		if (!$from)
+			return $select;
+			
+		$sql="SELECT ".$select." FROM ".$from;
+		if ($where) $sql.=" WHERE ".$where;
+		if ($sort) $sql.=" ORDER BY ".$sort;
+		if ($start || $count) 
+			$sql.=" OFFSET ".$start." LIMIT ".$count;
+		return $sql;
+	}
+		
+	public function get_next($res){
+		return pg_fetch_assoc($res);
+	}
+	
+	public function get_new_id(){
+		$res  = pg_query( $this->connection, "SELECT LASTVAL() AS seq");
+		$data = pg_fetch_assoc($res);
+				pg_free_result($res);
+		return $data['seq'];
+	}
+	
+	public function escape($data){
+		//need to use oci_bind_by_name
+		return pg_escape_string($this->connection,$data);
+	}
+
+	public function tables_list() {
+		$sql = "SELECT table_name FROM information_schema.tables WHERE table_schema = 'public'";
+		$res = pg_query($this->connection, $sql);
+		$tables = array();
+		while ($table = pg_fetch_assoc($res)) {
+			$tables[] = $table['table_name'];
+		}
+		return $tables;
+	}
+
+	public function fields_list($table) {
+		$sql = "SELECT * FROM information_schema.constraint_column_usage";
+		$result = pg_query($this->connection, $sql);
+		$field = pg_fetch_assoc($result);
+		$id = $field['column_name'];
+
+		$sql = "SELECT * FROM information_schema.columns WHERE table_name ='".$table."';";
+		$result = pg_query($this->connection, $sql);
+		$fields = array();
+        $id = "";
+		while ($field = pg_fetch_assoc($result)) {
+		    $fields[] = $field["column_name"];
+		}
+		return array('fields' => $fields, 'key' => $id );
+	}
+}
+?>
+\ No newline at end of file