require 'spec_helper'
require 'flydata-core/mysql/compatibility_checker'

module FlydataCore
  module Mysql
    describe CompatibilityChecker do
      let(:database) { 'test_db' }
      let(:tables) { %w(table_1 table_2 table_3) }
      let(:option) do
        { database: database, tables: tables }
      end

      describe PrimaryKeyChecker do
        let(:subject_object) { described_class.new(option) }

        describe '#create_query' do
          subject { subject_object.create_query }
          it { is_expected.to eq <<EOT
SELECT k.table_name as table_name
FROM information_schema.table_constraints t
JOIN information_schema.key_column_usage k
USING(constraint_name,table_schema,table_name)
WHERE t.constraint_type='PRIMARY KEY'
  AND t.table_schema='test_db'
  AND t.table_name in ('table_1','table_2','table_3')
GROUP BY k.table_name;
EOT
          }
        end

        describe '#check_reesult' do
          let(:result) { [] }
          subject { subject_object.check_result(result) }

          context 'when all tables have pk' do
            let(:result) do
              [ {"table_name" => "table_1"},
                {"table_name" => "table_2"},
                {"table_name" => "table_3"}, ]
            end
            it { expect{subject}.not_to raise_error }
          end

          context 'when some tables does not have pk' do
            let(:result) { [{"table_name" => "table_2"} ] }
            it do
              expect{subject}.to raise_error {|e|
                expect(e).to be_kind_of(FlydataCore::MysqlCompatibilityError)
                expect(e.to_s.include?("table_1")).to be_truthy
                expect(e.to_s.include?("table_2")).to be_falsey
                expect(e.to_s.include?("table_3")).to be_truthy
              }
            end
          end
        end
      end
    end

    describe BinlogParameterChecker do
      let(:subject_object) { BinlogParameterChecker.new({}) }

      describe "#check_result" do
        let(:sys_var) do
          [
            {'Variable_name'=>'binlog_format','Value'=>'ROW'},
            {'Variable_name'=>'binlog_checksum','Value'=>'NONE'},
            {'Variable_name'=>'log_bin_use_v1_row_events','Value'=>'ON'},
            {'Variable_name'=>'log_slave_updates','Value'=>'ON'},
            {'Variable_name'=>'net_read_timeout','Value'=>600},
            {'Variable_name'=>'net_write_timeout','Value'=>600},
            {'Variable_name'=>'wait_timeout','Value'=>60}
          ]
        end
        subject { subject_object.check_result(sys_var, {}) }

        context "where parameters are valid" do
          it do
            expect{subject}.to_not raise_error
          end
        end
        context "where parameters are invalid" do
          let(:sys_var) do
            [
              {'Variable_name'=>'binlog_format','Value'=>'MIXED'},
              {'Variable_name'=>'binlog_checksum','Value'=>'NONE'},
              {'Variable_name'=>'log_bin_use_v1_row_events','Value'=>'ON'},
              {'Variable_name'=>'log_slave_updates','Value'=>'ON'},
              {'Variable_name'=>'net_read_timeout','Value'=>600},
              {'Variable_name'=>'net_write_timeout','Value'=>600},
              {'Variable_name'=>'wait_timeout','Value'=>30}
            ]
          end
          it do
            expect{subject}.to raise_error(FlydataCore::MysqlCompatibilityError, /binlog_format.*\n.*wait_timeout/)
          end
        end
      end
      describe "#compare_sys_var_values" do
        let(:expected_val) do
          {
            :value_1 => 'foo',
            :value_2 => 50,
            :value_3 => {">"=>100}
          }
        end
        let(:errors) { {} }
        let(:exception_arr) { [] }
        subject { subject_object.send(:compare_sys_var_values, input_val, expected_val, errors, exception_arr) }

        shared_examples "expect correct errors from values" do
          it do
            subject
            expect(errors).to eq( expecting_errors )
          end
        end

        context "when getting valid parameters" do
          let(:input_val) do
            {
              :value_1 => 'foo',
              :value_2 => 50,
              :value_3 => 200
            }
          end
          let(:expecting_errors) { {} }
          it_behaves_like "expect correct errors from values"
        end
        context "when getting one invalid exact parameters for int" do
          let(:input_val) do
            {
              :value_1 => 'foo',
              :value_2 => 20,
              :value_3 => 100
            }
          end
          let(:expecting_errors) { {value_2:20} }
          it_behaves_like "expect correct errors from values"
        end
        context "when getting one invalid exact parameter for string" do
          let(:input_val) do
            {
              :value_1 => 'fo',
              :value_2 => 50,
              :value_3 => 100
            }
          end
          let(:expecting_errors) { {value_1:'fo'} }
          it_behaves_like "expect correct errors from values"
        end
        context "when getting one invalid comparitive parameter that's lower than required" do
          let(:input_val) do
            {
              :value_1 => 'foo',
              :value_2 => 50,
              :value_3 => 1
            }
          end
          let(:expecting_errors) { {value_3:1} }
          it_behaves_like "expect correct errors from values"
        end
        context "when getting a valid comparitive parameter that's higher than required" do
          let(:input_val) do
            {
              :value_1 => 'foo',
              :value_2 => 50,
              :value_3 => 101
            }
          end
          let(:expecting_errors) { {} }
          it_behaves_like "expect correct errors from values"
        end
        context "when getting muliple invalid parameters" do
          let(:input_val) do
            {
              :value_1 => 'fo',
              :value_2 => 50,
              :value_3 => 15
            }
          end
          let(:expecting_errors) { {value_1:'fo', value_3:15} }
          it_behaves_like "expect correct errors from values"
        end
      end
    end
  end
end