QCassandraRowPredicate.cpp

Go to the documentation of this file.

/*
 * Text:
 *      QCassandraRowPredicate.cpp
 *
 * Description:
 *      Definition of row (and column) predicates to get row ranges.
 *
 * Documentation:
 *      See each function below.
 *
 * License:
 *      Copyright (c) 2011 Made to Order Software Corp.
 * 
 *      http://snapwebsites.org/
 *      contact@m2osw.com
 * 
 *      Permission is hereby granted, free of charge, to any person obtaining a
 *      copy of this software and associated documentation files (the
 *      "Software"), to deal in the Software without restriction, including
 *      without limitation the rights to use, copy, modify, merge, publish,
 *      distribute, sublicense, and/or sell copies of the Software, and to
 *      permit persons to whom the Software is furnished to do so, subject to
 *      the following conditions:
 *
 *      The above copyright notice and this permission notice shall be included
 *      in all copies or substantial portions of the Software.
 *
 *      THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 *      OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 *      MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 *      IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
 *      CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
 *      TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 *      SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */

#include "QtCassandra/QCassandraRowPredicate.h"
//#include "QtCassandra/QCassandraTable.h"
#include "thrift-gencpp-cassandra/cassandra_types.h"
#include <stdexcept>

namespace QtCassandra
{

QCassandraRowPredicate::QCassandraRowPredicate()
    //: f_start_row() -- auto-init
    //  f_end_row() -- auto-init
    : f_count(100),
      f_wrap(false),
      f_column_predicate(new QCassandraColumnPredicate)
{
}

QString QCassandraRowPredicate::startRowName() const
{
    return QString::fromUtf8(f_start_row.data());
}

void QCassandraRowPredicate::setStartRowName(const QString& row_name)
{
    setStartRowKey(row_name.toUtf8());
}

const QByteArray& QCassandraRowPredicate::startRowKey() const
{
    return f_start_row;
}

void QCassandraRowPredicate::setStartRowKey(const QByteArray& row_key)
{
    if(row_key.size() > 65535) {
        throw std::runtime_error("the start row key is more than 64Kb");
    }
    f_start_row = row_key;
}

QString QCassandraRowPredicate::endRowName() const
{
    return QString::fromUtf8(f_end_row.data());
}

void QCassandraRowPredicate::setEndRowName(const QString& row_name)
{
    setEndRowKey(row_name.toUtf8());
}

const QByteArray& QCassandraRowPredicate::endRowKey() const
{
    return f_end_row;
}

void QCassandraRowPredicate::setEndRowKey(const QByteArray& row_key)
{
    if(row_key.size() > 65535) {
        throw std::runtime_error("the end row key is more than 64Kb");
    }
    f_end_row = row_key;
}

int32_t QCassandraRowPredicate::count() const
{
    return f_count;
}

void QCassandraRowPredicate::setCount(int32_t count)
{
    f_count = count;
}

bool QCassandraRowPredicate::wrap() const
{
    return f_wrap;
}

void QCassandraRowPredicate::setWrap(bool wrap)
{
    f_wrap = wrap;
}

QSharedPointer<QCassandraColumnPredicate> QCassandraRowPredicate::columnPredicate() const
{
    return f_column_predicate;
}

void QCassandraRowPredicate::setColumnPredicate(QSharedPointer<QCassandraColumnPredicate> column_predicate)
{
    f_column_predicate = column_predicate;
}

void QCassandraRowPredicate::toPredicate(void *data) const
{
    org::apache::cassandra::KeyRange *key_range = reinterpret_cast<org::apache::cassandra::KeyRange *>(data);

    if(f_wrap) {
        key_range->__set_start_token(f_start_row.data());
        key_range->__set_end_token(f_end_row.data());
    }
    else {
        key_range->__set_start_key(f_start_row.data());
        key_range->__set_end_key(f_end_row.data());
    }
    key_range->__set_count(f_count);
}


} // namespace QtCassandra
// vim: ts=4 sw=4 et