xoonips/AL/xnpal.cc

/*
        VPAL: Visiome Platform Abstract Layer
        
        zend_parse_parametersはphp4.1.0が必要
        .soファイルは外から見えない場所に置くべき。
        C++では、extern "C"{}, BEGIN/END_EXTERN_C()が必要。
*/


#include <stdio.h>
#include "vpal.h"

// global variables
MYSQL *mysql = NULL;


/* declaration of functions to be exported */
extern "C" {
ZEND_FUNCTION(first_module);
ZEND_FUNCTION(vp_initialize_db);
ZEND_FUNCTION(vp_login_user);
ZEND_FUNCTION(vp_logout_user);
};
/* compiled function list so Zend knows what's in this module */
zend_function_entry vpalmod_functions[] =
{
    ZEND_FE(first_module, NULL)
    ZEND_FE(vp_initialize_db, NULL)
    ZEND_FE(vp_login_user, NULL)
    ZEND_FE(vp_logout_user, NULL)
    {NULL, NULL, NULL}
};

/* compiled module information */
zend_module_entry vpalmod_module_entry =
{
    STANDARD_MODULE_HEADER,
    "Visiome Platform Abstract Layer",
    vpalmod_functions,
    NULL, 
    NULL, 
    NULL, 
    NULL, 
    NULL,
    NO_VERSION_YET,
    STANDARD_MODULE_PROPERTIES
};

/* implement standard "stub" routine to introduce ourselves to Zend */
#if COMPILE_DL_FIRST_MODULE
BEGIN_EXTERN_C()
ZEND_GET_MODULE(vpalmod)
END_EXTERN_C()
#endif

/* implement function that is meant to be made available to PHP */
ZEND_FUNCTION(first_module)
{
    long parameter;
//      if(ZEND_NUM_ARGS() != 2) WRONG_PARAM_COUNT;
    if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &parameter) == FAILURE) {
        return;
    }
        parameter++;
    RETURN_LONG(parameter);
}
/** zvalからCの文字列を得る。
  */
char *getZvalString( zval **p ){
        convert_to_string_ex(p);
        return Z_STRVAL_PP(p); //(**p).value.str.val;
}

/** zvalからintを得る。
  */
int getZvalInt( zval **p ){
        convert_to_long_ex(p);
        return Z_LVAL_PP(p); // (int)(**p).value.lval;
}

/** DBに接続する。既に接続中の接続は閉じられる。
    @param host      接続先。省略時はlocalhost
    @param user      DB接続時のユーザ名。省略時はNULL
    @param password  DB接続時のパスワード。省略時はNULL
    @param dbname    DB接続時のDB名。省略時はNULL
    @param port      接続先のポート。省略時は3336
    @return 0 success <br>
    @return 1 cannot mysql_init  <br>
    @return 2 cannot mysql_real_connect <br>
    int initialize_db ( char* host="localhost", char* user=NULL, char* password=NULL, char* dbname=NULL, int port=3336 )
  */
ZEND_FUNCTION(vp_initialize_db)
{
        zval **parameters[5];
        char *host;
        char *user;
        char *passwd;
        char *db;
        int port;

        /* get the number of arguments */
        int argNum = ZEND_NUM_ARGS();
        if (argNum > 5)
                WRONG_PARAM_COUNT;

        /* argument count is correct, now retrieve arguments */
        if(zend_get_parameters_array_ex(argNum, parameters) != SUCCESS)
                WRONG_PARAM_COUNT;

        if (argNum < 1) host = "localhost";
        else            host = getZvalString( parameters[0] );
        
        if (argNum < 2) user = NULL;
        else            user = getZvalString( parameters[1] );
        
        if (argNum < 3) passwd = NULL;
        else            passwd = getZvalString( parameters[2] );
        
        if (argNum < 4) db = NULL;
        else            db = getZvalString( parameters[3] );
        
        if (argNum < 5) port = 3336;
        else            port = getZvalInt( parameters[4] );
        
        // 既に接続中なら、一旦切断
        if ( mysql != NULL )
                mysql_close( mysql );
        
        // 初期化と接続
        mysql = mysql_init(NULL);
        if ( mysql == NULL ){
                RETURN_LONG(1);
        }
        char *unix_socket = NULL; // ?
        uint flag = 0;       // ?
        if ( NULL == mysql_real_connect( mysql, host, user, passwd, db, port, unix_socket, flag ) ){
                RETURN_LONG(2);
        }
    
    RETURN_LONG(0);
}

//              session_t* login_user(char* uname, char* passwd)
ZEND_FUNCTION(vp_login_user)
{
        char *uname;
        int unameLen;
        char *passwd;
        int passwdLen;
        
        if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss", 
          &uname, &unameLen, &passwd, &passwdLen) == FAILURE) {
                return;
        }
        
        //ここでログイン
        
        
    RETURN_LONG(0);
}

//      void logout_user( session_t* sid )
ZEND_FUNCTION(vp_logout_user)
{
        long sid;
        
        if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &sid) == FAILURE) {
                return;
        }
        
        // ここでログアウト
        
    RETURN_NULL();
}


/*
MYSQL *g_mysql_a = NULL; // test db
ZEND_FUNCTION(mysql_test1)
{
        char *host = NULL;   // localhost
        char *user = NULL;   // default
        char *passwd = NULL; // default
        char *db = "test";
        uint port = 0;       // default
        char *unix_socket = NULL; // ?
        uint flag = 0;       // ?


        if ( g_mysql_a != NULL )
                mysql_close( g_mysql_a );
        g_mysql_a = mysql_init(NULL);
        if ( g_mysql_a == NULL ){
                zend_error(E_WARNING, "mysql_test1: cannot mysql_init()");
                RETURN_NULL();
        }
        
        if (NULL == mysql_real_connect(g_mysql_a, host, user, passwd, db, port, unix_socket, flag)){
                zend_error(E_WARNING, "mysql_test1: cannot connect to mysql");
                RETURN_NULL();
        }
        
        int result = mysql_query(g_mysql_a, "select * from test1");
        unsigned int err = mysql_errno(g_mysql_a);
        if (result || err){
                zend_error(E_WARNING, "mysql_test1: mysql_query() failed.");
                RETURN_NULL();
        }
        
        MYSQL_RES *res = mysql_store_result(g_mysql_a);
        int num_fields = mysql_num_fields(res);
        int rows = (int)mysql_num_rows(res);
        
        zval *ar1;
        MAKE_STD_ZVAL(ar1);
        array_init(ar1);
        
        for ( int i = 0; i < rows; i++ ){
                MYSQL_ROW row = mysql_fetch_row(res);
                unsigned long *lengths = mysql_fetch_lengths(res);
                
                zval *ar2;
                MAKE_STD_ZVAL(ar2);
                array_init(ar2);
                
                for ( int j = 0; j < num_fields; j++ ){
                        add_index_stringl(ar2, (uint)j, row[j], lengths[j], 1);
                }
                add_index_zval(ar1, (uint)i, ar2);
        }
        
        mysql_free_result(res);
        *return_value = *ar1;
        zval_copy_ctor(return_value);

}
*/
