This is an automated email from the ASF dual-hosted git repository.
doebele pushed a commit to branch version3
in repository https://gitbox.apache.org/repos/asf/empire-db.git
The following commit(s) were added to refs/heads/version3 by this push:
new 6e0742a EMPIREDB-362 DBVarArgsFuncExpr
6e0742a is described below
commit 6e0742a85613330481fb21d83641540fefef1a0b
Author: Rainer Döbele <[email protected]>
AuthorDate: Thu Jan 27 15:57:02 2022 +0100
EMPIREDB-362 DBVarArgsFuncExpr
---
.../org/apache/empire/commons/Unwrappable.java | 17 ++-
.../empire/db/expr/column/DBVarArgsFuncExpr.java | 152 +++++++++++++++++++++
2 files changed, 168 insertions(+), 1 deletion(-)
diff --git a/empire-db/src/main/java/org/apache/empire/commons/Unwrappable.java
b/empire-db/src/main/java/org/apache/empire/commons/Unwrappable.java
index 6bb9610..8963db1 100644
--- a/empire-db/src/main/java/org/apache/empire/commons/Unwrappable.java
+++ b/empire-db/src/main/java/org/apache/empire/commons/Unwrappable.java
@@ -1,5 +1,20 @@
/*
- * ESTEAM Software GmbH, 27.01.2022
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
*/
package org.apache.empire.commons;
diff --git
a/empire-db/src/main/java/org/apache/empire/db/expr/column/DBVarArgsFuncExpr.java
b/empire-db/src/main/java/org/apache/empire/db/expr/column/DBVarArgsFuncExpr.java
new file mode 100644
index 0000000..02762f2
--- /dev/null
+++
b/empire-db/src/main/java/org/apache/empire/db/expr/column/DBVarArgsFuncExpr.java
@@ -0,0 +1,152 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.empire.db.expr.column;
+
+import java.util.Set;
+
+import org.apache.empire.data.DataType;
+import org.apache.empire.db.DBColumn;
+import org.apache.empire.db.DBColumnExpr;
+import org.apache.empire.db.DBDatabase;
+import org.apache.empire.exceptions.InvalidArgumentException;
+import org.apache.empire.xml.XMLUtil;
+import org.w3c.dom.Element;
+
+
+public class DBVarArgsFuncExpr extends DBColumnExpr
+{
+ private DBDatabase database;
+ private DataType dataType;
+ private String template;
+ private DBColumnExpr[] cols;
+
+ public DBVarArgsFuncExpr(DBDatabase db, DataType dataType, String
template, DBColumnExpr... cols)
+ {
+ if (template.indexOf("?")<0)
+ throw new InvalidArgumentException("template", template);
+
+ this.database = db;
+ this.dataType = dataType;
+ this.template = template;
+ this.cols = cols;
+ }
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public final <T extends DBDatabase> T getDatabase()
+ {
+ return (T) database;
+ }
+
+ @Override
+ public DataType getDataType()
+ {
+ return dataType;
+ }
+
+ @Override
+ public String getName()
+ {
+ return getNameFromTemplate(template);
+ }
+
+ @Override
+ public boolean isAggregate()
+ {
+ return false;
+ }
+
+ @Override
+ public DBColumn getSourceColumn()
+ {
+ return cols[0].getSourceColumn();
+ }
+
+ @Override
+ public DBColumn getUpdateColumn()
+ {
+ return null;
+ }
+
+ @Override
+ public void addReferencedColumns(Set<DBColumn> list)
+ {
+ for (int i=0; i<cols.length; i++)
+ {
+ DBColumn col = cols[i].getUpdateColumn();
+ if (col!=null)
+ list.add(col);
+ }
+ }
+
+ @Override
+ public void addSQL(StringBuilder sql, long context)
+ {
+ StringBuilder b = new StringBuilder();
+ for (int i=0; i<cols.length; i++)
+ {
+ if (i>0)
+ b.append(", ");
+ // add SQL
+ DBColumnExpr col = cols[i];
+ col.addSQL(b, CTX_DEFAULT);
+ }
+ // Get Template
+ String prefix = template;
+ String postfix = "";
+ int sep = template.indexOf("?");
+ if (sep >= 0)
+ {
+ prefix = template.substring(0, sep);
+ postfix = template.substring(sep + 1);
+ }
+ // append
+ sql.append(prefix);
+ sql.append(b.toString());
+ sql.append(postfix);
+ }
+
+ @Override
+ public Element addXml(Element parent, long flags)
+ {
+ Element elem = XMLUtil.addElement(parent, "column");
+ elem.setAttribute("name", getName());
+ // Add Other Attributes
+ if (attributes!=null)
+ attributes.addXml(elem, flags);
+ // Done
+ elem.setAttribute("function", getName());
+ return elem;
+ }
+
+ private static String getNameFromTemplate(String template)
+ {
+ String s = template.trim();
+ int i=0;
+ for (; i<s.length(); i++)
+ if (s.charAt(i)<'A')
+ break;
+ // return name
+ if (i>0)
+ return s.substring(0,i);
+ // default
+ return "unknownFunc";
+ }
+
+}
