Public Functions
void	appendTables (QStringList &tl, QSqlQuery &t, QChar type)

void	detectBackslashEscape ()

PGresult *	exec (const char *stmt) const

PGresult *	exec (const QString &stmt) const

QPSQLDriver::Protocol	getPSQLVersion ()

	QPSQLDriverPrivate (QPSQLDriver *qq)

void	setDatestyle ()

bool	setEncodingUtf8 ()

Public Variables
PGconn *	connection

bool	hasBackslashEscape

bool	isUtf8

bool	pendingNotifyCheck

QPSQLDriver::Protocol	pro

QPSQLDriver *	q

QStringList	seid

QSocketNotifier *	sn

Detailed Description

Definition at line 120 of file qsql_psql.cpp.

Constructors and Destructors

◆ QPSQLDriverPrivate()

QPSQLDriverPrivate::QPSQLDriverPrivate ( QPSQLDriver * qq )

inline

Definition at line 123 of file qsql_psql.cpp.

       : q(qq),
         connection(0),
         isUtf8(false),
         pro(QPSQLDriver::Version6),
         sn(0),
         pendingNotifyCheck(false),
         hasBackslashEscape(false)
     { }

Functions

◆ appendTables()

void QPSQLDriverPrivate::appendTables	(	QStringList &	tl,
		QSqlQuery &	t,
		QChar	type
	)

Definition at line 151 of file qsql_psql.cpp.

Referenced by QPSQLDriver::tables().

 {
     QString query;
     if (pro >= QPSQLDriver::Version73) {
         query = QString::fromLatin1("select pg_class.relname, pg_namespace.nspname from pg_class "
                   "left join pg_namespace on (pg_class.relnamespace = pg_namespace.oid) "
                   "where (pg_class.relkind = '%1') and (pg_class.relname !~ '^Inv') "
                   "and (pg_class.relname !~ '^pg_') "
                   "and (pg_namespace.nspname != 'information_schema') ").arg(type);
     } else {
         query = QString::fromLatin1("select relname, null from pg_class where (relkind = '%1') "
                   "and (relname !~ '^Inv') "
                   "and (relname !~ '^pg_') ").arg(type);
     }
     t.exec(query);
     while (t.next()) {
         QString schema = t.value(1).toString();
         if (schema.isEmpty() || schema == QLatin1String("public"))
             tl.append(t.value(0).toString());
         else
             tl.append(t.value(0).toString().prepend(QLatin1Char('.')).prepend(schema));
     }
 }

◆ detectBackslashEscape()

void QPSQLDriverPrivate::detectBackslashEscape ( )

Definition at line 650 of file qsql_psql.cpp.

Referenced by QPSQLDriver::open(), and QPSQLDriver::QPSQLDriver().

 {
     // standard_conforming_strings option introduced in 8.2
     // http://www.postgresql.org/docs/8.2/static/runtime-config-compatible.html
     if (pro < QPSQLDriver::Version82) {
         hasBackslashEscape = true;
     } else {
         hasBackslashEscape = false;
         PGresult* result = exec(QLatin1String("SELECT '\\\\' x"));
         int status = PQresultStatus(result);
         if (status == PGRES_COMMAND_OK || status == PGRES_TUPLES_OK)
             if (QString::fromLatin1(PQgetvalue(result, 0, 0)) == QLatin1String("\\"))
                 hasBackslashEscape = true;
         PQclear(result);
     }
 }

◆ exec() [1/2]

PGresult * QPSQLDriverPrivate::exec ( const char * stmt ) const

Definition at line 175 of file qsql_psql.cpp.

Referenced by QPSQLDriver::beginTransaction(), QPSQLDriver::commitTransaction(), QPSQLResult::exec(), exec(), QPSQLResult::prepare(), qDeallocatePreparedStmt(), QPSQLResult::reset(), QPSQLDriver::rollbackTransaction(), QPSQLDriver::subscribeToNotificationImplementation(), and QPSQLDriver::unsubscribeFromNotificationImplementation().

 {
     PGresult *result = PQexec(connection, stmt);
     if (seid.size() && !pendingNotifyCheck) {
         pendingNotifyCheck = true;
         QMetaObject::invokeMethod(q, "_q_handleNotification", Qt::QueuedConnection, Q_ARG(int,0));
     }
     return result;
 }

◆ exec() [2/2]

PGresult * QPSQLDriverPrivate::exec ( const QString & stmt ) const

Definition at line 185 of file qsql_psql.cpp.

 {
     return exec(isUtf8 ? stmt.toUtf8().constData() : stmt.toLocal8Bit().constData());
 }

◆ getPSQLVersion()

QPSQLDriver::Protocol QPSQLDriverPrivate::getPSQLVersion ( )

Definition at line 711 of file qsql_psql.cpp.

Referenced by QPSQLDriver::open(), and QPSQLDriver::QPSQLDriver().

 {
     QPSQLDriver::Protocol serverVersion = QPSQLDriver::Version6;
     PGresult* result = exec("select version()");
     int status = PQresultStatus(result);
     if (status == PGRES_COMMAND_OK || status == PGRES_TUPLES_OK) {
         QString val = QString::fromAscii(PQgetvalue(result, 0, 0));
 
         QRegExp rx(QLatin1String("(\\d+)\\.(\\d+)"));
         rx.setMinimal(true); // enforce non-greedy RegExp
 
         if (rx.indexIn(val) != -1) {
             int vMaj = rx.cap(1).toInt();
             int vMin = rx.cap(2).toInt();
             serverVersion = qMakePSQLVersion(vMaj, vMin);
 #ifdef PG_MAJORVERSION
             if (rx.indexIn(QLatin1String(PG_MAJORVERSION)) != -1) {
                 vMaj = rx.cap(1).toInt();
                 vMin = rx.cap(2).toInt();
             }
             QPSQLDriver::Protocol clientVersion = qMakePSQLVersion(vMaj, vMin);
 
             if (serverVersion >= QPSQLDriver::Version9 && clientVersion < QPSQLDriver::Version9) {
                 //Client version before QPSQLDriver::Version9 only supports escape mode for bytea type,
                 //but bytea format is set to hex by default in PSQL 9 and above. So need to force the
                 //server use the old escape mode when connects to the new server with old client library.
                 result = exec("SET bytea_output=escape; ");
                 status = PQresultStatus(result);
             } else if (serverVersion == QPSQLDriver::VersionUnknown) {
                 serverVersion = clientVersion;
                 if (serverVersion != QPSQLDriver::VersionUnknown)
                    qWarning("The server version of this PostgreSQL is unknown, falling back to the client version.");
             }
 #endif
         }
     }
     PQclear(result);
 
     //keep the old behavior unchanged
     if (serverVersion == QPSQLDriver::VersionUnknown)
         serverVersion = QPSQLDriver::Version6;
 
     if (serverVersion < QPSQLDriver::Version71) {
         qWarning("This version of PostgreSQL is not supported and may not work.");
     }
 
     return serverVersion;
 }

◆ setDatestyle()

void QPSQLDriverPrivate::setDatestyle ( )

Definition at line 641 of file qsql_psql.cpp.

Referenced by QPSQLDriver::open().

 {
     PGresult* result = exec("SET DATESTYLE TO 'ISO'");
     int status =  PQresultStatus(result);
     if (status != PGRES_COMMAND_OK)
         qWarning("%s", PQerrorMessage(connection));
     PQclear(result);
 }

◆ setEncodingUtf8()

bool QPSQLDriverPrivate::setEncodingUtf8 ( )

Definition at line 633 of file qsql_psql.cpp.

Referenced by QPSQLDriver::open().

 {
     PGresult* result = exec("SET CLIENT_ENCODING TO 'UNICODE'");
     int status = PQresultStatus(result);
     PQclear(result);
     return status == PGRES_COMMAND_OK;
 }