分享封装好的异步Mysql动态的库(DyNetMysql.dll) + 项目源码

// TestDll.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include "../../DyNetServer/NetServer.h"
#include "../../DyNetMysql/DbSession.h"
#include "../../DyNetMysql/DbRecordSet.h"

#include <iostream>
using namespace std;

NetServer*	gNetServer;
IDbSession*	gDataBase;

void OnNetMsgEnter( NetSocket& rSocket );
void OnNetMsgExit( NetSocket& rSocket );
void OnNetMsg( NetSocket& rSocket , NetMsgHead* pHead );

#pragma pack(push,1)
struct CharacterInfo
{
	int64 type_idx;
	char nick[32];
	int32 level;
};
#pragma pack(pop)

void DBCallbase(void* pUser, const void* pMsg)
{
	const DbRecordSet* pRecordSet = static_cast<const DbRecordSet*>(pMsg);
	for (int32 i = 0 ; i < pRecordSet->CountRecord();++i )
	{
		const CharacterInfo* pInfo = static_cast<const CharacterInfo*>(pRecordSet->GetRecordBuff(i));
		printf("id:%ld nick:%s level:%d \n",pInfo->type_idx,pInfo->nick,pInfo->level);
	}
}

int _tmain(int argc, _TCHAR* argv[])
{

	// 启动msyql
	gDataBase = DbSessionMgr::Instance()->AddDatabase("127.0.0.1", "root", "root", "swa_data", false);
	ASSERT(gDataBase);

	// 初始化Scoket服务
	gNetServer = NetServerMgr::Instance()->AddNetServer();
	gNetServer->SetAddress("127.0.0.1", 4321);
	gNetServer->SetHandler(OnNetMsgEnter, OnNetMsg, OnNetMsgExit);

	// 启动Socket服务
	gNetServer->Start();

	gDataBase->ExecuteAsyncSQL("SELECT `type_idx`,`nick`,`level` FROM `character`",NULL,DBCallbase);
	while (true)
	{
		Sleep(1);
		NetServerMgr::Instance()->Update(0); //逻辑处理
		DbSessionMgr::Instance()->Update(0); //SQL处理及回调
	}
	return 0;
}

void OnNetMsgEnter(NetSocket& rSocket)
{
	int a = 1;
}

void OnNetMsg(NetSocket& rSocket, NetMsgHead* pHead)
{
	int a = 1;
}

void OnNetMsgExit(NetSocket& rSocket)
{
	int a = 1;
}

    DbRecordSet&    m_rRecordSet;
    vector<DbField>    m_vecFields;
    char            m_arrRowBuff[65536]; // 每一行内容记录，每个字段记录它的开始位置即可，则一行记录最大为64k 
    uint32            m_nBuffBegin; // 已经使用的位置

            switch
             (nType)
    {
    
            case
             FIELD_TYPE_TINY:
    {
        mI64Val = pszValue ? atol(pszValue) : 0;
        memcpy(&m_arrRowBuff[m_nBuffBegin], &mI64Val, 1);
        m_nBuffBegin += 1;
    }
        break;
    case FIELD_TYPE_SHORT:
    {
        mI64Val = pszValue ? atol(pszValue) : 0;
        memcpy(&m_arrRowBuff[m_nBuffBegin], &mI64Val, 2);
        m_nBuffBegin += 2;
    }
        break;
    case FIELD_TYPE_LONG:
    {
        mI64Val = pszValue ? atol(pszValue) : 0;
        memcpy(&m_arrRowBuff[m_nBuffBegin], &mI64Val, 4);
        m_nBuffBegin += 4;
    }
        break;
    case FIELD_TYPE_FLOAT:
    {
        mF64Val = pszValue ? atof(pszValue) : 0;
        memcpy(&m_arrRowBuff[m_nBuffBegin], &mF64Val, 4);
        m_nBuffBegin += 4;
    }
        break;
    case FIELD_TYPE_LONGLONG:
    {
        mI64Val = pszValue ? atol(pszValue) : 0;
        memcpy(&m_arrRowBuff[m_nBuffBegin], &mI64Val, 8);
        m_nBuffBegin += 8;
    }
        break;
    case FIELD_TYPE_DOUBLE:
    {
        mF64Val = pszValue ? atof(pszValue) : 0;
        memcpy(&m_arrRowBuff[m_nBuffBegin], &mF64Val, 8);
        m_nBuffBegin += 8;
    }
        break;
    case FIELD_TYPE_STRING:// charcase FIELD_TYPE_VAR_STRING:// var_char    {
        memcpy(&m_arrRowBuff[m_nBuffBegin], pszValue, nLen / 3); // mysql char 定义大小会按最大长底去计算长度，这里限制按字节大小去截断
        m_nBuffBegin += nLen / 3;
    }
        break;
    case MYSQL_TYPE_TINY_BLOB:
    case MYSQL_TYPE_MEDIUM_BLOB:
    case MYSQL_TYPE_LONG_BLOB:
    case MYSQL_TYPE_BLOB:
    {
        memcpy(&m_arrRowBuff[m_nBuffBegin], pszValue, nLen);
        m_nBuffBegin += nLen;
    }
        break;