xoonips/AL/commonal.cc

/*
 * 
 * $Revision: 1.8 $
 * $Log: commonal.cc,v $
 * Revision 1.8  2004/11/26 06:36:55  aga
 * 繝ｻcreateSession, getSession 繧剃ｽ懈?.
 *
 * Revision 1.7  2004/11/26 04:51:47  youi
 * dbprefix繧貞ｮ夂ｾｩ縺励◆.
 * insertAccount繧貞ｮ夂ｾｩ縺励◆.
 * isValidSessionID繧貞ｮ夂ｾｩ縺励◆.
 *
 * Revision 1.6  2004/11/26 04:35:55  aga
 * 繝ｻloginUser(), logoutUser()繧剃ｽ懈?.
 *
 * Revision 1.5  2004/11/26 01:08:25  aga
 * 繝ｻaddSlashes()菴懈?.
 *
 * Revision 1.4  2004/11/25 12:14:29  youi
 * getUid縺ｮ蜃ｦ逅?ｒ螳夂ｾｩ縺励◆.
 *
 * Revision 1.3  2004/11/25 11:13:59  youi
 * getLastErrorString/setLastErrorString繧貞ｮ夂ｾｩ.
 *
 * Revision 1.2  2004/11/25 08:55:19  youi
 * 蠑墓焚縺ｮ蝙九ｒ菫ｮ豁｣.
 * freeResult繧定ｿｽ蜉?.
 *
 * Revision 1.1  2004/11/25 05:14:58  youi
 * initial version
 *
 * 
 */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql.h>
#include <string>
using namespace std;

#include "common.h"
#include "account.h"
#include "group.h"
#include "session.h"
#include "criteria.h"
#include "commonal.h"


static MYSQL* mysql = NULL; //!< MySQL縺ｮ繝上Φ繝峨Ν
static string dbprefix; //!< XOOPS繝??繧ｿ繝吶?繧ｹ繝??繝悶Ν縺ｮPREFIX

/** 
 * 
 * php縺ｮaddslashes縺ｨ蜷後§縲?/span>
 * 
 * @param addslashes縺吶∋縺肴枚蟄怜?縲?ULL謖?ｮ壻ｸ榊庄縲?/span>
 * @return addslashes縺輔ｌ縺滓枚蟄怜?
 */
string addSlashes( const char *str )
{
        int len = strlen(str);
        char *buf = new char[len*2+1];
        int bufLen = mysql_real_escape_string( mysql, buf, str, len );
        string s( buf, bufLen );
        return s;
}


/**
 * 
 * 繝??繧ｿ繝吶?繧ｹ縺ｮ蛻晄悄蛹?/span>
 * 
 * @param host 繝??繧ｿ繝吶?繧ｹ縺ｮ繝帙せ繝亥錐
 * @param user 繝??繧ｿ繝吶?繧ｹ縺ｫ繧｢繧ｯ繧ｻ繧ｹ縺吶ｋ繝ｦ繝ｼ繧ｶ蜷?/span>
 * @param password 荳願ｨ倥Θ繝ｼ繧ｶ縺ｮ繝代せ繝ｯ繝ｼ繝?/span>
 * @param dbname 繝??繧ｿ繝吶?繧ｹ縺ｮ蜷榊燕
 * @param prefix XOOPS繝??繧ｿ繝吶?繧ｹ繝??繝悶Ν縺ｮPREFIX
 * @return result_t
 * @refer result_t
 */
result_t initializeDB( const char* host, const char* user, const char* password, const char* dbname, const char* prefix )
{
    // 譌｢縺ｫ謗･邯壻ｸｭ縺ｪ繧峨?∽ｸ?譌ｦ蛻?妙
    if ( mysql != NULL )
        mysql_close( mysql );
    
    dbprefix = prefix;
    
    // 蛻晄悄蛹悶→謗･邯?/span>
    mysql = mysql_init(NULL);
    if ( mysql == NULL ){
        return RES_DB_INITIALIZE_ERROR;
    }
    char *unix_socket = NULL; // ?
    uint flag = 0;       // ?
    if ( NULL == mysql_real_connect( mysql, host, user, password, dbname, 3306, unix_socket, flag ) ){
        return RES_DB_CONNECT_ERROR;
    }
    
    return RES_OK;
}


/**
 * 
 * Platform繝ｦ繝ｼ繧ｶ謇ｿ隱咲憾諷句叙蠕?/span>
 * 
 * @param 
 * @return 
 * 
 */
bool isActivated( sessionid_t sid, userid_t uid )
{
    return false;
}

/**
 * 
 * Platform繝ｦ繝ｼ繧ｶ謇ｿ隱咲憾諷句､画峩
 * 
 * @param 
 * @return 
 * 
 */
result_t activate( sessionid_t sid, userid_t uid, bool activate )
{
    return RES_ERROR;
}

/**
 * 
 * 繧｢繧ｫ繧ｦ繝ｳ繝域焚
 * 
 * @param 
 * @return 
 * 
 */
int getAccountCount( sessionid_t sid )
{
    return 0;
}

/**
 * 
 * 繧｢繧ｫ繧ｦ繝ｳ繝亥炎髯､
 * 
 * @param 
 * @return 
 * 
 */
result_t deleteAccount( sessionid_t sid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * 繧｢繧ｫ繧ｦ繝ｳ繝域ュ蝣ｱ蜿門ｾ?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t getAccount( sessionid_t sid, userid_t uid, const account_t** )
{
    return RES_ERROR;
}

/**
 * 
 * 繧｢繧ｫ繧ｦ繝ｳ繝域ュ蝣ｱ蜿門ｾ?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t getAccounts( sessionid_t sid, const userid_t* uids, int uidsLen, const criteria_t* cri, const account_t** accounts, int* accountsLen )
{
    return RES_ERROR;
}

/**
 * 
 * 繧｢繧ｫ繧ｦ繝ｳ繝育匳骭ｲ
 * 
 * @param sid 繧ｻ繝?す繝ｧ繝ｳ
 * @param 
 * @return 
 * 
 */
result_t insertAccount( sessionid_t sid, const account_t* account )
{
//    if( !isValidSessionID( sid ) ) return RES_NO_SUCH_SESSION;
    string sql;
    string tmp;
    char buf[ 12 ];
    
    //xoops縺ｮ繝ｦ繝ｼ繧ｶ繝??繝悶Ν縺ｫ譖ｸ縺崎ｾｼ繧?
    sql = "INSERT INTO " + dbprefix + "_users (uname, name, email, url, user_avatar, user_regdate, user_icq, user_from, user_sig, user_viewemail, actkey, user_aim, user_yim, user_msnm, pass, posts, attachsig, rank, level, theme, timezone_offset, last_login, umode, uorder, notify_method, notify_mode, user_occ, bio, user_intrest, user_mailok) VALUES (";
    sql += "'" + string( addSlashes( account -> getUname( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getName( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getEmail( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getURL( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getUserAvatar( ) ) ) + "', ";
    snprintf( buf, 12, "%d", time( NULL ) );
    sql += string( buf ) + ", ";
    sql += "'" + string( addSlashes( account -> getUserIcq( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getUserFrom( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getUserSig( ) ) ) + "', ";
    snprintf( buf, 12, "%d", account -> getUserViewemail( ) );
    sql += string( buf ) + ", ";
    sql += "'" + string( addSlashes( account -> getActkey( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getUserAim( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getUserYim( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getUserMsnm( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getPass( ) ) ) + "', ";
    snprintf( buf, 12, "%d", account -> getPosts( ) );
    sql += string( buf ) + ", ";
    snprintf( buf, 12, "%d", account -> getAttachsig( ) );
    sql += string( buf ) + ", ";
    snprintf( buf, 12, "%d", account -> getRank( ) );
    sql += string( buf ) + ", ";
    snprintf( buf, 12, "%d", account -> getLevel( ) );
    sql += string( buf ) + ", ";
    sql += "'" + string( addSlashes( account -> getTheme( ) ) ) + "', ";
    snprintf( buf, 12, "%lf", account -> getTimezoneOffset( ) );
    sql += string( buf ) + ", ";
    sql += "0, "; //last login
    sql += "'" + string( addSlashes( account -> getUmode( ) ) ) + "', ";
    snprintf( buf, 12, "%d", account -> getUorder( ) );
    sql += string( buf ) + ", ";
    snprintf( buf, 12, "%d", account -> getNotifyMethod( ) );
    sql += string( buf ) + ", ";
    snprintf( buf, 12, "%d", account -> getNotifyMode( ) );
    sql += string( buf ) + ", ";
    sql += "'" + string( addSlashes( account -> getUserOcc( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getBio( ) ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getUserIntrest( ) ) ) + "', ";
    snprintf( buf, 12, "%d", account -> getUserMailok( ) );
    sql += string( buf ) + ")";
    fprintf( stderr, "%s\n", sql.c_str( ) );
    if( mysql_query( mysql, sql.c_str( ) ) ){
        return RES_DB_QUERY_ERROR;
    }
    
    //繝ｦ繝ｼ繧ｶID繧貞叙蠕励☆繧?/span>
    userid_t uid;
    if( getUid( account -> getUname( ), &uid ) != RES_OK ){
        return RES_ERROR;
    }
    
    //vpaccount縺ｮ繝ｦ繝ｼ繧ｶ繝??繝悶Ν縺ｫ谿九ｊ縺ｮ諠??ｱ繧呈嶌縺崎ｾｼ繧?
    sql = "INSERT INTO " + dbprefix + "_vpaccount_users (uid, activate, address, institute, tel, organization, country, zipcode, fax, base_url, notice_mail, datetime) VALUES (";
    snprintf( buf, 12, "%d", uid );
    sql += string( buf ) + ", ";
    if( account -> getActivate() ){
        sql += "1, ";
    }else{
        sql += "0, ";
    }
    sql += "'" + string( addSlashes( account -> getAddress() ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getInstitute() ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getTel() ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getOrganization() ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getCountry() ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getZipcode() ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getFax() ) ) + "', ";
    sql += "'" + string( addSlashes( account -> getBaseURL() ) ) + "', ";
    snprintf( buf, 12, "%d", account -> getNoticeMail( ) );
    sql += string( buf ) + ", ";
    snprintf( buf, 12, "%d", account -> getNoticeMailSince( ) );
    sql += string( buf ) + ")";
    fprintf( stderr, "%s\n", sql.c_str( ) );
    if( mysql_query( mysql, sql.c_str( ) ) ){
        //xoops_users縺ｸinsert縺励◆繝ｬ繧ｳ繝ｼ繝峨ｒ蜑企勁縺吶ｋ
        sql = "DELETE FROM " + dbprefix + "_users where uid=";
        snprintf( buf, 12, "%d", uid );
        sql += string( buf );
        return RES_DB_QUERY_ERROR;
    }
    
    return RES_OK;
}

/**
 * 
 * 繧｢繧ｫ繧ｦ繝ｳ繝亥､画峩
 * 
 * @param 
 * @return 
 * 
 */
result_t updateAccount( sessionid_t sid, const account_t* account )
{
    return RES_ERROR;
}

/**
 * 
 * 繝ｦ繝ｼ繧ｶID荳?隕ｧ
 * 
 * @param 
 * @return 
 * 
 */
result_t dumpUids( sessionid_t sid, const criteria_t* cri, userid_t** uids, int* uidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝玲焚
 * 
 * @param 
 * @return 
 * 
 */
int getGroupCount( sessionid_t sid )
{
    return 0;
}

/**
 * 
 * 謇?螻槭げ繝ｫ繝ｼ繝嶺ｸ?隕ｧ蜿門ｾ?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t getGroupsByUid( sessionid_t sid, userid_t uid, const criteria_t* cri, groupid_t** gids, int* gidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝礼ｮ｡逅?ｨｩ髯仙撫蜷医○
 * 
 * @param 
 * @return 
 * 
 */
bool isGroupAdmin( sessionid_t sid, groupid_t gid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝悠D荳?隕ｧ
 * 
 * @param 
 * @return 
 * 
 */
result_t dumpGids( sessionid_t sid, const criteria_t* cri, groupid_t** gids, int* gidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝礼ｮ｡逅???D蜿門ｾ?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t dumpGroupAdmins( sessionid_t sid, groupid_t gid, const criteria_t* cri, userid_t** uids, int* uidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝玲園螻槭Θ繝ｼ繧ｶ蜑企勁
 * 
 * @param 
 * @return 
 * 
 */
result_t deleteMember( sessionid_t sid, groupid_t gid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝玲園螻槭Θ繝ｼ繧ｶ霑ｽ蜉?
 * 
 * @param 
 * @return 
 * 
 */
result_t insertMember( sessionid_t sid, groupid_t gid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝玲園螻槭Θ繝ｼ繧ｶ蜿門ｾ?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t getMembers( sessionid_t sid, groupid_t gid, const criteria_t* cri, userid_t** uids, int* uidsLen )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝励?蜑企勁
 * 
 * @param 
 * @return 
 * 
 */
result_t deleteGroup( sessionid_t sid, groupid_t gid )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝励?逋ｻ骭ｲ
 * 
 * @param 
 * @return 
 * 
 */
result_t insertGroup( sessionid_t sid, const group_t* group )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝励?螟画峩
 * 
 * @param 
 * @return 
 * 
 */
result_t updateGroup( sessionid_t sid, const group_t* group )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝玲ュ蝣ｱ蜿門ｾ?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t getGroup( sessionid_t sid, groupid_t gid, const group_t** group )
{
    return RES_ERROR;
}

/**
 * 
 * 繧ｰ繝ｫ繝ｼ繝玲ュ蝣ｱ蜿門ｾ?/span>
 * 
 * @param 
 * @return 
 * 
 */
result_t getGroups( sessionid_t sid, groupid_t* gids, int gidsLen, const criteria_t* cri, const group_t** groups, int* groupsLen )
{
    return RES_ERROR;
}

/**
 * 
 * 繝｢繝?Ξ繝ｼ繧ｿ讓ｩ髯仙撫蜷医○
 * 
 * @param 
 * @return 
 * 
 */
bool isModerator( sessionid_t sid, userid_t uid )
{
    return RES_ERROR;
}

/**
 * 
 * 繝ｦ繝ｼ繧ｶID蜿門ｾ?/span>
 * 
 * @param uname ID繧貞叙蠕励＠縺溘＞繝ｦ繝ｼ繧ｶ繝ｼ蜷?/span>
 * @param uid ID繧剃ｻ｣蜈･縺励◆縺?､画焚縺ｮ繝昴う繝ｳ繧ｿ
 * @return RES_ERROR | RES_OK 
 * @refer result_t
 * 
 */
result_t getUid( const char* uname, userid_t* uid )
{
    string sql;
    
    if( uname == NULL ) return RES_ERROR;
    
    string uname2 = addSlashes( uname );
    sql = "SELECT uid FROM " + dbprefix + "_users WHERE uname='" + uname2 + "'";
    if( mysql_query( mysql, sql.c_str( ) ) ){
        return RES_DB_QUERY_ERROR;
    }
    MYSQL_RES* result = mysql_use_result( mysql ) ;
    MYSQL_ROW row = mysql_fetch_row(result);
    if( row ){
        *uid = atoi( row[0] );
        mysql_free_result( result );
        return RES_OK;
    }else{
        mysql_free_result( result );
        return RES_NO_SUCH_USER;
    }
}

/**
 * 
 * 繧ｻ繝?す繝ｧ繝ｳ繧剃ｽ懈?縺踊oops_vpaccount_session縺ｫ譖ｸ縺崎ｾｼ繧?縲 sessionid_t繧痴ession縺ｫ霑斐☆縲?/span>
 * 
 * @param uid xoops_users縺ｮuid
 * @param remoteHost remote ip (host order)
 * @param session sessionid_t繧貞女縺大叙繧九◆繧√?繝昴う繝ｳ繧ｿ縲?/span>
 * @return RES_OK 謌仙粥
 * @return RES_DB_QUERY_ERROR DB蝠上＞蜷医ｏ縺帑ｸｭ縺ｮ繧ｨ繝ｩ繝ｼ
 */
static result_t addSession( userid_t uid, unsigned long remoteHost, sessionid_t* session )
{
    result_t ret;
    string sql = "INSERT INTO " + dbprefix + "_vpaccount_session (uid,remote_host) values (" + 
      unsignedIntToString(uid) + "," + unsignedIntToString((unsigned int)remoteHost) + ")";
    if ( 0 == mysql_query( mysql, sql.c_str() ) ){
        *session = (int)mysql_insert_id(mysql);
        ret = RES_OK;
    }
    else {
        ret = RES_DB_QUERY_ERROR;
    }
    return ret;
}


/**
 * 
 * 繝ｭ繧ｰ繧､繝ｳ隱崎ｨｼ縺ｨ繧ｻ繝?す繝ｧ繝ｳ菴懈?
 * 
 * @param uname 繝ｭ繧ｰ繧､繝ｳ蜷?/span>
 * @param passwd 繝代せ繝ｯ繝ｼ繝?/span>
 * @param session sessionid_t繧貞女縺大叙繧九◆繧√?繝昴う繝ｳ繧ｿ縲?/span>
 * @return RES_OK 繝ｭ繧ｰ繧､繝ｳ謌仙粥縲Ｔession縺ｫsessionid_t繧呈嶌縺崎ｾｼ繧薙□縲?/span>
 * @return RES_LOGIN_FAILURE uname縺ｾ縺溘?passwd縺檎焚蟶ｸ
 * @return RES_DB_QUERY_ERROR DB蝠上＞蜷医ｏ縺帑ｸｭ縺ｮ繧ｨ繝ｩ繝ｼ
 * 
 */
result_t loginUser(const char* uname, const char* passwd, sessionid_t* session )
{
    result_t ret;
    string sql;
    
    // uname, passwd -> uid
    string escUname = addSlashes( uname );
    string escPasswd = addSlashes( passwd );
    sql = "SELECT uid FROM " + dbprefix + "_users WHERE uname='" + escUname + "' and paswd=md5('" + escPasswd + "')";
    if( 0 == mysql_query( mysql, sql.c_str( ) ) ){
        MYSQL_RES* result = mysql_store_result( mysql );
        if( result ){
            MYSQL_ROW row = mysql_fetch_row(result);
            if( row ){
                userid_t uid = atoi(row[0]);
                ret = addSession( uid, 0, session );
            }else{
                ret = RES_LOGIN_FAILURE;
            }
            mysql_free_result( result );
        }else {
            ret = RES_DB_QUERY_ERROR;
        }
    }else{
        ret = RES_DB_QUERY_ERROR;
    }
    
    return ret;
}

/**
 * 
 * 繝ｭ繧ｰ繧｢繧ｦ繝医→繧ｻ繝?す繝ｧ繝ｳ邨ゆｺ?/span>
 * 
 * @param sid session id
 * @return 縺ｪ縺?/span>
 * 
 */
void logoutUser( sessionid_t sid ){
    result_t ret;
    string sql;
    sql = "DELETE FROM " + dbprefix + "_vpaccount_session WHERE sid=" + intToString((int)sid);
    if ( 0 == mysql_query( mysql, sql.c_str() ) ){
        if ( mysql_affected_rows(mysql) == 1 ){
            // 繝ｭ繧ｰ繧｢繧ｦ繝医＠縺?/span>
        }
        else {
            // sid縺檎┌蜉ｹ
        }
    }
    else {
        // DB蝠上＞蜷医ｏ縺帑ｸｭ縺ｮ繧ｨ繝ｩ繝ｼ
    }
}

/**
 * 
 * 繧ｻ繝?す繝ｧ繝ｳ縺ｮ菴懈?.<br>
 * XOOPS縺ｮsession繝??繝悶Ν縺ｫ險倬鹸縺輔ｌ縺殱ess_id縺ｨ蠑墓焚sessionid縺檎ｭ峨＠縺代ｌ
 * 縺ｰ?茎ession_t繧剃ｽ懈?縺吶ｋ縲?/span>
 * 繝??繧ｿ繝吶?繧ｹ縺ｫ繧ｻ繝?す繝ｧ繝ｳ縺ｨ蠑墓焚縺ｮ諠??ｱ繧定ｨ倬鹸縺吶ｋ
 * 
 * @param sessionid xoops縺ｮsession_id
 * @param uid  xoops_users縺ｮuid
 * @param remoteHost remote ip (host order)
 * @param session sessionid_t繧貞女縺大叙繧九◆繧√?繝昴う繝ｳ繧ｿ縲?/span>
 * @return RES_OK
 * @return RES_ERROR
 * @return RES_DB_QUERY_ERROR
 *
 */
result_t createSession( const char* sessionid, userid_t uid, unsigned long remoteHost, sessionid_t* session )
{
    result_t ret;
    string sql;
    
    string escSessionid = addSlashes(sessionid);
    sql = "SELECT sess_id from " + dbprefix + "_session where sess_id='" + escSessionid + "'";
    if( 0 == mysql_query( mysql, sql.c_str( ) ) ){
        MYSQL_RES* result = mysql_store_result( mysql );
        if( result ){
            MYSQL_ROW row = mysql_fetch_row(result);
            if( row ){
                ret = addSession( uid, remoteHost, session );
            }else{
                ret = RES_ERROR;
            }
            mysql_free_result( result );
        }else {
            ret = RES_DB_QUERY_ERROR;
        }
    }else{
        ret = RES_DB_QUERY_ERROR;
    }
    

    return RES_ERROR;
}

/**
 * 
 * 繧ｻ繝?す繝ｧ繝ｳ縺ｮ隧ｳ邏ｰ繧痴ession_t縺ｧ蜿門ｾ励☆繧?<br>
 * 
 * @param sess_id
 * @param session
 * @return 
 *
 */
result_t getSession( sessionid_t sess_id, const session_t** ppsession )
{
    result_t ret;
    string sql;
    
    sql = "SELECT sid, uid, unix_timestamp(timestamp), remote_host from " + dbprefix + 
      "_vpaccount_session where sid=" + unsignedIntToString((unsigned int)sess_id);
    if( 0 == mysql_query( mysql, sql.c_str( ) ) ){
        MYSQL_RES* result = mysql_store_result( mysql );
        if( result ){
            MYSQL_ROW row = mysql_fetch_row(result);
            if( row ){
                session_t *p = new session();
                p->setSessionID(sess_id);
                p->setUserID(atoi(row[1]));
                p->setDate(atoi(row[2]));
                p->setRemoteHost(atoi(row[3]));
                *ppsession = p;
                ret = RES_OK;
            }else{
                ret = RES_NO_SUCH_SESSION;
            }
            mysql_free_result( result );
        }else {
            ret = RES_DB_QUERY_ERROR;
        }
    }else{
        ret = RES_DB_QUERY_ERROR;
    }
    
    return RES_ERROR;
}

/**
 * 
 * 繧ｻ繝?す繝ｧ繝ｳ縺ｮ豁｣蠖捺?ｧ繧偵メ繧ｧ繝?け縺吶ｋ.
 * 
 * @param sid 繝√ぉ繝?け縺励◆縺гession
 * @return true 豁｣蠖?/span>
 * @return false 荳肴ｭ｣
 *
 */
bool isValidSessionID( sessionid_t sid )
{
    string sql;
    string sidstr;
    char buf[ 12 ];
    snprintf( buf, 12, "%d", sid );
    
    sql = "SELECT * FROM " + dbprefix + "_vpaccount_session WHERE session_id=" + string( buf );
    if( mysql_query( mysql, sql.c_str( ) ) ){
        return false;
    }
    MYSQL_RES* result = mysql_use_result( mysql ) ;
    MYSQL_ROW row = mysql_fetch_row(result);
    if( row ){
        return true;
    }else{
        return false;
    }
}

void freeResult( account_t* ptr ){ delete[] ptr; }

void freeResult( group_t* ptr ){ delete[] ptr; }

void freeResult( session_t* ptr ){ delete[] ptr; }

void freeResult( int* ptr ){ delete[] ptr; }

static string errstr;
const char* getLastErrorString()
{
    return errstr.c_str( );
}

void setLastErrorString( const char* str )
{
    errstr = str;
}