Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/db-copy.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ void db_copy_thread_t::thread_t::start_copy(
}

sql.push_back('\0');
m_db_connection.copy_start(sql.data());
m_db_connection.copy_start(to_string(sql));

m_inflight = target;
}
Expand Down
4 changes: 2 additions & 2 deletions src/gen/gen-base.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -99,14 +99,14 @@ pg_result_t gen_base_t::dbexec(params_t const &tmp_params,
return connection().exec(sql_template.render());
}

void gen_base_t::dbprepare(std::string_view stmt, std::string const &templ)
void gen_base_t::dbprepare(std::string const &stmt, std::string const &templ)
{
template_t sql_template{templ};
sql_template.set_params(get_params());
connection().prepare(stmt, fmt::runtime(sql_template.render()));
}

void gen_base_t::dbprepare(std::string_view stmt, params_t const &tmp_params,
void gen_base_t::dbprepare(std::string const &stmt, params_t const &tmp_params,
std::string const &templ)
{
template_t sql_template{templ};
Expand Down
4 changes: 2 additions & 2 deletions src/gen/gen-base.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -101,9 +101,9 @@ class gen_base_t

pg_result_t dbexec(params_t const &tmp_params, std::string const &templ);

void dbprepare(std::string_view stmt, std::string const &templ);
void dbprepare(std::string const &stmt, std::string const &templ);

void dbprepare(std::string_view stmt, params_t const &tmp_params,
void dbprepare(std::string const &stmt, params_t const &tmp_params,
std::string const &templ);

void raster_table_preprocess(std::string const &table);
Expand Down
2 changes: 1 addition & 1 deletion src/middle-pgsql.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ void middle_pgsql_t::dbexec(std::string_view templ) const
m_db_connection.exec(render_template(templ));
}

void middle_query_pgsql_t::prepare(std::string_view stmt,
void middle_query_pgsql_t::prepare(std::string const &stmt,
std::string const &sql_cmd) const
{
m_db_connection.prepare(stmt, fmt::runtime(sql_cmd));
Expand Down
2 changes: 1 addition & 1 deletion src/middle-pgsql.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ class middle_query_pgsql_t : public middle_query_t
bool relation_get(osmid_t id,
osmium::memory::Buffer *buffer) const override;

void prepare(std::string_view stmt, std::string const &sql_cmd) const;
void prepare(std::string const &stmt, std::string const &sql_cmd) const;

private:
osmium::Location get_node_location_flatnodes(osmid_t id) const;
Expand Down
10 changes: 5 additions & 5 deletions src/pgsql.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -136,12 +136,12 @@ pg_result_t pg_conn_t::exec(std::string const &sql) const
return exec(sql.c_str());
}

void pg_conn_t::copy_start(std::string_view sql) const
void pg_conn_t::copy_start(std::string const &sql) const
{
assert(m_conn);

log_sql("(C{}) {}", m_connection_id, sql);
pg_result_t const res{PQexec(m_conn.get(), sql.data())};
pg_result_t const res{PQexec(m_conn.get(), sql.c_str())};
if (res.status() != PGRES_COPY_IN) {
throw fmt_error("Database error on COPY: {}", error_msg());
}
Expand Down Expand Up @@ -194,15 +194,15 @@ void pg_conn_t::copy_end(std::string_view context) const
}
}

void pg_conn_t::prepare_internal(std::string_view stmt,
std::string_view sql) const
void pg_conn_t::prepare_internal(std::string const &stmt,
std::string const &sql) const
{
if (get_logger().log_sql()) {
log_sql("(C{}) PREPARE {} AS {}", m_connection_id, stmt, sql);
}

pg_result_t const res{
PQprepare(m_conn.get(), stmt.data(), sql.data(), 0, nullptr)};
PQprepare(m_conn.get(), stmt.c_str(), sql.c_str(), 0, nullptr)};
if (res.status() != PGRES_COMMAND_OK) {
throw fmt_error("Prepare failed for '{}': {}.", sql, error_msg());
}
Expand Down
7 changes: 4 additions & 3 deletions src/pgsql.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -195,7 +195,7 @@ class pg_conn_t
* status code PGRES_COMMAND_OK).
*/
template <typename... TArgs>
void prepare(std::string_view stmt, fmt::format_string<TArgs...> sql,
void prepare(std::string const &stmt, fmt::format_string<TArgs...> sql,
TArgs... params) const
{
std::string const query =
Expand Down Expand Up @@ -241,7 +241,7 @@ class pg_conn_t
*/
void set_config(char const *setting, char const *value) const;

void copy_start(std::string_view sql) const;
void copy_start(std::string const &sql) const;
void copy_send(std::string_view data, std::string_view context) const;
void copy_end(std::string_view context) const;

Expand All @@ -252,7 +252,8 @@ class pg_conn_t
void close();

private:
void prepare_internal(std::string_view stmt, std::string_view sql) const;
void prepare_internal(std::string const &stmt,
std::string const &sql) const;

pg_result_t exec_prepared_internal(char const *stmt, int num_params,
char const *const *param_values,
Expand Down