package com.l7tech.server.jdbc;

import java.util.ArrayList;
import java.util.concurrent.Callable;
import javax.security.auth.Subject;

class h implements Callable<String> {
   final String val$connectionName;
   final String val$query;
   final String val$schemaName;
   final int val$queryTimeout;
   final JdbcAdminImpl this$0;

   h(JdbcAdminImpl var1, String var2, String var3, String var4, int var5) {
      this.this$0 = var1;
      this.val$connectionName = var2;
      this.val$query = var3;
      this.val$schemaName = var4;
      this.val$queryTimeout = var5;
   }

   public String call() throws Exception {
      Callable var1 = this::lambda$call$0;

      try {
         if (this.this$0.a(this.this$0.e.getJdbcConnection(this.val$connectionName))) {
            return Subject.callAs(null, var1);
         }
      } catch (Exception var2) {
         throw a(var2);
      }

      return (String)var1.call();
   }

   private String lambda$call$0(String var1, String var2, String var3, int var4) throws Exception {
      Object var5 = this.this$0.f.performJdbcQuery(var1, var2, var3, 1, var4, new ArrayList<>());

      try {
         if (var5 instanceof String var10000) {
            return var10000;
         }
      } catch (Exception var6) {
         throw a(var6);
      }

      return null;
   }

   private static Exception a(Exception var0) {
      return var0;
   }
}