[SAMMELTHREAD] Kleine Scripting Fragen

/**
 * MySQL plugin R39-6
 */


#if defined mysql_included
    #endinput
#endif
#define mysql_included


/**
 * Common error codes
 *
 * Client: http://dev.mysql.com/doc/refman/5.1/en/error-messages-client.html
 * Server: http://dev.mysql.com/doc/refman/5.1/en/error-messages-server.html
 */

#define ER_DBACCESS_DENIED_ERROR         1044
#define ER_ACCESS_DENIED_ERROR             1045
#define ER_UNKNOWN_TABLE                 1109
#define ER_SYNTAX_ERROR                 1149
#define CR_SERVER_GONE_ERROR             2006
#define CR_SERVER_LOST                     2013
#define CR_COMMAND_OUT_OF_SYNC             2014
#define CR_SERVER_LOST_EXTENDED         2055


enum E_MYSQL_LOGLEVEL
{
    LOG_NONE = 0,
    LOG_ERROR = 1,
    LOG_WARNING = 2,
    LOG_DEBUG = 4,
    
    LOG_ALL = LOG_ERROR | LOG_WARNING | LOG_DEBUG
};

enum E_MYSQL_LOGTYPE
{
    LOG_TYPE_TEXT = 1,
    LOG_TYPE_HTML = 2
};

enum ORM_Error
{
    ERROR_OK,
    ERROR_NO_DATA
};

enum E_MYSQL_OPTION
{
    DUPLICATE_CONNECTIONS,
    LOG_TRUNCATE_DATA
};

enum E_EXECTIME_UNIT
{
    UNIT_MILLISECONDS,
    UNIT_MICROSECONDS
};


#define mysql_real_escape_string                     mysql_escape_string
#define cache_num_fields                             cache_get_field_count
#define cache_num_rows                                 cache_get_row_count
#define mysql_function_query(%0,%1,%2,%3,"%4"%5)     mysql_tquery(%0,%1,%3,#%4%5)
#define mysql_reload(%0)                             mysql_tquery(%0,"FLUSH PRIVILEGES")
#define mysql_debug(%0)                                (%0?mysql_log(LOG_ALL):mysql_log())
#define ismysqlnull(%0)                             (strcmp(%0,"NULL",false)==0)


// ORM functions
native ORM:orm_create(const table[], connectionHandle = 1);
native orm_destroy(ORM:id);

native ORM_Error:orm_errno(ORM:id);

native orm_apply_cache(ORM:id, row);
native orm_select(ORM:id, callback[] = "", format[] = "", {Float, _}:...);
/*
native orm_select_inline(ORM:id, callback:Callback, format[], {Float,_}:...); //y_inline
*/
native orm_update(ORM:id);
native orm_insert(ORM:id, callback[] = "", format[] = "", {Float, _}:...);
/*
native orm_insert_inline(ORM:id, callback:Callback, format[], {Float,_}:...); //y_inline
*/
native orm_delete(ORM:id, bool:clearvars=true);

native orm_load(ORM:id, callback[] = "", format[] = "", {Float, _}:...) = orm_select;
native orm_save(ORM:id, callback[] = "", format[] = "", {Float, _}:...);

native orm_addvar_int(ORM:id, &var, varname[]);
native orm_addvar_float(ORM:id, &Float:var, varname[]);
native orm_addvar_string(ORM:id, var[], var_maxlen, varname[]);

native orm_delvar(ORM:id, varname[]);
native orm_setkey(ORM:id, varname[]);


// MySQL functions
native mysql_log(E_MYSQL_LOGLEVEL:loglevel = LOG_ERROR | LOG_WARNING, E_MYSQL_LOGTYPE:logtype = LOG_TYPE_TEXT);
native mysql_connect(const host[], const user[], const database[], const password[], port = 3306, bool:autoreconnect = true, pool_size = 2);
native mysql_close(connectionHandle = 1);
native mysql_reconnect(connectionHandle = 1);

native mysql_unprocessed_queries(connectionHandle = 1);
native mysql_current_handle();
native mysql_option(E_MYSQL_OPTION:type, value);

native mysql_errno(connectionHandle = 1);
native mysql_escape_string(const source[], destination[], connectionHandle = 1, max_len = sizeof(destination));
native mysql_format(connectionHandle, output[], len, format[], {Float,_}:...);
native mysql_pquery(connectionHandle, query[], callback[] = "", format[] = "", {Float,_}:...);
/*
native mysql_pquery_inline(connHandle, query[], callback:Callback, format[], {Float,_}:...); //y_inline
*/
native mysql_tquery(connectionHandle, query[], callback[] = "", format[] = "", {Float,_}:...);
/*
native mysql_tquery_inline(connHandle, query[], callback:Callback, format[], {Float,_}:...); //y_inline
*/
native Cache:mysql_query(conhandle, query[], bool:use_cache = true);

native mysql_stat(destination[], connectionHandle = 1, max_len = sizeof(destination));
native mysql_get_charset(destination[], connectionHandle = 1, max_len = sizeof(destination));
native mysql_set_charset(charset[], connectionHandle = 1);


// Cache functions
native cache_get_data(&num_rows, &num_fields, connectionHandle = 1);
native cache_get_row_count(connectionHandle = 1);
native cache_get_field_count(connectionHandle = 1);
native cache_get_field_name(field_index, destination[], connectionHandle = 1, max_len = sizeof(destination));

native cache_get_row(row, field_idx, destination[], connectionHandle = 1, max_len = sizeof(destination));
native cache_get_row_int(row, field_idx, connectionHandle = 1);
native Float:cache_get_row_float(row, field_idx, connectionHandle = 1);

native cache_get_field_content(row, const field_name[], destination[], connectionHandle = 1, max_len = sizeof(destination));
native cache_get_field_content_int(row, const field_name[], connectionHandle = 1);
native Float:cache_get_field_content_float(row, const field_name[], connectionHandle = 1);

native Cache:cache_save(connectionHandle = 1);
native cache_delete(Cache:cache_id, connectionHandle = 1);
native cache_set_active(Cache:cache_id, connectionHandle = 1);
native cache_is_valid(Cache:cache_id, connectionHandle = 1);

native cache_affected_rows(connectionHandle = 1);
native cache_insert_id(connectionHandle = 1);
native cache_warning_count(connectionHandle = 1);

native cache_get_query_exec_time(E_EXECTIME_UNIT:unit = UNIT_MICROSECONDS);
native cache_get_query_string(destination[], max_len = sizeof(destination));


// Forward declarations
forward OnQueryError(errorid, error[], callback[], query[], connectionHandle);


#if defined MYSQL_USE_YINLINE || defined E_CALLBACK_DATA
    #if !defined E_CALLBACK_DATA
        #include <YSI\y_inline>
    #endif
    
    static g_MySQL_InlineData[1000][E_CALLBACK_DATA];
    static g_MySQL_VarArray[32][YSI_MAX_STRING];
    static g_MySQL_AddressArray[32];

    stock MySQL_Internal_SaveInline(callback:CB) 
    {
        static bool:g_MySQL_LazyInit = true;
        if(g_MySQL_LazyInit == true) 
        {
            //set g_MySQL_InlineData empty
            for(new i=0; i < sizeof(g_MySQL_InlineData); ++i)
                for(new E_CALLBACK_DATA:e = E_CALLBACK_DATA:0; e < E_CALLBACK_DATA; ++e)
                    g_MySQL_InlineData[i][e] = 0;
            g_MySQL_LazyInit = false;
        }
        
        for(new i=0; i < sizeof(g_MySQL_InlineData); ++i)
            if(_:g_MySQL_InlineData[i][E_CALLBACK_DATA_POINTER] == 0)
                if (Callback_Get(CB, g_MySQL_InlineData[i]))
                    return i;
                    
        return -1;
    }
    
    #define mysql_pquery_inline(%0,%1,%2,"%3"%4) \
        mysql_pquery(%0,%1,"FJ37DH3JG_MYSQL_INTERNAL","d"#%3,MySQL_Internal_SaveInline(%2)%4)
        
    #define mysql_tquery_inline(%0,%1,%2,"%3"%4) \
        mysql_tquery(%0,%1,"FJ37DH3JG_MYSQL_INTERNAL","d"#%3,MySQL_Internal_SaveInline(%2)%4)
    
    #define orm_select_inline(%0,%1,"%2"%3) \
        orm_select(%0,"FJ37DH3JG_MYSQL_INTERNAL","d"#%2,MySQL_Internal_SaveInline(%1)%3)
    
    #define orm_insert_inline(%0,%1,"%2"%3) \
        orm_insert(%0,"FJ37DH3JG_MYSQL_INTERNAL","d"#%2,MySQL_Internal_SaveInline(%1)%3)


    forward FJ37DH3JG_MYSQL_INTERNAL(...);
    public FJ37DH3JG_MYSQL_INTERNAL(...) 
    {
        new InlineDataIndex = getarg(0);
        if(InlineDataIndex < 0)
            return 0;
        
        for(new i=0; i < numargs()-1; ++i) 
        {
            for(new l=0; l < YSI_MAX_STRING; ++l) 
            {
                new TmpVal = getarg(i+1, l);
                if(l == 0 || g_MySQL_VarArray[i][l-1] < 256)
                    g_MySQL_VarArray[i][l] = TmpVal;
                else 
                    break;
            }
            
            g_MySQL_AddressArray[i] = AMX_GetRelativeAddress(g_MySQL_VarArray[i][0]);
        }
        
        Callback_Array(g_MySQL_InlineData[InlineDataIndex], g_MySQL_AddressArray);
        
        Callback_Release(g_MySQL_InlineData[InlineDataIndex]);
        for(new E_CALLBACK_DATA:e = E_CALLBACK_DATA:0; e < E_CALLBACK_DATA; ++e)
            g_MySQL_InlineData[InlineDataIndex][e] = 0;
        
        for(new i=0; i < numargs()-1; ++i) 
        {
            g_MySQL_AddressArray[i] = 0;
            for(new l=0, lmax=strlen(g_MySQL_VarArray[i]); l < lmax; ++l)
                g_MySQL_VarArray[i][l] = 0;
        }
        return 1;
    }
#endif

/**
 * MySQL plugin R39-6
 */


#if defined mysql_included
    #endinput
#endif
#define mysql_included


/**
 * Common error codes
 *
 * Client: http://dev.mysql.com/doc/refman/5.1/en/error-messages-client.html
 * Server: http://dev.mysql.com/doc/refman/5.1/en/error-messages-server.html
 */

#define ER_DBACCESS_DENIED_ERROR         1044
#define ER_ACCESS_DENIED_ERROR             1045
#define ER_UNKNOWN_TABLE                 1109
#define ER_SYNTAX_ERROR                 1149
#define CR_SERVER_GONE_ERROR             2006
#define CR_SERVER_LOST                     2013
#define CR_COMMAND_OUT_OF_SYNC             2014
#define CR_SERVER_LOST_EXTENDED         2055


enum E_MYSQL_LOGLEVEL
{
    LOG_NONE = 0,
    LOG_ERROR = 1,
    LOG_WARNING = 2,
    LOG_DEBUG = 4,

    LOG_ALL = LOG_ERROR | LOG_WARNING | LOG_DEBUG
};

enum E_MYSQL_LOGTYPE
{
    LOG_TYPE_TEXT = 1,
    LOG_TYPE_HTML = 2
};

enum ORM_Error
{
    ERROR_OK,
    ERROR_NO_DATA
};

enum E_MYSQL_OPTION
{
    DUPLICATE_CONNECTIONS,
    LOG_TRUNCATE_DATA
};

enum E_EXECTIME_UNIT
{
    UNIT_MILLISECONDS,
    UNIT_MICROSECONDS
};


#define mysql_real_escape_string                     mysql_escape_string
#define cache_num_fields                             cache_get_field_count
#define cache_num_rows                                 cache_get_row_count
#define mysql_function_query(%0,%1,%2,%3,"%4"%5)     mysql_tquery(%0,%1,%3,#%4%5)
#define mysql_reload(%0)                             mysql_tquery(%0,"FLUSH PRIVILEGES")
#define mysql_debug(%0)                                (%0?mysql_log(LOG_ALL):mysql_log())
#define ismysqlnull(%0)                             (strcmp(%0,"NULL",false)==0)


// ORM functions
native ORM:orm_create(const table[], connectionHandle = 1);
native orm_destroy(ORM:id);

native ORM_Error:orm_errno(ORM:id);

native orm_apply_cache(ORM:id, row);
native orm_select(ORM:id, const callback[] = "", const format[] = "", {Float, _}:...);
/*
native orm_select_inline(ORM:id, callback:Callback, format[], {Float,_}:...); //y_inline
*/
native orm_update(ORM:id);
native orm_insert(ORM:id, const callback[] = "", const format[] = "", {Float, _}:...);
/*
native orm_insert_inline(ORM:id, callback:Callback, format[], {Float,_}:...); //y_inline
*/
native orm_delete(ORM:id, bool:clearvars=true);

native orm_load(ORM:id, const callback[] = "", const format[] = "", {Float, _}:...) = orm_select;
native orm_save(ORM:id, const callback[] = "", const format[] = "", {Float, _}:...);

native orm_addvar_int(ORM:id, &var, varname[]);
native orm_addvar_float(ORM:id, &Float:var, varname[]);
native orm_addvar_string(ORM:id, var[], var_maxlen, varname[]);

native orm_delvar(ORM:id, const varname[]);
native orm_setkey(ORM:id, const varname[]);


// MySQL functions
native mysql_log(E_MYSQL_LOGLEVEL:loglevel = LOG_ERROR | LOG_WARNING, E_MYSQL_LOGTYPE:logtype = LOG_TYPE_TEXT);
native mysql_connect(const host[], const user[], const database[], const password[], port = 3306, bool:autoreconnect = true, pool_size = 2);
native mysql_close(connectionHandle = 1);
native mysql_reconnect(connectionHandle = 1);

native mysql_unprocessed_queries(connectionHandle = 1);
native mysql_current_handle();
native mysql_option(E_MYSQL_OPTION:type, value);

native mysql_errno(connectionHandle = 1);
native mysql_escape_string(const source[], const destination[], connectionHandle = 1, max_len = sizeof(destination));
native mysql_format(connectionHandle, const output[], len, const format[], {Float,_}:...);
native mysql_pquery(connectionHandle, const query[], const callback[] = "", const format[] = "", {Float,_}:...);
/*
native mysql_pquery_inline(connHandle, query[], callback:Callback, format[], {Float,_}:...); //y_inline
*/
native mysql_tquery(connectionHandle, const query[], const callback[] = "", const format[] = "", {Float,_}:...);
/*
native mysql_tquery_inline(connHandle, query[], callback:Callback, format[], {Float,_}:...); //y_inline
*/
native Cache:mysql_query(conhandle, const query[], bool:use_cache = true);

native mysql_stat(const destination[], connectionHandle = 1, max_len = sizeof(destination));
native mysql_get_charset(const destination[], connectionHandle = 1, max_len = sizeof(destination));
native mysql_set_charset(const charset[], connectionHandle = 1);


// Cache functions
native cache_get_data(&num_rows, &num_fields, connectionHandle = 1);
native cache_get_row_count(connectionHandle = 1);
native cache_get_field_count(connectionHandle = 1);
native cache_get_field_name(field_index, const destination[], connectionHandle = 1, max_len = sizeof(destination));

native cache_get_row(row, field_idx, const destination[], connectionHandle = 1, max_len = sizeof(destination));
native cache_get_row_int(row, field_idx, connectionHandle = 1);
native Float:cache_get_row_float(row, field_idx, connectionHandle = 1);

native cache_get_field_content(row, const field_name[], const destination[], connectionHandle = 1, max_len = sizeof(destination));
native cache_get_field_content_int(row, const field_name[], connectionHandle = 1);
native Float:cache_get_field_content_float(row, const field_name[], connectionHandle = 1);

native Cache:cache_save(connectionHandle = 1);
native cache_delete(Cache:cache_id, connectionHandle = 1);
native cache_set_active(Cache:cache_id, connectionHandle = 1);
native cache_is_valid(Cache:cache_id, connectionHandle = 1);

native cache_affected_rows(connectionHandle = 1);
native cache_insert_id(connectionHandle = 1);
native cache_warning_count(connectionHandle = 1);

native cache_get_query_exec_time(E_EXECTIME_UNIT:unit = UNIT_MICROSECONDS);
native cache_get_query_string(const destination[], max_len = sizeof(destination));


// Forward declarations
forward OnQueryError(errorid, error[], callback[], query[], connectionHandle);


#if defined MYSQL_USE_YINLINE || defined E_CALLBACK_DATA
    #if !defined E_CALLBACK_DATA
        #include <YSI\y_inline>
    #endif

    static g_MySQL_InlineData[1000][E_CALLBACK_DATA];
    static g_MySQL_VarArray[32][YSI_MAX_STRING];
    static g_MySQL_AddressArray[32];

    stock MySQL_Internal_SaveInline(callback:CB)
    {
        static bool:g_MySQL_LazyInit = true;
        if(g_MySQL_LazyInit == true)
        {
            //set g_MySQL_InlineData empty
            for(new i=0; i < sizeof(g_MySQL_InlineData); ++i)
                for(new E_CALLBACK_DATA:e = E_CALLBACK_DATA:0; e < E_CALLBACK_DATA; ++e)
                    g_MySQL_InlineData[i][e] = 0;
            g_MySQL_LazyInit = false;
        }

        for(new i=0; i < sizeof(g_MySQL_InlineData); ++i)
            if(_:g_MySQL_InlineData[i][E_CALLBACK_DATA_POINTER] == 0)
                if (Callback_Get(CB, g_MySQL_InlineData[i]))
                    return i;

        return -1;
    }

    #define mysql_pquery_inline(%0,%1,%2,"%3"%4) \
        mysql_pquery(%0,%1,"FJ37DH3JG_MYSQL_INTERNAL","d"#%3,MySQL_Internal_SaveInline(%2)%4)

    #define mysql_tquery_inline(%0,%1,%2,"%3"%4) \
        mysql_tquery(%0,%1,"FJ37DH3JG_MYSQL_INTERNAL","d"#%3,MySQL_Internal_SaveInline(%2)%4)

    #define orm_select_inline(%0,%1,"%2"%3) \
        orm_select(%0,"FJ37DH3JG_MYSQL_INTERNAL","d"#%2,MySQL_Internal_SaveInline(%1)%3)

    #define orm_insert_inline(%0,%1,"%2"%3) \
        orm_insert(%0,"FJ37DH3JG_MYSQL_INTERNAL","d"#%2,MySQL_Internal_SaveInline(%1)%3)


    forward FJ37DH3JG_MYSQL_INTERNAL(...);
    public FJ37DH3JG_MYSQL_INTERNAL(...)
    {
        new InlineDataIndex = getarg(0);
        if(InlineDataIndex < 0)
            return 0;

        for(new i=0; i < numargs()-1; ++i)
        {
            for(new l=0; l < YSI_MAX_STRING; ++l)
            {
                new TmpVal = getarg(i+1, l);
                if(l == 0 || g_MySQL_VarArray[i][l-1] < 256)
                    g_MySQL_VarArray[i][l] = TmpVal;
                else
                    break;
            }

            g_MySQL_AddressArray[i] = AMX_GetRelativeAddress(g_MySQL_VarArray[i][0]);
        }

        Callback_Array(g_MySQL_InlineData[InlineDataIndex], g_MySQL_AddressArray);

        Callback_Release(g_MySQL_InlineData[InlineDataIndex]);
        for(new E_CALLBACK_DATA:e = E_CALLBACK_DATA:0; e < E_CALLBACK_DATA; ++e)
            g_MySQL_InlineData[InlineDataIndex][e] = 0;

        for(new i=0; i < numargs()-1; ++i)
        {
            g_MySQL_AddressArray[i] = 0;
            for(new l=0, lmax=strlen(g_MySQL_VarArray[i]); l < lmax; ++l)
                g_MySQL_VarArray[i][l] = 0;
        }
        return 1;
    }
#endif