odbc 存储过程

//---------------------------------------------------------------------------------
//修改或者插入用户的积分信息
//modify by yanxiang 20061113
//增加差值判断
//修改或者插入用户的积分信息
//参数：STRU_ODBC_USER_GRADE& astruUserGradeInfo 用户的积分信息,bool abWholeValue
//返回值： int    ( 1 = 成功
//        NORMAL_ERROR = 一般错误； CRITICAL_ERROR = 严重错误)
//---------------------------------------------------------------------------------
int UpdateUserGrade(STRU_ODBC_USER_GRADE& astruUserGradeInfo,bool abWholeValue)
{
    HSTMT        l_hstmt;
    RETCODE        li_ret = 0;
    char        lc_sql_state[SQLSTATESIZE] = {0};
    int            li_result = 0;
    HENV        l_henv;
    HDBC        l_hdbc;
    DWORD        ldw_object;
    USHORT        lus_index;

    memset(lc_sql_state, 0, SQLSTATESIZE);
    l_hstmt = INVALID_HANDLE_VALUE;

    _try
    {        
        /*ldw_object = WaitForMultipleObjects(giConnCount, gah_mutex[DEF_GAME_DB], FALSE, INFINITE);

        if (ldw_object < WAIT_OBJECT_0 || ldw_object >= WAIT_ABANDONED_0)
        {
            li_result = NORMAL_ERROR;
            _leave;
        }

        lus_index = (unsigned short)(ldw_object - WAIT_OBJECT_0);

        assert(lus_index < giConnCount);

        l_henv = ga_henv[DEF_GAME_DB][lus_index];
        l_hdbc = ga_hdbc[DEF_GAME_DB][lus_index];*/
        GET_DB_CONNECTION(l_henv, l_hdbc, DEF_GAME_DB, lus_index)

        li_ret = SQLAllocStmt(l_hdbc, &l_hstmt);

        if (li_ret != SQL_SUCCESS)
        {
            li_result = HandleODBCError(l_henv, l_hdbc, 0);
            _leave;
        }

        strcpy(lc_sql_state,"{call dbo.pr_update_user_grade(?,?,?,?,?,?,?,?,?,?) }");
        
        // 捆绑输入参数
        SQLBindParameter(l_hstmt, 1, SQL_PARAM_INPUT, SQL_C_UBIGINT, SQL_BIGINT,
                         0, 0, &astruUserGradeInfo.mbiUserId, 0, NULL);

        SQLBindParameter(l_hstmt, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR,
                         GUID_STR_LEN, 0, astruUserGradeInfo.macPluginGuid, 0, NULL);

        SQLBindParameter(l_hstmt, 3, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER,
                         0, 0, &(astruUserGradeInfo.mlUserMark), 0, NULL);

        SQLBindParameter(l_hstmt, 4, SQL_PARAM_INPUT, SQL_C_SHORT , SQL_SMALLINT,
                         0, 0, &(astruUserGradeInfo.mwUserGrade), 0, NULL);

        SQLBindParameter(l_hstmt, 5, SQL_PARAM_INPUT, SQL_C_LONG , SQL_INTEGER,
                         0, 0, &(astruUserGradeInfo.mlWinCounts), 0, NULL);

        SQLBindParameter(l_hstmt, 6, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER,
                         0, 0, &(astruUserGradeInfo.mlLossCounts), 0, NULL);

        SQLBindParameter(l_hstmt, 7, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER,
                         0, 0, &(astruUserGradeInfo.mlEqualCounts), 0, NULL);

        SQLBindParameter(l_hstmt, 8, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER,
                         0, 0, &(astruUserGradeInfo.mlEscapeCounts), 0, NULL);

        SQLBindParameter(l_hstmt, 9, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR,
                         NICK_NAME_LEN, 0, astruUserGradeInfo.macNicknm, 0, NULL);
    
        SQLBindParameter(l_hstmt, 10, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER,
            0, 0, &abWholeValue, 0, NULL);

        li_ret = SQLExecDirect(l_hstmt, (unsigned char *)lc_sql_state, SQL_NTS);

        if (li_ret != SQL_SUCCESS)
        {
            li_result = HandleODBCError(l_henv, l_hdbc, l_hstmt, lc_sql_state);
            SQLTransact(l_henv, l_hdbc, SQL_ROLLBACK);            
        }
        else
        {
            SQLTransact(l_henv, l_hdbc, SQL_COMMIT);
            li_result = 1;
        }
    }

    _finally
    {
        if (l_hstmt != INVALID_HANDLE_VALUE)
            SQLFreeStmt(l_hstmt, SQL_DROP);

        //ReleaseMutex(gah_mutex[DEF_GAME_DB][lus_index]);
        RELEASE_DB_CONNECTION(l_henv, l_hdbc, DEF_GAME_DB, lus_index)

        return li_result;
    }
}