iframe-proxy | Sunbelt Computer Software

156 lines (138 loc) · 5.54 KB
/* This file is part of VoltDB.
 * Copyright (C) 2008-2016 VoltDB Inc.
 * 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 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 <vector>
#include "Table.h"
#include "TableIterator.h"
#include "Row.hpp"
namespace voltdb {
    Table::Table(SharedByteBuffer buffer) : m_buffer(buffer) {
        buffer.position(5);
        size_t columnCount = static_cast<size_t>(buffer.getInt16());
        assert(columnCount > 0);
        boost::shared_ptr<std::vector< voltdb::Column> > columns(
                                new std::vector< voltdb::Column>(columnCount));
        m_columns = columns;
        std::vector<int8_t> types(columnCount);
        for (size_t ii = 0; ii < columnCount; ii++) {
            types[ii] = buffer.getInt8();
        for (size_t ii = 0; ii < columnCount; ii++) {
            bool wasNull = false;
            m_columns->at(ii) = voltdb::Column(buffer.getString(wasNull), static_cast<WireType>(types[ii]));
            assert(!wasNull);
        m_rowStart = m_buffer.getInt32(0) + 4;
        m_rowCount = m_buffer.getInt32(m_rowStart);
        m_buffer.position(m_buffer.limit());
    int8_t Table::getStatusCode() const{
        return m_buffer.getInt8(4);
    TableIterator Table::iterator() const{
        m_buffer.position(m_rowStart + 4);//skip row count
        return TableIterator(m_buffer.slice(), m_columns, m_rowCount);
    int32_t Table::rowCount() const{
        return m_rowCount;
    int32_t Table::columnCount() const{
        return static_cast<int32_t>(m_columns->size());
    std::vector<voltdb::Column> Table::columns() const {
        return *m_columns;
    std::string Table::toString() const {
        std::ostringstream ostream;
        toString(ostream, std::string(""));
        return ostream.str();
    void Table::toString(std::ostringstream &ostream, std::string indent) const {
        ostream << indent << "Table size: " << m_buffer.capacity() << std::endl;
        ostream << indent << "Status code: " << static_cast<int32_t>(getStatusCode()) << std::endl;
        ostream << indent << "Column names: ";
        for (size_t ii = 0; ii < m_columns->size(); ii++) {
            if (ii != 0) {
                ostream << ", ";
            ostream << m_columns->at(ii).m_name;
        ostream << std::endl << indent << "Column types: ";
        for (size_t ii = 0; ii < m_columns->size(); ii++) {
            if (ii != 0) {
                ostream << ", ";
            ostream << wireTypeToString(m_columns->at(ii).m_type);
        ostream << std::endl;
        TableIterator iter = iterator();
        while (iter.hasNext()) {
            Row row = iter.next();
            row.toString(ostream, indent + "    ");
            ostream << std::endl;
    void Table::operator >> (std::ostream &ostream) const {
        int32_t size = m_buffer.limit();
        ostream.write((const char*)&size, sizeof(size));
        if (size != 0) {
            ostream.write(m_buffer.bytes(), size);
    //Do easy checks first before heavyweight checks.
    bool Table::operator==(const Table& rhs) const {
        if (this == &rhs) return true;
        bool eq = (this->rowCount() == rhs.rowCount() && this->columnCount() == rhs.columnCount());
        if (!eq) return false;
        //Make sure all columns and their order matches.
        if (m_columns != rhs.m_columns) return false;
        //Is underlying buffer same?
        return (m_buffer == rhs.m_buffer);
    //Do easy checks first before heavyweight checks.
    bool Table::operator!=(const Table& rhs) const {
        if (this == &rhs) return false;
        bool noteq = (this->rowCount() != rhs.rowCount() || this->columnCount() != rhs.columnCount());
        if (noteq) return true;
        //Make sure all columns and their order matches.
        if (m_columns != rhs.m_columns) return true;
        //Is underlying buffer same?
        return (m_buffer != rhs.m_buffer);
    static voltdb::SharedByteBuffer readByteBuffer(std::istream &istream) {
        int32_t size;
        istream.read((char*)&size, sizeof(size));
        if (size != 0) {
            boost::shared_array<char> buffer(new char[size]);
            istream.read(buffer.get(), size);
            return voltdb::SharedByteBuffer(buffer, size);
        } else {
            return SharedByteBuffer();
    Table::Table(std::istream &istream) {
        voltdb::SharedByteBuffer buffer = readByteBuffer(istream);
        if (buffer.limit() != 0) {
            *this = Table(buffer);
Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

Table.cpp

Latest commit

History

Table.cpp

File metadata and controls
