Function get_join_table_result_set

sqladvisor/main.cc:272–327

}

uint get_join_table_result_set(TABLE_LIST *table) {
    MYSQL *con = mysql_init(NULL);
    if (con == NULL) {
        finish_with_error(con);
    }

    if (mysql_real_connect(con, options.host, options.username,
            options.password, options.dbname, options.port, NULL, 0) == NULL) {
        finish_with_error(con);
    }

    mysql_query(con, "set names utf8");

    uint result_set_count;
    GString *cardinality_sql = g_string_new(NULL);
    if (table->index_field_head != NULL) {
        if (table->index_field_head->index_field->field_name->table_name
                == NULL) {
            g_string_sprintf(cardinality_sql,
                    "explain select * from %s where %s", table->table_name,
                    table->index_field_head->index_field->field_print);
        } else {
            g_string_sprintf(cardinality_sql,
                    "explain select * from %s as %s where %s",
                    table->table_name,
                    table->index_field_head->index_field->field_name->table_name,
                    table->index_field_head->index_field->field_print);
        }
    } else {
        g_string_sprintf(cardinality_sql, "explain select * from %s",
                table->table_name);
    }

    print_sql(cardinality_sql->str);

    if (mysql_query(con, cardinality_sql->str)) {
        finish_with_error(con);
    }

    MYSQL_RES *result = mysql_store_result(con);
    if (result == NULL) {
        finish_with_error(con);
    }

    int num_fields = mysql_num_fields(result);

    MYSQL_ROW row;

    if ((row = mysql_fetch_row(result))) {
        result_set_count = atoi(row[EXPLAIN_ROWS]);
    }
    g_string_free(cardinality_sql, TRUE);
    mysql_free_result(result);
    mysql_close(con);
    return result_set_count;
}

void final_table_drived() {