store_j.h

Go to the documentation of this file.

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

#ifndef XPACE_STORE_J_H
#define XPACE_STORE_J_H

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

#include "base/java/types_j.h"

PassJNI<jintArray> convert_pass
  (JNIEnv* jniEnv,
   const Xpace::Store::Location& val);

// C++ caller for Java Store_Sink - used in several places
namespace Xpace
{
  class JavaStoreSink : public Store::Sink 
  {
  public:
    JavaStoreSink
      (JNIEnv* jnienv,
       jobject jsink);

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

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

    // ------------------------------ by Location -------------

    virtual bool set 
      (const Store::Location& loc,
       int64 value) override
    {
      return !!env->CallBooleanMethod(jsink, set_loc_int64, convert_pass(env, loc).get(), convert_pass(env, value).get());
    }

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

    virtual bool set 
      (const Store::Location& loc,
       const Xpace::String8& value) override
    {  
      return !!env->CallBooleanMethod(jsink, set_loc_string, convert_pass(env, loc).get(), convert_pass(env, value).get());
    }

    virtual bool set 
      (const Store::Location& loc,
       const Xpace::String16& value) override
    {
      return !!env->CallBooleanMethod(jsink, set_loc_string, convert_pass(env, loc).get(), convert_pass(env, value).get());
    }

    virtual bool set 
      (const Store::Location& loc,
       const Xpace::BytesRef& value) override
    {
      return !!env->CallBooleanMethod(jsink, set_loc_bytes, convert_pass(env, loc).get(), convert_pass(env, value).get());
    }

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

      return !!env->CallBooleanMethod(jsink, set_loc_dateTime, convert_pass(env, loc).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());
    }
    
    // ------------------------------ by Child Name -----------

    virtual bool set 
      (const String8& child,
       int64 value) override
    {
      return !!env->CallBooleanMethod(jsink, set_name_int64, convert_pass(env, child).get(), convert_pass(env, value).get());
    }

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

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

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

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

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

      return !!env->CallBooleanMethod(jsink, set_name_dateTime, convert_pass(env, child).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());
    }

    // ------------------------------ by Child Name -----------

    virtual bool set 
      (int child,
       int64 value) override
    {
      return !!env->CallBooleanMethod(jsink, set_num_int64, convert_pass(env, child).get(), convert_pass(env, value).get());
    }

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

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

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

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

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

      return !!env->CallBooleanMethod(jsink, set_num_dateTime, convert_pass(env, child).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());
    }

    // ------------------------------ close -------------------

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

  private:
    JNIEnv* env;
    jobject jsink;

    jmethodID set_count;
    jmethodID start_doc;

    // by Location
    jmethodID set_loc_int64;
    jmethodID set_loc_float;
    jmethodID set_loc_string;
    jmethodID set_loc_bytes;
    jmethodID set_loc_dateTime;

    // by child name
    jmethodID set_name_int64;
    jmethodID set_name_float;
    jmethodID set_name_string;
    jmethodID set_name_bytes;
    jmethodID set_name_dateTime;

    // by child num
    jmethodID set_num_int64;
    jmethodID set_num_float;
    jmethodID set_num_string;
    jmethodID set_num_bytes;
    jmethodID set_num_dateTime;

    jmethodID do_close;
  };
}

#endif