blob: 47da185aa5a5520d8c2138fb459c628fe14f97e3 [file] [log] [blame]
// SPDX-License-Identifier: LGPL-2.1-or-later
// Copyright (c) 2012-2014 Monty Program Ab
// Copyright (c) 2015-2021 MariaDB Corporation Ab
package org.mariadb.jdbc.plugin.codec;
import java.io.IOException;
import java.sql.SQLDataException;
import java.util.Calendar;
import java.util.EnumSet;
import org.mariadb.jdbc.client.*;
import org.mariadb.jdbc.client.socket.Writer;
import org.mariadb.jdbc.plugin.Codec;
/** Double codec */
public class DoubleCodec implements Codec<Double> {
/** default instance */
public static final DoubleCodec INSTANCE = new DoubleCodec();
private static final EnumSet<DataType> COMPATIBLE_TYPES =
EnumSet.of(
DataType.TINYINT,
DataType.SMALLINT,
DataType.MEDIUMINT,
DataType.INTEGER,
DataType.FLOAT,
DataType.DOUBLE,
DataType.BIGINT,
DataType.YEAR,
DataType.OLDDECIMAL,
DataType.DECIMAL,
DataType.VARCHAR,
DataType.VARSTRING,
DataType.STRING,
DataType.BLOB,
DataType.TINYBLOB,
DataType.MEDIUMBLOB,
DataType.LONGBLOB);
public String className() {
return Double.class.getName();
}
public boolean canDecode(ColumnDecoder column, Class<?> type) {
return COMPATIBLE_TYPES.contains(column.getType())
&& ((type.isPrimitive() && type == Double.TYPE) || type.isAssignableFrom(Double.class));
}
public boolean canEncode(Object value) {
return value instanceof Double;
}
@Override
@SuppressWarnings("fallthrough")
public Double decodeText(ReadableByteBuf buf, int length, ColumnDecoder column, Calendar cal)
throws SQLDataException {
return column.decodeDoubleText(buf, length);
}
@Override
@SuppressWarnings("fallthrough")
public Double decodeBinary(ReadableByteBuf buf, int length, ColumnDecoder column, Calendar cal)
throws SQLDataException {
return column.decodeDoubleBinary(buf, length);
}
@Override
public void encodeText(Writer encoder, Context context, Object value, Calendar cal, Long maxLen)
throws IOException {
encoder.writeAscii(value.toString());
}
@Override
public void encodeBinary(Writer encoder, Object value, Calendar cal, Long maxLength)
throws IOException {
encoder.writeDouble((Double) value);
}
public int getBinaryEncodeType() {
return DataType.DOUBLE.get();
}
}