fix the binary function: from_base64, from_base32 (#17466)

Author: alpass163

integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase32ColumnFunctionIT.java

@@ -80,6 +80,8 @@ public class IoTDBFromBase32ColumnFunctionIT {
         // Case 10: Optional padding test (decoder should handle missing padding)
         // 'foo' (0x666f6f) -> Base32 without padding: MZXW6
         "INSERT INTO table1(time, c_text, c_string) VALUES (10, 'MZXW6', 'MZXW6')",
+        // case 11: lower case
+        "INSERT INTO table1(time, c_text, c_string) VALUES (11, 'mzxw6', 'mzxw6')",
       };
 
   @BeforeClass
@@ -119,6 +121,8 @@ public void testFromBase32OnValidInputs() {
           "1970-01-01T00:00:00.009Z,0x666f6f6201,0x666f6f6201,",
           // 10. Optional padding
           "1970-01-01T00:00:00.010Z,0x666f6f,0x666f6f,",
+          // 11. lower case will be considered as upper case
+          "1970-01-01T00:00:00.011Z,0x666f6f,0x666f6f,",
         };
 
     tableResultSetEqualTest(

integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBFromBase64ColumnFunctionIT.java

@@ -54,7 +54,8 @@ public class IoTDBFromBase64ColumnFunctionIT {
         "INSERT INTO table1(time, c_text, c_string) VALUES (3, '', '')",
         "INSERT INTO table1(time, c_int) VALUES (4, 404)",
         // invalid base64
-        "INSERT INTO table1(time, c_text, c_string) VALUES (5, 'not_base64', 'not_base64')"
+        "INSERT INTO table1(time, c_text, c_string) VALUES (5, 'not_base64', 'not_base64')",
+        "INSERT INTO table1(time, c_text, c_string) VALUES (6, 'abc', 'abc')"
       };
 
   @BeforeClass
@@ -95,10 +96,15 @@ public void testFromBase64OnTextString() {
   public void testFromBase64OnInvalidBase64() {
     String expectedErrorMessage =
         TSStatusCode.SEMANTIC_ERROR.getStatusCode()
-            + ": Failed to execute function 'from_base64' due to an invalid input format. Problematic value: not_base64";
+            + ": Failed to execute function 'from_base64' due to an invalid input format. Problematic value: ";
     tableAssertTestFail(
         "SELECT from_base64(c_text) FROM table1 WHERE time = 5",
-        expectedErrorMessage,
+        expectedErrorMessage + "not_base64",
+        DATABASE_NAME);
+
+    tableAssertTestFail(
+        "SELECT from_base64(c_text) FROM table1 WHERE time = 6",
+        expectedErrorMessage + "abc",
         DATABASE_NAME);
   }
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/factory/CodecStrategiesFactory.java

@@ -46,6 +46,10 @@ public final class CodecStrategiesFactory {
   public static final CodecStrategy FROM_BASE64 =
       (input) -> {
         try {
+          if (input.length % 4 != 0) {
+            throw new SemanticException(
+                "Base64 length must be a multiple of 4 (including padding '=')");
+          }
           return Base64.getDecoder().decode(input);
         } catch (IllegalArgumentException e) {
           // wrap the specific exception in dependency into a general one for uniform handling in
@@ -71,7 +75,8 @@ public final class CodecStrategiesFactory {
   public static final CodecStrategy FROM_BASE32 =
       (input) -> {
         try {
-          return GUAVA_BASE32_ENCODING.decode(new String(input, TSFileConfig.STRING_CHARSET));
+          return GUAVA_BASE32_ENCODING.decode(
+              new String(input, TSFileConfig.STRING_CHARSET).toUpperCase());
         } catch (IllegalArgumentException e) {
           throw new SemanticException("decode base32 error");
         }