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
|
/**
* SPDX-License-Identifier: GPL-2.0-or-later
*
* This file is part of osm2pgsql (https://osm2pgsql.org/).
*
* Copyright (C) 2006-2021 by the osm2pgsql developer community.
* For a full list of authors see the git log.
*/
#include <catch.hpp>
#include "geometry-processor.hpp"
#include "middle-pgsql.hpp"
#include "osmdata.hpp"
#include "output-multi.hpp"
#include "taginfo-impl.hpp"
#include "common-import.hpp"
#include "common-options.hpp"
static testing::db::import_t db;
TEST_CASE("parse point")
{
options_t options = testing::opt_t().slim();
options.database_options = db.db().db_options();
export_list columns;
{
taginfo info;
info.name = "amenity";
info.type = "text";
columns.add(osmium::item_type::node, info);
}
auto mid_pgsql = std::make_shared<middle_pgsql_t>(&options);
mid_pgsql->start();
auto const midq = mid_pgsql->get_query_instance();
std::vector<std::shared_ptr<output_t>> outputs;
// let's make lots of tables!
for (int i = 0; i < 10; ++i) {
std::string const name{"foobar_{}"_format(i)};
auto processor = geometry_processor::create("point", &options);
auto out_test = std::make_shared<output_multi_t>(
name, processor, columns, midq, options,
std::make_shared<db_copy_thread_t>(
options.database_options.conninfo()));
outputs.push_back(out_test);
}
auto dependency_manager =
std::unique_ptr<dependency_manager_t>(new dependency_manager_t{});
testing::parse_file(options, std::move(dependency_manager), mid_pgsql,
outputs, "liechtenstein-2013-08-03.osm.pbf");
auto conn = db.db().connect();
for (int i = 0; i < 10; ++i) {
std::string const buf{"foobar_{}"_format(i)};
char const *name = buf.c_str();
conn.require_has_table(name);
REQUIRE(244 == conn.get_count(name));
REQUIRE(36 == conn.get_count(name, "amenity='parking'"));
REQUIRE(34 == conn.get_count(name, "amenity='bench'"));
REQUIRE(1 == conn.get_count(name, "amenity='vending_machine'"));
}
}
|
