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 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159
|
/*
Copyright (C) 2017-2018 Brazil
Copyright (C) 2019-2024 Sutou Kouhei <kou@clear-code.com>
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.
This library 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
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/
#pragma once
#include "grn_db.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
grn_obj source_buffer;
grn_obj *source;
grn_column_cache *cache;
size_t n_required_args;
} grn_expr_executor_scorer_data;
typedef struct _grn_expr_executor grn_expr_executor;
typedef double (*grn_expr_executor_scorer_func)(
grn_ctx *ctx,
grn_expr_executor *executor,
grn_id id,
grn_obj *args,
grn_expr_executor_scorer_data *data);
typedef struct {
uint32_t codes_start_offset;
uint32_t codes_end_offset;
grn_proc_ctx proc_ctx;
grn_obj **args;
int n_args;
grn_obj *buffers;
int n_buffers;
} grn_expr_executor_data_simple_proc;
typedef union {
struct {
grn_obj *value;
} constant;
struct {
grn_obj *column;
grn_obj value_buffer;
} value;
struct {
grn_obj result_buffer;
void *regex;
grn_obj value_buffer;
grn_obj *normalizer;
} simple_regexp;
struct {
grn_obj result_buffer;
grn_obj *normalizer;
void *regex;
grn_obj *normalized_sub_text;
const char *normalized_sub_text_raw;
unsigned int normalized_sub_text_raw_length_in_bytes;
grn_obj value_buffer;
} simple_match;
struct {
grn_expr_executor_data_simple_proc data;
} simple_proc;
struct {
grn_obj result_buffer;
} simple_condition_constant;
struct {
grn_obj result_buffer;
grn_ra *ra;
grn_ra_cache ra_cache;
unsigned int ra_element_size;
grn_obj value_buffer;
grn_obj constant_buffer;
grn_operator_exec_func *exec;
} simple_condition_ra;
struct {
bool need_exec;
grn_obj result_buffer;
grn_obj value_buffer;
grn_obj constant_buffer;
grn_operator_exec_func *exec;
} simple_condition;
struct {
grn_obj *score_column;
grn_expr_executor_data_simple_proc data;
} simple_proc_scorer;
struct {
grn_obj *score_column;
grn_obj args;
grn_obj score_buffer;
grn_expr_executor_scorer_func *funcs;
grn_expr_executor_scorer_data *datas;
size_t n_funcs;
size_t n_allocated_funcs;
} scorer;
} grn_expr_executor_data;
typedef grn_obj *(*grn_expr_executor_exec_func)(grn_ctx *ctx,
grn_expr_executor *executor,
grn_id id);
typedef void (*grn_expr_executor_fin_func)(grn_ctx *ctx,
grn_expr_executor *executor);
struct _grn_expr_executor {
grn_obj *expr;
grn_obj *variable;
grn_obj replace_ids;
grn_obj replace_values;
grn_expr_executor_exec_func exec;
grn_expr_executor_fin_func fin;
grn_expr_executor_data data;
};
grn_rc
grn_expr_executor_init(grn_ctx *ctx,
grn_expr_executor *executor,
grn_obj *expr);
grn_rc
grn_expr_executor_fin(grn_ctx *ctx, grn_expr_executor *executor);
grn_expr_executor *
grn_expr_executor_open(grn_ctx *ctx, grn_obj *expr);
grn_rc
grn_expr_executor_close(grn_ctx *ctx, grn_expr_executor *executor);
/* Replace `GRN_OP_GET_VALUE` of `id` object's value with `value`. */
grn_rc
grn_expr_executor_add_replace_value(grn_ctx *ctx,
grn_expr_executor *executor,
grn_id id,
grn_obj *value);
grn_obj *
grn_expr_executor_exec(grn_ctx *ctx, grn_expr_executor *executor, grn_id id);
grn_rc
grn_expr_executor_exec_batch(grn_ctx *ctx,
grn_expr_executor *executor,
grn_table_cursor *cursor);
#ifdef __cplusplus
}
#endif
|