| 29 | | index_start = len(self.extra_select.keys()) |
|---|
| 30 | | values = [self.convert_values(v, None) for v in row[:index_start]] |
|---|
| | 29 | # If this query has limit/offset information, then we expect the |
|---|
| | 30 | # first column to be an extra "_RN" column that we need to throw |
|---|
| | 31 | # away. |
|---|
| | 32 | if self.high_mark is not None or self.low_mark: |
|---|
| | 33 | rn_offset = 1 |
|---|
| | 34 | else: |
|---|
| | 35 | rn_offset = 0 |
|---|
| | 36 | index_start = rn_offset + len(self.extra_select.keys()) |
|---|
| | 37 | values = [self.convert_values(v, None) |
|---|
| | 38 | for v in row[rn_offset:index_start]] |
|---|
| 100 | | # `get_columns` needs to be called before `get_ordering` to |
|---|
| 101 | | # populate `_select_alias`. |
|---|
| 102 | | self.pre_sql_setup() |
|---|
| 103 | | self.get_columns() |
|---|
| 104 | | ordering = self.get_ordering() |
|---|
| 105 | | |
|---|
| 106 | | # Oracle's ROW_NUMBER() function requires an ORDER BY clause. |
|---|
| 107 | | if ordering: |
|---|
| 108 | | rn_orderby = ', '.join(ordering) |
|---|
| 109 | | else: |
|---|
| 110 | | # Create a default ORDER BY since none was specified. |
|---|
| 111 | | qn = self.quote_name_unless_alias |
|---|
| 112 | | opts = self.model._meta |
|---|
| 113 | | rn_orderby = '%s.%s' % (qn(opts.db_table), |
|---|
| 114 | | qn(opts.fields[0].db_column or opts.fields[0].column)) |
|---|
| 115 | | |
|---|
| 116 | | # Ensure the base query SELECTs our special "_RN" column |
|---|
| 117 | | self.extra_select['_RN'] = ('ROW_NUMBER() OVER (ORDER BY %s)' |
|---|
| 118 | | % rn_orderby, '') |
|---|
| 131 | | def set_limits(self, low=None, high=None): |
|---|
| 132 | | super(OracleQuery, self).set_limits(low, high) |
|---|
| 133 | | # We need to select the row number for the LIMIT/OFFSET sql. |
|---|
| 134 | | # A placeholder is added to extra_select now, because as_sql is |
|---|
| 135 | | # too late to be modifying extra_select. However, the actual sql |
|---|
| 136 | | # depends on the ordering, so that is generated in as_sql. |
|---|
| 137 | | self.extra_select['_RN'] = ('1', '') |
|---|
| 138 | | |
|---|
| 139 | | def clear_limits(self): |
|---|
| 140 | | super(OracleQuery, self).clear_limits() |
|---|
| 141 | | if '_RN' in self.extra_select: |
|---|
| 142 | | del self.extra_select['_RN'] |
|---|
| 143 | | |
|---|