-
Notifications
You must be signed in to change notification settings - Fork 4k
/
Copy pathfilesort.h
104 lines (85 loc) · 3.67 KB
/
filesort.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
/* Copyright (c) 2006, 2019, Oracle 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 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.
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 */
#ifndef FILESORT_INCLUDED
#define FILESORT_INCLUDED
#include <stddef.h>
#include <sys/types.h>
#include "my_base.h" /* ha_rows */
#include "my_dbug.h"
#include "my_inttypes.h"
#include "sql/sort_param.h"
class Addon_fields;
class Field;
class QEP_TAB;
class RowIterator;
class Sort_result;
class THD;
struct ORDER;
struct TABLE;
struct st_sort_field;
enum class Addon_fields_status;
/**
Sorting related info.
*/
class Filesort {
public:
THD *m_thd;
/// The QEP entry for the table to be sorted
QEP_TAB *const qep_tab;
/// Maximum number of rows to return
ha_rows limit;
/// ORDER BY list with some precalculated info for filesort
st_sort_field *sortorder;
/// true means we are using Priority Queue for order by with limit.
bool using_pq;
/// true means force stable sorting
bool m_force_stable_sort;
bool m_remove_duplicates;
// If true, we will always sort references to rows on table (and crucially,
// the result iterators used will always position the underlying table on
// the original row before returning from Read()).
bool m_force_sort_positions;
// TODO: Consider moving this into private members of Filesort.
Sort_param m_sort_param;
Filesort(THD *thd, QEP_TAB *tab_arg, ORDER *order, ha_rows limit_arg,
bool force_stable_sort, bool remove_duplicates,
bool force_sort_positions);
Addon_fields *get_addon_fields(ulong max_length_for_sort_data,
Field **ptabfield, uint sortlength,
Addon_fields_status *addon_fields_status,
uint *plength, uint *ppackable_length);
// Number of elements in the sortorder array.
uint sort_order_length() const { return m_sort_order_length; }
/// Whether we are using addon fields (sort entire rows) or not (sort row
/// IDs). Note that on the first call, this actually makes Sort_param
/// compute the decision and cache it, so it cannot be called before the sort
/// order is properly set up.
bool using_addon_fields();
private:
/* Prepare ORDER BY list for sorting. */
uint make_sortorder(ORDER *order);
uint m_sort_order_length;
};
bool filesort(THD *thd, Filesort *fsort, RowIterator *source_iterator,
Filesort_info *fs_info, Sort_result *sort_result,
ha_rows *found_rows);
void filesort_free_buffers(TABLE *table, bool full);
void change_double_for_sort(double nr, uchar *to);
/// Declared here so we can unit test it.
uint sortlength(THD *thd, st_sort_field *sortorder, uint s_length);
#endif /* FILESORT_INCLUDED */