Remove PrimitiveCodec

Author: mirromutth

r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/codec/AbstractPrimitiveCodec.java

@@ -25,7 +25,7 @@
  *
  * @param <T> the boxed type of handling primitive data.
  */
-abstract class AbstractPrimitiveCodec<T> implements PrimitiveCodec<T> {
+abstract class AbstractPrimitiveCodec<T> implements Codec<T> {
 
     private final Class<T> primitiveClass;
 
@@ -44,7 +44,6 @@ public final boolean canDecode(MySqlReadableMetadata metadata, Class<?> target)
         return (target.isAssignableFrom(boxedClass) || target.equals(primitiveClass)) && doCanDecode(metadata);
     }
 
-    @Override
     public final Class<T> getPrimitiveClass() {
         return primitiveClass;
     }

r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/codec/DefaultCodecs.java

@@ -108,9 +108,8 @@ private DefaultCodecs(List<Codec<?>> codecs) {
                 fastPath.putIfAbsent(mainClass, codec);
             }
 
-            if (codec instanceof PrimitiveCodec<?>) {
-                // Primitive codec must be class-based codec, cannot support ParameterizedType.
-                PrimitiveCodec<?> c = (PrimitiveCodec<?>) codec;
+            if (codec instanceof AbstractPrimitiveCodec<?>) {
+                AbstractPrimitiveCodec<?> c = (AbstractPrimitiveCodec<?>) codec;
 
                 fastPath.putIfAbsent(c.getPrimitiveClass(), c);
             } else if (codec instanceof ParameterizedCodec<?>) {
@@ -230,7 +229,7 @@ public MySqlParameter encode(Object value, CodecContext context) {
         }
 
         for (Codec<?> codec : codecs) {
-            if (codec.canEncode(valueToEncode)) {
+            if (codec != fast && codec.canEncode(valueToEncode)) {
                 return codec.encode(valueToEncode, context);
             }
         }
@@ -293,7 +292,7 @@ private <T> T decodeNormal(NormalFieldValue value, MySqlReadableMetadata metadat
         }
 
         for (Codec<?> codec : codecs) {
-            if (codec.canDecode(metadata, type)) {
+            if (codec != fast && codec.canDecode(metadata, type)) {
                 @SuppressWarnings("unchecked")
                 Codec<T> c = (Codec<T>) codec;
                 return c.decode(value.getBufferSlice(), metadata, type, binary, context);
@@ -327,7 +326,7 @@ private <T> T decodeMassive(LargeFieldValue value, MySqlReadableMetadata metadat
         }
 
         for (MassiveCodec<?> codec : massiveCodecs) {
-            if (codec.canDecode(metadata, type)) {
+            if (codec != fast && codec.canDecode(metadata, type)) {
                 @SuppressWarnings("unchecked")
                 MassiveCodec<T> c = (MassiveCodec<T>) codec;
                 return c.decodeMassive(value.getBufferSlices(), metadata, type, binary, context);