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
|
/* Implements the output-layer processing for osm2pgsql
* storing the data in several PostgreSQL tables
* with the final PostGIS geometries for each entity
*/
#ifndef OUTPUT_PGSQL_H
#define OUTPUT_PGSQL_H
#include "expire-tiles.hpp"
#include "id-tracker.hpp"
#include "osmium-builder.hpp"
#include "output.hpp"
#include "table.hpp"
#include "tagtransform.hpp"
#include <vector>
#include <memory>
class output_pgsql_t : public output_t {
public:
enum table_id {
t_point = 0, t_line, t_poly, t_roads, t_MAX
};
output_pgsql_t(const middle_query_t* mid_, const options_t &options_);
virtual ~output_pgsql_t();
output_pgsql_t(const output_pgsql_t& other);
std::shared_ptr<output_t> clone(const middle_query_t* cloned_middle) const override;
int start() override;
void stop(osmium::thread::Pool *pool) override;
void commit() override;
void enqueue_ways(pending_queue_t &job_queue, osmid_t id, size_t output_id, size_t& added) override;
int pending_way(osmid_t id, int exists) override;
void enqueue_relations(pending_queue_t &job_queue, osmid_t id, size_t output_id, size_t& added) override;
int pending_relation(osmid_t id, int exists) override;
int node_add(osmium::Node const &node) override;
int way_add(osmium::Way *way) override;
int relation_add(osmium::Relation const &rel) override;
int node_modify(osmium::Node const &node) override;
int way_modify(osmium::Way *way) override;
int relation_modify(osmium::Relation const &rel) override;
int node_delete(osmid_t id) override;
int way_delete(osmid_t id) override;
int relation_delete(osmid_t id) override;
size_t pending_count() const override;
void merge_pending_relations(output_t *other) override;
void merge_expire_trees(output_t *other) override;
protected:
void pgsql_out_way(osmium::Way const &way, taglist_t *tags, bool polygon,
bool roads);
int pgsql_process_relation(osmium::Relation const &rel, bool pending);
int pgsql_delete_way_from_output(osmid_t osm_id);
int pgsql_delete_relation_from_output(osmid_t osm_id);
std::unique_ptr<tagtransform_t> m_tagtransform;
//enable output of a generated way_area tag to either hstore or its own column
int m_enable_way_area;
std::vector<std::shared_ptr<table_t> > m_tables;
std::unique_ptr<export_list> m_export_list;
geom::osmium_builder_t m_builder;
expire_tiles expire;
id_tracker ways_pending_tracker, rels_pending_tracker;
std::shared_ptr<id_tracker> ways_done_tracker;
osmium::memory::Buffer buffer;
osmium::memory::Buffer rels_buffer;
};
#endif
|
