Connection.h

Go to the documentation of this file.

/*
 * $Id:Connection.h 540 2007-08-20 07:51:56Z mindstorm2600 $
 *
 * X-VR2 
 * 
 * Copyright (C) Juan V. Guerrero 2007
 * 
 * Juan V. Guerrero <mindstorm2600@users.sourceforge.net>
 * 
 * This program is free software, distributed under the terms of
 * the GNU General Public License Version 2. See the LICENSE file
 * at the top of the source tree.
 */
#ifndef __XVR2_SQL_Connection_H__
#define __XVR2_SQL_Connection_H__

#include<xvr2/xvr2config.h>
#include<xvr2/SQL/Driver.h>
#include<xvr2/SQL/DatabaseException.h>
#include<xvr2/StringBuffer.h>

namespace xvr2{
        namespace SQL {
                class Connection:public Object{
                        private:
                                void *__conn;
                        protected:
                                Driver  *driver;
                                String  _server;
                                String  _user;
                                String  _password;
                                String  _dbname;
                                int             _port;
                                bool    __connected;
                                String  *bulk_delim;
                        public:
                                Connection(Driver *drv);
                                Connection(Driver *drv, const String &server, 
                                              const String &dbname,
                                              const String &u, const String &p, 
                                              int port = 0);
                                ~Connection();
                                Connection();
                                void connect(const String &server, const String &u, 
                                             const String &dbname,
                                             const String &p, int port = 0);
                                void connect(Driver *d, const String &server, const String &u, 
                                             const String &dbname,
                                             const String &p, int port = 0);
                                void connect();
                                void open(const String &datafile);
                                void disconnect();
                                ResultSet *query(const String &cmd);
                                ResultSet *query(const StringBuffer &cmd);
                                int execCommand(const String &cmd);
                                int execCommand(const StringBuffer &cmd);
                                void commit();
                                void bulkUploadBegin(const String &table, const String &cols, const String &_delim);
                                void bulkUploadData(const String &data);
                                void bulkUploadEnd();

                                String escapeString(const String &s);
                                //char *escapeString(const char *);
                                const char *errorMessage();
                                const bool isConnected();
                };
        };
};

#endif

---