WebSVN - OpenConcerto - Diff - Rev 156 and 182 - /trunk/OpenConcerto/src/org/openconcerto/sql/model/SQLSyntaxPG.java

 /*
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
+ *
- * Copyright 2011 OpenConcerto, by ILM Informatique. All rights reserved.
+ * Copyright 2011-2019 OpenConcerto, by ILM Informatique. All rights reserved.
+ *
  * The contents of this file are subject to the terms of the GNU General Public License Version 3
  * only ("GPL"). You may not use this file except in compliance with the License. You can obtain a
  * copy of the License at http://www.gnu.org/licenses/gpl-3.0.html See the License for the specific
  * language governing permissions and limitations under the License.
 import org.openconcerto.utils.FileUtils;
 import org.openconcerto.utils.ListMap;
 import org.openconcerto.utils.StringUtils;
 import org.openconcerto.utils.Tuple2;
 import org.openconcerto.utils.cc.ITransformer;
+import org.openconcerto.xml.XMLCodecUtils;
+import java.beans.DefaultPersistenceDelegate;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.math.BigDecimal;
  * (already set up on Ubuntu).
  * <p>
+ *
  * @author Sylvain CUAZ
  */
-class SQLSyntaxPG extends SQLSyntax {
+public class SQLSyntaxPG extends SQLSyntax {
     // From http://www.postgresql.org/docs/9.0/interactive/multibyte.html
     static final short MAX_BYTES_PER_CHAR = 4;
     // http://www.postgresql.org/docs/9.0/interactive/datatype-character.html
     private static final short MAX_LENGTH_BYTES = 4;
         DATE_SPECS.put(DateProp.DAY_NAME_IN_WEEK, "TMday");
         DATE_SPECS.put(DateProp.HOUR, "HH24");
         DATE_SPECS.put(DateProp.MINUTE, "MI");
         DATE_SPECS.put(DateProp.SECOND, "SS");
         DATE_SPECS.put(DateProp.MICROSECOND, "US");
+        XMLCodecUtils.register(SQLSyntaxPG.class, new DefaultPersistenceDelegate(new String[] {}));
+    }
-    SQLSyntaxPG() {
+    public SQLSyntaxPG() {
         super(SQLSystem.POSTGRESQL, DATE_SPECS);
         this.typeNames.addAll(Boolean.class, "boolean", "bool", "bit");
         this.typeNames.addAll(Short.class, "smallint", "int2");
         this.typeNames.addAll(Integer.class, "integer", "int", "int4");
         this.typeNames.addAll(Long.class, "bigint", "int8");
     @Override
     public boolean isDeadLockException(SQLException exn) {
         return SQLUtils.findWithSQLState(exn).getSQLState().equals("40P01");
+    }
+    @Override
+    public boolean isTableNotFoundException(Exception exn) {
+        return SQLUtils.findWithSQLState(exn).getSQLState().equals("42P01");
+    }
+    @Override
+    public String getSetLockTimeoutQuery(int millis) {
+        return "SET lock_timeout to " + millis;
+    }
+    @Override
+    public String getShowLockTimeoutQuery() {
+        final String interval = cast("setting||unit", "INTERVAL");
+        return "select  CAST( EXTRACT(milliseconds from " + interval + ") as int) from pg_settings where \"name\" = 'lock_timeout'";
+    }
     private static final Pattern NOW_PTRN = Pattern.compile("\\(?'now'::text\\)?(::timestamp)");
     @Override
     public String transfDefaultJDBC2SQL(SQLField f) {
         if (f.getDefaultValue() != null && Date.class.isAssignableFrom(f.getType().getJavaType())) {
     @Override
     public String getDropTrigger(Trigger t) {
         return "DROP TRIGGER " + SQLBase.quoteIdentifier(t.getName()) + " on " + t.getTable().getSQLName().quote();
+    }
+    @Override
+    public String getSessionIDExpression() {
+        return "pg_backend_pid()";
+    }
+    @Override
+    public String getSessionsQuery(final DBSystemRoot sysRoot, final boolean includeSelf) {
+        final String allRows = "SELECT pid as \"ID\", query as \"QUERY\", usename as \"USER_NAME\" FROM pg_stat_activity WHERE datname=" + quoteString(sysRoot.getName());
+        if (includeSelf)
+            return allRows;
+        return allRows + " and pid != " + this.getSessionIDExpression();
+    }
+    @Override
+    public String getVersionFunction() {
+        // shorter than version() : "PostgreSQL 9.6.9 on x86_64-pc-linux-gnu (Ubuntu
+        // 9.6.9-2.pgdg16.04+1), compiled by gcc (Ubuntu 5.4.0-6ubuntu1~16.04.9) 5.4.0 20160609,
+        // 64-bit"
+        return "current_setting('server_version')";
+    }
+    @Override
+    public String getAllowConnectionsQuery(String sysRootName, boolean allow) {
+        // REVOKE CONNECT ON DATABASE "ControleKD" TO public : superusers can still connect
+        // to recover if all DB (even postgres and templates) run postgres --single
+        // (single user / standalone mode ignores datallowconn)
+        return "UPDATE pg_database SET datallowconn=" + SQLType.getBoolean(this).toString(allow) + " WHERE datname=" + quoteString(sysRootName);
+        // "ALTER DATABASE WITH ALLOW_CONNECTIONS" isn't allowed on our own base
+    }
+    @Override
+    public boolean isConnectionDisallowedException(SQLException exn) {
+        return "55000".equals(exn.getSQLState());
+    }
+    @Override
+    public String getSQLArray(final List<String> sqlExpressions, final String type) {
+        if (type == null)
+            return "ARRAY[" + CollectionUtils.join(sqlExpressions, ", ") + ']';
+        else
+            return this.quoteString('{' + CollectionUtils.join(sqlExpressions, ", ") + '}') + "::" + type + "[]";
+    }
+    @Override
+    public String getSQLArrayContains(String arrayExpression, String itemExpression) {
+        return itemExpression + " = ANY(" + arrayExpression + ")";
+    }
+    @Override
+    public String getSQLArrayLength(final String arrayExpression) {
+        return "ARRAY_LENGTH(" + arrayExpression + ", 1)";
+    }
+    @Override
+    public String getSQLArrayConcat(final String arrayExpression, final String array2Expression) {
+        return "array_cat(" + arrayExpression + ", " + array2Expression + ")";
+    }
+    @Override
+    public String getSQLArrayAppend(final String arrayExpression, final String itemExpression) {
+        // don't use || as it doesn't handle varchar literal
+        return "array_append(" + arrayExpression + ", " + itemExpression + ")";
+    }
+    @Override
+    public String getSQLArraySlice(final String arrayExpression, final String index1Expression, final String index2Expression) {
+        return '(' + arrayExpression + ")[" + index1Expression + ":" + index2Expression + "]";
+    }
+}

Dépôt officiel du code source de l'ERP OpenConcerto

svn://code.openconcerto.org/openconcerto

(root)/trunk/OpenConcerto/src/org/openconcerto/sql/model/SQLSyntaxPG.java - Rev 156 → 182