Line 0
Link Here
|
0 |
- |
1 |
use Modern::Perl; |
|
|
2 |
|
3 |
use Koha::Patrons; |
4 |
use Koha::SearchEngine::Elasticsearch; |
5 |
|
6 |
use Koha::SearchEngine::Elasticsearch::Indexer; |
7 |
|
8 |
my $index_name = "patrons"; |
9 |
my $indexer = Koha::SearchEngine::Elasticsearch::Indexer->new( { index => $index_name } ); |
10 |
|
11 |
$indexer->drop_index; |
12 |
|
13 |
my $patrons = Koha::Patrons->search; |
14 |
|
15 |
my ( @id_buffer, @commit_buffer ); |
16 |
while ( my $patron = $patrons->next ) { |
17 |
my $id = $patron->borrowernumber; |
18 |
my $record = $patron->unblessed; |
19 |
$record->{_id} = $id; |
20 |
push @id_buffer, $id; |
21 |
push @commit_buffer, $record; |
22 |
} |
23 |
|
24 |
warn "committing"; |
25 |
|
26 |
if ( !$indexer->store ) { |
27 |
|
28 |
my $params = $indexer->get_elasticsearch_params(); |
29 |
my $mappings = { |
30 |
data => { |
31 |
properties => { |
32 |
borrowernumber => { |
33 |
type => 'string', |
34 |
search_analyzer => 'analyser_standard', |
35 |
index_analyzer => 'analyser_standard', |
36 |
}, |
37 |
cardnumber => { |
38 |
type => 'string', |
39 |
search_analyzer => 'analyser_standard', |
40 |
index_analyzer => 'analyser_standard', |
41 |
}, |
42 |
surname => { |
43 |
type => 'string', |
44 |
search_analyzer => 'analyser_standard', |
45 |
index_analyzer => 'analyser_standard', |
46 |
}, |
47 |
} |
48 |
} |
49 |
}; |
50 |
$indexer->store( |
51 |
Catmandu::Store::ElasticSearch->new( |
52 |
%$params, |
53 |
index_settings => $indexer->get_elasticsearch_settings(), |
54 |
index_mappings => $mappings, |
55 |
) |
56 |
); |
57 |
} |
58 |
|
59 |
$indexer->store->bag->add_many(\@commit_buffer); |
60 |
$indexer->store->bag->commit; |