SQLDriverSQLR.C

/* 
 * Copyright (c) 2005-2011, Guillaume Gimenez <guillaume@blackmilk.fr>
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *     * Redistributions of source code must retain the above copyright
 *       notice, this list of conditions and the following disclaimer.
 *     * Redistributions in binary form must reproduce the above copyright
 *       notice, this list of conditions and the following disclaimer in the
 *       documentation and/or other materials provided with the distribution.
 *     * Neither the name of G.Gimenez nor the names of its contributors may
 *       be used to endorse or promote products derived from this software
 *       without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL G.GIMENEZ BE LIABLE FOR ANY DIRECT,
 * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * Authors:
 *     * Guillaume Gimenez <guillaume@blackmilk.fr>
 *
 */
#include "raii.H"
#include "SQLDriverSQLR.H"
#include "ResultSetImplSQLR.H"


namespace raii {
namespace sql {

extern "C" {

bool isPoolable() {
        return false;
}

raii::ptr<raii::sql::SQLDriver> getDriver( const raii::String& user, const raii::String& password,
                                           const raii::String& host, int port,
                                           const raii::String& path, const raii::String& query) {

        return new raii::sql::SQLDriverSQLR(host,port,path,user,password);
}

}
	SQLDriverSQLR::SQLDriverSQLR(const String& host, int port, const String& path, const String& user, const String& password)
		:	SQLDriver(),
			autoCommit(true)
		{

		conn= new sqlrconnection(host.c_str(),port,path.c_str(),user.c_str(),password.c_str(),1,1);
		if ( !conn )
			throw SQLrelayException("connexion impossible");

                //STRANGE !!! si on ne lance pas une requête à ce moment, ça ne marche poa...
                query("SELECT 1");
	}




	SQLDriverSQLR::~SQLDriverSQLR() {

		if ( !isAutoCommitOn() )
			rollback();
		delete (sqlrconnection*)conn;
	}


	ptr<ResultSetImpl> SQLDriverSQLR::query(const String& q) {

		return new ResultSetImplSQLR(*this,q);
	}

	bool SQLDriverSQLR::isAutoCommitOn() {
		return autoCommit;
	}

	void SQLDriverSQLR::autoCommitOn() {
		if ( !autoCommit ) {
			query("ROLLBACK");
			autoCommit=true;
		}
	}

	void SQLDriverSQLR::autoCommitOff() {
		if ( autoCommit ) {
			query("BEGIN");
			autoCommit=false;
		}
	}

	void SQLDriverSQLR::commit() {
		if ( !autoCommit ) {
			query("COMMIT");
			query("BEGIN");
		}
	}

	void SQLDriverSQLR::rollback() {
		if ( !autoCommit ) {
			query("ROLLBACK");
			query("BEGIN");
		}
	}

        String SQLDriverSQLR::identifyDriver() {

                String identification = "sqlrelay(";

                const char * sqlrID = ((sqlrconnection*)conn)->identify();
                if ( sqlrID )
                        identification += sqlrID;
                else
                        identification += "null";
                identification += ")";
                return identification;
        }

	String SQLDriverSQLR::sqlize(const String& str) {

		StringStream res;
		for ( size_t i = 0 ; i < str.size() ; i++ ) {
			res << str[i];
			if ( str[i] == '\'' )
				res << "'";
			if ( str[i] == '\\' )
				res << "\\";
		}
		return res.str();
	}

}
}