17918087582

Committed 22 Sep 2025 02:12PM UTC coverage: 63.132% (+0.6%) from 62.535%

Build # 17918087582

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #16157 from miodvallat/backport-16112-to-auth-4.9.x

auth 4.9.x: backport "Fix EDNS Cookie & Proxy protocol "

Run Details

12965 of 27306 branches covered (47.48%)

Branch coverage included in aggregate %.

0 of 1 new or added line in 1 file covered. (0.0%)

10 existing lines in 3 files now uncovered.

41856 of 59530 relevant lines covered (70.31%)

5665405.83 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

67.7

/modules/gpgsqlbackend/spgsql.cc

/*
 * This file is part of PowerDNS or dnsdist.
 * Copyright -- PowerDNS.COM B.V. and its contributors
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of version 2 of the GNU General Public License as
 * published by the Free Software Foundation.
 *
 * In addition, for the avoidance of any doubt, permission is granted to
 * link this program with OpenSSL and to (re)distribute the binaries
 * produced as the result of such linking.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include <string>
#include "spgsql.hh"
#include <sys/time.h>
#include <iostream>
#include "pdns/logger.hh"
#include "pdns/dns.hh"
#include "pdns/namespaces.hh"
#include <algorithm>

class SPgSQLStatement : public SSqlStatement
{
public:
  SPgSQLStatement(const string& query, bool dolog, int nparams, SPgSQL* db, unsigned int nstatement)
  {
    d_query = query;
    d_dolog = dolog;
    d_parent = db;
    d_nparams = nparams;
    d_nstatement = nstatement;
  }

  SSqlStatement* bind(const string& name, bool value) override { return bind(name, string(value ? "t" : "f")); }
  SSqlStatement* bind(const string& name, int value) override { return bind(name, std::to_string(value)); }
  SSqlStatement* bind(const string& name, uint32_t value) override { return bind(name, std::to_string(value)); }
  SSqlStatement* bind(const string& name, long value) override { return bind(name, std::to_string(value)); }
  SSqlStatement* bind(const string& name, unsigned long value) override { return bind(name, std::to_string(value)); }
  SSqlStatement* bind(const string& name, long long value) override { return bind(name, std::to_string(value)); }
  SSqlStatement* bind(const string& name, unsigned long long value) override { return bind(name, std::to_string(value)); }
  SSqlStatement* bind(const string& /* name */, const std::string& value) override
  {
    prepareStatement();
    allocate();
    if (d_paridx >= d_nparams) {
      releaseStatement();
      throw SSqlException("Attempt to bind more parameters than query has: " + d_query);
    }
    paramValues[d_paridx] = new char[value.size() + 1];
    memset(paramValues[d_paridx], 0, sizeof(char) * (value.size() + 1));
    value.copy(paramValues[d_paridx], value.size());
    paramLengths[d_paridx] = value.size();
    d_paridx++;
    return this;
  }
  SSqlStatement* bindNull(const string& /* name */) override
  {
    prepareStatement();
    d_paridx++;
    return this;
  } // these are set null in allocate()
  SSqlStatement* execute() override
  {
    prepareStatement();
    if (d_dolog) {
      g_log << Logger::Warning << "Query " << ((long)(void*)this) << ": Statement: " << d_query << endl;
      if (d_paridx) {
        // Log message is similar, but not exactly the same as the postgres server log.
        std::stringstream log_message;
        log_message << "Query " << ((long)(void*)this) << ": Parameters: ";
        for (int i = 0; i < d_paridx; i++) {
          if (i != 0) {
            log_message << ", ";
          }
          log_message << "$" << (i + 1) << " = ";
          if (paramValues[i] == nullptr) {
            log_message << "NULL";
          }
          else {
            log_message << "'" << paramValues[i] << "'";
          }
        }
        g_log << Logger::Warning << log_message.str() << endl;
      }
      d_dtime.set();
    }
    if (!d_stmt.empty()) {
      d_res_set = PQexecPrepared(d_db(), d_stmt.c_str(), d_nparams, paramValues, paramLengths, nullptr, 0);
    }
    else {
      d_res_set = PQexecParams(d_db(), d_query.c_str(), d_nparams, nullptr, paramValues, paramLengths, nullptr, 0);
    }
    ExecStatusType status = PQresultStatus(d_res_set);
    if (status != PGRES_COMMAND_OK && status != PGRES_TUPLES_OK && status != PGRES_NONFATAL_ERROR) {
      string errmsg(PQresultErrorMessage(d_res_set));
      releaseStatement();
      throw SSqlException("Fatal error during query: " + d_query + string(": ") + errmsg);
    }
    d_cur_set = 0;
    if (d_dolog) {
      auto diff = d_dtime.udiffNoReset();
      g_log << Logger::Warning << "Query " << ((long)(void*)this) << ": " << diff << " us to execute" << endl;
    }

    nextResult();
    return this;
  }

  void nextResult()
  {
    if (d_res_set == nullptr)
      return;
    if (d_cur_set >= PQntuples(d_res_set)) {
      PQclear(d_res_set);
      d_res_set = nullptr;
      return;
    }
    if (PQftype(d_res_set, 0) == 1790) { // REFCURSOR
      g_log << Logger::Error << "Postgres query returned a REFCURSOR and we do not support those - see https://github.com/PowerDNS/pdns/pull/10259" << endl;
      PQclear(d_res_set);
      d_res_set = nullptr;
    }
    else {
      d_res = d_res_set;
      d_res_set = nullptr;
      d_resnum = PQntuples(d_res);
    }
  }

  bool hasNextRow() override
  {
    if (d_dolog && d_residx == d_resnum) {
      g_log << Logger::Warning << "Query " << ((long)(void*)this) << ": " << d_dtime.udiff() << " us total to last row" << endl;
    }

    return d_residx < d_resnum;
  }

  SSqlStatement* nextRow(row_t& row) override
  {
    int i;
    row.clear();
    if (d_residx >= d_resnum || !d_res)
      return this;
    row.reserve(PQnfields(d_res));
    for (i = 0; i < PQnfields(d_res); i++) {
      if (PQgetisnull(d_res, d_residx, i)) {
        row.emplace_back("");
      }
      else if (PQftype(d_res, i) == 16) { // BOOLEAN
        char* val = PQgetvalue(d_res, d_residx, i);
        row.emplace_back(val[0] == 't' ? "1" : "0");
      }
      else {
        row.emplace_back(PQgetvalue(d_res, d_residx, i));
      }
    }
    d_residx++;
    if (d_residx >= d_resnum) {
      PQclear(d_res);
      d_res = nullptr;
      nextResult();
    }
    return this;
  }

  SSqlStatement* getResult(result_t& result) override
  {
    result.clear();
    if (d_res == nullptr)
      return this;
    result.reserve(d_resnum);
    row_t row;
    while (hasNextRow()) {
      nextRow(row);
      result.push_back(std::move(row));
    }
    return this;
  }

  SSqlStatement* reset() override
  {
    int i;
    if (d_res) {
      PQclear(d_res);
    }
    if (d_res_set) {
      PQclear(d_res_set);
    }
    d_res_set = nullptr;
    d_res = nullptr;
    d_paridx = d_residx = d_resnum = 0;
    if (paramValues) {
      for (i = 0; i < d_nparams; i++) {
        if (paramValues[i]) {
          delete[] paramValues[i];
        }
      }
    }
    delete[] paramValues;
    paramValues = nullptr;
    delete[] paramLengths;
    paramLengths = nullptr;
    return this;
  }

  const std::string& getQuery() override { return d_query; }

  ~SPgSQLStatement() override
  {
    releaseStatement();
  }

private:
  PGconn* d_db()
  {
    return d_parent->db();
  }

  void releaseStatement()
  {
    d_prepared = false;
    reset();
    if (!d_stmt.empty()) {
      string cmd = string("DEALLOCATE " + d_stmt);
      PGresult* res = PQexec(d_db(), cmd.c_str());
      PQclear(res);
      d_stmt.clear();
    }
  }

  void prepareStatement()
  {
    if (d_prepared)
      return;
    if (d_parent->usePrepared()) {
      // prepare a statement; name must be unique per session (using d_nstatement to ensure this).
      this->d_stmt = string("stmt") + std::to_string(d_nstatement);
      PGresult* res = PQprepare(d_db(), d_stmt.c_str(), d_query.c_str(), d_nparams, nullptr);
      ExecStatusType status = PQresultStatus(res);
      string errmsg(PQresultErrorMessage(res));
      PQclear(res);
      if (status != PGRES_COMMAND_OK && status != PGRES_TUPLES_OK && status != PGRES_NONFATAL_ERROR) {
        releaseStatement();
        throw SSqlException("Fatal error during prePQpreparepare: " + d_query + string(": ") + errmsg);
      }
    }
    paramValues = nullptr;
    paramLengths = nullptr;
    d_cur_set = d_paridx = d_residx = d_resnum = 0;
    d_res = nullptr;
    d_res_set = nullptr;
    d_prepared = true;
  }

  void allocate()
  {
    if (paramValues != nullptr)
      return;
    paramValues = new char*[d_nparams];
    paramLengths = new int[d_nparams];
    memset(paramValues, 0, sizeof(char*) * d_nparams);
    memset(paramLengths, 0, sizeof(int) * d_nparams);
  }

  string d_query;
  string d_stmt;
  SPgSQL* d_parent;
  PGresult* d_res_set{nullptr};
  PGresult* d_res{nullptr};
  bool d_dolog;
  DTime d_dtime; // only used if d_dolog is set
  bool d_prepared{false};
  int d_nparams;
  int d_paridx{0};
  char** paramValues{nullptr};
  int* paramLengths{nullptr};
  int d_residx{0};
  int d_resnum{0};
  int d_cur_set{0};
  unsigned int d_nstatement;
};

bool SPgSQL::s_dolog;

static string escapeForPQparam(const string& v)
{
  string ret = v;
  boost::replace_all(ret, "\\", "\\\\");
  boost::replace_all(ret, "'", "\\'");

  return string("'") + ret + string("'");
}

SPgSQL::SPgSQL(const string& database, const string& host, const string& port, const string& user,
               const string& password, const string& extra_connection_parameters, const bool use_prepared)
{
  d_db = nullptr;
  d_in_trx = false;
  d_connectstr = "";
  d_nstatements = 0;

  if (!database.empty())
    d_connectstr += "dbname=" + escapeForPQparam(database);

  if (!user.empty())
    d_connectstr += " user=" + escapeForPQparam(user);

  if (!host.empty())
    d_connectstr += " host=" + escapeForPQparam(host);

  if (!port.empty())
    d_connectstr += " port=" + escapeForPQparam(port);

  if (!extra_connection_parameters.empty())
    d_connectstr += " " + extra_connection_parameters;

  d_connectlogstr = d_connectstr;

  if (!password.empty()) {
    d_connectlogstr += " password=<HIDDEN>";
    d_connectstr += " password=" + escapeForPQparam(password);
  }

  d_use_prepared = use_prepared;

  d_db = PQconnectdb(d_connectstr.c_str());

  if (!d_db || PQstatus(d_db) == CONNECTION_BAD) {
    try {
      throw sPerrorException("Unable to connect to database, connect string: " + d_connectlogstr);
    }
    catch (...) {
      if (d_db)
        PQfinish(d_db);
      d_db = 0;
      throw;
    }
  }
}

void SPgSQL::setLog(bool state)
{
  s_dolog = state;
}

SPgSQL::~SPgSQL()
{
  PQfinish(d_db);
}

SSqlException SPgSQL::sPerrorException(const string& reason)
{
  return SSqlException(reason + string(": ") + (d_db ? PQerrorMessage(d_db) : "no connection"));
}

void SPgSQL::execute(const string& query)
{
  PGresult* res = PQexec(d_db, query.c_str());
  ExecStatusType status = PQresultStatus(res);
  string errmsg(PQresultErrorMessage(res));
  PQclear(res);
  if (status != PGRES_COMMAND_OK && status != PGRES_TUPLES_OK && status != PGRES_NONFATAL_ERROR) {
    throw sPerrorException("Fatal error during query: " + errmsg);
  }
}

std::unique_ptr<SSqlStatement> SPgSQL::prepare(const string& query, int nparams)
{
  d_nstatements++;
  return std::make_unique<SPgSQLStatement>(query, s_dolog, nparams, this, d_nstatements);
}

void SPgSQL::startTransaction()
{
  execute("begin");
  d_in_trx = true;
}

void SPgSQL::commit()
{
  execute("commit");
  d_in_trx = false;
}

void SPgSQL::rollback()
{
  execute("rollback");
  d_in_trx = false;
}

bool SPgSQL::isConnectionUsable()
{
  if (PQstatus(d_db) != CONNECTION_OK) {
    return false;
  }

  bool usable = false;
  int sd = PQsocket(d_db);
  bool wasNonBlocking = isNonBlocking(sd);

  if (!wasNonBlocking) {
    if (!setNonBlocking(sd)) {
      return usable;
    }
  }

  usable = isTCPSocketUsable(sd);

  if (!wasNonBlocking) {
    if (!setBlocking(sd)) {
      usable = false;
    }
  }

  return usable;
}

void SPgSQL::reconnect()
{
  PQreset(d_db);
}

1	/*
2	* This file is part of PowerDNS or dnsdist.
3	* Copyright -- PowerDNS.COM B.V. and its contributors
4	*
5	* This program is free software; you can redistribute it and/or modify
6	* it under the terms of version 2 of the GNU General Public License as
7	* published by the Free Software Foundation.
8	*
9	* In addition, for the avoidance of any doubt, permission is granted to
10	* link this program with OpenSSL and to (re)distribute the binaries
11	* produced as the result of such linking.
12	*
13	* This program is distributed in the hope that it will be useful,
14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16	* GNU General Public License for more details.
17	*
18	* You should have received a copy of the GNU General Public License
19	* along with this program; if not, write to the Free Software
20	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
21	*/
22
23	#ifdef HAVE_CONFIG_H
24	#include "config.h"
25	#endif
26	#include <string>
27	#include "spgsql.hh"
28	#include <sys/time.h>
29	#include <iostream>
30	#include "pdns/logger.hh"
31	#include "pdns/dns.hh"
32	#include "pdns/namespaces.hh"
33	#include <algorithm>
34
35	class SPgSQLStatement : public SSqlStatement
36	{
37	public:
38	SPgSQLStatement(const string& query, bool dolog, int nparams, SPgSQL* db, unsigned int nstatement)
39	{	107,216✔
40	d_query = query;	107,216✔
41	d_dolog = dolog;	107,216✔
42	d_parent = db;	107,216✔
43	d_nparams = nparams;	107,216✔
44	d_nstatement = nstatement;	107,216✔
45	}	107,216✔
46
47	SSqlStatement* bind(const string& name, bool value) override { return bind(name, string(value ? "t" : "f")); }	528,699✔
48	SSqlStatement* bind(const string& name, int value) override { return bind(name, std::to_string(value)); }	451,496✔
49	SSqlStatement* bind(const string& name, uint32_t value) override { return bind(name, std::to_string(value)); }	316,663✔
50	SSqlStatement* bind(const string& name, long value) override { return bind(name, std::to_string(value)); }	77✔
51	SSqlStatement* bind(const string& name, unsigned long value) override { return bind(name, std::to_string(value)); }	11✔
52	SSqlStatement* bind(const string& name, long long value) override { return bind(name, std::to_string(value)); }	×
53	SSqlStatement* bind(const string& name, unsigned long long value) override { return bind(name, std::to_string(value)); }	×
54	SSqlStatement* bind(const string& /* name */, const std::string& value) override
55	{	2,218,774✔
56	prepareStatement();	2,218,774✔
57	allocate();	2,218,774✔
58	if (d_paridx >= d_nparams) {	2,218,774!
59	releaseStatement();	×
60	throw SSqlException("Attempt to bind more parameters than query has: " + d_query);	×
61	}	×
62	paramValues[d_paridx] = new char[value.size() + 1];	2,218,774✔
63	memset(paramValues[d_paridx], 0, sizeof(char) * (value.size() + 1));	2,218,774✔
64	value.copy(paramValues[d_paridx], value.size());	2,218,774✔
65	paramLengths[d_paridx] = value.size();	2,218,774✔
66	d_paridx++;	2,218,774✔
67	return this;	2,218,774✔
68	}	2,218,774✔
69	SSqlStatement* bindNull(const string& /* name */) override
70	{	162,658✔
71	prepareStatement();	162,658✔
72	d_paridx++;	162,658✔
73	return this;	162,658✔
74	} // these are set null in allocate()	162,658✔
75	SSqlStatement* execute() override
76	{	328,511✔
77	prepareStatement();	328,511✔
78	if (d_dolog) {	328,511!
79	g_log << Logger::Warning << "Query " << ((long)(void*)this) << ": Statement: " << d_query << endl;	×
80	if (d_paridx) {	×
81	// Log message is similar, but not exactly the same as the postgres server log.
82	std::stringstream log_message;	×
83	log_message << "Query " << ((long)(void*)this) << ": Parameters: ";	×
84	for (int i = 0; i < d_paridx; i++) {	×
85	if (i != 0) {	×
86	log_message << ", ";	×
87	}	×
88	log_message << "$" << (i + 1) << " = ";	×
89	if (paramValues[i] == nullptr) {	×
90	log_message << "NULL";	×
91	}	×
92	else {	×
93	log_message << "'" << paramValues[i] << "'";	×
94	}	×
95	}	×
96	g_log << Logger::Warning << log_message.str() << endl;	×
97	}	×
98	d_dtime.set();	×
99	}	×
100	if (!d_stmt.empty()) {	328,511!
101	d_res_set = PQexecPrepared(d_db(), d_stmt.c_str(), d_nparams, paramValues, paramLengths, nullptr, 0);	328,511✔
102	}	328,511✔
UNCOV 103	else {	×
UNCOV 104	d_res_set = PQexecParams(d_db(), d_query.c_str(), d_nparams, nullptr, paramValues, paramLengths, nullptr, 0);	×
UNCOV 105	}	×
106	ExecStatusType status = PQresultStatus(d_res_set);	328,511✔
107	if (status != PGRES_COMMAND_OK && status != PGRES_TUPLES_OK && status != PGRES_NONFATAL_ERROR) {	328,511!
108	string errmsg(PQresultErrorMessage(d_res_set));	×
109	releaseStatement();	×
110	throw SSqlException("Fatal error during query: " + d_query + string(": ") + errmsg);	×
111	}	×
112	d_cur_set = 0;	328,511✔
113	if (d_dolog) {	328,511!
114	auto diff = d_dtime.udiffNoReset();	×
115	g_log << Logger::Warning << "Query " << ((long)(void*)this) << ": " << diff << " us to execute" << endl;	×
116	}	×
117
118	nextResult();	328,511✔
119	return this;	328,511✔
120	}	328,511✔
121
122	void nextResult()
123	{	344,958✔
124	if (d_res_set == nullptr)	344,958✔
125	return;	16,446✔
126	if (d_cur_set >= PQntuples(d_res_set)) {	328,512✔
127	PQclear(d_res_set);	312,064✔
128	d_res_set = nullptr;	312,064✔
129	return;	312,064✔
130	}	312,064✔
131	if (PQftype(d_res_set, 0) == 1790) { // REFCURSOR	16,448!
132	g_log << Logger::Error << "Postgres query returned a REFCURSOR and we do not support those - see https://github.com/PowerDNS/pdns/pull/10259" << endl;	×
133	PQclear(d_res_set);	×
134	d_res_set = nullptr;	×
135	}	×
136	else {	16,448✔
137	d_res = d_res_set;	16,448✔
138	d_res_set = nullptr;	16,448✔
139	d_resnum = PQntuples(d_res);	16,448✔
140	}	16,448✔
141	}	16,448✔
142
143	bool hasNextRow() override
144	{	269,870✔
145	if (d_dolog && d_residx == d_resnum) {	269,870!
146	g_log << Logger::Warning << "Query " << ((long)(void*)this) << ": " << d_dtime.udiff() << " us total to last row" << endl;	×
147	}	×
148
149	return d_residx < d_resnum;	269,870✔
150	}	269,870✔
151
152	SSqlStatement* nextRow(row_t& row) override
153	{	248,324✔
154	int i;	248,324✔
155	row.clear();	248,324✔
156	if (d_residx >= d_resnum \|\| !d_res)	248,324!
157	return this;	×
158	row.reserve(PQnfields(d_res));	248,324✔
159	for (i = 0; i < PQnfields(d_res); i++) {	2,386,402✔
160	if (PQgetisnull(d_res, d_residx, i)) {	2,138,078✔
161	row.emplace_back("");	175,646✔
162	}	175,646✔
163	else if (PQftype(d_res, i) == 16) { // BOOLEAN	1,962,432✔
164	char* val = PQgetvalue(d_res, d_residx, i);	146✔
165	row.emplace_back(val[0] == 't' ? "1" : "0");	146✔
166	}	146✔
167	else {	1,962,286✔
168	row.emplace_back(PQgetvalue(d_res, d_residx, i));	1,962,286✔
169	}	1,962,286✔
170	}	2,138,078✔
171	d_residx++;	248,324✔
172	if (d_residx >= d_resnum) {	248,324✔
173	PQclear(d_res);	16,446✔
174	d_res = nullptr;	16,446✔
175	nextResult();	16,446✔
176	}	16,446✔
177	return this;	248,324✔
178	}	248,324✔
179
180	SSqlStatement* getResult(result_t& result) override
181	{	1,035✔
182	result.clear();	1,035✔
183	if (d_res == nullptr)	1,035✔
184	return this;	149✔
185	result.reserve(d_resnum);	886✔
186	row_t row;	886✔
187	while (hasNextRow()) {	1,837✔
188	nextRow(row);	951✔
189	result.push_back(std::move(row));	951✔
190	}	951✔
191	return this;	886✔
192	}	1,035✔
193
194	SSqlStatement* reset() override
195	{	432,191✔
196	int i;	432,191✔
197	if (d_res) {	432,191!
198	PQclear(d_res);	×
199	}	×
200	if (d_res_set) {	432,191!
201	PQclear(d_res_set);	×
202	}	×
203	d_res_set = nullptr;	432,191✔
204	d_res = nullptr;	432,191✔
205	d_paridx = d_residx = d_resnum = 0;	432,191✔
206	if (paramValues) {	432,191✔
207	for (i = 0; i < d_nparams; i++) {	2,709,926✔
208	if (paramValues[i]) {	2,381,429✔
209	delete[] paramValues[i];	2,218,773✔
210	}	2,218,773✔
211	}	2,381,429✔
212	}	328,497✔
213	delete[] paramValues;	432,191✔
214	paramValues = nullptr;	432,191✔
215	delete[] paramLengths;	432,191✔
216	paramLengths = nullptr;	432,191✔
217	return this;	432,191✔
218	}	432,191✔
219
220	const std::string& getQuery() override { return d_query; }	×
221
222	~SPgSQLStatement() override
223	{	103,681✔
224	releaseStatement();	103,681✔
225	}	103,681✔
226
227	private:
228	PGconn* d_db()
229	{	340,073✔
230	return d_parent->db();	340,073✔
231	}	340,073✔
232
233	void releaseStatement()
234	{	103,681✔
235	d_prepared = false;	103,681✔
236	reset();	103,681✔
237	if (!d_stmt.empty()) {	103,681✔
238	string cmd = string("DEALLOCATE " + d_stmt);	5,658✔
239	PGresult* res = PQexec(d_db(), cmd.c_str());	5,658✔
240	PQclear(res);	5,658✔
241	d_stmt.clear();	5,658✔
242	}	5,658✔
243	}	103,681✔
244
245	void prepareStatement()
246	{	2,709,942✔
247	if (d_prepared)	2,709,942✔
248	return;	2,704,034✔
249	if (d_parent->usePrepared()) {	5,908✔
250	// prepare a statement; name must be unique per session (using d_nstatement to ensure this).
251	this->d_stmt = string("stmt") + std::to_string(d_nstatement);	5,905✔
252	PGresult* res = PQprepare(d_db(), d_stmt.c_str(), d_query.c_str(), d_nparams, nullptr);	5,905✔
253	ExecStatusType status = PQresultStatus(res);	5,905✔
254	string errmsg(PQresultErrorMessage(res));	5,905✔
255	PQclear(res);	5,905✔
256	if (status != PGRES_COMMAND_OK && status != PGRES_TUPLES_OK && status != PGRES_NONFATAL_ERROR) {	5,905!
257	releaseStatement();	×
258	throw SSqlException("Fatal error during prePQpreparepare: " + d_query + string(": ") + errmsg);	×
259	}	×
260	}	5,905✔
261	paramValues = nullptr;	5,908✔
262	paramLengths = nullptr;	5,908✔
263	d_cur_set = d_paridx = d_residx = d_resnum = 0;	5,908✔
264	d_res = nullptr;	5,908✔
265	d_res_set = nullptr;	5,908✔
266	d_prepared = true;	5,908✔
267	}	5,908✔
268
269	void allocate()
270	{	2,218,772✔
271	if (paramValues != nullptr)	2,218,772✔
272	return;	1,890,274✔
273	paramValues = new char*[d_nparams];	328,498✔
274	paramLengths = new int[d_nparams];	328,498✔
275	memset(paramValues, 0, sizeof(char) d_nparams);	328,498✔
276	memset(paramLengths, 0, sizeof(int) * d_nparams);	328,498✔
277	}	328,498✔
278
279	string d_query;
280	string d_stmt;
281	SPgSQL* d_parent;
282	PGresult* d_res_set{nullptr};
283	PGresult* d_res{nullptr};
284	bool d_dolog;
285	DTime d_dtime; // only used if d_dolog is set
286	bool d_prepared{false};
287	int d_nparams;
288	int d_paridx{0};
289	char** paramValues{nullptr};
290	int* paramLengths{nullptr};
291	int d_residx{0};
292	int d_resnum{0};
293	int d_cur_set{0};
294	unsigned int d_nstatement;
295	};
296
297	bool SPgSQL::s_dolog;
298
299	static string escapeForPQparam(const string& v)
300	{	2,800✔
301	string ret = v;	2,800✔
302	boost::replace_all(ret, "\\", "\\\\");	2,800✔
303	boost::replace_all(ret, "'", "\\'");	2,800✔
304
305	return string("'") + ret + string("'");	2,800✔
306	}	2,800✔
307
308	SPgSQL::SPgSQL(const string& database, const string& host, const string& port, const string& user,
309	const string& password, const string& extra_connection_parameters, const bool use_prepared)
310	{	1,625✔
311	d_db = nullptr;	1,625✔
312	d_in_trx = false;	1,625✔
313	d_connectstr = "";	1,625✔
314	d_nstatements = 0;	1,625✔
315
316	if (!database.empty())	1,625!
317	d_connectstr += "dbname=" + escapeForPQparam(database);	1,625✔
318
319	if (!user.empty())	1,625✔
320	d_connectstr += " user=" + escapeForPQparam(user);	1,175✔
321
322	if (!host.empty())	1,625!
323	d_connectstr += " host=" + escapeForPQparam(host);	×
324
325	if (!port.empty())	1,625!
326	d_connectstr += " port=" + escapeForPQparam(port);	×
327
328	if (!extra_connection_parameters.empty())	1,625!
329	d_connectstr += " " + extra_connection_parameters;	×
330
331	d_connectlogstr = d_connectstr;	1,625✔
332
333	if (!password.empty()) {	1,625!
334	d_connectlogstr += " password=<HIDDEN>";	×
335	d_connectstr += " password=" + escapeForPQparam(password);	×
336	}	×
337
338	d_use_prepared = use_prepared;	1,625✔
339
340	d_db = PQconnectdb(d_connectstr.c_str());	1,625✔
341
342	if (!d_db \|\| PQstatus(d_db) == CONNECTION_BAD) {	1,625!
343	try {	×
344	throw sPerrorException("Unable to connect to database, connect string: " + d_connectlogstr);	×
345	}	×
346	catch (...) {	×
347	if (d_db)	×
348	PQfinish(d_db);	×
349	d_db = 0;	×
350	throw;	×
351	}	×
352	}	×
353	}	1,625✔
354
355	void SPgSQL::setLog(bool state)
356	{	1,625✔
357	s_dolog = state;	1,625✔
358	}	1,625✔
359
360	SPgSQL::~SPgSQL()
361	{	1,571✔
362	PQfinish(d_db);	1,571✔
363	}	1,571✔
364
365	SSqlException SPgSQL::sPerrorException(const string& reason)
366	{	×
367	return SSqlException(reason + string(": ") + (d_db ? PQerrorMessage(d_db) : "no connection"));	×
368	}	×
369
370	void SPgSQL::execute(const string& query)
371	{	877✔
372	PGresult* res = PQexec(d_db, query.c_str());	877✔
373	ExecStatusType status = PQresultStatus(res);	877✔
374	string errmsg(PQresultErrorMessage(res));	877✔
375	PQclear(res);	877✔
376	if (status != PGRES_COMMAND_OK && status != PGRES_TUPLES_OK && status != PGRES_NONFATAL_ERROR) {	877!
377	throw sPerrorException("Fatal error during query: " + errmsg);	×
378	}	×
379	}	877✔
380
381	std::unique_ptr<SSqlStatement> SPgSQL::prepare(const string& query, int nparams)
382	{	107,238✔
383	d_nstatements++;	107,238✔
384	return std::make_unique<SPgSQLStatement>(query, s_dolog, nparams, this, d_nstatements);	107,238✔
385	}	107,238✔
386
387	void SPgSQL::startTransaction()
388	{	440✔
389	execute("begin");	440✔
390	d_in_trx = true;	440✔
391	}	440✔
392
393	void SPgSQL::commit()
394	{	420✔
395	execute("commit");	420✔
396	d_in_trx = false;	420✔
397	}	420✔
398
399	void SPgSQL::rollback()
400	{	17✔
401	execute("rollback");	17✔
402	d_in_trx = false;	17✔
403	}	17✔
404
405	bool SPgSQL::isConnectionUsable()
406	{	20,889✔
407	if (PQstatus(d_db) != CONNECTION_OK) {	20,889!
408	return false;	×
409	}	×
410
411	bool usable = false;	20,889✔
412	int sd = PQsocket(d_db);	20,889✔
413	bool wasNonBlocking = isNonBlocking(sd);	20,889✔
414
415	if (!wasNonBlocking) {	20,889!
416	if (!setNonBlocking(sd)) {	×
417	return usable;	×
418	}	×
419	}	×
420
421	usable = isTCPSocketUsable(sd);	20,889✔
422
423	if (!wasNonBlocking) {	20,889!
424	if (!setBlocking(sd)) {	×
425	usable = false;	×
426	}	×
427	}	×
428
429	return usable;	20,889✔
430	}	20,889✔
431
432	void SPgSQL::reconnect()
433	{	×
434	PQreset(d_db);	×
435	}	×

PowerDNS / pdns / 17918087582

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous