################################################################################
# Before running test, set up the test db & table with:
#     rake setup
# or create the database manually if your environment doesn't permit
################################################################################
require_relative "helper"
require "minitest/autorun"
require "minitest/pride"

class TestPostgresqlCursor < Minitest::Test
  def test_each
    c = PostgreSQLCursor::Cursor.new("select * from products order by 1")
    nn = 0
    n = c.each { nn += 1 }
    assert_equal nn, n
  end

  def test_each_batch
    c = PostgreSQLCursor::Cursor.new("select * from products order by 1")
    nn = 0
    n = c.each_batch { |b| nn += 1 }
    assert_equal nn, n
  end

  def test_enumerables
    assert_equal true, PostgreSQLCursor::Cursor.new("select * from products order by 1").any?
    assert_equal false, PostgreSQLCursor::Cursor.new("select * from products where id<0").any?
  end

  def test_each_while_until
    c = PostgreSQLCursor::Cursor.new("select * from products order by 1", until: true)
    n = c.each { |r| r["id"].to_i > 100 }
    assert_equal 101, n

    c = PostgreSQLCursor::Cursor.new("select * from products order by 1", while: true)
    n = c.each { |r| r["id"].to_i < 100 }
    assert_equal 100, n
  end

  def test_each_batch_while_until
    c = PostgreSQLCursor::Cursor.new("select * from products order by id asc", until: true, block_size: 50)
    n = c.each_batch { |b| b.last["id"].to_i > 100 }
    assert_equal 3, n

    c = PostgreSQLCursor::Cursor.new("select * from products order by id asc", while: true, block_size: 50)
    n = c.each_batch { |b| b.last["id"].to_i < 100 }
    assert_equal 2, n
  end

  def test_each_array
    c = PostgreSQLCursor::Cursor.new("select * from products where id = 1")
    c.each_array do |ary|
      assert_equal Array, ary.class
      assert_equal 1, ary[0].to_i
    end
  end

  def test_each_array_batch
    c = PostgreSQLCursor::Cursor.new("select * from products where id = 1")
    c.each_array_batch do |b|
      assert_equal 1, b.size
      ary = b.first
      assert_equal Array, ary.class
      assert_equal 1, ary[0].to_i
    end
  end

  def test_relation
    nn = 0
    Product.where("id>0").each_row { |r| nn += 1 }
    assert_equal 1000, nn
  end

  def test_relation_batch
    nn = 0
    row = nil
    Product.where("id>0").each_row_batch(block_size: 100) { |b|
      row = b.last
      nn += 1
    }
    assert_equal 10, nn
    assert_equal Hash, row.class

    nn = 0
    row = nil
    Product.where("id>0").each_instance_batch(block_size: 100) { |b|
      row = b.last
      nn += 1
    }
    assert_equal 10, nn
    assert_equal Product, row.class
  end

  def test_activerecord
    nn = 0
    row = nil
    Product.each_row_by_sql("select * from products") { |r|
      row = r
      nn += 1
    }
    assert_equal 1000, nn
    assert_equal Hash, row.class

    nn = 0
    Product.each_instance_by_sql("select * from products") { |r|
      row = r
      nn += 1
    }
    assert_equal 1000, nn
    assert_equal Product, row.class
  end

  def test_activerecord_batch
    nn = 0
    row = nil
    Product.each_row_batch_by_sql("select * from products", block_size: 100) { |b|
      row = b.last
      nn += 1
    }
    assert_equal 10, nn
    assert_equal Hash, row.class

    nn = 0
    Product.each_instance_batch_by_sql("select * from products", block_size: 100) { |b|
      row = b.last
      nn += 1
    }
    assert_equal 10, nn
    assert_equal Product, row.class
  end

  def test_exception
    Product.each_row_by_sql("select * from products") do |r|
      raise "Oops"
    end
  rescue => e
    assert_equal e.message, "Oops"
  end

  def test_batch_exception
    Product.each_row_batch_by_sql("select * from products") do |r|
      raise "Oops"
    end
  rescue => e
    assert_equal e.message, "Oops"
  end

  def test_exception_in_failed_transaction
    Product.each_row_by_sql("select * from products") do |r|
      Product.connection.execute("select kaboom")
    end
  rescue => e
    assert_match(/PG::InFailedSqlTransaction/, e.message)
  end

  def test_batch_exception_in_failed_transaction
    Product.each_row_batch_by_sql("select * from products") do |r|
      Product.connection.execute("select kaboom")
    end
  rescue => e
    assert_match(/PG::InFailedSqlTransaction/, e.message)
  end

  def test_cursor
    cursor = Product.all.each_row
    assert cursor.respond_to?(:each)
    r = cursor.map { |row| row["id"] }
    assert_equal 1000, r.size
    cursor = Product.each_row_by_sql("select * from products")
    assert cursor.respond_to?(:each)
    r = cursor.map { |row| row["id"] }
    assert_equal 1000, r.size
  end

  def test_batched_cursor
    cursor = Product.all.each_row_batch(block_size: 100)
    assert cursor.respond_to?(:each)
    b = cursor.map { |batch| batch.map { |r| r["id"] } }
    assert_equal 10, b.size
    cursor = Product.each_row_batch_by_sql("select * from products", block_size: 100)
    assert cursor.respond_to?(:each)
    b = cursor.map { |batch| batch.map { |r| r["id"] } }
    assert_equal 10, b.size
  end

  def test_pluck
    r = Product.pluck_rows(:id)
    assert_equal 1000, r.size
    r = Product.all.pluck_instances(:id)
    assert_equal 1000, r.size
    assert_equal Integer, r.first.class
  end

  def test_with_hold
    items = 0
    Product.where("id < 4").each_instance(with_hold: true, block_size: 1) do |row|
      Product.transaction do
        row.update(data: Time.now.to_f.to_s)
        items += 1
      end
    end
    assert_equal 3, items
  end

  def test_fetch_symbolize_keys
    Product.transaction do
      # cursor = PostgreSQLCursor::Cursor.new("select * from products order by 1")
      cursor = Product.all.each_row
      r = cursor.fetch
      assert r.has_key?("id")
      r = cursor.fetch(symbolize_keys: true)
      assert r.has_key?(:id)
      cursor.close
    end
  end

  def test_bad_sql
    ActiveRecord::Base.each_row_by_sql("select * from bad_table") {}
    raise "Did Not Raise Expected Exception"
  rescue => e
    assert_match(/bad_table/, e.message)
  end

  def test_relation_association_is_not_loaded
    cursor = Product.first.prices.each_instance
    refute cursor.instance_variable_get(:@type).loaded?
  end
end