@@ -116,9 +116,10 @@ std::string build_sql(options_t const &options, std::string const &templ)
116
116
} // anonymous namespace
117
117
118
118
middle_pgsql_t ::table_desc::table_desc(options_t const &options,
119
- table_sql const &ts )
119
+ std::string_view name )
120
120
: m_copy_target(std::make_shared<db_target_descr_t >(
121
- options.middle_dbschema, build_sql(options, ts.name), " id" ))
121
+ options.middle_dbschema, fmt::format(" {}_{}" , options.prefix, name),
122
+ " id" ))
122
123
{
123
124
}
124
125
@@ -1201,42 +1202,6 @@ void middle_pgsql_t::wait()
1201
1202
1202
1203
namespace {
1203
1204
1204
- table_sql sql_for_users (middle_pgsql_options const &store_options)
1205
- {
1206
- table_sql sql{};
1207
-
1208
- sql.name = " {prefix}_users" ;
1209
-
1210
- return sql;
1211
- }
1212
-
1213
- table_sql sql_for_nodes (middle_pgsql_options const &options)
1214
- {
1215
- table_sql sql{};
1216
-
1217
- sql.name = " {prefix}_nodes" ;
1218
-
1219
- return sql;
1220
- }
1221
-
1222
- table_sql sql_for_ways ()
1223
- {
1224
- table_sql sql{};
1225
-
1226
- sql.name = " {prefix}_ways" ;
1227
-
1228
- return sql;
1229
- }
1230
-
1231
- table_sql sql_for_relations ()
1232
- {
1233
- table_sql sql{};
1234
-
1235
- sql.name = " {prefix}_rels" ;
1236
-
1237
- return sql;
1238
- }
1239
-
1240
1205
void init_params (params_t *params, options_t const &options)
1241
1206
{
1242
1207
std::string const schema = " \" " + options.middle_dbschema + " \" ." ;
@@ -1304,11 +1269,11 @@ middle_pgsql_t::middle_pgsql_t(std::shared_ptr<thread_pool_t> thread_pool,
1304
1269
1305
1270
init_params (&m_params, *options);
1306
1271
1307
- m_tables.nodes () = table_desc{*options, sql_for_nodes (m_store_options) };
1308
- m_tables.ways () = table_desc{*options, sql_for_ways () };
1309
- m_tables.relations () = table_desc{*options, sql_for_relations () };
1272
+ m_tables.nodes () = table_desc{*options, " nodes " };
1273
+ m_tables.ways () = table_desc{*options, " ways " };
1274
+ m_tables.relations () = table_desc{*options, " rels " };
1310
1275
1311
- m_users_table = table_desc{*options, sql_for_users (m_store_options) };
1276
+ m_users_table = table_desc{*options, " users " };
1312
1277
}
1313
1278
1314
1279
void middle_pgsql_t::set_requirements (
0 commit comments