require 'oci8'
require File.dirname(__FILE__) + '/config'

conn = OCI8.new($dbuser, $dbpass, $dbname)
error_message = nil
begin
  conn.describe_type('rb_test_int_array')
  conn.describe_type('rb_test_flt_array')
  conn.describe_type('rb_test_num_array')
  conn.describe_type('rb_test_bdbl_array')
  conn.describe_type('rb_test_bflt_array')
  conn.describe_type('rb_test_str_array')
  conn.describe_type('rb_test_raw_array')
  conn.describe_type('rb_test_obj_elem_array')
  conn.describe_type('rb_test_obj_elem_ary_of_ary')
  conn.describe_type('rb_test_obj')
  conn.describe_table('rb_test_obj_tab1')
  conn.describe_table('rb_test_obj_tab2')

  class RbTestObj < OCI8::Object::Base
  end

  begin
    version = RbTestObj.test_object_version(conn)
    error_message = "Invalid test object version" if version != 3
  rescue NoMethodError
    raise unless $!.to_s.include?('test_object_version')
    error_message = "rb_test_obj.test_object_version is not declared."
  end
rescue OCIError
  raise if $!.code != 4043
  error_message = $!.to_s
ensure
  conn.logoff
end

raise <<EOS if error_message

#{error_message}
You need to execute SQL statements in #{File.dirname(__FILE__)}/setup_test_object.sql as follows:

  $ sqlplus USERNAME/PASSWORD
  SQL> @test/setup_test_object.sql

EOS


class RbTestIntArray < OCI8::Object::Base
end

class RbTestObjBase < OCI8::Object::Base
end

class RbTestObjSub < RbTestObjBase
end

class TestObj1 < Minitest::Test
  Delta = 0.00001

  def setup
    @conn = get_oci8_connection
    RbTestObj.default_connection = @conn
  end

  def teardown
    @conn.logoff
  end

  class ExpectedValObjElem
    def initialize(x, y)
      @attributes = {:x => x, :y => y}
    end
    def ==(val)
      @attributes[:x] == val.x and @attributes[:y] == val.y
    end
  end

  class ExpectedVal
    include Minitest::Assertions

    attr_reader :n
    attr_reader :int_val
    attr_reader :flt_val
    attr_reader :num_val
    attr_reader :bdbl_val
    attr_reader :bflt_val
    attr_reader :str_val
    attr_reader :raw_val
    attr_reader :clob_val
    attr_reader :nclob_val
    attr_reader :blob_val
    attr_reader :obj_val
    attr_reader :int_array_val
    attr_reader :flt_array_val
    attr_reader :num_array_val
    attr_reader :bdbl_array_val
    attr_reader :bflt_array_val
    attr_reader :str_array_val
    attr_reader :raw_array_val
    attr_reader :obj_array_val
    attr_reader :obj_ary_of_ary_val
    attr_reader :date_val
#    attr_reader :date_array_val

    attr_accessor :assertions

    def initialize
      @n = 0.0
      @assertions = 0
    end

    def to_test_date(n)
      year = (1990 + n).round
      month = (n.round * 5) % 12 + 1
      mday = (n.round * 7) % 27 + 1
      hour = (n.round * 9) % 24
      minute = (n.round * 11) % 60
      sec = (n.round * 13) % 60
      convert_to_time(year, month, mday, hour, minute, sec, 0, nil)
    end
    private :to_test_date

    def next
      @n += 1.2
      @n = (@n * 10).round / 10.0
      @int_val = @n.round
      @flt_val = @n
      @num_val = @n
      @bdbl_val = @n
      @bflt_val = @n
      @str_val = @n.to_s
      @str_val = $` if /.0$/ =~ @str_val
      @raw_val = @str_val
      @clob_val = @str_val
      @nclob_val = @str_val
      @blob_val = @str_val
      @obj_val = ExpectedValObjElem.new(@int_val, @int_val + 1)
      @date_val = to_test_date(@n)
      if @int_val == 1
        @int_array_val = nil
        @flt_array_val = nil
        @num_array_val = nil
        @bdbl_array_val = nil
        @bflt_array_val = nil
        @str_array_val = nil
        @raw_array_val = nil
        @obj_array_val = nil
        @obj_ary_of_ary_val = nil
#        @date_array_val = nil
      else
        @int_array_val = []
        @flt_array_val = []
        @num_array_val = []
        @bdbl_array_val = []
        @bflt_array_val = []
        @str_array_val = []
        @raw_array_val = []
        @obj_array_val = []
        @obj_ary_of_ary_val = []
#        @date_array_val = []
        0.upto(2) do |i|
          val = (@n + i).to_s
          val = $` if /.0$/ =~ val
          @int_array_val[i] = @int_val + i
          @flt_array_val[i] = @n + i
          @num_array_val[i] = @n + i
          @bdbl_array_val[i] = @n + i
          @bflt_array_val[i] = @n + i
          @str_array_val[i] = val
          @raw_array_val[i] = val
          @obj_array_val[i] = ExpectedValObjElem.new(@int_val + i, @int_val + i + 1)
#          @date_array_val[i] = to_test_date(@n + i)
        end
        @obj_ary_of_ary_val[0] = @obj_array_val
      end
      @n <= 20
    end

    def should_be_equal(val)
      if val.is_a? Array
        int_val = val[0]
        flt_val = val[1]
        num_val = val[2]
        bdbl_val = val[3]
        bflt_val = val[4]
        str_val = val[5]
        raw_val = val[6]
        clob_val = val[7] && val[7].read
        nclob_val = val[8] && val[8].read
        blob_val = val[9] && val[9].read
        obj_val = val[10]
        int_array_val = val[11]
        flt_array_val = val[12]
        num_array_val = val[13]
        bdbl_array_val = val[14]
        bflt_array_val = val[15]
        str_array_val = val[16]
        raw_array_val = val[17]
        obj_array_val = val[18]
        obj_ary_of_ary_val = val[19]
        date_val = val[20]
#        date_array_val = val[18]
      else
        assert_instance_of(RbTestObj, val)
        int_val = val.int_val
        flt_val = val.flt_val
        num_val = val.num_val
        bdbl_val = val.bdbl_val
        bflt_val = val.bflt_val
        str_val = val.str_val
        raw_val = val.raw_val
        clob_val = val.clob_val && val.clob_val.read
        nclob_val = val.nclob_val && val.nclob_val.read
        blob_val = val.blob_val && val.blob_val.read
        obj_val = val.obj_val
        int_array_val = val.int_array_val
        flt_array_val = val.flt_array_val
        num_array_val = val.num_array_val
        bdbl_array_val = val.bdbl_array_val
        bflt_array_val = val.bflt_array_val
        str_array_val = val.str_array_val
        raw_array_val = val.raw_array_val
        obj_array_val = val.obj_array_val
        obj_ary_of_ary_val = val.obj_ary_of_ary_val
        date_val = val.date_val
#        date_array_val = val.date_array_val
      end

      assert_equal(@int_val, int_val)
      assert_in_delta(@flt_val, flt_val, Delta)
      assert_in_delta(@num_val, num_val, Delta)
      assert_in_delta(@bdbl_val, bdbl_val, Delta)
      assert_in_delta(@bflt_val, bflt_val, Delta)
      assert_equal(@str_val, str_val)
      assert_equal(@raw_val, raw_val)
      assert_equal(@clob_val, clob_val)
      assert_equal(@nclob_val, nclob_val)
      assert_equal(@blob_val, blob_val)
      assert_equal(@obj_val, obj_val)
      if @int_array_val
        assert_equal(@int_array_val, int_array_val.to_ary)
      else
        assert_nil(@int_array_val, int_array_val)
      end
      assert_array_in_delta(@flt_array_val, flt_array_val && flt_array_val.to_ary)
      assert_array_in_delta(@num_array_val, num_array_val && num_array_val.to_ary)
      assert_array_in_delta(@bdbl_array_val, bdbl_array_val && bdbl_array_val.to_ary)
      assert_array_in_delta(@bflt_array_val, bflt_array_val && bflt_array_val.to_ary)
      if @str_array_val
        assert_equal(@str_array_val, str_array_val.to_ary)
      else
        assert_nil(str_array_val)
      end
      if @raw_array_val
        assert_equal(@raw_array_val, raw_array_val.to_ary)
      else
        assert_nil(raw_array_val)
      end
      if @obj_array_val
        assert_equal(@obj_array_val, obj_array_val.to_ary)
      else
        assert_nil(obj_array_val)
      end
      if @obj_ary_of_ary_val
        assert_equal(@obj_ary_of_ary_val, obj_ary_of_ary_val.to_ary.collect { |elem| elem.to_ary })
      else
        assert_nil(obj_ary_of_ary_val)
      end
      assert_equal(@date_val, date_val)
#      assert_equal(@date_array_val, date_array_val && date_array_val.to_ary)
    end

    def assert_array_in_delta(exp, val)
      if exp && val
        assert_equal(exp.size, val.size)
        exp.each_with_index do |elem, idx|
          assert_in_delta(elem, val[idx], Delta)
        end
      elsif exp.nil?
        assert_nil(val)
      else
        assert_equal(exp, val)
      end
    end
  end

  def test_select1
    expected_val = ExpectedVal.new
    @conn.exec("select * from rb_test_obj_tab1 order by n") do |row|
      assert(expected_val.next)

      assert_in_delta(expected_val.n, row[0], Delta)
      expected_val.should_be_equal(row[1])
    end
    assert(!expected_val.next)
  end

  def test_select2
    expected_val = ExpectedVal.new
    orig_val = OCI8::BindType::Mapping[:date]
    begin
      @conn.exec("select * from rb_test_obj_tab2 order by int_val") do |row|
        assert(expected_val.next)
        expected_val.should_be_equal(row)
      end
      assert(!expected_val.next)
    ensure
      OCI8::BindType::Mapping[:date] = orig_val
    end
  end

  def test_select3
    expected_val = ExpectedVal.new
    @conn.exec("select value(p) from rb_test_obj_tab2 p order by int_val") do |row|
      assert(expected_val.next)
      expected_val.should_be_equal(row[0])
    end
    assert(!expected_val.next)
  end

  def _test_select4 # TODO
    expected_val = ExpectedVal.new
    @conn.exec("select ref(p) from rb_test_obj_tab2 p order by int_val") do |row|
      assert(expected_val.next)

      expected_val.should_be_equal(row[0])
    end
    assert(!expected_val.next)
  end

  def test_explicit_constructor
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.new(expected_val.n)
      expected_val.should_be_equal(obj)
      obj.inspect
    end
  end

  def _test_implicit_constructor # TODO
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.new(expected_val.int_val, expected_val.flt_val, expected_val.str_val, expected_val.raw_val, expected_val.str_array_val, expected_val.raw_array_val, expected_val.num_array_val)
      expected_val.should_be_equal(obj)
    end
  end

  def _test_implicit_constructor2 # TODO
    obj = RbTestObj.new(nil, nil, nil)
    assert_nil(obj.int_val)
    assert_nil(obj.flt_val)
    assert_nil(obj.str_val)
  end

  def _test_class_func
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.class_func(expected_val.n)
      expected_val.should_be_equal(obj)
    end
  end

  def test_class_proc1
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.new(0)
      RbTestObj.class_proc1(obj, expected_val.n)
      expected_val.should_be_equal(obj)
    end
  end

  def _test_class_proc2
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.new
      obj.int_val = expected_val.int_val - 1
      obj.flt_val = expected_val.flt_val
      obj.num_val = expected_val.num_val
      obj.bdbl_val = expected_val.bdbl_val
      obj.bflt_val = expected_val.bflt_val
      obj.str_val = expected_val.str_val
      obj.raw_val = expected_val.raw_val
      obj.clob_val = expected_val.clob_val
      obj.nclob_val = expected_val.nclob_val
      obj.blob_val = expected_val.blob_val
      obj.obj_val = expected_val.obj_val
      obj.int_array_val = expected_val.int_array_val
      obj.flt_array_val = expected_val.flt_array_val
      obj.num_array_val = expected_val.num_array_val
      obj.bdbl_array_val = expected_val.bdbl_array_val
      obj.bflt_array_val = expected_val.bflt_array_val
      obj.str_array_val = expected_val.str_array_val
      obj.raw_array_val = expected_val.raw_array_val
      obj.obj_array_val = expected_val.obj_array_val
      obj.obj_ary_of_ary_val = expected_val.obj_ary_of_ary_val
      RbTestObj.class_proc2(obj)
      expected_val.should_be_equal(obj)
    end
  end

  def test_member_func
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.new(expected_val.n)
      assert_equal(expected_val.int_val, obj.member_func)
    end
  end

  def _test_plsql_member_func
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.new(expected_val.n)
      rv = @conn.exec(<<EOS, obj, [nil, Integer])
declare
  obj rb_test_obj := :obj;
begin
  :rv := obj.member_func;
end;
EOS
      assert_equal(expected_val.int_val, rv[1])
    end
  end

  def test_member_proc
    expected_val = ExpectedVal.new
    while expected_val.next
      obj = RbTestObj.new
      obj.member_proc(expected_val.int_val)
      assert_equal(expected_val.int_val, obj.int_val)
    end
  end

  def test_bind_nil
    csr = @conn.parse(<<EOS)
DECLARE
  obj RB_TEST_OBJ := :in;
BEGIN
  IF obj IS NULL THEN
    :out := 'IS NULL';
  ELSE
    :out := 'IS NOT NULL';
  END IF;
END;
EOS
    csr.bind_param(:in, nil, RbTestObj)
    csr.bind_param(:out, nil, String, 11)
    csr.exec
    assert_equal('IS NULL', csr[:out])
    csr[:in] = RbTestObj.new(@conn)
    csr.exec
    assert_equal('IS NOT NULL', csr[:out])
    csr[:in] = nil
    csr.exec
    assert_equal('IS NULL', csr[:out])
  end

  def test_bind_array
    csr = @conn.parse <<EOS
DECLARE
  ary RB_TEST_INT_ARRAY := :in;
BEGIN
  IF ary IS NULL THEN
    :cnt := -1;
  ELSE
    :cnt := ary.count;
    IF :cnt != 0 THEN
      :out1 := ary(1);
      :out2 := ary(2);
      :out3 := ary(3);
    END IF;
  END IF;
END;
EOS
    [nil, [], [1, nil, 3]].each do |ary|
      csr.bind_param(:in, ary, :named_type, 'rb_test_int_array')
      csr.bind_param(:cnt, nil, Integer)
      csr.bind_param(:out1, nil, Integer)
      csr.bind_param(:out2, nil, Integer)
      csr.bind_param(:out3, nil, Integer)
      csr.exec
      if ary
        assert_equal(ary.length, csr[:cnt])
      else
        assert_equal(-1, csr[:cnt])
      end
      if ary && ary[0]
        assert_equal(ary[0], csr[:out1])
      else
        assert_nil(csr[:out1])
      end
      if ary && ary[1]
        assert_equal(ary[1], csr[:out2])
      else
        assert_nil(csr[:out2])
      end
      if ary && ary[2]
        assert_equal(ary[2], csr[:out3])
      else
        assert_nil(csr[:out3])
      end
    end
  end

  def test_get_subtype
    csr = @conn.parse("BEGIN :result := rb_test_obj_get_object(:1); END;")
    csr.bind_param(1, nil, RbTestObjBase)
    csr.bind_param(2, nil, Integer)

    csr[2] = 0
    csr.exec
    val = csr[1]
    assert_instance_of(RbTestObjBase, val)
    assert_equal(val.id, 'base')

    csr[2] = 1
    csr.exec
    val = csr[1]
    assert_instance_of(RbTestObjSub, val)
    assert_equal(val.id, 'sub')
    assert_equal(val.subid, 'subid')
  end
end