Contents

package org.embulk.output.jdbc;

import org.embulk.spi.Column;
import org.embulk.spi.time.Timestamp;
import org.msgpack.value.Value;


public class MemoryRecord implements Record
{
    private final Object[] values;

    public MemoryRecord(int columnCount)
    {
        values = new Object[columnCount];
    }


    public boolean isNull(Column column)
    {
        return getValue(column) == null;
    }

    public boolean getBoolean(Column column)
    {
        return (Boolean)getValue(column);
    }

    public long getLong(Column column)
    {
        return (Long)getValue(column);
    }

    public double getDouble(Column column)
    {
        return (Double)getValue(column);
    }

    public String getString(Column column)
    {
        return (String)getValue(column);
    }

    public Timestamp getTimestamp(Column column)
    {
        return (Timestamp)getValue(column);
    }

    public Value getJson(Column column)
    {
        return (Value)getValue(column);
    }

    private Object getValue(Column column)
    {
        return values[column.getIndex()];
    }

    public void setValue(Column column, Object value)
    {
        values[column.getIndex()] = value;
    }
}

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
embulk-output-jdbc-0.8.7	src/main/java/org/embulk/output/jdbc/MemoryRecord.java
embulk-output-jdbc-0.8.5	src/main/java/org/embulk/output/jdbc/MemoryRecord.java
embulk-output-jdbc-0.8.4	src/main/java/org/embulk/output/jdbc/MemoryRecord.java
embulk-output-jdbc-0.8.3	src/main/java/org/embulk/output/jdbc/MemoryRecord.java