Function create_embedded_thd

libmysqld/lib_sql.cc:705–736

@brief Initialize a new THD for a connection in the embedded server @param client_flag Client capabilities which this thread supports @return pointer to the created THD object @todo This function copies code from several places in the server, including create_new_thread(), and prepare_new_connection_state(). This should be refactored to avoid code duplication. */

  be refactored to avoid code duplication.
*/
void *create_embedded_thd(ulong client_flag)
{
  THD * thd= new THD(next_thread_id());

  thd->thread_stack= (char*) &thd;
  thd->store_globals();
  lex_start(thd);

  /* TODO - add init_connect command execution */

  if (thd->variables.max_join_size == HA_POS_ERROR)
    thd->variables.option_bits |= OPTION_BIG_SELECTS;
  thd->mark_connection_idle();
  thd->set_time();
  thd->init_for_queries();
  thd->client_capabilities= client_flag | MARIADB_CLIENT_EXTENDED_METADATA;
  thd->real_id= pthread_self();

  thd->db= null_clex_str;
#ifndef NO_EMBEDDED_ACCESS_CHECKS
  thd->security_ctx->db_access= DB_ACLS;
  thd->security_ctx->master_access= ALL_KNOWN_ACL;
#endif
  thd->cur_data= 0;
  thd->first_data= 0;
  thd->data_tail= &thd->first_data;
  bzero((char*) &thd->net, sizeof(thd->net));
  server_threads.insert(thd);
  thd->mysys_var= 0;
  thd->reset_globals();
  return thd;
}


THD *embedded_get_current_thd()