blob: 83bfcd5e74b918cdf6efb36b02dae160991562ee (
plain)
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
|
#include "pq-prepared.h"
#include "command.h"
#include "pq-command.h"
#include "pq-connection.h"
#include <iosfwd>
#include <libpq-fe.h>
#include <map>
#include <utility>
#include <vector>
PQ::PreparedStatement::PreparedStatement(Connection * c, const std::string & sql, const DB::CommandOptionsCPtr & opts) :
DB::Command(sql), Command(c, sql, opts), pstmt(nullptr)
{
}
const char *
PQ::PreparedStatement::prepare() const
{
if (pstmt) {
return pstmt;
}
auto i = c->preparedStatements.find(hash);
if (i != c->preparedStatements.end()) {
return (pstmt = i->second.c_str());
}
std::stringstream psql;
prepareSql(psql, sql);
c->checkResultFree(PQprepare(c->conn, stmntName.c_str(), std::move(psql).str().c_str(),
static_cast<int>(values.size()), nullptr),
PGRES_COMMAND_OK);
return (pstmt = c->preparedStatements.insert({hash, stmntName}).first->second.c_str());
}
|
