WebSVN - OpenConcerto - Diff - Rev 142 and 182 - /trunk/OpenConcerto/src/org/openconcerto/sql/model/SQLSyntaxH2.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.sql.model.SQLField.Properties;
 import org.openconcerto.sql.model.graph.TablesMap;
 import org.openconcerto.sql.utils.ChangeTable.ClauseType;
 import org.openconcerto.sql.utils.SQLUtils;
+import org.openconcerto.utils.CollectionUtils;
 import org.openconcerto.utils.ListMap;
-import org.openconcerto.utils.NetUtils;
 import org.openconcerto.utils.Tuple2;
+import org.openconcerto.utils.cc.ITransformer;
+import org.openconcerto.utils.cc.Transformer;
+import org.openconcerto.xml.XMLCodecUtils;
+import java.beans.DefaultPersistenceDelegate;
 import java.io.File;
 import java.math.BigDecimal;
 import java.sql.Blob;
 import java.sql.Clob;
 import java.sql.SQLException;
 import java.sql.Timestamp;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.IdentityHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import org.h2.constant.ErrorCode;
-class SQLSyntaxH2 extends SQLSyntax {
+public class SQLSyntaxH2 extends SQLSyntax {
     static protected final IdentityHashMap<String, String> DATE_SPECS;
     static {
         DATE_SPECS = new IdentityHashMap<String, String>(DateProp.JAVA_DATE_SPECS_PURE);
         DATE_SPECS.put(DateProp.MICROSECOND, "SSS000");
+        XMLCodecUtils.register(SQLSyntaxH2.class, new DefaultPersistenceDelegate(new String[] {}));
+    }
+    final static SQLSyntax create(DBSystemRoot sysRoot) {
+        boolean standardArray = true;
+        if (sysRoot != null) {
-    SQLSyntaxH2() {
+            try {
+                standardArray = Arrays.equals(new String[] { "foo" }, (Object[]) sysRoot.getDataSource().executeScalar("SELECT ARRAY['foo']"));
+            } catch (RuntimeException e) {
+                if (SQLUtils.findWithSQLState(e).getErrorCode() == ErrorCode.COLUMN_NOT_FOUND_1)
+                    standardArray = false;
+                else
+                    throw e;
+            }
+        }
+        return new SQLSyntaxH2(standardArray);
+    }
+    private final boolean standardArray;
+    public SQLSyntaxH2(final boolean standardArray) {
         super(SQLSystem.H2, DATE_SPECS);
+        this.standardArray = standardArray;
         this.typeNames.addAll(Boolean.class, "boolean", "bool", "bit");
         this.typeNames.addAll(Integer.class, "integer", "int", "int4", "mediumint");
         this.typeNames.addAll(Byte.class, "tinyint");
         this.typeNames.addAll(Short.class, "smallint", "int2");
         this.typeNames.addAll(Long.class, "bigint", "int8");
         final String quotedSel = quoteString(SQLSyntaxPG.selectAll(t).asString());
         t.getBase().getDataSource().execute("CALL CSVWRITE(" + quotedPath + ", " + quotedSel + ", 'UTF8', ',', '\"', '\\', '\\N', '\n');");
+    }
     @Override
-    protected boolean isServerLocalhost(SQLServer s) {
-        return s.getName().startsWith("mem") || s.getName().startsWith("file") || NetUtils.isSelfAddr(getAddr(s));
-    }
-    private String getAddr(SQLServer s) {
-        if (s.getName().startsWith("tcp") || s.getName().startsWith("ssl")) {
-            final int startIndex = "tcp://".length();
-            final int endIndex = s.getName().indexOf('/', startIndex);
-            return s.getName().substring(startIndex, endIndex < 0 ? s.getName().length() : endIndex);
-        } else
-            return null;
-    }
-    @Override
     public String getCreateSynonym(SQLTable t, SQLName newName) {
         return null;
+    }
     @Override
         // in MVCC, if two transactions modify the same row the second one will repeatedly throw
         // CONCURRENT_UPDATE_1 until LockTimeout
         // otherwise, the second one will timeout while waiting for the table lock
         return stateExn.getErrorCode() == ErrorCode.DEADLOCK_1 || stateExn.getErrorCode() == ErrorCode.LOCK_TIMEOUT_1;
+    }
+    @Override
+    public boolean isTableNotFoundException(Exception exn) {
+        final SQLException stateExn = SQLUtils.findWithSQLState(exn);
+        return stateExn.getErrorCode() == ErrorCode.TABLE_OR_VIEW_NOT_FOUND_1 || stateExn.getErrorCode() == ErrorCode.SCHEMA_NOT_FOUND_1;
+    }
+    @Override
+    public String getSessionIDExpression() {
+        return "SESSION_ID()";
+    }
+    @Override
+    public String getSessionsQuery(final DBSystemRoot sysRoot, final boolean includeSelf) {
+        final String allRows = "SELECT \"ID\", \"STATEMENT\" as \"QUERY\", \"USER_NAME\" FROM INFORMATION_SCHEMA.SESSIONS";
+        if (includeSelf)
+            return allRows;
+        return allRows + " WHERE \"ID\" != " + this.getSessionIDExpression();
+    }
+    @Override
+    public String getVersionFunction() {
+        return "H2VERSION()";
+    }
+    @Override
+    public String getAllowConnectionsQuery(String sysRootName, final boolean allow) {
+        return "SET EXCLUSIVE " + (allow ? "0" : "1");
+    }
+    @Override
+    public boolean isConnectionDisallowedException(SQLException exn) {
+        return exn.getErrorCode() == ErrorCode.DATABASE_IS_IN_EXCLUSIVE_MODE;
+    }
+    @Override
+    public String getSQLArray(final List<String> sqlExpressions, final String type) {
+        // H2 cannot specify type in SQL, so cast each item
+        final ITransformer<? super String, ?> tf = type == null ? Transformer.nopTransformer() : (s) -> {
+            return this.cast(s, type);
+        };
+        final String items = CollectionUtils.join(sqlExpressions, ", ", tf);
+        if (this.standardArray) {
+            return "ARRAY[" + items + ']';
+        } else {
+            // For the comma, see http://h2database.com/html/grammar.html#array
+            return '(' + items + (sqlExpressions.size() == 1 ? ",)" : ")");
+        }
+    }
+    @Override
+    public String getSQLArrayContains(String arrayExpression, String itemExpression) {
+        return "ARRAY_CONTAINS(" + arrayExpression + ", " + itemExpression + ")";
+    }
+    @Override
+    public String getSQLArrayLength(final String arrayExpression) {
+        return "ARRAY_LENGTH(" + arrayExpression + ")";
+    }
+    @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) {
+        return "array_append(" + arrayExpression + ", " + itemExpression + ")";
+    }
+    @Override
+    public String getSQLArraySlice(final String arrayExpression, final String index1Expression, final String index2Expression) {
+        return "ARRAY_SLICE(" + 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/SQLSyntaxH2.java - Rev 142 → 182