instead of upsert, fallback to default query on PgSQL <= 9.4

because there is no upsert yet

Signed-off-by: Arthur Schiwon <blizzz@arthur-schiwon.de>

2 files changed, 24 insertions, 3 deletions

diff --git a/lib/private/DB/AdapterPgSql.php b/lib/private/DB/AdapterPgSql.php
index af1978d051c..42e57cd45f7 100644
--- a/lib/private/DB/AdapterPgSql.php
+++ b/lib/private/DB/AdapterPgSql.php
@@ -24,7 +24,11 @@
 
 namespace OC\DB;
 
+use Doctrine\DBAL\DBALException;
+
 class AdapterPgSql extends Adapter {
+	protected $compatModePre9_5 = null;
+
 	public function lastInsertId($table) {
 		return $this->conn->fetchColumn('SELECT lastval()');
 	}
@@ -40,12 +44,29 @@ class AdapterPgSql extends Adapter {
 	 * @suppress SqlInjectionChecker
 	 */
 	public function insertIgnoreConflict(string $table,array $values) : int {
+		if($this->isPre9_5CompatMode() === true) {
+			return parent::insertIgnoreConflict($table, $values);
+		}
+
+		// "upsert" is only available since PgSQL 9.5, but the generic way
+		// would leave error logs in the DB.
 		$builder = $this->conn->getQueryBuilder();
 		$builder->insert($table);
-		foreach($values as $key => $value) {
+		foreach ($values as $key => $value) {
 			$builder->setValue($key, $builder->createNamedParameter($value));
 		}
 		$queryString = $builder->getSQL() . ' ON CONFLICT DO NOTHING';
 		return $this->conn->executeUpdate($queryString, $builder->getParameters(), $builder->getParameterTypes());
 	}
+
+	protected function isPre9_5CompatMode(): bool {
+		if($this->compatModePre9_5 !== null) {
+			return $this->compatModePre9_5;
+		}
+
+		$version = $this->conn->fetchColumn('SHOW SERVER_VERSION');
+		$this->compatModePre9_5 = version_compare($version, '9.5', '<');
+
+		return $this->compatModePre9_5;
+	}
 }
diff --git a/lib/private/legacy/util.php b/lib/private/legacy/util.php
index 32069053257..810f22fb9e5 100644
--- a/lib/private/legacy/util.php
+++ b/lib/private/legacy/util.php
@@ -978,9 +978,9 @@ class OC_Util {
 				$data = $result->fetchRow();
 				if (isset($data['server_version'])) {
 					$version = $data['server_version'];
-					if (version_compare($version, '9.5.0', '<')) {
+					if (version_compare($version, '9.0.0', '<')) {
 						$errors[] = array(
-							'error' => $l->t('PostgreSQL >= 9.5 required'),
+							'error' => $l->t('PostgreSQL >= 9 required'),
 							'hint' => $l->t('Please upgrade your database version')
 						);
 					}