This commit is contained in:
kssenii 2021-06-09 07:46:49 +00:00
parent 0521851afa
commit 8cbd9ec733
3 changed files with 10 additions and 6 deletions

6
.gitmodules vendored
View File

@ -210,9 +210,6 @@
[submodule "contrib/fast_float"]
path = contrib/fast_float
url = https://github.com/fastfloat/fast_float
[submodule "contrib/libpqxx"]
path = contrib/libpqxx
url = https://github.com/jtv/libpqxx
[submodule "contrib/libpq"]
path = contrib/libpq
url = https://github.com/ClickHouse-Extras/libpq
@ -231,3 +228,6 @@
[submodule "contrib/yaml-cpp"]
path = contrib/yaml-cpp
url = https://github.com/ClickHouse-Extras/yaml-cpp.git
[submodule "contrib/libpqxx"]
path = contrib/libpqxx
url = https://github.com/ClickHouse-Extras/libpqxx.git

2
contrib/libpqxx vendored

@ -1 +1 @@
Subproject commit 8fcd332202e806d3d82ca27c60c8f7ebb6282aed
Subproject commit 1e29e01d7943fa1481e3694050e03bdddfa38703

View File

@ -267,11 +267,15 @@ private:
struct StreamTo
{
pqxx::work tx;
Names columns;
pqxx::stream_to stream;
StreamTo(pqxx::connection & connection, pqxx::table_path table_path, Names columns)
StreamTo(pqxx::connection & connection, pqxx::table_path table_, Names columns_)
: tx(connection)
, stream(pqxx::stream_to::raw_table(tx, connection.quote_table(table_path), connection.quote_columns(columns))) {}
, columns(std::move(columns_))
, stream(pqxx::stream_to::raw_table(tx, connection.quote_table(table_), connection.quote_columns(columns)))
{
}
void complete()
{