e5342afe2a
* Add PostgreSQL DBI extension Bug #3849 This adds a postgresql database driver called "pgsql". The ambuild script changes could be very wrong ;) * Add pgsql support to clientprefs This was originally made by Lyfe in bug 3849! Thanks for that. PostgreSQL supports the 'IF NOT EXISTS' clause when creating tables since version 9.1, so i've switched to use that. * Added pgsql support to sql-admin-manager * Add --pgsql-path to ambuild configure * More ambuild fixes * Compile libpq with ambuild * Try to generate postgres configs * Add dummy config file * More ambuild fixes * Get errorcode and readable error in preparequery No need to stop getting the errorCode, if the error string should be retrieved. Just return both! * Fix indentation in AMBuilderPGSQL * Try to patch and configure postgres through ambuild * Revert "Try to patch and configure postgres through ambuild" This reverts commit 68dfc82b8eb0ce11f621af67ec247b5f47e4a189. * Update to use PostgreSQL 9.4 * Move postgres preparation into seperate script Fetching, preparing and configuring of the postgresql sourcecode is done in a seperate prepare_postgresql.sh script now. People can use this script for their manual builds, if they don't want to use checkout-deps.sh. * Add patch to configure.in again Remove the version check for autoconf in postgres 9.4 too. * Nit: Support older objdirs for hasPgSql ambuild option * Update to use PostgreSQL 9.4.6 * Use newer AMTL and PGSQL 9.6 * Fix threaded queries When running the thread part of a query, it already gets the atomic lock. Don't try to get it twice in that case. Use a seperate lock to protect access to the lastInsertID and lastAffectedRows variables. * Fix SetCharacterSet racing with threaded queries Same fix like in the mysql driver. * Use ke::AutoLock for lastInsertID mutex * Fix fetching one more row than available Don't try to access a row that doesn't exist when iterating rows. * Improve sanity checks on column access Don't call libpq functions with out of bounds column indices. * Let QuoteString return false if quoting failed * Fix build for x64 support changes and update to PGSQL 9.6.9 * Fix linux build * Fix building of connection options string snprintf doesn't support overlapping buffers. * Update to PostgreSQL 9.6.15 * Fix crash after freeing first IQuery object * Fix code crunch * Fix memory leak, cleanup * Nuke MSVC project and Makefile * Remove unsupported numeric error codes * Use STL threads * Add prebuilt libpq for Linux and Windows * Restore and fix version.rc file * Add PostgreSQL build instructions * Add prebuilt libpq for Mac * Add win64 libpq build This is version 9.6.15 since that's what I still had laying around. * Fix buildscript * Fix x64 build on linux and mac Co-authored-by: Erik Minekus <tsunami@tsunami-productions.nl>
103 lines
3.4 KiB
C++
103 lines
3.4 KiB
C++
/**
|
|
* vim: set ts=4 :
|
|
* =============================================================================
|
|
* SourceMod PostgreSQL Extension
|
|
* Copyright (C) 2013 AlliedModders LLC. All rights reserved.
|
|
* =============================================================================
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify it under
|
|
* the terms of the GNU General Public License, version 3.0, as published by the
|
|
* Free Software Foundation.
|
|
*
|
|
* 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, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* As a special exception, AlliedModders LLC gives you permission to link the
|
|
* code of this program (as well as its derivative works) to "Half-Life 2," the
|
|
* "Source Engine," the "SourcePawn JIT," and any Game MODs that run on software
|
|
* by the Valve Corporation. You must obey the GNU General Public License in
|
|
* all respects for all other code used. Additionally, AlliedModders LLC grants
|
|
* this exception to all derivative works. AlliedModders LLC defines further
|
|
* exceptions, found in LICENSE.txt (as of this writing, version JULY-31-2007),
|
|
* or <http://www.sourcemod.net/license.php>.
|
|
*
|
|
* Version: $Id$
|
|
*/
|
|
|
|
#ifndef _INCLUDE_SM_PGSQL_BASIC_RESULTS_H_
|
|
#define _INCLUDE_SM_PGSQL_BASIC_RESULTS_H_
|
|
|
|
#include <amtl/am-refcounting.h>
|
|
#include "PgDatabase.h"
|
|
|
|
class PgQuery;
|
|
class PgStatement;
|
|
|
|
class PgBasicResults :
|
|
public IResultSet,
|
|
public IResultRow
|
|
{
|
|
friend class PgQuery;
|
|
friend class PgStatement;
|
|
public:
|
|
PgBasicResults(PGresult *res);
|
|
~PgBasicResults();
|
|
public: //IResultSet
|
|
unsigned int GetRowCount();
|
|
unsigned int GetFieldCount();
|
|
const char *FieldNumToName(unsigned int columnId);
|
|
bool FieldNameToNum(const char *name, unsigned int *columnId);
|
|
bool MoreRows();
|
|
IResultRow *FetchRow();
|
|
bool Rewind();
|
|
DBType GetFieldType(unsigned int field);
|
|
DBType GetFieldDataType(unsigned int field);
|
|
IResultRow *CurrentRow();
|
|
public: //IResultRow
|
|
DBResult GetString(unsigned int columnId, const char **pString, size_t *length);
|
|
DBResult GetFloat(unsigned int columnId, float *pFloat);
|
|
DBResult GetInt(unsigned int columnId, int *pInt);
|
|
bool IsNull(unsigned int columnId);
|
|
DBResult GetBlob(unsigned int columnId, const void **pData, size_t *length);
|
|
DBResult CopyBlob(unsigned int columnId, void *buffer, size_t maxlength, size_t *written);
|
|
DBResult CopyString(unsigned int columnId,
|
|
char *buffer,
|
|
size_t maxlength,
|
|
size_t *written);
|
|
size_t GetDataSize(unsigned int columnId);
|
|
protected:
|
|
void Update();
|
|
private:
|
|
PGresult *m_pRes;
|
|
bool m_RowFetched;
|
|
unsigned int m_CurRow;
|
|
unsigned int m_ColCount;
|
|
unsigned int m_RowCount;
|
|
};
|
|
|
|
class PgQuery : public IQuery
|
|
{
|
|
friend class PgBasicResults;
|
|
public:
|
|
PgQuery(PgDatabase *db, PGresult *res);
|
|
public:
|
|
IResultSet *GetResultSet();
|
|
bool FetchMoreResults();
|
|
void Destroy();
|
|
public: // Used by the driver to implement GetInsertIDForQuery()/GetAffectedRowsForQuery()
|
|
unsigned int GetInsertID();
|
|
unsigned int GetAffectedRows();
|
|
private:
|
|
ke::RefPtr<PgDatabase> m_pParent;
|
|
PgBasicResults m_rs;
|
|
unsigned int m_InsertID;
|
|
unsigned int m_AffectedRows;
|
|
};
|
|
|
|
#endif //_INCLUDE_SM_PGSQL_BASIC_RESULTS_H_
|