61.2. Функции для индексных методов доступа
Индексный метод доступа должен определить в IndexAmRoutine
следующие функции построения и обслуживания индексов:
IndexBuildResult * ambuild (Relation heapRelation, Relation indexRelation, IndexInfo *indexInfo);
Строит новый индекс. Отношение индекса уже физически создано, но пока пусто. Оно должно быть наполнено фиксированными данными, которые требуются методу доступа, и записями для всех кортежей, уже существующих в таблице. Обычно функция ambuild
вызывает table_index_build_scan()
для поиска в таблице существующих кортежей и для вычисления ключей, которые должны вставляться в этот индекс. Эта функция должна возвращать структуру, выделенную вызовом palloc и содержащую статистику нового индекса.
void ambuildempty (Relation indexRelation);
Создаёт пустой индекс и записывает его в слой инициализации (INIT_FORKNUM
) данного отношения. Этот метод вызывается только для нежурналируемых индексов; пустой индекс, записанный в слой инициализации, будет копироваться в основной слой отношения при каждом перезапуске сервера.
bool aminsert (Relation indexRelation, Datum *values, bool *isnull, ItemPointer heap_tid, Relation heapRelation, IndexUniqueCheck checkUnique, IndexInfo *indexInfo);
Вставляет новый кортеж в существующий индекс. В массивах values
и isnull
передаются значения ключа, которые должны быть проиндексированы, а в heap_tid
— идентификатор индексируемого кортежа (TID). Если метод доступа поддерживает уникальные индексы (флаг amcanunique
установлен), параметр checkUnique
указывает, какая проверка уникальности должна выполняться. Это зависит от того, является ли ограничение уникальности откладываемым; за подробностями обратитесь к Разделу 61.5. Обычно параметр heapRelation
нужен методу доступа только для проверки уникальности (так как он должен обратиться к основным данным, чтобы убедиться в актуальности кортежа).
Возвращаемый функцией булев результат имеет значение, только когда параметр checkUnique
равен UNIQUE_CHECK_PARTIAL
. В этом случае результат true означает, что новая запись признана уникальной, тогда как false означает, что она может быть неуникальной (и требуется назначить отложенную проверку уникальности). В других случаях рекомендуется возвращать постоянный результат false.
Некоторые индексы могут индексировать не все кортежи. Если кортеж не будет индексирован, aminsert
должна просто завершиться, не делая ничего.
Если индексный МД хочет кешировать данные между операциями добавления в индекс в одном операторе SQL, он может выделить память в indexInfo->ii_Context
и сохранить указатель на эти данные в поле indexInfo->ii_AmCache
(которое изначально равно NULL).
IndexBulkDeleteResult * ambulkdelete (IndexVacuumInfo *info, IndexBulkDeleteResult *stats, IndexBulkDeleteCallback callback, void *callback_state);
Удаляет кортеж(и) из индекса. Это операция «массового удаления», которая предположительно будет реализована путём сканирования всего индекса и проверки для каждой записи, должна ли она удаляться. Переданная функция callback
должна вызываться в стиле callback(
с результатом bool, который говорит, должна ли удаляться запись индекса, на которую указывает передаваемый TID. Возвращать эта функция должна NULL или структуру, выделенную вызовом palloc и содержащую статистику результата удаления. NULL можно вернуть, если никакая информация не должна передаваться в TID
, callback_state)amvacuumcleanup
.
Из-за ограничения maintenance_work_mem
процедура ambulkdelete
может вызываться несколько раз, когда удалению подлежит большое количество кортежей. В аргументе stats
передаётся результат предыдущего вызова для данного индекса (при первом вызове в ходе операции VACUUM
он содержит NULL). Это позволяет методу доступа накапливать статистику в процессе всей операции. Обычно ambulkdelete
модифицирует и возвращает одну и ту же структуру, если в stats
передаётся не NULL.
IndexBulkDeleteResult * amvacuumcleanup (IndexVacuumInfo *info, IndexBulkDeleteResult *stats);
Провести уборку после операции VACUUM
(до этого ambulkdelete
могла вызываться несколько или ноль раз). От этой функции не требуется ничего, кроме как выдать статистику по индексу, но она может произвести массовую уборку, например, высвободить пустые страницы индекса. В stats
ей передаётся структура, возвращённая при последнем вызове ambulkdelete
, либо NULL, если ambulkdelete
не вызывалась, так как никакие кортежи удалять не требовалось. Эта функция должна возвращать NULL или структуру, выделенную вызовом palloc. Содержащаяся в этой структуре статистика будет отражена в записи в pg_class
и попадёт в вывод команды VACUUM
, если она выполнялась с указанием VERBOSE
. NULL может возвращаться, если индекс вовсе не изменился в процессе операции VACUUM
, но в противном случае должна возвращаться корректная статистика.
Начиная с PostgreSQL версии 8.4, amvacuumcleanup
также вызывается в конце операции ANALYZE
. В этом случае stats
всегда NULL и любое возвращаемое значение игнорируется. Этот вариант вызова можно распознать, проверив поле info->analyze_only
. При таком вызове методу доступа рекомендуется ничего не делать, кроме как провести уборку после добавления данных, и только в рабочем процессе автоочистки.
bool amcanreturn (Relation indexRelation, int attno);
Проверяет, поддерживается ли сканирование только индекса для заданного столбца, когда из индекса можно получить исходное значение столбца. Атрибуты нумеруются с 1, то есть для первого столбца attno равен 1. Возвращает true, если такое сканирование поддерживается, а иначе — false. Эта функция должна всегда возвращать true для неключевых столбцов (если таковые поддерживаются), так как неключевые столбцы, значения которые нельзя извлечь, не имеют смысла. Если индексный метод доступа в принципе не поддерживает сканирование только индекса, в поле amcanreturn
его структуры IndexAmRoutine
можно записать NULL.
void amcostestimate (PlannerInfo *root, IndexPath *path, double loop_count, Cost *indexStartupCost, Cost *indexTotalCost, Selectivity *indexSelectivity, double *indexCorrelation, double *indexPages);
Рассчитывает примерную стоимость сканирования индекса. Эта функция полностью описывается ниже в Разделе 61.6.
bytea * amoptions (ArrayType *reloptions, bool validate);
Разбирает и проверяет массив параметров для индекса. Эта функция вызывается, только когда для индекса задан отличный от NULL массив reloptions. Массив reloptions
состоит из элементов типа text
, содержащих записи вида имя
=
значение
. Данная функция должна получить значение типа bytea
, которое будет скопировано в поле rd_options
записи индекса в relcache. Содержимое этого значения bytea
определяется самим методом доступа; большинство стандартных методов доступа помещают в него структуру StdRdOptions
. Когда параметр validate
равен true, эта функция должна выдать подходящее сообщение об ошибке, если какие-либо параметры нераспознаны или имеют недопустимые значения; если же validate
равен false, некорректные записи должны просто игнорироваться. (В validate
передаётся false, когда параметры уже загружены в pg_catalog
; при этом неверная запись может быть обнаружена, только если в методе доступа поменялись правила обработки параметров, и в этом случае стоит просто игнорировать такие записи.) NULL можно вернуть, когда нужно получить поведение по умолчанию.
bool amproperty (Oid index_oid, int attno, IndexAMProperty prop, const char *propname, bool *res, bool *isnull);
Процедура amproperty
позволяет индексным методам доступа переопределять стандартное поведение функции pg_index_column_has_property
и связанных с ней. Если метод доступа не проявляет никаких особенностей при запросе свойств индексов, поле amproperty
в структуре IndexAmRoutine
может содержать NULL. В противном случае процедура amproperty
будет вызываться с нулевыми параметрами index_oid
и attno
при вызове pg_indexam_has_property
, либо с корректным index_oid
и нулевым attno
при вызове pg_index_has_property
, либо с корректным index_oid
и положительным attno
при вызове pg_index_column_has_property
. В prop
передаётся значение перечисления, указывающее на проверяемое значение, а в propname
— строка с именем свойства. Если код ядра не распознаёт имя свойства, в prop
передаётся AMPROP_UNKNOWN
. Методы доступа могут воспринимать нестандартные имена свойств, проверяя propname
на совпадение (для согласованности с кодом ядра используйте для проверки pg_strcasecmp
); для имён, известных коду ядра, лучше проверять prop
. Если процедура amproperty
возвращает true
, это значит, что она установила результат проверки свойства: она должна задать в *res
возвращаемое логическое значение или установить в *isnull
значение true
, чтобы возвратить NULL. (Перед вызовом обе упомянутые переменные инициализируются значением false
.) Если amproperty
возвращает false
, код ядра переключается на обычную логику определения результата проверки свойства.
Методы доступа, поддерживающие операторы упорядочивания, должны реализовывать проверку свойства AMPROP_DISTANCE_ORDERABLE
, так как код ядра не знает, как это сделать и возвращает NULL. Также может быть полезно реализовать проверку AMPROP_RETURNABLE
, если это можно сделать проще, чем обращаясь к индексу и вызывая amcanreturn
(что делает код ядра по умолчанию). Для всех остальных стандартных свойств поведение ядра по умолчанию можно считать удовлетворительным.
char * ambuildphasename (int64 phasenum);
Возвращает текстовое название переданной фазы построения индекса. Номера фаз передаются в процессе построения индекса функции pgstat_progress_update_param
. Названия фаз показываются в представлении pg_stat_progress_create_index
.
bool amvalidate (Oid opclassoid);
Проверяет записи в каталоге для заданного класса операторов, насколько это может сделать метод доступа. Например, это может включать проверку, все ли необходимые опорные функции реализованы. Функция amvalidate
должна вернуть false, если класс операторов непригоден к использованию. Сообщения о проблеме следует выдать через ereport
.
Цель индекса, конечно, в том, чтобы поддерживать поиск кортежей, соответствующих индексируемому условию WHERE
, по ограничению или ключу поиска. Сканирование индекса описывается более полно ниже, в Разделе 61.3. Индексный метод доступа может поддерживать «простое» сканирование, сканирование по «битовой карте» или и то, и другое. Метод доступа должен или может реализовывать следующие функции, связанные со сканированием:
IndexScanDesc ambeginscan (Relation indexRelation, int nkeys, int norderbys);
Подготавливает метод к сканированию индекса. В параметрах nkeys
и norderbys
задаётся количество операторов условия и сортировки, которые будут задействованы при сканировании; это может быть полезно для выделения памяти. Заметьте, что фактические значения ключей сканирования в этот момент ещё не предоставляются. В результате функция должна выдать структуру, выделенную средствами palloc. В связи с особенностями реализации, метод доступа должен создать эту структуру, вызвав RelationGetIndexScan()
. В большинстве случаев все действия ambeginscan
сводятся только к выполнению этого вызова и, возможно, получению блокировок; всё самое интересное при запуске сканирования индекса происходит в amrescan
.
void amrescan (IndexScanDesc scan, ScanKey keys, int nkeys, ScanKey orderbys, int norderbys);
Запускает или перезапускает сканирование индекса, возможно, с новыми ключами сканирования. (Для перезапуска сканирования с ранее переданными ключами в keys
и/или orderbys
передаётся NULL.) Заметьте, что количество ключей или операторов сортировки не может превышать значения, поступившие в ambeginscan
. На практике возможность перезапуска используется, когда в соединении со вложенным циклом выбирается новый внешний кортеж, так что требуется сравнение с новым ключом, но структура ключей сканирования не меняется.
bool amgettuple (IndexScanDesc scan, ScanDirection direction);
Выбирает следующий кортеж в ходе данного сканирования, с передвижением по индексу в заданном направлении (вперёд или назад). Возвращает true, если кортеж был получен, или false, если подходящих кортежей не осталось. В случае успеха в структуре scan
сохраняется TID кортежа. Заметьте, что под «успехом» здесь подразумевается только, что индекс содержит запись, соответствующую ключам сканирования, а не то, что данный кортеж обязательно существует в данных или оказывается видимым в снимке вызывающего субъекта. При положительном результате amgettuple
должна также установить для свойства scan->xs_recheck
значение true или false. Значение false будет означать, что запись индекса точно соответствует ключам сканирования, а true — что есть сомнение в этом, так что условия, представленные ключами сканирования, необходимо ещё раз перепроверить для фактического кортежа, когда он будет получен. Это свойство введено для поддержки «неточных» операторов индексов. Заметьте, что такая перепроверка касается только условий сканирования; предикат частичного индекса (если он имеется) никогда не перепроверяется кодом, вызывающим amgettuple
.
Если индекс поддерживает сканирование только индекса (то есть amcanreturn
выдаёт true для каких-либо его столбцов), то в случае успеха метод доступа должен также проверить флаг scan->xs_want_itup
и, если он установлен, должен вернуть исходные индексированные данные для этой записи индекса. В столбцах, для которых amcanreturn
выдаёт false, можно вернуть null. Данные могут возвращаться посредством указателя на IndexTuple
, сохранённого в scan->xs_itup
, с дескриптором scan->xs_itupdesc
; либо посредством указателя на HeapTuple
, сохранённого в scan->xs_hitup
, с дескриптором кортежа scan->xs_hitupdesc
. (Второй вариант должен использоваться при восстановлении данных, которые могут не уместиться в IndexTuple
.) В любом случае за управление целевой областью данных, определяемой этим указателем, отвечает метод доступа. Данные должны оставаться актуальными как минимум до следующего вызова amgettuple
, amrescan
или amendscan
в процессе сканирования.
Функция amgettuple
должна быть реализована, только если метод доступа поддерживает «простое» сканирование индекса. В противном случае поле amgettuple
в структуре IndexAmRoutine
должно содержать NULL.
int64 amgetbitmap (IndexScanDesc scan, TIDBitmap *tbm);
Выбирает все кортежи для данного сканирования и добавляет их в передаваемую вызывающим кодом структуру TIDBitmap
(то есть, получает логическое объединение множества TID выбранных кортежей с множеством, уже записанным в битовой карте). Возвращает эта функция число полученных кортежей (это может быть только приблизительная оценка; например, некоторые методы доступа не учитывают повторяющиеся значения). Добавляя идентификаторы кортежей в битовую карту, amgetbitmap
может обозначить, что для этих кортежей нужно перепроверить условия сканирования. Для этого так же, как и в amgettuple
, устанавливается выходной параметр xs_recheck
. Замечание: в текущей реализации эта возможность увязывается с возможностью неточного хранения самих битовых карт, таким образом вызывающий код перепроверяет для отмеченных кортежей и условия сканирования, и предикат частичного индекса (если он имеется). Однако так может быть не всегда. Функции amgetbitmap
и amgettuple
не могут использоваться в одном сканировании индекса; есть и другие ограничения в применении amgetbitmap
, описанные в Разделе 61.3.
Функция amgetbitmap
должна быть реализована, только если метод доступа поддерживает сканирование индекса «по битовой карте». В противном случае поле amgetbitmap
в структуре IndexAmRoutine
должно содержать NULL.
void amendscan (IndexScanDesc scan);
Завершает сканирование и освобождает ресурсы. Саму структуру scan
освобождать не следует, но любые блокировки или закрепления объектов, установленные внутри метода доступа, должны быть сняты.
void ammarkpos (IndexScanDesc scan);
Помечает текущую позицию сканирования. Метод доступа должен поддерживать сохранение только одной позиции в процессе сканирования.
Функция ammarkpos
должна быть реализована, только если метод доступа поддерживает сканирование по порядку. Если это не так, в поле ammarkpos
в структуре IndexAmRoutine
можно записать NULL.
void amrestrpos (IndexScanDesc scan);
Восстанавливает позицию сканирования, отмеченную последней.
Функция amrestrpos
должна быть реализована, только если метод доступа поддерживает сканирование по порядку. Если это не так, в поле amrestrpos
в структуре IndexAmRoutine
можно записать NULL.
Помимо обычного сканирования некоторые типы индексов могут поддерживать параллельное сканирование индекса, что позволяет осуществлять совместное сканирование индекса нескольким обслуживающим процессам. Для этого метод доступа должен организовать работу так, чтобы каждый из взаимодействующих процессов возвращал подмножество кортежей, которое бы возвращалось при обычном, не параллельном сканировании, и таким образом, чтобы объединение этих подмножеств совпадало с множеством кортежей, возвращаемых при обычном сканировании. Более того, чтобы не требовалась глобальная сортировка кортежей, возвращаемых при параллельном сканировании, порядок кортежей в подмножествах, выдаваемых всеми взаимодействующими процессами, должен соответствовать запрошенному. Для поддержки параллельного сканирования по индексу должны быть реализованы следующие функции:
Size amestimateparallelscan (void);
Рассчитывает и возвращает объём (в байтах) в динамической разделяемой памяти, который может потребоваться для осуществления параллельного сканирования. (Этот объём дополняет, а не заменяет объём памяти, затребованный для данных, независимо от МД, в ParallelIndexScanDescData
.)
Эту функцию можно не реализовывать для методов доступа, которые не поддерживают параллельное сканирование, или для которых объём дополнительно требующейся памяти равен нулю.
void aminitparallelscan (void *target);
Эта функция будет вызываться для инициализации области динамической разделяемой памяти в начале параллельного сканирования. Параметр target
будет указывать на область объёма, не меньшего, чем возвратила функция amestimateparallelscan
, и данная функция может хранить в этой области любые нужные ей данные.
Эту функцию можно не реализовывать для методов доступа, которые не поддерживают параллельное сканирование, или когда выделенная область в разделяемой памяти не требует инициализации.
void amparallelrescan (IndexScanDesc scan);
Эта функция, если её реализовать, будет вызываться перед перезапуском параллельного сканирования индекса. Она должна сбросить всё разделяемое состояние, установленное функцией aminitparallelscan
, с тем, чтобы такое сканирование перезапустилось с начала.