Method run

lib_acl_cpp/src/db/db_service.cpp:45–73

���� ipc_request ���Զ����ô˻ص������������

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