You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@vxquery.apache.org by pr...@apache.org on 2012/08/29 01:58:14 UTC
svn commit: r1378390 - in
/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery:
functions/builtin-functions.xml
runtime/functions/datetime/FnDateTimeScalarEvaluatorFactory.java
Author: prestonc
Date: Tue Aug 28 23:58:14 2012
New Revision: 1378390
URL: http://svn.apache.org/viewvc?rev=1378390&view=rev
Log:
Added fn:dateTime.
Added:
incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/datetime/FnDateTimeScalarEvaluatorFactory.java (with props)
Modified:
incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/functions/builtin-functions.xml
Modified: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/functions/builtin-functions.xml
URL: http://svn.apache.org/viewvc/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/functions/builtin-functions.xml?rev=1378390&r1=1378389&r2=1378390&view=diff
==============================================================================
--- incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/functions/builtin-functions.xml (original)
+++ incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/functions/builtin-functions.xml Tue Aug 28 23:58:14 2012
@@ -199,6 +199,7 @@
<param name="arg1" type="xs:date?"/>
<param name="arg2" type="xs:time?"/>
<return type="xs:dateTime?"/>
+ <runtime type="scalar" class="org.apache.vxquery.runtime.functions.datetime.FnDateTimeScalarEvaluatorFactory"/>
</function>
<!-- fn:day-from-date($arg as xs:date?) as xs:integer? -->
Added: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/datetime/FnDateTimeScalarEvaluatorFactory.java
URL: http://svn.apache.org/viewvc/incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/datetime/FnDateTimeScalarEvaluatorFactory.java?rev=1378390&view=auto
==============================================================================
--- incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/datetime/FnDateTimeScalarEvaluatorFactory.java (added)
+++ incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/datetime/FnDateTimeScalarEvaluatorFactory.java Tue Aug 28 23:58:14 2012
@@ -0,0 +1,103 @@
+package org.apache.vxquery.runtime.functions.datetime;
+
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.vxquery.datamodel.accessors.TaggedValuePointable;
+import org.apache.vxquery.datamodel.accessors.atomic.XSDatePointable;
+import org.apache.vxquery.datamodel.accessors.atomic.XSTimePointable;
+import org.apache.vxquery.datamodel.util.DateTime;
+import org.apache.vxquery.datamodel.values.ValueTag;
+import org.apache.vxquery.exceptions.ErrorCode;
+import org.apache.vxquery.exceptions.SystemException;
+import org.apache.vxquery.runtime.functions.base.AbstractTaggedValueArgumentScalarEvaluator;
+import org.apache.vxquery.runtime.functions.base.AbstractTaggedValueArgumentScalarEvaluatorFactory;
+
+import edu.uci.ics.hyracks.algebricks.common.exceptions.AlgebricksException;
+import edu.uci.ics.hyracks.algebricks.runtime.base.IScalarEvaluator;
+import edu.uci.ics.hyracks.algebricks.runtime.base.IScalarEvaluatorFactory;
+import edu.uci.ics.hyracks.api.context.IHyracksTaskContext;
+import edu.uci.ics.hyracks.data.std.api.IPointable;
+import edu.uci.ics.hyracks.data.std.util.ArrayBackedValueStorage;
+
+public class FnDateTimeScalarEvaluatorFactory extends AbstractTaggedValueArgumentScalarEvaluatorFactory {
+ private static final long serialVersionUID = 1L;
+
+ public FnDateTimeScalarEvaluatorFactory(IScalarEvaluatorFactory[] args) {
+ super(args);
+ }
+
+ @Override
+ protected IScalarEvaluator createEvaluator(IHyracksTaskContext ctx, IScalarEvaluator[] args)
+ throws AlgebricksException {
+ final XSDatePointable datep = (XSDatePointable) XSDatePointable.FACTORY.createPointable();
+ final XSTimePointable timep = (XSTimePointable) XSTimePointable.FACTORY.createPointable();
+ final ArrayBackedValueStorage abvs = new ArrayBackedValueStorage();
+ final DataOutput dOut = abvs.getDataOutput();
+
+ return new AbstractTaggedValueArgumentScalarEvaluator(args) {
+ @Override
+ protected void evaluate(TaggedValuePointable[] args, IPointable result) throws SystemException {
+ TaggedValuePointable tvp1 = args[0];
+ if (tvp1.getTag() != ValueTag.XS_DATE_TAG) {
+ throw new SystemException(ErrorCode.FORG0006);
+ }
+ tvp1.getValue(datep);
+
+ TaggedValuePointable tvp2 = args[1];
+ if (tvp2.getTag() != ValueTag.XS_TIME_TAG) {
+ throw new SystemException(ErrorCode.FORG0006);
+ }
+ tvp2.getValue(timep);
+
+ // Set the timezone.
+ byte timezoneHour, timezoneMinute;
+ if (datep.getTimezoneHour() == DateTime.TIMEZONE_HOUR_NULL
+ && datep.getTimezoneMinute() == DateTime.TIMEZONE_MINUTE_NULL
+ && timep.getTimezoneHour() == DateTime.TIMEZONE_HOUR_NULL
+ && timep.getTimezoneMinute() == DateTime.TIMEZONE_MINUTE_NULL) {
+ // both null.
+ timezoneHour = DateTime.TIMEZONE_HOUR_NULL;
+ timezoneMinute = DateTime.TIMEZONE_MINUTE_NULL;
+ } else if (datep.getTimezoneHour() == DateTime.TIMEZONE_HOUR_NULL
+ && datep.getTimezoneMinute() == DateTime.TIMEZONE_MINUTE_NULL
+ && timep.getTimezoneHour() != DateTime.TIMEZONE_HOUR_NULL
+ && timep.getTimezoneMinute() != DateTime.TIMEZONE_MINUTE_NULL) {
+ // date is null.
+ timezoneHour = (byte) timep.getTimezoneHour();
+ timezoneMinute = (byte) timep.getTimezoneMinute();
+ } else if (datep.getTimezoneHour() != DateTime.TIMEZONE_HOUR_NULL
+ && datep.getTimezoneMinute() != DateTime.TIMEZONE_MINUTE_NULL
+ && timep.getTimezoneHour() == DateTime.TIMEZONE_HOUR_NULL
+ && timep.getTimezoneMinute() == DateTime.TIMEZONE_MINUTE_NULL) {
+ // time is null.
+ timezoneHour = (byte) datep.getTimezoneHour();
+ timezoneMinute = (byte) datep.getTimezoneMinute();
+ } else if (datep.getTimezoneHour() == timep.getTimezoneHour()
+ && datep.getTimezoneMinute() == timep.getTimezoneMinute()) {
+ // timezones are the same.
+ timezoneHour = (byte) datep.getTimezoneHour();
+ timezoneMinute = (byte) datep.getTimezoneMinute();
+ } else {
+ // Neither match.
+ throw new SystemException(ErrorCode.FORG0008);
+ }
+
+ try {
+ abvs.reset();
+ dOut.write(ValueTag.XS_DATETIME_TAG);
+ dOut.write(datep.getByteArray(), datep.getStartOffset(),
+ XSDatePointable.TYPE_TRAITS.getFixedLength() - 2);
+ dOut.write(timep.getByteArray(), timep.getStartOffset(),
+ XSTimePointable.TYPE_TRAITS.getFixedLength() - 2);
+ dOut.write(timezoneHour);
+ dOut.write(timezoneMinute);
+
+ result.set(abvs);
+ } catch (IOException e) {
+ throw new SystemException(ErrorCode.SYSE0001, e);
+ }
+ }
+ };
+ }
+}
Propchange: incubator/vxquery/trunk/vxquery/vxquery-core/src/main/java/org/apache/vxquery/runtime/functions/datetime/FnDateTimeScalarEvaluatorFactory.java
------------------------------------------------------------------------------
svn:eol-style = native