table_j.h

Go to the documentation of this file.

/**************************************************************
 **
 ** @file data/store/java/table_j.h
 **
 ** Copyright (C) 2012  Xpace, LLC.  All rights reserved
 **
 ** www.xpace.net
 **
 **************************************************************/

#ifndef XPACE_TABLE_J_H
#define XPACE_TABLE_J_H

#include "base/datetime.h"
#include "data/store/table.h"

#include "base/java/types_j.h"

// C++ caller for Java Table_Sink - used in several places
namespace Xpace
{
  class JavaTableSink : public Table::Sink 
  {
  public:
    static
    std::unique_ptr<Table::Sink> create
      (JNIEnv* jnienv,
       jobject jsink);

    virtual uint add
      (const String& name,
       DerivedDataType type,
       uint column = ~0,
       bool* added = 0) override   // TODO: add this param to the Java call
    {
      DerivedDataType::type t(convert_pass(env, type).get().getDerivedType());
      if (t == BaseDataType::btUint)
        t = static_cast<DerivedDataType::type>(BaseDataType::btInt);

      uint ret(env->CallIntMethod(jsink, add_column, 
                                  convert_pass(env, name).get(), 
                                  t,
                                  convert_pass(env, column).get()));
      if (added)
        *added = true;  // TODO
      return ret;
    }

    virtual bool setCount
      (uint64 count) override
    {
      return !!env->CallBooleanMethod(jsink, set_count, 
                                      convert_pass(env, count).get());
    }

    virtual int64 start
      (uint64 row) override
    {
      return env->CallLongMethod(jsink, start_row, 
                                 convert_pass(env, row).get());
    }

    virtual bool set 
      (uint column,
       int64 value) override
    {
      return !!env->CallBooleanMethod(jsink, set_int64, 
                                      convert_pass(env, column).get(), 
                                      convert_pass(env, value).get());
    }

    virtual bool set 
      (uint column,
       const Xpace::DecimalFloat& value) override
    {
      return !!env->CallBooleanMethod(jsink, set_float, 
                                      convert_pass(env, column).get(), 
                                      convert_pass(env, value.getMantissa()).get(), 
                                      convert_pass(env, value.getDecimals()).get());
    }

    virtual bool set 
      (uint column,
       const Xpace::String8& value) override
    {  
      return !!env->CallBooleanMethod(jsink, set_string, column, 
                                      convert_pass(env, value).get());
    }

    virtual bool set 
      (uint column,
       const Xpace::String16& value) override
    {
      return !!env->CallBooleanMethod(jsink, set_string, column, 
                                      convert_pass(env, value).get());
    }

    virtual bool set 
      (uint column,
       const Xpace::BytesRef& value) override
    {
      return !!env->CallBooleanMethod(jsink, set_bytes, column, 
                                      convert_pass(env, value).get());
    }

    virtual bool set 
      (uint column,
       const Xpace::DateTime& value) 
    {
      Xpace::Date date(value.getDate());
      Xpace::Time time(value.getTime());

      return !!env->CallBooleanMethod(jsink, set_dateTime, convert_pass(env, column).get(), 
                                      convert_pass(env, date.getYear()).get(), 
                                      convert_pass(env, date.getMonth()).get(), 
                                      convert_pass(env, date.getDay()).get(),
                                      convert_pass(env, time.getHour()).get(), 
                                      convert_pass(env, time.getMinute()).get(), 
                                      convert_pass(env, time.getSecond()).get(), 
                                      convert_pass(env, time.getMillisecond()).get());
    }

    virtual void close
      () override
    {
      env->CallVoidMethod(jsink, do_close);
    }

  private:
    JavaTableSink
      (JNIEnv* jnienv,
       jobject jsink);

    JNIEnv* env;
    jobject jsink;

    jmethodID add_column;
    jmethodID set_count;
    jmethodID start_row;
    jmethodID set_int64;
    jmethodID set_float;
    jmethodID set_string;
    jmethodID set_bytes;
    jmethodID set_dateTime;
    jmethodID do_close;
  };

  class JavaStatus
  {
  public:
    JavaStatus
      (JNIEnv* jnienv,
       jobject jsink);

    int64 operator()
      (int64 val)
    {
      return env->CallLongMethod(jstatus, status, val);
    }

  private:
    JNIEnv* env;
    jobject jstatus;

    jmethodID status;
  };
}

#endif