diff options
| -rw-r--r-- | include/dblayer/functions_pgsql.inc.php | 30 |
1 files changed, 29 insertions, 1 deletions
diff --git a/include/dblayer/functions_pgsql.inc.php b/include/dblayer/functions_pgsql.inc.php index a04da9620..6dcf26f6d 100644 --- a/include/dblayer/functions_pgsql.inc.php +++ b/include/dblayer/functions_pgsql.inc.php @@ -70,8 +70,36 @@ function pwg_query($query) { global $conf,$page,$debug,$t2; + $replace_pattern = '`REPLACE INTO\s(\S*)\s*([^)]*\))\s*VALUES\(([^,]*),(.*)\)\s*`mi'; + $start = get_moment(); - ($result = pg_query($query)) or die($query."\n<br>".pg_last_error()); + + if (preg_match($replace_pattern, $query, $matches) + && $matches[1]==SESSIONS_TABLE) + { + $select_query = ' +SELECT id FROM '.$matches[1].' + WHERE id='.$matches[3]; + ( $result = pg_query($select_query)) or die($query."\n<br>".pg_last_error()); + if (pwg_db_num_rows($result)==1) + { + $query = ' +UPDATE '.$matches[1].' + SET expiration=now() + WHERE id='.$matches[3]; + } + else + { + $query = ' +INSERT INTO '.$matches[1].' + '.$matches[2].' VALUES('.$matches[3].','.$matches[4].')'; + } + ( $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()); + } $time = get_moment() - $start; |