psdatabase.h

Go to the documentation of this file.

/*
 * psdatabase.h - Author: Keith Fulton
 *
 * Copyright (C) 2001 Atomic Blue ([email protected], http://www.atomicblue.org) 
 *
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation (version 2 of the License)
 * 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., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 *
 */

#ifndef __PSDATABASE_H__
#define __PSDATABASE_H__

#include <stdio.h>
#include <string.h>

#include <idal.h>      // Database Abstraction Layer Interface

struct iObjectRegistry;
class psAdminResponseList;
class stringList;
class csVector3;
class psString;
class csRandomGen;

// implementation of the plugin

#define  PS_DBNAME  "planeshift"
#define  PS_USER    "planeshift"
#define  PS_PASS    "planeshift"

class psDatabase
{
public:
    psDatabase(iObjectRegistry *objectreg);

    virtual ~psDatabase();

    virtual bool Initialize(const char* host, unsigned int port, const char* user,
                            const char* password, const char* database);

    void Close();


    const char* GetLastSQLError ();

    void SetLastError(const char *str) { lasterror = str; }

    const char* GetLastError ();
    const char* GetLastQuery ();

 protected:
    
    iObjectRegistry *object_reg;
    csRef<iDataConnection> mysql;

    csString lasterror;

    int InsertResponse ( psAdminResponseList& responses );
    int InsertResponse ( csString &response );

    int InsertResponseSet( stringList& responseSet );
    int InsertTrigger( const char* trigger, const char* area, 
                      int maxAttitude, int minAttitude, 
                      int responseID, int priorID );
};


struct Result
{
    iResultSet *rs;

    Result() { rs = NULL; }
    Result(iResultSet* resset) : rs(resset) {}
    ~Result() { if (rs) rs->Release(); }

    bool IsValid() { return rs != NULL; }

    void operator = (iResultSet* resset)
    { 
        if (rs) rs->Release();
        rs = resset; 
    }

    iResultRow& operator[](unsigned long whichrow)
    {
        return (*rs)[whichrow];
    }
    
    unsigned long Count(void) { return rs->Count(); }
};



#endif