Method query

lib_acl_cpp/src/hsocket/hsclient.cpp:363–415

}

bool hsclient::query(const char* oper, const char* values[], int num,
	const char* limit_offset, char mop,
	const char* to_values[], int to_num)
{
	acl_assert(tbl_curr_);

	bool retried = false;

	while (true) {
		// ������������
		hsproto::build_request(buf_, tbl_curr_->id_, oper, values,
			num, limit_offset, mop, to_values, to_num);

		if (debugOn_) {
			printf("%s(%d)>>>send: (%s)\n",
				__FUNCTION__, __LINE__, buf_.c_str());
		}

		// �����ݿ�ͨ�Ų������ݿ��ý��
		if (chat()) {
			break;
		}

		// ��������ݿ�ͨ��ʧ�ܵ���������ʱ������Ҳʧ���򷵻ش���
		if (retry_enable_ == false || retried) {
			close_stream();
			return false;
		}

		retried = true;

		// �Ȼ��嵱ǰ���ṹ�е���Ϣ
		string dbn(tbl_curr_->dbn_), tbl(tbl_curr_->tbl_);
		string idx(tbl_curr_->idx_), flds(tbl_curr_->flds_);

		// �ȹرվɵ����Ӷ������еı�����
		close_stream();

		// �����´����Ӷ��󲢴򿪱�����
		if (!open_tbl(dbn.c_str(), tbl.c_str(), idx.c_str(),
			flds.c_str(), true)) {

			logger_error("reopen error");
			return (false);
		}
	}

	if (debugOn_) {
		printf("%s(%d): gets: (%s)\n",
			__FUNCTION__, __LINE__, buf_.c_str());
	}
	return proto_.parse_respond(tbl_curr_->nfld_, buf_, error_, serror_);
}

bool hsclient::chat(void)
{