Revert "[SPARK-12567] [SQL] Add aes_{encrypt,decrypt} UDFs"

This reverts commit 4f9a66481849dc867cf6592d53e0e9782361d20a.

3 files changed, 0 insertions, 175 deletions

diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
index ae09c3d71f..1be97c7b81 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/FunctionRegistry.scala
@@ -278,8 +278,6 @@ object FunctionRegistry {
     expression[ArrayContains]("array_contains"),
 
     // misc functions
-    expression[AesEncrypt]("aes_encrypt"),
-    expression[AesDecrypt]("aes_decrypt"),
     expression[Crc32]("crc32"),
     expression[Md5]("md5"),
     expression[Murmur3Hash]("hash"),
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/misc.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/misc.scala
index 3b66f5797b..dcbb594afd 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/misc.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/misc.scala
@@ -19,8 +19,6 @@ package org.apache.spark.sql.catalyst.expressions
 
 import java.security.{MessageDigest, NoSuchAlgorithmException}
 import java.util.zip.CRC32
-import javax.crypto.Cipher
-import javax.crypto.spec.SecretKeySpec
 
 import org.apache.commons.codec.digest.DigestUtils
 
@@ -443,90 +441,3 @@ case class PrintToStderr(child: Expression) extends UnaryExpression {
        """.stripMargin)
   }
 }
-
-/**
- * A function that encrypts input using AES. Key lengths of 128, 192 or 256 bits can be used. 192
- * and 256 bits keys can be used if Java Cryptography Extension (JCE) Unlimited Strength Jurisdic-
- * tion Policy Files are installed. If either argument is NULL, the result will also be null. If
- * input is invalid, key length is not one of the permitted values or using 192/256 bits key before
- * installing JCE, an exception will be thrown.
- */
-@ExpressionDescription(
-  usage = "_FUNC_(input, key) - Encrypts input using AES.",
-  extended = "> SELECT Base64(_FUNC_('ABC', '1234567890123456'));\n 'y6Ss+zCYObpCbgfWfyNWTw=='")
-case class AesEncrypt(left: Expression, right: Expression)
-  extends BinaryExpression with ImplicitCastInputTypes {
-
-  override def dataType: DataType = BinaryType
-  override def inputTypes: Seq[DataType] = Seq(BinaryType, BinaryType)
-
-  protected override def nullSafeEval(input1: Any, input2: Any): Any = {
-    val cipher = Cipher.getInstance("AES")
-    val secretKey: SecretKeySpec = new SecretKeySpec(input2.asInstanceOf[Array[Byte]], 0,
-      input2.asInstanceOf[Array[Byte]].length, "AES")
-    cipher.init(Cipher.ENCRYPT_MODE, secretKey)
-    cipher.doFinal(input1.asInstanceOf[Array[Byte]], 0, input1.asInstanceOf[Array[Byte]].length)
-  }
-
-  override def genCode(ctx: CodegenContext, ev: ExprCode): String = {
-    nullSafeCodeGen(ctx, ev, (str, key) => {
-      val Cipher = "javax.crypto.Cipher"
-      val SecretKeySpec = "javax.crypto.spec.SecretKeySpec"
-      s"""
-          try {
-            $Cipher cipher = $Cipher.getInstance("AES");
-            $SecretKeySpec secret = new $SecretKeySpec($key, 0, $key.length, "AES");
-            cipher.init($Cipher.ENCRYPT_MODE, secret);
-            ${ev.value} = cipher.doFinal($str, 0, $str.length);
-          } catch (java.security.GeneralSecurityException e) {
-            org.apache.spark.unsafe.Platform.throwException(e);
-          }
-      """
-    })
-  }
-}
-
-/**
- * A function that decrypts input using AES. Key lengths of 128, 192 or 256 bits can be used. 192
- * and 256 bits keys can be used if Java Cryptography Extension (JCE) Unlimited Strength Jurisdic-
- * tion Policy Files are installed. If either argument is NULL, the result will also be null. If
- * input is invalid, key length is not one of the permitted values or using 192/256 bits key before
- * installing JCE, an exception will be thrown.
- */
-@ExpressionDescription(
-  usage = "_FUNC_(input, key) - Decrypts input using AES.",
-  extended = "> SELECT _FUNC_(UnBase64('y6Ss+zCYObpCbgfWfyNWTw=='),'1234567890123456');\n 'ABC'")
-case class AesDecrypt(left: Expression, right: Expression)
-  extends BinaryExpression with ImplicitCastInputTypes {
-
-  override def dataType: DataType = StringType
-  override def inputTypes: Seq[DataType] = Seq(BinaryType, BinaryType)
-
-  protected override def nullSafeEval(input1: Any, input2: Any): Any = {
-    val cipher = Cipher.getInstance("AES")
-    val secretKey = new SecretKeySpec(input2.asInstanceOf[Array[Byte]], 0,
-      input2.asInstanceOf[Array[Byte]].length, "AES")
-
-    cipher.init(Cipher.DECRYPT_MODE, secretKey)
-    UTF8String.fromBytes(
-      cipher.doFinal(input1.asInstanceOf[Array[Byte]], 0,
-        input1.asInstanceOf[Array[Byte]].length))
-  }
-
-  override def genCode(ctx: CodegenContext, ev: ExprCode): String = {
-    nullSafeCodeGen(ctx, ev, (str, key) => {
-      val Cipher = "javax.crypto.Cipher"
-      val SecretKeySpec = "javax.crypto.spec.SecretKeySpec"
-      s"""
-          try {
-            $Cipher cipher = $Cipher.getInstance("AES");
-            $SecretKeySpec secret = new $SecretKeySpec($key, 0, $key.length, "AES");
-            cipher.init($Cipher.DECRYPT_MODE, secret);
-            ${ev.value} = UTF8String.fromBytes(cipher.doFinal($str, 0, $str.length));
-          } catch (java.security.GeneralSecurityException e) {
-            org.apache.spark.unsafe.Platform.throwException(e);
-          }
-      """
-    })
-  }
-}
diff --git a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/MiscFunctionsSuite.scala b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/MiscFunctionsSuite.scala
index 67f2dc457d..75131a6170 100644
--- a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/MiscFunctionsSuite.scala
+++ b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/MiscFunctionsSuite.scala
@@ -132,88 +132,4 @@ class MiscFunctionsSuite extends SparkFunSuite with ExpressionEvalHelper {
       }
     }
   }
-
-  test("aesEncrypt") {
-    val expr1 = AesEncrypt(Literal("ABC".getBytes), Literal("1234567890123456".getBytes))
-    val expr2 = AesEncrypt(Literal("".getBytes), Literal("1234567890123456".getBytes))
-
-    checkEvaluation(Base64(expr1), "y6Ss+zCYObpCbgfWfyNWTw==")
-    checkEvaluation(Base64(expr2), "BQGHoM3lqYcsurCRq3PlUw==")
-
-    // input is null
-    checkEvaluation(AesEncrypt(Literal.create(null, BinaryType),
-      Literal("1234567890123456".getBytes)), null)
-    // key is null
-    checkEvaluation(AesEncrypt(Literal("ABC".getBytes),
-      Literal.create(null, BinaryType)), null)
-    // both are null
-    checkEvaluation(AesEncrypt(Literal.create(null, BinaryType),
-      Literal.create(null, BinaryType)), null)
-
-    val expr3 = AesEncrypt(Literal("ABC".getBytes), Literal("1234567890".getBytes))
-    // key length (80 bits) is not one of the permitted values (128, 192 or 256 bits)
-    intercept[java.security.InvalidKeyException] {
-      evaluate(expr3)
-    }
-    intercept[java.security.InvalidKeyException] {
-      UnsafeProjection.create(expr3 :: Nil).apply(null)
-    }
-  }
-
-  test("aesDecrypt") {
-    val expr1 = AesDecrypt(UnBase64(Literal("y6Ss+zCYObpCbgfWfyNWTw==")),
-      Literal("1234567890123456".getBytes))
-    val expr2 = AesDecrypt(UnBase64(Literal("BQGHoM3lqYcsurCRq3PlUw==")),
-      Literal("1234567890123456".getBytes))
-
-    checkEvaluation(expr1, "ABC")
-    checkEvaluation(expr2, "")
-
-    // input is null
-    checkEvaluation(AesDecrypt(UnBase64(Literal.create(null, StringType)),
-      Literal("1234567890123456".getBytes)), null)
-    // key is null
-    checkEvaluation(AesDecrypt(UnBase64(Literal("y6Ss+zCYObpCbgfWfyNWTw==")),
-      Literal.create(null, BinaryType)), null)
-    // both are null
-    checkEvaluation(AesDecrypt(UnBase64(Literal.create(null, StringType)),
-      Literal.create(null, BinaryType)), null)
-
-    val expr3 = AesDecrypt(UnBase64(Literal("y6Ss+zCYObpCbgfWfyNWTw==")),
-      Literal("1234567890".getBytes))
-    val expr4 = AesDecrypt(UnBase64(Literal("y6Ss+zCsdYObpCbgfWfyNW3Twewr")),
-      Literal("1234567890123456".getBytes))
-    val expr5 = AesDecrypt(UnBase64(Literal("t6Ss+zCYObpCbgfWfyNWTw==")),
-      Literal("1234567890123456".getBytes))
-
-    // key length (80 bits) is not one of the permitted values (128, 192 or 256 bits)
-    intercept[java.security.InvalidKeyException] {
-      evaluate(expr3)
-    }
-    intercept[java.security.InvalidKeyException] {
-      UnsafeProjection.create(expr3 :: Nil).apply(null)
-    }
-    // input can not be decrypted
-    intercept[javax.crypto.IllegalBlockSizeException] {
-      evaluate(expr4)
-    }
-    intercept[javax.crypto.IllegalBlockSizeException] {
-      UnsafeProjection.create(expr4 :: Nil).apply(null)
-    }
-    // input can not be decrypted
-    intercept[javax.crypto.BadPaddingException] {
-      evaluate(expr5)
-    }
-    intercept[javax.crypto.BadPaddingException] {
-      UnsafeProjection.create(expr5 :: Nil).apply(null)
-    }
-  }
-
-  ignore("aesEncryptWith256bitsKey") {
-    // Before testing this, installing Java Cryptography Extension (JCE) Unlimited Strength Juris-
-    // diction Policy Files first. Otherwise `java.security.InvalidKeyException` will be thrown.
-    // Because Oracle JDK does not support 192 and 256 bits key out of box.
-    checkEvaluation(Base64(AesEncrypt(Literal("ABC".getBytes),
-      Literal("12345678901234561234567890123456".getBytes))), "nYfCuJeRd5eD60yXDw7WEA==")
-  }
 }