aboutsummaryrefslogtreecommitdiffstats
path: root/include/dblayer/functions_pgsql.inc.php
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--include/dblayer/functions_pgsql.inc.php73
1 files changed, 72 insertions, 1 deletions
diff --git a/include/dblayer/functions_pgsql.inc.php b/include/dblayer/functions_pgsql.inc.php
index dbbe3d52d..67c42eeb1 100644
--- a/include/dblayer/functions_pgsql.inc.php
+++ b/include/dblayer/functions_pgsql.inc.php
@@ -91,7 +91,8 @@ function pwg_query($query)
{
global $conf,$page,$debug,$t2;
- $replace_pattern = '`REPLACE INTO\s(\S*)\s*([^)]*\))\s*VALUES\(([^,]*),(.*)\)\s*`mi';
+ $replace_pattern = '`REPLACE INTO\s(\S*)\s*([^)]*\))\s*VALUES\(([^,]*),(.*)\)\s*`mi';
+ $select_distinct_pattern = '/SELECT\s+DISTINCT\s*(\S[^;]*\S)\s*(FROM[^(;]+WHERE[^;]+)\s+ORDER\s+BY\s+([^;]*\S)\s*;?/i';
$start = get_moment();
@@ -117,6 +118,76 @@ INSERT INTO '.$matches[1].'
}
( $result = pg_query($query)) or die($query."\n<br>".pg_last_error());
}
+ elseif (preg_match($select_distinct_pattern, $query, $matches))
+ {
+ $select_fields_string='';
+ $distinct_fields_string='';
+ $orderby_fields_string='';
+
+ foreach (preg_split( '/\s*,\s*/', $matches[1]) as $field)
+ {
+ $split_field = preg_split( '/\s*AS\s*/i', $field);
+ if (isset($split_field[1]))
+ {
+ $distinct_fields[ $split_field[1] ] = $field;
+ }
+ else
+ {
+ $distinct_fields[ $field ] = $field;
+ }
+ }
+
+ foreach (preg_split( '/\s*,\s*/', $matches[3]) as $field)
+ {
+ $kv = preg_split( '/\s+/', $field );
+ $orderby_fields[ $kv[0] ] = $kv[1];
+ }
+
+ foreach ($distinct_fields as $as_field => $field)
+ {
+ if ($distinct_fields_string)
+ {
+ $distinct_fields_string=$distinct_fields_string.', ';
+ }
+
+ $distinct_fields_string=$distinct_fields_string.$as_field;
+
+ if ($select_fields_string)
+ {
+ $select_fields_string=$select_fields_string.', ';
+ }
+
+ $select_fields_string=$select_fields_string.$field;
+
+ if ($orderby_fields_string)
+ {
+ $orderby_fields_string=$orderby_fields_string.', ';
+ }
+
+ $orderby_fields_string=$orderby_fields_string.$as_field.' ';
+
+ if (isset($orderby_fields[$as_field]))
+ {
+ $orderby_fields_string=$orderby_fields_string.$orderby_fields[$as_field];
+ unset($orderby_fields[$as_field]);
+ }
+ else
+ {
+ $orderby_fields_string=$orderby_fields_string.'ASC';
+ }
+ }
+
+ foreach ($orderby_fields as $field => $order)
+ {
+ $orderby_fields_string=$orderby_fields_string.', '.$field.' '.$order;
+ }
+
+ $query = '
+SELECT DISTINCT ON ('.$distinct_fields_string.') '.$select_fields_string.'
+ '.$matches[2].'
+ ORDER BY '.$orderby_fields_string;
+ ($result = pg_query($query)) or die($query."\n<br>".pg_last_error());
+ }
else
{
($result = pg_query($query)) or die($query."\n<br>".pg_last_error());