Main | License | Installation | FAQ | Screenshots | Contact | Links | Sf.net | Freshmeat.net | KDE-Apps.org

mysqlSocket.cpp

Go to the documentation of this file.

/* Copyright (C) 2006 Jan Wedekind.
   This file is part of the recipe database application AnyMeal.

   AnyMeal 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; either version 3 of the License, or (at your option)
   any later version.

   AnyMeal is distributed in the hope that it will be useful, but WITHOUT ANY
   WARRANTY; without even the implied warranty of MERCHANTIBILITY 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/>. */
#include <mysql/errmsg.h>
#include "mysqlDatabase.hpp"
#include "mysqlSocket.hpp"
#include "timer.hpp"

using namespace std;

MySQLSocket::MySQLSocket( const std::string &_userName,
                          const std::string &_passWord,
                          const std::string &_socketName,
                          MySQLDaemonPtr _daemon ) throw (Error):
  MySQLServer( _userName, _passWord ), socketName(_socketName),
  daemon(_daemon)
{
  connect( "", &connection );
}

void MySQLSocket::connect( const std::string &database, MYSQL *m )
  throw (Error)
{
  mysql_init( m );

  const int timeout = 10;// seconds
  mysql_options( m, MYSQL_OPT_CONNECT_TIMEOUT,
                 (const char *)&timeout );

  try {

    MYSQL *result = NULL;
    timer t;

    // Loop if the mysql-daemon was started by this program (server may not
    // be up yet in this case).
    do {
      // Specifying an alternative port will lead to a crash in the library :-(
      result = mysql_real_connect( m, NULL,
                                   userName.c_str(),
                                   passWord.empty() ? (const char *)NULL :
                                   passWord.c_str(),
                                   database.empty() ? (const char *)NULL :
                                   database.c_str(),
                                   0, socketName.c_str(), 0 );
      if ( result == NULL ) {
        if ( t.elapsed() > timeout ||
             mysql_errno( m ) != CR_CONNECTION_ERROR ||
             !daemon ) {
          ERRORMACRO( result != NULL, Error, , "Error connecting to socket '"
                      << socketName << "' as user '" << userName << "' "
                      << ( passWord.empty() ? "without" : "with" )
                      << " password: " << mysql_error( m ) );
        } else
          sleep( 1 );
      };
    } while ( result == NULL );

    // Set character-set of connection to UTF-8.
    // If the server is older than MySQL 4.1, the resulting error-message is
    // being ignored.
    mysql_query( m, "SET NAMES utf8;" );

  } catch ( Error &e ) {

    mysql_close( m );
    throw e;

  };
};

MySQLSocket::~MySQLSocket(void)
{
  mysql_close( &connection );
}

---