Class db_ipc_request

lib_acl_cpp/src/db/db_service.cpp:28–115

// �������̵߳Ĵ�����

class db_ipc_request : public ipc_request
{
public:
	db_ipc_request(db_handle* db, const char* sql, db_query* query, bool has_res)
	: db_(db)
	, sql_(sql)
	, query_(query)
	, has_res_(has_res)
	{
	}

	~db_ipc_request(void)
	{
	}

protected:
	// ���� ipc_request ���Զ����ô˻ص������������
	virtual void run(ipc_client* ipc)
	{
		DB_IPC_DAT data;

		data.db = db_;
		data.query = query_;
		data.rows = NULL;
		data.affected_rows = 0;

		if (!db_->dbopen()) {
			ipc->send_message(DB_ERR_OPEN, &data, sizeof(data));
		} else if (has_res_) {
			if (!db_->sql_select(sql_.c_str())) {
				ipc->send_message(DB_ERR_EXEC_SQL, &data, sizeof(data));
			} else {
				data.rows = db_->get_result();
				ipc->send_message(DB_OK, &data, sizeof(data));
			}
		} else if (!db_->sql_update(sql_.c_str())) {
			ipc->send_message(DB_ERR_EXEC_SQL, &data, sizeof(data));
		} else {
			data.rows = db_->get_result();
			// �޸IJ�������Ҫȡһ�� SQL ����Ӱ�������
			data.affected_rows = db_->affect_count();
			ipc->send_message(DB_OK, &data, sizeof(data));
		}
		// ��Ϊ����������Ƕ�̬�����ģ�������Ҫ�ͷ�
		delete this;
	}

#ifdef ACL_WINDOWS

	// ������ӿڣ�ʹ���߳̿�����ִ��������������̷߳��� ACL_WINDOWS ������Ϣ

	virtual void run(HWND hWnd)
	{
		DB_IPC_DAT* data = (DB_IPC_DAT*) acl_mymalloc(sizeof(DB_IPC_DAT));

		data->db = db_;
		data->query = query_;
		data->rows = NULL;