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
|
local tables = {}
tables.t1 = osm2pgsql.define_way_table('osm2pgsql_test_t1', {
{ column = 'tags', type = 'hstore' },
{ column = 'geom', type = 'linestring', not_null = true },
})
tables.t2 = osm2pgsql.define_way_table('osm2pgsql_test_t2', {
{ column = 'tags', type = 'hstore' },
{ column = 'rel_ids', type = 'text' },
{ column = 'geom', type = 'linestring', not_null = true },
})
tables.tboth = osm2pgsql.define_way_table('osm2pgsql_test_tboth', {
{ column = 'tags', type = 'hstore' },
{ column = 'rel_ids', type = 'text' },
{ column = 'geom', type = 'linestring', not_null = true },
})
local w2r = {}
local function get_ids(data)
if data then
local ids = {}
for rel_id, _ in pairs(data) do
ids[#ids + 1] = rel_id
end
table.sort(ids)
return '{' .. table.concat(ids, ',') .. '}'
end
end
function osm2pgsql.process_way(object)
if object.tags.t1 then
tables.t1:insert{
tags = object.tags,
geom = object:as_linestring()
}
end
if osm2pgsql.stage == 2 and object.tags.t2 then
local ids = get_ids(w2r[object.id])
if ids then
tables.t2:insert{
rel_ids = ids,
geom = object:as_linestring()
}
end
end
if object.tags.tboth then
local ids = get_ids(w2r[object.id])
tables.tboth:insert{
tags = object.tags,
rel_ids = ids,
geom = object:as_linestring()
}
end
end
local function way_member_ids(relation)
local ids = {}
for _, member in ipairs(relation.members) do
if member.type == 'w' and member.role == 'mark' then
ids[#ids + 1] = member.ref
end
end
return ids
end
function osm2pgsql.select_relation_members(relation)
return { ways = way_member_ids(relation) }
end
function osm2pgsql.process_relation(object)
for _, member in ipairs(object.members) do
if member.type == 'w' and member.role == 'mark' then
if not w2r[member.ref] then
w2r[member.ref] = {}
end
w2r[member.ref][object.id] = true
end
end
end
|
