Method run

phxsqlproxy/test/testsqlproxy.cpp:42–115

    }

    int run() {
        co_enable_hook_sys();

        MYSQL my;
        memset(&my, 0, sizeof(my));
        MYSQL * mysql_connection = mysql_init(&my);

        const int conn_timeout = 200;
        const int read_timeout = 200;
        const int write_timeout = read_timeout;

        //mysql_options( mysql_connection, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&conn_timeout );
        //mysql_options( mysql_connection, MYSQL_OPT_READ_TIMEOUT, (const char *)&read_timeout );
        //mysql_options( mysql_connection, MYSQL_OPT_WRITE_TIMEOUT, (const char *)&write_timeout );

        //uint64_t s = gt();
        printf("connect %s:%d\n", config_->GetListeip(), config_->GetListenPort());
        mysql_connection = mysql_real_connect(mysql_connection, config_->GetListeip(), "root", "", "abc",
                                              config_->GetListenPort(), NULL, 0ul);
        //uint64_t e = gt();
        //printf("end connect used %llu ms (%s)\n",e - s,strerror( errno ) );
        printf("conn ret %p\n", mysql_connection);

        if (!mysql_connection) {
            printf("conn failed\n");
            yield();
        }
        int query_count = 0;
        while (true) {
            query_count++;
            int ret = mysql_ping(mysql_connection);
            if (ret != 0) {
                printf("ping %d failed, ret %d\n", query_count, ret);
                break;
            }
            if (query_count % 100 == 0) {
                printf("ping %d\n", query_count);
            }
            poll(0, 0, 1000);
        }
        mysql_close(mysql_connection);
        yield();
        //for( int i = 0; i < query_count; ++i )
        //{
        //	//std::string sql_string = "/* phxsql_no_master_required */select * from t1;";
        //	std::string sql_string = "/* */select * from t1;";
        //	//s = gt();
        //	int ret = mysql_real_query( mysql_connection, sql_string.c_str(), sql_string.size() );
        //	//e = gt();
        //	if ( ret == 0 )
        //	{
        //		MYSQL_RES * res = mysql_store_result( mysql_connection );

        //		int rows = -1;
        //		if( res )
        //		{
        //			rows = mysql_num_rows( res );
        //			mysql_free_result( res );