IntBlobCodec.java

IntBlobCodec.java

package com.datastax.driver.extras.codecs.blobs;

import com.datastax.driver.core.DataType;
import com.datastax.driver.core.ProtocolVersion;
import com.datastax.driver.core.TypeCodec;

import java.nio.ByteBuffer;

public class IntBlobCodec extends TypeCodec.PrimitiveIntCodec {

    public static final IntBlobCodec INSTANCE = new IntBlobCodec();

    private IntBlobCodec() {
        super(DataType.blob());
    }

    @Override
    public ByteBuffer serializeNoBoxing(int value, ProtocolVersion protocolVersion) {
        return wrap(value);
    }

    @Override
    public int deserializeNoBoxing(ByteBuffer value, ProtocolVersion protocolVersion) {
        return unwrap(value);
    }

    @Override
    public Integer parse(String value) {
        return unwrap(TypeCodec.blob().parse(value));
    }

    @Override
    public String format(Integer value) {
        return TypeCodec.blob().format(wrap(value));
    }

    private ByteBuffer wrap(int value) {
        ByteBuffer bb = ByteBuffer.allocate(4);
        bb.putInt(value);
        bb.flip();
        return bb;
    }

    private int unwrap(ByteBuffer bytes) {
        return (bytes == null || bytes.remaining() == 0) ? 0 : bytes.duplicate().getInt();
    }

}