00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016 #include <mysql/mysqld_error.h>
00017 #include "mysqlDatabase.hpp"
00018 #include "mysqlNetwork.hpp"
00019
00020 using namespace std;
00021
00022 MySQLNetwork::MySQLNetwork( const std::string &_userName,
00023 const std::string &_passWord,
00024 const std::string &_serverName,
00025 int _portNumber ) throw (Error):
00026 MySQLServer( _userName, _passWord ), serverName(_serverName),
00027 portNumber( _portNumber )
00028 {
00029 connect( "", &connection );
00030 }
00031
00032
00033 void MySQLNetwork::connect( const std::string &database, MYSQL *m )
00034 throw (Error)
00035 {
00036 mysql_init( m );
00037
00038 const int timeout = 10;
00039 mysql_options( m, MYSQL_OPT_CONNECT_TIMEOUT,
00040 (const char *)&timeout );
00041
00042 try {
00043
00044
00045 ERRORMACRO( mysql_real_connect( m,
00046 serverName.c_str(), userName.c_str(),
00047 passWord.empty() ? (const char *)NULL :
00048 passWord.c_str(),
00049 database.empty() ? (const char *)NULL :
00050 database.c_str(),
00051 portNumber != MYSQL_PORT ? portNumber : 0,
00052 NULL, 0 ),
00053 Error, , "Error connecting to server '"
00054 << serverName << "' as user '" << userName << "' "
00055 << ( passWord.empty() ? "without" : "with" ) << " password: "
00056 << mysql_error( m ) );
00057
00058
00059
00060
00061 mysql_query( m, "SET NAMES utf8;" );
00062
00063 } catch ( Error &e ) {
00064
00065 mysql_close( m );
00066 throw e;
00067
00068 };
00069 };
00070
00071
00072 MySQLNetwork::~MySQLNetwork(void)
00073 {
00074 mysql_close( &connection );
00075 }