Function dump_sql_event

tools/cdb2_sqlreplay/cdb2_sqlreplay.cpp:595–624

}

void dump_sql_event(cson_value *event) {
    cson_object *obj;

    cson_value_fetch_object(event, &obj);
    cson_value *params_obj = cson_object_get(obj, "bound_parameters");
    if (params_obj != nullptr) {
        cson_array *params = cson_value_get_array(params_obj);
        for (int i = 0; i < cson_array_length_get(params); i++) {
            cson_value *v = cson_array_get(params, i);
            if (!cson_value_is_object(v)) {
                fprintf(stderr, "Unexpected bound parameter type\n");
            }
            dump_param(v);
        }
    }
    cson_value *sqlval = cson_object_get(obj, "sql");
    if (sqlval == nullptr) {
        fprintf(stderr, ">No sql statement in sql event?\n");
        return;
    }
    if (!cson_value_is_string(sqlval)) {
        fprintf(stderr, ">Unexpected type of sql member in sql event?\n");
        return;
    }
    char *sqlptr = cson_value_get_string(sqlval);
    std::string sql(sqlptr);
    std::replace(sql.begin(), sql.end(), '\n', ' ');
    std::replace(sql.begin(), sql.end(), '\r', ' ');
    printf("tranid 0 %s", sql.c_str());
}

void replay(cdb2_hndl_tp *db, cson_value *event_val) {
    const char *sql = get_strprop(event_val, "sql");