Method run

lib_acl_cpp/samples/db/mysql_manager/main.cpp:246–343

protected:
	void* run()
	{
		int n = 0;

		for (int i = 0; i < max_; i++)
		{
			acl::db_pool* pool = (acl::db_pool*)
				manager_.get(addr_.c_str(), false, true);
			if (pool == NULL)
			{
				printf("peek db_pool failed\r\n");
				break;
			}

			acl::db_handle* db = pool->peek_open();
			if (db == NULL)
			{
				printf("peek db connection error\r\n");
				break;
			}

			bool ret = tbl_insert(*db, i);
			if (ret)
			{
				printf(">>insert ok: i=%d, affected: %d\r",
					i, db->affect_count());
				n++;
			}
			else
				printf(">>insert error: i = %d\r\n", i);

			pool->put(db);
		}
		printf("\r\n");
		printf(">>insert total: %d\r\n", n);

		n = 0;
		// ������ѯ����
		for (int i = 0; i < max_; i++)
		{
			acl::db_pool* pool = (acl::db_pool*)
				manager_.get(addr_.c_str(), false, true);
			if (pool == NULL)
			{
				printf("peek db_pool failed\r\n");
				break;
			}
			acl::db_handle* db = pool->peek_open();
			if (db == NULL)
			{
				printf("peek db connection error\r\n");
				break;
			}

			int  ret = tbl_select(*db, i);
			if (ret >= 0)
			{
				n += ret;