23 #include <drizzled/lock.h>
24 #include <drizzled/session.h>
25 #include <drizzled/probes.h>
26 #include <drizzled/statement/insert_select.h>
27 #include <drizzled/select_insert.h>
28 #include <drizzled/sql_lex.h>
29 #include <drizzled/open_tables_state.h>
36 TableList *all_tables= lex().query_tables;
37 assert(first_table == all_tables && first_table != 0);
38 Select_Lex *select_lex= &lex().select_lex;
46 select_lex->options|= SELECT_NO_UNLOCK;
48 lex().unit.set_limit(select_lex);
50 if (session().wait_if_global_read_lock(
false,
true))
56 if (! (res= session().openTablesLock(all_tables)))
58 DRIZZLE_INSERT_SELECT_START(session().getQueryString()->c_str());
61 select_lex->table_list.first= (
unsigned char*) second_table;
62 select_lex->context.table_list= select_lex->context.first_name_resolution_table= second_table;
63 res= insert_select_prepare(&session());
66 select_insert sel_result(first_table, first_table->
table, &lex().field_list, &lex().update_list, &lex().value_list, lex().duplicates, lex().ignore);
67 res=
handle_select(&session(), &lex(), &sel_result, OPTION_SETUP_TABLES_DONE);
75 if (first_table->lock_type == TL_WRITE_CONCURRENT_INSERT && session().open_tables.lock)
84 select_lex->table_list.first= (
unsigned char*) first_table;
91 session().startWaitingGlobalReadLock();