diff options
Diffstat (limited to '0.8/src/data/data_base.cpp')
| -rw-r--r-- | 0.8/src/data/data_base.cpp | 203 |
1 files changed, 0 insertions, 203 deletions
diff --git a/0.8/src/data/data_base.cpp b/0.8/src/data/data_base.cpp deleted file mode 100644 index 57705e0..0000000 --- a/0.8/src/data/data_base.cpp +++ /dev/null @@ -1,203 +0,0 @@ -/*:* - *: File: ./src/data/data_base.cpp - *: - *: yChat; Homepage: ychat.buetow.org; Version 0.9.0-CURRENT - *: - *: Copyright (C) 2003 Paul C. Buetow, Volker Richter - *: Copyright (C) 2004 Paul C. Buetow - *: Copyright (C) 2005 EXA Digital Solutions GbR - *: Copyright (C) 2006, 2007 Paul C. Buetow - *: - *: 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; either version 2 - *: of the License, or (at your option) any later version. - *: - *: 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. - *:*/ -#include "data_base.h" - -#ifdef DATABASE -#ifndef DATA_BASE_CPP -#define DATA_BASE_CPP - -using namespace std; - -data_base::data_base( ) -{ - - vector<string> vec_keys = *wrap::CONF->get_key_vector(); - vector<string>::iterator iter; - - // Reads all DATA_ elements of conf.txt! - for ( iter = vec_keys.begin(); iter != vec_keys.end(); iter++ ) - { - if ( iter->length() > 20 - && iter->compare(0, 19, "chat.database.mysql") == 0 - && iter->find(".descr") == string::npos ) - { - vector<string> vec_tokens; - string s_element = wrap::CONF->get_elem(*iter); - unsigned i_pos = 0; - - for ( bool b_find = 1; b_find; ) - { - i_pos = s_element.find_first_of( " ", 0 ); - - if ( i_pos != string::npos ) - { - vec_tokens.push_back( s_element.substr(0, i_pos) ); - s_element = s_element.substr( i_pos+1 ); - } - else - { - vec_tokens.push_back( s_element ); - b_find = 0; - } - } - - string s_mysqlquery = iter->substr(20); - wrap::system_message(MYSQLQ2 + s_mysqlquery); - map_queries[s_mysqlquery] = vec_tokens; - } - } -} - -void data_base::init_connections() -{ - int i_min_con = tool::string2int( wrap::CONF->get_elem("chat.database.mincon") ), - i_max_con = tool::string2int( wrap::CONF->get_elem("chat.database.maxcon") ); - - wrap::system_message(DATAIN0 + tool::int2string(i_max_con)); - wrap::system_message(DATAIN1 + tool::int2string(i_min_con)); - - for ( int i = 0; i < i_min_con && i < i_max_con; i++ ) - push_back( new con() ); -} - -data_base::~data_base() -{} - -hashmap<string> -data_base::select_user_data( string s_user, string s_query) -{ - print_query( DATAQUE + s_query ); - hashmap<string> map_ret; - return map_ret; -} - -void -data_base::insert_user_data( string s_user, string s_query, hashmap<string> insert_map ) -{ - print_query( DATAQUE + s_query ); -} - - -void -data_base::update_user_data( string s_user, string s_query, hashmap<string> update_map ) -{ - print_query( DATAQUE + s_query ); -} - -void -data_base::print_query( string s_query ) -{ -#ifdef DATA_PRINT_QUERIES - print_query_( s_query ); -#endif -} - -#ifdef DATA_PRINT_QUERIES -void -data_base::print_query_( string s_query ) -{ - wrap::system_message( s_query ); -} -#endif - -con* -data_base::get_con() -{ - - if ( empty() ) - { - wrap::system_message( DATANEW + string("(") + tool::int2string(size()+1) + ")" ); - return new con; - } - else if ( size() > i_max_con-1 ) - { - wrap::system_message( DATAMAX + string("(") + tool::int2string(i_max_con) + ")" ); - usleep( 5000000 ); - return get_con(); - } - - - con* p_con = *begin(); - pop_front(); - - wrap::system_message( DATAGET ); - - p_con->renew_timeout(); - return p_con; -} - -void -data_base::push_con( con* p_con ) -{ - push_front( p_con ); - - wrap::system_message( DATAADD ); -} - -void -data_base::disconnect_all_connections() -{ - wrap::system_message( DATADIS ); - - while ( !empty() ) - { - con* p_con = *begin(); - pop_front(); - delete p_con; - } - -} - -void -data_base::check_data_con_timeout() -{ - int i_timeout_time = tool::string2int(wrap::CONF->get_elem("chat.database.contimeout")); - int i_last_activity; - - - list< list<con*>::iterator > erase_list; - for ( list<con*>::iterator iter = begin(); - iter != end(); iter++ ) - { - i_last_activity = (int) (*iter)->get_last_activity(); - if ( i_timeout_time <= i_last_activity ) - { - con* p_con = *iter; - erase_list.push_back(iter); - delete p_con; - wrap::system_message(DATADI2 + tool::int2string(size()-erase_list.size()+1) + "," - + tool::int2string(i_timeout_time) + "," - + tool::int2string(i_last_activity) + ")"); - } - } - for ( list< list<con*>::iterator >::iterator erase_iter = erase_list.begin(); - erase_iter != erase_list.end(); erase_iter++ ) - erase( *erase_iter ); - -} - - -#endif -#endif |