/* Copyright (c) 2018, 2021, Alibaba and/or its affiliates. All rights reserved.
   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License, version 2.0,
   as published by the Free Software Foundation.
   This program is also distributed with certain software (including
   but not limited to OpenSSL) that is licensed under separate terms,
   as designated in a particular file or component or in included license
   documentation.  The authors of MySQL/PolarDB-X Engine hereby grant you an
   additional permission to link the program and your derivative works with the
   separately licensed software that they have included with
   MySQL/PolarDB-X Engine.
   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License, version 2.0, for more details.
   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA */


#include "my_config.h"
#include "sql/derror.h"  // ER_THD

#include "sql/package/package.h"
#include "sql/package/package_common.h"
#include "sql/package/show_native_procedure.h"

#include "sql/protocol.h"

namespace im {

LEX_CSTRING ADMIN_PROC_SCHEMA = {C_STRING_WITH_LEN("dbms_admin")};

Proc *Show_native_procedure_proc::instance() {
  static Proc *proc = new Show_native_procedure_proc();
  return proc;
}

Sql_cmd *Show_native_procedure_proc::evoke_cmd(THD *thd,
                                               List<Item> *list) const {
  return new (thd->mem_root) Sql_cmd_type(thd, list, this);
}

bool Sql_cmd_show_native_procedure::pc_execute(THD *) {
  DBUG_ENTER("Sql_cmd_show_native_procedure::pc_execute");
  DBUG_RETURN(false);
}

const std::string sql_command_enum_to_string(enum_sql_command e) {
  switch (e) {
    case SQLCOM_ADMIN_PROC:
      return "ADMIN_PROC";
    case SQLCOM_TRANS_PROC:
      return "TRANS_PROC";
    default:
      /* Not allow other sql command other than ADMIN_PROC and TRANS_PROC. */
      DBUG_ASSERT(0);
      return "UNKNOWN";
  }
}

std::string field_type_enum_to_string(const enum_field_types e) {
  switch (e) {
    case MYSQL_TYPE_DECIMAL:
      return "DECIMAL";
    case MYSQL_TYPE_TINY:
      return "TINY";
    case MYSQL_TYPE_SHORT:
      return "SHORT";
    case MYSQL_TYPE_LONG:
      return "LONG";
    case MYSQL_TYPE_FLOAT:
      return "FLOAT";
    case MYSQL_TYPE_DOUBLE:
      return "DOUBLE";
    case MYSQL_TYPE_NULL:
      return "NULL";
    case MYSQL_TYPE_TIMESTAMP:
      return "TIMESTAMP";
    case MYSQL_TYPE_LONGLONG:
      return "LONGLONG";
    case MYSQL_TYPE_INT24:
      return "INT24";
    case MYSQL_TYPE_DATE:
      return "DATE";
    case MYSQL_TYPE_TIME:
      return "TIME";
    case MYSQL_TYPE_DATETIME:
      return "DATETIME";
    case MYSQL_TYPE_YEAR:
      return "YEAR";
    case MYSQL_TYPE_NEWDATE:
      return "NEWDATE";
    case MYSQL_TYPE_VARCHAR:
      return "VARCHAR";
    case MYSQL_TYPE_BIT:
      return "BIT";
    case MYSQL_TYPE_TIMESTAMP2:
      return "TIMESTAMP2";
    case MYSQL_TYPE_DATETIME2:
      return "DATETIME2";
    case MYSQL_TYPE_TIME2:
      return "TIME2";
    case MYSQL_TYPE_JSON:
      return "JSON";
    case MYSQL_TYPE_NEWDECIMAL:
      return "NEWDECIMAL";
    case MYSQL_TYPE_ENUM:
      return "ENUM";
    case MYSQL_TYPE_SET:
      return "SET";
    case MYSQL_TYPE_TINY_BLOB:
      return "TINY_BLOB";
    case MYSQL_TYPE_MEDIUM_BLOB:
      return "MEDIUM_BLOB";
    case MYSQL_TYPE_LONG_BLOB:
      return "LONG_BLOB";
    case MYSQL_TYPE_BLOB:
      return "BLOB";
    case MYSQL_TYPE_VAR_STRING:
      return "VAR_STRING";
    case MYSQL_TYPE_STRING:
      return "STRING";
    case MYSQL_TYPE_GEOMETRY:
      return "GEOMETRY";
    default:
      DBUG_ASSERT(0);
      return "UNKNOWN";
  }
}

void Sql_cmd_show_native_procedure::send_result(THD *thd, bool error) {
  DBUG_ENTER("Sql_cmd_show_native_procedure::send_result");
  Protocol *protocol = thd->get_protocol();

  if (error) {
    DBUG_ASSERT(thd->is_error());
    DBUG_VOID_RETURN;
  }

  if (m_proc->send_result_metadata(thd)) DBUG_VOID_RETURN;

  auto all_m_proc_map = Package::instance()->get_all_element<Proc>();

  std::string schema_name_str, element_name_str, sql_command_code_str,
      params_str;

  const Proc *procit;
  const Sql_cmd *sqlcmdit;

  using mproc_pairkey = Package_element_map<Proc>::key_type;
  std::set<mproc_pairkey> sorted_proc_schema_name;

  for (auto it = all_m_proc_map->cbegin(); it != all_m_proc_map->cend(); ++it) {
    sorted_proc_schema_name.insert(
        mproc_pairkey(it->first.first, it->first.second));
  }

  for (auto it = sorted_proc_schema_name.begin();
       it != sorted_proc_schema_name.end(); ++it) {
    schema_name_str = it->first;
    element_name_str = it->second;
    procit =
        all_m_proc_map->find(mproc_pairkey(schema_name_str, element_name_str))
            ->second;

    /**
      Evoke the sql_cmd object to get sql_command_code,
      notice that we use nullptr to mock List<Item> *list, so the evoked
      sql_cmd cann't be called here.
    */
    sqlcmdit = procit->evoke_cmd(thd, nullptr);
    const std::string sql_command_code_str =
        sql_command_enum_to_string(sqlcmdit->sql_command_code());

    params_str = "";
    Proc::Parameters_list parameters_list;
    if (procit->get_parameters_list().size() == 0) {
      parameters_list.push_back(procit->get_parameters());
    } else {
      parameters_list = procit->get_parameters_list();
    }

    int index = 0;
    for (auto parameters : parameters_list) {
      if (index) params_str += " / ";

      std::size_t param_size = parameters->size();
      if (param_size == 0)
        params_str += "NULL";
      else {
        params_str += field_type_enum_to_string(parameters->at(0));
        if (param_size > 1)
          for (std::size_t ii = 1; ii < param_size; ii++) {
            params_str += ", ";
            params_str += field_type_enum_to_string(parameters->at(ii));
          }
      }

      index++;
    }

    protocol->start_row();
    protocol->store_string(schema_name_str.c_str(), schema_name_str.length(),
                           system_charset_info);
    protocol->store_string(element_name_str.c_str(), element_name_str.length(),
                           system_charset_info);
    protocol->store_string(sql_command_code_str.c_str(),
                           sql_command_code_str.length(), system_charset_info);
    protocol->store_string(params_str.c_str(), params_str.length(),
                           system_charset_info);
    if (protocol->end_row()) DBUG_VOID_RETURN;
  }

  my_eof(thd);
  DBUG_VOID_RETURN;
}

} /* namespace im */