Support io.r2dbc.spi.Parameter

Motivation:
Should support it

Modifications:
Modify DefaultCodecs to support Parameter

Result:
Now support Parameter

Author: jchrys

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

@@ -23,6 +23,7 @@
 import io.asyncer.r2dbc.mysql.message.NormalFieldValue;
 import io.asyncer.r2dbc.mysql.util.InternalArrays;
 import io.netty.buffer.ByteBufAllocator;
+import io.r2dbc.spi.Parameter;
 import reactor.util.annotation.Nullable;
 
 import java.lang.reflect.ParameterizedType;
@@ -169,13 +170,26 @@ public MySqlParameter encode(Object value, CodecContext context) {
         requireNonNull(value, "value must not be null");
         requireNonNull(context, "context must not be null");
 
+        final Object valueToEncode = getValueToEncode(value);
+        if (null == valueToEncode) {
+            return encodeNull();
+        }
+
         for (Codec<?> codec : codecs) {
-            if (codec.canEncode(value)) {
-                return codec.encode(value, context);
+            if (codec.canEncode(valueToEncode)) {
+                return codec.encode(valueToEncode, context);
             }
         }
 
-        throw new IllegalArgumentException("Cannot encode " + value.getClass());
+        throw new IllegalArgumentException("Cannot encode " + valueToEncode.getClass());
+    }
+
+    @Nullable
+    private static Object getValueToEncode(Object value) {
+        if (value instanceof Parameter) {
+            return ((Parameter) value).getValue();
+        }
+        return value;
     }
 
     @Override