public class org.apache.drill.exec.store.jdbc.TestDataSource extends org.apache.drill.test.BaseTest
{
public org.apache.drill.test.BaseDirTestWatcher dirTestWatcher;
public org.junit.rules.ExpectedException thrown;
private static final java.lang.String DRIVER;
private java.lang.String url;
public void <init>()
{
org.apache.drill.test.BaseDirTestWatcher v;
org.apache.drill.exec.store.jdbc.TestDataSource v;
org.junit.rules.ExpectedException v;
v := @this: org.apache.drill.exec.store.jdbc.TestDataSource;
specialinvoke v.<org.apache.drill.test.BaseTest: void <init>()>();
v = new org.apache.drill.test.BaseDirTestWatcher;
specialinvoke v.<org.apache.drill.test.BaseDirTestWatcher: void <init>()>();
v.<org.apache.drill.exec.store.jdbc.TestDataSource: org.apache.drill.test.BaseDirTestWatcher dirTestWatcher> = v;
v = staticinvoke <org.junit.rules.ExpectedException: org.junit.rules.ExpectedException none()>();
v.<org.apache.drill.exec.store.jdbc.TestDataSource: org.junit.rules.ExpectedException thrown> = v;
return;
}
public void init() throws java.lang.Exception
{
org.apache.drill.test.BaseDirTestWatcher v;
org.apache.drill.exec.store.jdbc.TestDataSource v;
java.lang.String v, v;
java.io.File v;
v := @this: org.apache.drill.exec.store.jdbc.TestDataSource;
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: org.apache.drill.test.BaseDirTestWatcher dirTestWatcher>;
v = virtualinvoke v.<org.apache.drill.test.BaseDirTestWatcher: java.io.File getTmpDir()>();
v = virtualinvoke v.<java.io.File: java.lang.String getCanonicalPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("jdbc:h2:\u0001");
v.<org.apache.drill.exec.store.jdbc.TestDataSource: java.lang.String url> = v;
return;
}
public void testInitWithoutUserAndPassword()
{
java.lang.Throwable v;
org.apache.drill.common.logical.StoragePluginConfig$AuthMode v, v;
com.zaxxer.hikari.HikariDataSource v;
org.apache.drill.exec.store.jdbc.TestDataSource v;
java.lang.String v, v, v, v, v, v;
org.apache.drill.exec.store.jdbc.JdbcStorageConfig v;
v := @this: org.apache.drill.exec.store.jdbc.TestDataSource;
v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig;
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: java.lang.String url>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("org.h.Driver", v, null, null, 0, 0, null, null, null, 1000);
v = staticinvoke <org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: com.zaxxer.hikari.HikariDataSource initDataSource(org.apache.drill.exec.store.jdbc.JdbcStorageConfig,org.apache.drill.exec.store.security.UsernamePasswordCredentials)>(v, null);
label:
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.lang.String getDriverClassName()>();
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("org.h.Driver", v);
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: java.lang.String url>;
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.lang.String getJdbcUrl()>();
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.lang.String getUsername()>();
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.lang.String getPassword()>();
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: org.apache.drill.common.logical.StoragePluginConfig$AuthMode getAuthMode()>();
v = <org.apache.drill.common.logical.StoragePluginConfig$AuthMode: org.apache.drill.common.logical.StoragePluginConfig$AuthMode SHARED_USER>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
label:
virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testInitWithUserAndPassword()
{
java.lang.Throwable v;
org.apache.drill.common.logical.StoragePluginConfig$AuthMode v;
com.zaxxer.hikari.HikariDataSource v;
java.util.Optional v;
java.lang.Object v;
org.apache.drill.exec.store.jdbc.TestDataSource v;
java.lang.String v, v, v, v;
org.apache.drill.exec.store.jdbc.JdbcStorageConfig v;
v := @this: org.apache.drill.exec.store.jdbc.TestDataSource;
v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig;
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: java.lang.String url>;
v = <org.apache.drill.common.logical.StoragePluginConfig$AuthMode: org.apache.drill.common.logical.StoragePluginConfig$AuthMode SHARED_USER>;
v = virtualinvoke v.<org.apache.drill.common.logical.StoragePluginConfig$AuthMode: java.lang.String name()>();
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("org.h.Driver", v, "user", "password", 0, 0, null, null, v, 1000);
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: java.util.Optional getUsernamePasswordCredentials(org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(null);
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = staticinvoke <org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: com.zaxxer.hikari.HikariDataSource initDataSource(org.apache.drill.exec.store.jdbc.JdbcStorageConfig,org.apache.drill.exec.store.security.UsernamePasswordCredentials)>(v, v);
label:
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.lang.String getUsername()>();
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("user", v);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.lang.String getPassword()>();
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("password", v);
label:
virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testInitWithSourceParameters()
{
java.lang.Throwable v;
java.util.HashMap v;
java.lang.Integer v, v, v, v, v;
int v;
java.lang.Boolean v, v, v;
java.lang.String v, v, v;
org.apache.drill.exec.store.jdbc.JdbcStorageConfig v;
boolean v;
java.util.Properties v, v, v;
org.apache.drill.common.logical.StoragePluginConfig$AuthMode v;
com.zaxxer.hikari.HikariDataSource v;
java.util.Optional v;
java.lang.Object v, v, v, v;
org.apache.drill.exec.store.jdbc.TestDataSource v;
v := @this: org.apache.drill.exec.store.jdbc.TestDataSource;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(5);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("minimumIdle", v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(0);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("autoCommit", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("connectionTestQuery", "select * from information_schema.collations");
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("dataSource.cachePrepStmts", v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(250);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("dataSource.prepStmtCacheSize", v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("dataSource.minimumIdle", v);
v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig;
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: java.lang.String url>;
v = <org.apache.drill.common.logical.StoragePluginConfig$AuthMode: org.apache.drill.common.logical.StoragePluginConfig$AuthMode SHARED_USER>;
v = virtualinvoke v.<org.apache.drill.common.logical.StoragePluginConfig$AuthMode: java.lang.String name()>();
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("org.h.Driver", v, "user", "password", 0, 0, v, null, v, 1000);
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: java.util.Optional getUsernamePasswordCredentials(org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(null);
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = staticinvoke <org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: com.zaxxer.hikari.HikariDataSource initDataSource(org.apache.drill.exec.store.jdbc.JdbcStorageConfig,org.apache.drill.exec.store.security.UsernamePasswordCredentials)>(v, v);
label:
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: int getMinimumIdle()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(5L, v);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: boolean isAutoCommit()>();
staticinvoke <org.junit.Assert: void assertFalse(boolean)>(v);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.lang.String getConnectionTestQuery()>();
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("select * from information_schema.collations", v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.util.Properties getDataSourceProperties()>();
v = virtualinvoke v.<java.util.Properties: java.lang.Object get(java.lang.Object)>("cachePrepStmts");
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(250);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.util.Properties getDataSourceProperties()>();
v = virtualinvoke v.<java.util.Properties: java.lang.Object get(java.lang.Object)>("prepStmtCacheSize");
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: java.util.Properties getDataSourceProperties()>();
v = virtualinvoke v.<java.util.Properties: java.lang.Object get(java.lang.Object)>("minimumIdle");
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
label:
virtualinvoke v.<com.zaxxer.hikari.HikariDataSource: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testInitWithIncorrectSourceParameterName()
{
java.util.HashMap v;
org.apache.drill.common.logical.StoragePluginConfig$AuthMode v;
org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType v;
java.util.Optional v;
java.lang.Object v;
org.apache.drill.exec.store.jdbc.TestDataSource v;
java.lang.String v, v, v;
org.apache.drill.exec.store.jdbc.JdbcStorageConfig v;
org.junit.rules.ExpectedException v, v;
v := @this: org.apache.drill.exec.store.jdbc.TestDataSource;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("abc", "abc");
v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig;
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: java.lang.String url>;
v = <org.apache.drill.common.logical.StoragePluginConfig$AuthMode: org.apache.drill.common.logical.StoragePluginConfig$AuthMode SHARED_USER>;
v = virtualinvoke v.<org.apache.drill.common.logical.StoragePluginConfig$AuthMode: java.lang.String name()>();
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("org.h.Driver", v, "user", "password", 0, 0, v, null, v, 1000);
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: java.util.Optional getUsernamePasswordCredentials(org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(null);
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: org.junit.rules.ExpectedException thrown>;
virtualinvoke v.<org.junit.rules.ExpectedException: void expect(java.lang.Class)>(class "Lorg/apache/drill/common/exceptions/UserException;");
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: org.junit.rules.ExpectedException thrown>;
v = <org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType: org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType CONNECTION>;
v = virtualinvoke v.<org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType: java.lang.String name()>();
virtualinvoke v.<org.junit.rules.ExpectedException: void expectMessage(java.lang.String)>(v);
staticinvoke <org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: com.zaxxer.hikari.HikariDataSource initDataSource(org.apache.drill.exec.store.jdbc.JdbcStorageConfig,org.apache.drill.exec.store.security.UsernamePasswordCredentials)>(v, v);
return;
}
public void testInitWithIncorrectSourceParameterValue()
{
java.util.HashMap v;
org.apache.drill.common.logical.StoragePluginConfig$AuthMode v;
org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType v;
java.util.Optional v;
java.lang.Object v;
org.apache.drill.exec.store.jdbc.TestDataSource v;
java.lang.String v, v, v;
org.apache.drill.exec.store.jdbc.JdbcStorageConfig v;
org.junit.rules.ExpectedException v, v;
v := @this: org.apache.drill.exec.store.jdbc.TestDataSource;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("minimumIdle", "abc");
v = new org.apache.drill.exec.store.jdbc.JdbcStorageConfig;
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: java.lang.String url>;
v = <org.apache.drill.common.logical.StoragePluginConfig$AuthMode: org.apache.drill.common.logical.StoragePluginConfig$AuthMode SHARED_USER>;
v = virtualinvoke v.<org.apache.drill.common.logical.StoragePluginConfig$AuthMode: java.lang.String name()>();
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: void <init>(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,boolean,java.util.Map,org.apache.drill.common.logical.security.CredentialsProvider,java.lang.String,int)>("org.h.Driver", v, "user", "password", 0, 0, v, null, v, 1000);
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStorageConfig: java.util.Optional getUsernamePasswordCredentials(org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(null);
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: org.junit.rules.ExpectedException thrown>;
virtualinvoke v.<org.junit.rules.ExpectedException: void expect(java.lang.Class)>(class "Lorg/apache/drill/common/exceptions/UserException;");
v = v.<org.apache.drill.exec.store.jdbc.TestDataSource: org.junit.rules.ExpectedException thrown>;
v = <org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType: org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType CONNECTION>;
v = virtualinvoke v.<org.apache.drill.exec.proto.UserBitShared$DrillPBError$ErrorType: java.lang.String name()>();
virtualinvoke v.<org.junit.rules.ExpectedException: void expectMessage(java.lang.String)>(v);
staticinvoke <org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: com.zaxxer.hikari.HikariDataSource initDataSource(org.apache.drill.exec.store.jdbc.JdbcStorageConfig,org.apache.drill.exec.store.security.UsernamePasswordCredentials)>(v, v);
return;
}
}