Function write_execute_load_query_log_event

sql/sql_load.cc:867–1004

#ifndef EMBEDDED_LIBRARY
static bool write_execute_load_query_log_event(THD *thd, const sql_exchange* ex,
                                               const char* db_arg,  /* table's database */
                                               const char* table_name_arg,
                                               bool is_concurrent,
                                               enum enum_duplicates duplicates,
                                               bool ignore,
                                               bool transactional_table,
                                               int errcode)
{
  char                *load_data_query;
  my_off_t             fname_start, fname_end;
  Item                *item, *val;
  int                  n;
  StringBuffer<1024>   query_str(system_charset_info);

  query_str.append(STRING_WITH_LEN("LOAD DATA "));

  if (is_concurrent)
    query_str.append(STRING_WITH_LEN("CONCURRENT "));

  fname_start= query_str.length();

  if (thd->lex->local_file)
    query_str.append(STRING_WITH_LEN("LOCAL "));
  query_str.append(STRING_WITH_LEN("INFILE '"));
  query_str.append_for_single_quote(ex->file_name, strlen(ex->file_name));
  query_str.append(STRING_WITH_LEN("' "));

  if (duplicates == DUP_REPLACE)
    query_str.append(STRING_WITH_LEN("REPLACE "));
  else if (ignore)
    query_str.append(STRING_WITH_LEN("IGNORE "));

  query_str.append(STRING_WITH_LEN("INTO"));

  fname_end= query_str.length();

  query_str.append(STRING_WITH_LEN(" TABLE "));
  if (!thd->db.str || strcmp(db_arg, thd->db.str))
  {
    /*
      If used database differs from table's database, 
      prefix table name with database name so that it 
      becomes a FQ name.
     */
    append_identifier(thd, &query_str, db_arg, strlen(db_arg));
    query_str.append(STRING_WITH_LEN("."));
  }
  append_identifier(thd, &query_str, table_name_arg, strlen(table_name_arg));

  if (ex->cs)
  {
    query_str.append(STRING_WITH_LEN(" CHARACTER SET "));
    query_str.append(ex->cs->cs_name);
  }

  /* We have to create all optional fields as the default is not empty */
  query_str.append(STRING_WITH_LEN(" FIELDS TERMINATED BY '"));