51 lines
938 B
C++
51 lines
938 B
C++
#include <thread>
|
|
#include <string>
|
|
|
|
#include "pgxx/pgxx.hpp"
|
|
|
|
auto main(int argc, char* args[]) -> int
|
|
{
|
|
const std::string con = "";
|
|
|
|
try
|
|
{
|
|
PGXX().init("con_1", 300, con);
|
|
PGXX().init("con_2", 300, con);
|
|
}
|
|
catch(hack::exception& ex)
|
|
{
|
|
ex.log();
|
|
throw;
|
|
}
|
|
|
|
if (!PGXX().ready())
|
|
hack::log()("error connection");
|
|
|
|
// pgxx::JSON j {
|
|
// {
|
|
// "params", { { "key_1", 1 }, { "key2", "value" } }
|
|
// }
|
|
// };
|
|
//
|
|
// for (auto i = 0; i < 1'000; ++i)
|
|
// {
|
|
// std::thread th([&j](){
|
|
// auto query = PGXX().prepare("read_and_write", j);
|
|
// auto r = PGXX().execute("con_1", query);
|
|
// });
|
|
// th.detach();
|
|
// }
|
|
//
|
|
//
|
|
// for (auto i = 0; i < 1'000; ++i)
|
|
// {
|
|
// std::thread th([&j](){
|
|
// auto query = PGXX().prepare("read_and_write", j);
|
|
// auto r = PGXX().execute("con_2", query);
|
|
// });
|
|
// th.detach();
|
|
// }
|
|
|
|
hack::log()("ok");
|
|
}
|