#988:Adapted Java integration tests for new ScriptOptions parser

exasol · Oct 21, 2024 · c438beb · c438beb
1 parent c289794
commit c438beb
Show file tree

Hide file tree

Showing 5 changed files with 308 additions and 91 deletions.
diff --git a/test_container/tests/lang/java/get_connection.sql b/test_container/tests/lang/java/get_connection.sql
@@ -10,6 +10,19 @@ class PRINT_CONNECTION {
 }
 /
 
+CREATE or replace java SCALAR SCRIPT print_connection_v2(conn varchar (1000))
+emits(type varchar(200), addr varchar(2000000), usr varchar(2000000), pwd varchar(2000000))
+as
+%env SCRIPT_OPTIONS_PARSER_VERSION=2;
+%jvmoption -Xms64m -Xmx128m -Xss512k;
+class PRINT_CONNECTION_V2 {
+    static void run(ExaMetadata exa, ExaIterator ctx) throws Exception {
+        ExaConnectionInformation c = exa.getConnection(ctx.getString("conn"));
+        ctx.emit(c.getType().toString().toLowerCase(),c.getAddress(),c.getUser(), c.getPassword());
+    }
+}
+/
+
 CREATE or replace java SET SCRIPT print_connection_set_emits(conn varchar (1000))
 emits(type varchar(200), addr varchar(2000000), usr varchar(2000000), pwd varchar(2000000))
 as

diff --git a/test_container/tests/test/generic/get_connection.py b/test_container/tests/test/generic/get_connection.py
@@ -48,6 +48,12 @@ def test_connection_not_found(self):
                 SELECT fn1.print_connection('FOO')
                 ''')
 
+    @requires('PRINT_CONNECTION_V2')
+    def test_print_existing_connection_v2(self):
+            rows = self.query('''
+                SELECT fn1.print_connection_v2('FOOCONN')
+                ''')
+            self.assertRowsEqual([('password', 'a', 'b', 'c')], rows)
 
 class GetConnectionAccessControlTest(udf.TestCase):
     def setUp(self):