← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/sql_derived.cc

Add Solaris atomics fixes and test files. Add replication.h header to makefile.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/sql_derived.cc
11
11
 
12
12
   You should have received a copy of the GNU General Public License
13
13
   along with this program; if not, write to the Free Software
14
 
   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
 
14
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
15
15
 
16
16
/*
17
17
  Derived tables
27
27
  Call given derived table processor (preparing or filling tables)
28
28
 
29
29
  SYNOPSIS
30
 
    handle_derived()
 
30
    mysql_handle_derived()
31
31
    lex                 LEX for this thread
32
32
    processor           procedure of derived table processing
33
33
 
35
35
    false  OK
36
36
    true   Error
37
37
*/
38
 
bool handle_derived(LEX *lex, bool (*processor)(Session*, LEX*, TableList*))
 
38
bool mysql_handle_derived(LEX *lex, bool (*processor)(Session*, LEX*, TableList*))
39
39
{
40
40
  bool res= false;
41
41
  if (lex->derived_tables)
54
54
          Force join->join_tmp creation, because we will use this JOIN
55
55
          twice for EXPLAIN and we have to have unchanged join for EXPLAINing
56
56
        */
57
 
        sl->uncacheable.set(UNCACHEABLE_EXPLAIN);
58
 
        sl->master_unit()->uncacheable.set(UNCACHEABLE_EXPLAIN);
 
57
        sl->uncacheable|= UNCACHEABLE_EXPLAIN;
 
58
        sl->master_unit()->uncacheable|= UNCACHEABLE_EXPLAIN;
59
59
      }
60
60
    }
61
61
  }
68
68
  Create temporary table structure (but do not fill it)
69
69
 
70
70
  SYNOPSIS
71
 
    derived_prepare()
 
71
    mysql_derived_prepare()
72
72
    session                     Thread handle
73
73
    lex                 LEX for this thread
74
74
    orig_table_list     TableList for the upper SELECT
88
88
    false  OK
89
89
    true   Error
90
90
*/
91
 
bool derived_prepare(Session *session, LEX *, TableList *orig_table_list)
 
91
bool mysql_derived_prepare(Session *session, LEX *, TableList *orig_table_list)
92
92
{
93
93
  Select_Lex_Unit *unit= orig_table_list->derived;
94
94
  uint64_t create_options;
137
137
    if (res)
138
138
    {
139
139
      if (table)
140
 
      {
141
 
        table= 0;
142
 
      }
 
140
        table->free_tmp_table(session);
143
141
      delete derived_result;
144
142
    }
145
143
    else
146
144
    {
 
145
      if (! session->fill_derived_tables())
 
146
      {
 
147
        delete derived_result;
 
148
        derived_result= NULL;
 
149
      }
147
150
      orig_table_list->derived_result= derived_result;
148
151
      orig_table_list->table= table;
149
 
      orig_table_list->setTableName(const_cast<char *>(table->getShare()->getTableName()));
150
 
      orig_table_list->table_name_length= table->getShare()->getTableNameSize();
 
152
      orig_table_list->table_name=        table->s->table_name.str;
 
153
      orig_table_list->table_name_length= table->s->table_name.length;
151
154
      table->derived_select_number= first_select->select_number;
152
 
      orig_table_list->setSchemaName((char *)"");
 
155
      table->s->tmp_table= message::Table::TEMPORARY;
 
156
      orig_table_list->db= (char *)"";
153
157
      orig_table_list->db_length= 0;
154
158
      /* Force read of table stats in the optimizer */
155
159
      table->cursor->info(HA_STATUS_VARIABLE);
156
160
      /* Add new temporary table to list of open derived tables */
157
 
      table->setNext(session->getDerivedTables());
158
 
      session->setDerivedTables(table);
 
161
      table->next= session->derived_tables;
 
162
      session->derived_tables= table;
159
163
    }
160
164
  }
161
165
 
166
170
  fill derived table
167
171
 
168
172
  SYNOPSIS
169
 
    derived_filling()
 
173
    mysql_derived_filling()
170
174
    session                     Thread handle
171
175
    lex                 LEX for this thread
172
176
    unit                node that contains all SELECT's for derived tables
184
188
    false  OK
185
189
    true   Error
186
190
*/
187
 
bool derived_filling(Session *session, LEX *lex, TableList *orig_table_list)
 
191
bool mysql_derived_filling(Session *session, LEX *lex, TableList *orig_table_list)
188
192
{
189
193
  Table *table= orig_table_list->table;
190
194
  Select_Lex_Unit *unit= orig_table_list->derived;
208
212
              first_select->options&= ~OPTION_FOUND_ROWS;
209
213
 
210
214
      lex->current_select= first_select;
211
 
      res= select_query(session, &first_select->ref_pointer_array,
 
215
      res= mysql_select(session, &first_select->ref_pointer_array,
212
216
                        (TableList*) first_select->table_list.first,
213
217
                        first_select->with_wild,
214
218
                        first_select->item_list, first_select->where,
215
219
                        (first_select->order_list.elements+
216
220
                        first_select->group_list.elements),
217
 
                        (Order *) first_select->order_list.first,
218
 
                        (Order *) first_select->group_list.first,
 
221
                        (order_st *) first_select->order_list.first,
 
222
                        (order_st *) first_select->group_list.first,
219
223
                        first_select->having,
220
224
                        (first_select->options | session->options | SELECT_NO_UNLOCK),
221
225
                        derived_result, unit, first_select);